You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/08/11 18:07:00 UTC
[jira] [Created] (FLINK-18893) Python tests fails with
"AppendStreamTableSink requires that Table has only insert changes."
Robert Metzger created FLINK-18893:
--------------------------------------
Summary: Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."
Key: FLINK-18893
URL: https://issues.apache.org/jira/browse/FLINK-18893
Project: Flink
Issue Type: Bug
Components: API / Python, Tests
Reporter: Robert Metzger
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=5392&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=455fddbf-5921-5b71-25ac-92992ad80b28
{code}
2020-08-11T09:33:00.6405057Z
2020-08-11T09:33:00.6407257Z =================================== FAILURES ===================================
2020-08-11T09:33:00.6407774Z _________ StreamPandasConversionTests.test_to_pandas_for_retract_table _________
2020-08-11T09:33:00.6408007Z
2020-08-11T09:33:00.6409313Z a = ('xro10353', <py4j.java_gateway.GatewayClient object at 0x7f9572c53ac8>, 'z:org.apache.flink.table.runtime.arrow.ArrowUtils', 'collectAsPandasDataFrame')
2020-08-11T09:33:00.6409732Z kw = {}
2020-08-11T09:33:00.6410610Z s = 'org.apache.flink.table.api.TableException: AppendStreamTableSink requires that Table has only insert changes.'
2020-08-11T09:33:00.6413478Z stack_trace = 'org.apache.flink.table.plan.nodes.datastream.DataStreamSink.writeToAppendSink(DataStreamSink.scala:118)\n\t at org.ap....api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)\n\t at java.lang.Thread.run(Thread.java:748)'
2020-08-11T09:33:00.6414468Z exception = 'org.apache.flink.table.api.TableException'
2020-08-11T09:33:00.6414663Z
2020-08-11T09:33:00.6414858Z def deco(*a, **kw):
2020-08-11T09:33:00.6415060Z try:
2020-08-11T09:33:00.6415274Z > return f(*a, **kw)
2020-08-11T09:33:00.6415419Z
2020-08-11T09:33:00.6415615Z pyflink/util/exceptions.py:147:
2020-08-11T09:33:00.6415918Z _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
2020-08-11T09:33:00.6416154Z
2020-08-11T09:33:00.6416459Z answer = 'xro10353'
2020-08-11T09:33:00.6416746Z gateway_client = <py4j.java_gateway.GatewayClient object at 0x7f9572c53ac8>
2020-08-11T09:33:00.6419376Z target_id = 'z:org.apache.flink.table.runtime.arrow.ArrowUtils'
2020-08-11T09:33:00.6420325Z name = 'collectAsPandasDataFrame'
2020-08-11T09:33:00.6420574Z
2020-08-11T09:33:00.6421009Z def get_return_value(answer, gateway_client, target_id=None, name=None):
2020-08-11T09:33:00.6421735Z """Converts an answer received from the Java gateway into a Python object.
2020-08-11T09:33:00.6422153Z
2020-08-11T09:33:00.6422538Z For example, string representation of integers are converted to Python
2020-08-11T09:33:00.6423113Z integer, string representation of objects are converted to JavaObject
2020-08-11T09:33:00.6423424Z instances, etc.
2020-08-11T09:33:00.6423594Z
2020-08-11T09:33:00.6423844Z :param answer: the string returned by the Java gateway
2020-08-11T09:33:00.6424203Z :param gateway_client: the gateway client used to communicate with the Java
2020-08-11T09:33:00.6424604Z Gateway. Only necessary if the answer is a reference (e.g., object,
2020-08-11T09:33:00.6424874Z list, map)
2020-08-11T09:33:00.6425375Z :param target_id: the name of the object from which the answer comes from
2020-08-11T09:33:00.6425735Z (e.g., *object1* in `object1.hello()`). Optional.
2020-08-11T09:33:00.6426069Z :param name: the name of the member from which the answer comes from
2020-08-11T09:33:00.6426422Z (e.g., *hello* in `object1.hello()`). Optional.
2020-08-11T09:33:00.6426648Z """
2020-08-11T09:33:00.6426868Z if is_error(answer)[0]:
2020-08-11T09:33:00.6427112Z if len(answer) > 1:
2020-08-11T09:33:00.6427358Z type = answer[1]
2020-08-11T09:33:00.6427665Z value = OUTPUT_CONVERTER[type](answer[2:], gateway_client)
2020-08-11T09:33:00.6428032Z if answer[1] == REFERENCE_TYPE:
2020-08-11T09:33:00.6428313Z raise Py4JJavaError(
2020-08-11T09:33:00.6428691Z "An error occurred while calling {0}{1}{2}.\n".
2020-08-11T09:33:00.6429083Z > format(target_id, ".", name), value)
2020-08-11T09:33:00.6429798Z E py4j.protocol.Py4JJavaError: An error occurred while calling z:org.apache.flink.table.runtime.arrow.ArrowUtils.collectAsPandasDataFrame.
2020-08-11T09:33:00.6430529Z E : org.apache.flink.table.api.TableException: AppendStreamTableSink requires that Table has only insert changes.
2020-08-11T09:33:00.6431132Z E at org.apache.flink.table.plan.nodes.datastream.DataStreamSink.writeToAppendSink(DataStreamSink.scala:118)
2020-08-11T09:33:00.6431793Z E at org.apache.flink.table.plan.nodes.datastream.DataStreamSink.writeToSink(DataStreamSink.scala:74)
2020-08-11T09:33:00.6432378Z E at org.apache.flink.table.plan.nodes.datastream.DataStreamSink.translateToPlan(DataStreamSink.scala:59)
2020-08-11T09:33:00.6433145Z E at org.apache.flink.table.planner.StreamPlanner.org$apache$flink$table$planner$StreamPlanner$$translateToCRow(StreamPlanner.scala:274)
2020-08-11T09:33:00.6434258Z E at org.apache.flink.table.planner.StreamPlanner$$anonfun$translate$1.apply(StreamPlanner.scala:120)
2020-08-11T09:33:00.6435151Z E at org.apache.flink.table.planner.StreamPlanner$$anonfun$translate$1.apply(StreamPlanner.scala:117)
2020-08-11T09:33:00.6436010Z E at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
2020-08-11T09:33:00.6436565Z E at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
2020-08-11T09:33:00.6437051Z E at scala.collection.Iterator$class.foreach(Iterator.scala:891)
2020-08-11T09:33:00.6437492Z E at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
2020-08-11T09:33:00.6437963Z E at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
2020-08-11T09:33:00.6438568Z E at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
2020-08-11T09:33:00.6439109Z E at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
2020-08-11T09:33:00.6439574Z E at scala.collection.AbstractTraversable.map(Traversable.scala:104)
2020-08-11T09:33:00.6440142Z E at org.apache.flink.table.planner.StreamPlanner.translate(StreamPlanner.scala:117)
2020-08-11T09:33:00.6440681Z E at org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1264)
2020-08-11T09:33:00.6441279Z E at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:733)
2020-08-11T09:33:00.6441924Z E at org.apache.flink.table.api.internal.TableImpl.execute(TableImpl.java:570)
2020-08-11T09:33:00.6442447Z E at org.apache.flink.table.runtime.arrow.ArrowUtils.collectAsPandasDataFrame(ArrowUtils.java:643)
2020-08-11T09:33:00.6442934Z E at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2020-08-11T09:33:00.6443477Z E at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2020-08-11T09:33:00.6444005Z E at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2020-08-11T09:33:00.6444476Z E at java.lang.reflect.Method.invoke(Method.java:498)
2020-08-11T09:33:00.6444953Z E at org.apache.flink.api.python.shaded.py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
2020-08-11T09:33:00.6445545Z E at org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
2020-08-11T09:33:00.6446079Z E at org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:282)
2020-08-11T09:33:00.6446631Z E at org.apache.flink.api.python.shaded.py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
2020-08-11T09:33:00.6447221Z E at org.apache.flink.api.python.shaded.py4j.commands.CallCommand.execute(CallCommand.java:79)
2020-08-11T09:33:00.6447764Z E at org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)
2020-08-11T09:33:00.6448224Z E at java.lang.Thread.run(Thread.java:748)
2020-08-11T09:33:00.6448437Z
2020-08-11T09:33:00.6449124Z .tox/py35-cython/lib/python3.5/site-packages/py4j/protocol.py:328: Py4JJavaError
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)