Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25768

Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks failed on azure

    XMLWordPrintableJSON

Details

    Description

      2022-01-22T01:51:13.0242386Z Jan 22 01:51:13 answer = 'xro24635'
2022-01-22T01:51:13.0242938Z Jan 22 01:51:13 gateway_client = <py4j.java_gateway.GatewayClient object at 0x7f24c092efa0>
2022-01-22T01:51:13.0243909Z Jan 22 01:51:13 target_id = 'o24634', name = 'addInsertSql'
2022-01-22T01:51:13.0244309Z Jan 22 01:51:13 
2022-01-22T01:51:13.0244761Z Jan 22 01:51:13     def get_return_value(answer, gateway_client, target_id=None, name=None):
2022-01-22T01:51:13.0245397Z Jan 22 01:51:13         """Converts an answer received from the Java gateway into a Python object.
2022-01-22T01:51:13.0245923Z Jan 22 01:51:13     
2022-01-22T01:51:13.0246348Z Jan 22 01:51:13         For example, string representation of integers are converted to Python
2022-01-22T01:51:13.0246963Z Jan 22 01:51:13         integer, string representation of objects are converted to JavaObject
2022-01-22T01:51:13.0247486Z Jan 22 01:51:13         instances, etc.
2022-01-22T01:51:13.0247820Z Jan 22 01:51:13     
2022-01-22T01:51:13.0248220Z Jan 22 01:51:13         :param answer: the string returned by the Java gateway
2022-01-22T01:51:13.0248846Z Jan 22 01:51:13         :param gateway_client: the gateway client used to communicate with the Java
2022-01-22T01:51:13.0249505Z Jan 22 01:51:13             Gateway. Only necessary if the answer is a reference (e.g., object,
2022-01-22T01:51:13.0249945Z Jan 22 01:51:13             list, map)
2022-01-22T01:51:13.0250470Z Jan 22 01:51:13         :param target_id: the name of the object from which the answer comes from
2022-01-22T01:51:13.0251084Z Jan 22 01:51:13             (e.g., *object1* in `object1.hello()`). Optional.
2022-01-22T01:51:13.0251607Z Jan 22 01:51:13         :param name: the name of the member from which the answer comes from
2022-01-22T01:51:13.0252199Z Jan 22 01:51:13             (e.g., *hello* in `object1.hello()`). Optional.
2022-01-22T01:51:13.0252646Z Jan 22 01:51:13         """
2022-01-22T01:51:13.0253198Z Jan 22 01:51:13         if is_error(answer)[0]:
2022-01-22T01:51:13.0253684Z Jan 22 01:51:13             if len(answer) > 1:
2022-01-22T01:51:13.0254169Z Jan 22 01:51:13                 type = answer[1]
2022-01-22T01:51:13.0254757Z Jan 22 01:51:13                 value = OUTPUT_CONVERTER[type](answer[2:], gateway_client)
2022-01-22T01:51:13.0255450Z Jan 22 01:51:13                 if answer[1] == REFERENCE_TYPE:
2022-01-22T01:51:13.0256085Z Jan 22 01:51:13 >                   raise Py4JJavaError(
2022-01-22T01:51:13.0256768Z Jan 22 01:51:13                         "An error occurred while calling {0}{1}{2}.\n".
2022-01-22T01:51:13.0257432Z Jan 22 01:51:13                         format(target_id, ".", name), value)
2022-01-22T01:51:13.0258250Z Jan 22 01:51:13 E                   py4j.protocol.Py4JJavaError: An error occurred while calling o24634.addInsertSql.
2022-01-22T01:51:13.0259174Z Jan 22 01:51:13 E                   : java.lang.NullPointerException
2022-01-22T01:51:13.0259824Z Jan 22 01:51:13 E                   	at java.util.Objects.requireNonNull(Objects.java:203)
2022-01-22T01:51:13.0260748Z Jan 22 01:51:13 E                   	at org.apache.calcite.rel.metadata.RelMetadataQuery.<init>(RelMetadataQuery.java:144)
2022-01-22T01:51:13.0261604Z Jan 22 01:51:13 E                   	at org.apache.calcite.rel.metadata.RelMetadataQuery.<init>(RelMetadataQuery.java:108)
2022-01-22T01:51:13.0262653Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.plan.metadata.FlinkRelMetadataQuery.<init>(FlinkRelMetadataQuery.java:78)
2022-01-22T01:51:13.0263927Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.plan.metadata.FlinkRelMetadataQuery.instance(FlinkRelMetadataQuery.java:59)
2022-01-22T01:51:13.0264864Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.calcite.FlinkRelOptClusterFactory$$anon$1.get(FlinkRelOptClusterFactory.scala:39)
2022-01-22T01:51:13.0266075Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.calcite.FlinkRelOptClusterFactory$$anon$1.get(FlinkRelOptClusterFactory.scala:38)
2022-01-22T01:51:13.0267017Z Jan 22 01:51:13 E                   	at org.apache.calcite.plan.RelOptCluster.getMetadataQuery(RelOptCluster.java:178)
2022-01-22T01:51:13.0267991Z Jan 22 01:51:13 E                   	at org.apache.calcite.rel.logical.LogicalFilter.create(LogicalFilter.java:108)
2022-01-22T01:51:13.0268849Z Jan 22 01:51:13 E                   	at org.apache.calcite.rel.core.RelFactories$FilterFactoryImpl.createFilter(RelFactories.java:344)
2022-01-22T01:51:13.0269861Z Jan 22 01:51:13 E                   	at org.apache.calcite.sql2rel.SqlToRelConverter.convertWhere(SqlToRelConverter.java:1042)
2022-01-22T01:51:13.0271035Z Jan 22 01:51:13 E                   	at org.apache.calcite.sql2rel.SqlToRelConverter.convertSelectImpl(SqlToRelConverter.java:666)
2022-01-22T01:51:13.0272198Z Jan 22 01:51:13 E                   	at org.apache.calcite.sql2rel.SqlToRelConverter.convertSelect(SqlToRelConverter.java:644)
2022-01-22T01:51:13.0273591Z Jan 22 01:51:13 E                   	at org.apache.calcite.sql2rel.SqlToRelConverter.convertQueryRecursive(SqlToRelConverter.java:3438)
2022-01-22T01:51:13.0274738Z Jan 22 01:51:13 E                   	at org.apache.calcite.sql2rel.SqlToRelConverter.convertQuery(SqlToRelConverter.java:570)
2022-01-22T01:51:13.0276034Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$rel(FlinkPlannerImpl.scala:169)
2022-01-22T01:51:13.0277371Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.calcite.FlinkPlannerImpl.rel(FlinkPlannerImpl.scala:161)
2022-01-22T01:51:13.0278632Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.operations.SqlToOperationConverter.toQueryOperation(SqlToOperationConverter.java:989)
2022-01-22T01:51:13.0279825Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.operations.SqlToOperationConverter.convertSqlQuery(SqlToOperationConverter.java:958)
2022-01-22T01:51:13.0280967Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.operations.SqlToOperationConverter.convert(SqlToOperationConverter.java:283)
2022-01-22T01:51:13.0282159Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.operations.SqlToOperationConverter.convertSqlInsert(SqlToOperationConverter.java:603)
2022-01-22T01:51:13.0283136Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.operations.SqlToOperationConverter.convert(SqlToOperationConverter.java:272)
2022-01-22T01:51:13.0284230Z Jan 22 01:51:13 E                   	at org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:101)
2022-01-22T01:51:13.0285228Z Jan 22 01:51:13 E                   	at org.apache.flink.table.api.internal.StatementSetImpl.addInsertSql(StatementSetImpl.java:51)
2022-01-22T01:51:13.0286152Z Jan 22 01:51:13 E                   	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-01-22T01:51:13.0286873Z Jan 22 01:51:13 E                   	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-01-22T01:51:13.0287759Z Jan 22 01:51:13 E                   	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-01-22T01:51:13.0288563Z Jan 22 01:51:13 E                   	at java.lang.reflect.Method.invoke(Method.java:498)
2022-01-22T01:51:13.0289502Z Jan 22 01:51:13 E                   	at org.apache.flink.api.python.shaded.py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
2022-01-22T01:51:13.0290465Z Jan 22 01:51:13 E                   	at org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
2022-01-22T01:51:13.0291304Z Jan 22 01:51:13 E                   	at org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:282)
2022-01-22T01:51:13.0292199Z Jan 22 01:51:13 E                   	at org.apache.flink.api.python.shaded.py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
2022-01-22T01:51:13.0293333Z Jan 22 01:51:13 E                   	at org.apache.flink.api.python.shaded.py4j.commands.CallCommand.execute(CallCommand.java:79)
2022-01-22T01:51:13.0294144Z Jan 22 01:51:13 E                   	at org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)
2022-01-22T01:51:13.0294762Z Jan 22 01:51:13 E                   	at java.lang.Thread.run(Thread.java:748)
2022-01-22T01:51:13.0295169Z Jan 22 01:51:13 
2022-01-22T01:51:13.0296060Z Jan 22 01:51:13 .tox/py38-cython/lib/python3.8/site-packages/py4j/protocol.py:326: Py4JJavaError
2022-01-22T01:51:13.0296859Z Jan 22 01:51:13 =============================== warnings summary ===============================
2022-01-22T01:51:13.0297737Z Jan 22 01:51:13 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_collections.py:13
2022-01-22T01:51:13.0298470Z Jan 22 01:51:13 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_collections.py:13
2022-01-22T01:51:13.0299180Z Jan 22 01:51:13 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_collections.py:13
2022-01-22T01:51:13.0300114Z Jan 22 01:51:13 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_collections.py:13
2022-01-22T01:51:13.0301173Z Jan 22 01:51:13 .tox/py38-cython/lib/python3.8/site-packages/py4j/java_collections.py:13

      https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=29931&view=logs&j=bdd9ea51-4de2-506a-d4d9-f3930e4d2355&t=98717c4f-b888-5636-bb1e-db7aca25755e&l=24650

      Attachments

        Activity

          People

            Unassigned Unassigned
            gaoyunhaii Yun Gao
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: