(DEPRECATED) Apache Flink Mailing List archive.

[jira] [Created] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

classic Classic list List threaded Threaded
♦
♦
 1 message Options
Shang Yuanchun (Jira)
Reply | Threaded
Open this post in threaded view
♦
♦
|

[jira] [Created] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

Shang Yuanchun (Jira)
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)
Free forum by Nabble Edit this page