[
https://issues.apache.org/jira/browse/FLINK-25768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480861#comment-17480861
]
Yun Gao commented on FLINK-25768:
---------------------------------
cc [~hxbks2ks] ~
> Python test BlinkBatchTableEnvironmentTests.test_explain_with_multi_sinks
> failed on azure
> -----------------------------------------------------------------------------------------
>
> Key: FLINK-25768
> URL: https://issues.apache.org/jira/browse/FLINK-25768
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.13.5
> Reporter: Yun Gao
> Priority: Major
> Labels: test-stability
>
> {code:java}
> 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
> {code}
> 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
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
