Yun Gao created FLINK-25768:
-------------------------------
Summary: 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
{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)
