[
https://issues.apache.org/jira/browse/FLINK-26529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509788#comment-17509788
]
Dian Fu commented on FLINK-26529:
---------------------------------
[~jschulte] [~hxbks2ks] Thanks for the comments.
It seems that this issue is caused because there is a breaking change from
release-1.13 to release-1.14 which is not documented carefully in the release
note. However, the behavior should be expected and so I guess we could close
this ticket as "Not a Bug". [~jschulte] [~hxbks2ks] What do you think?
> PyFlink 'tuple' object has no attribute '_values'
> -------------------------------------------------
>
> Key: FLINK-26529
> URL: https://issues.apache.org/jira/browse/FLINK-26529
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.14.3
> Environment: JAVA_VERSION=8
> SCALA_VERSION=2.12
> FLINK_VERSION=1.14.3
> PYTHON_VERSION=3.7.9
>
> Running in Kubernetes using spotify/flink-on-kubernetes-operator
> Reporter: James Schulte
> Priority: Major
> Attachments: flink_operators.py, main.py
>
>
>
> {code:java}
> Caused by: java.util.concurrent.ExecutionException:
> java.lang.RuntimeException: Error received from SDK harness for instruction
> 4: Traceback (most recent call last): File
> "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 289, in _execute response = task() File
> "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 362, in <lambda> lambda:
> self.create_worker().do_instruction(request), request) File
> "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 607, in do_instruction getattr(request, request_type),
> request.instruction_id) File
> "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py",
> line 644, in process_bundle
> bundle_processor.process_bundle(instruction_id)) File
> "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 1000, in process_bundle element.data) File
> "/usr/local/lib/python3.7/site-packages/apache_beam/runners/worker/bundle_processor.py",
> line 228, in process_encoded self.output(decoded_value) File
> "apache_beam/runners/worker/operations.py", line 357, in
> apache_beam.runners.worker.operations.Operation.output File
> "apache_beam/runners/worker/operations.py", line 359, in
> apache_beam.runners.worker.operations.Operation.output File
> "apache_beam/runners/worker/operations.py", line 221, in
> apache_beam.runners.worker.operations.SingletonConsumerSet.receive File
> "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 158, in
> pyflink.fn_execution.beam.beam_operations_fast.FunctionOperation.process
> File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 174, in
> pyflink.fn_execution.beam.beam_operations_fast.FunctionOperation.process
> File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 104, in
> pyflink.fn_execution.beam.beam_operations_fast.IntermediateOutputProcessor.process_outputs
> File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 158, in
> pyflink.fn_execution.beam.beam_operations_fast.FunctionOperation.process
> File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 174, in
> pyflink.fn_execution.beam.beam_operations_fast.FunctionOperation.process
> File "pyflink/fn_execution/beam/beam_operations_fast.pyx", line 92, in
> pyflink.fn_execution.beam.beam_operations_fast.NetworkOutputProcessor.process_outputs
> File "pyflink/fn_execution/beam/beam_coder_impl_fast.pyx", line 101, in
> pyflink.fn_execution.beam.beam_coder_impl_fast.FlinkLengthPrefixCoderBeamWrapper.encode_to_stream
> File "pyflink/fn_execution/coder_impl_fast.pyx", line 271, in
> pyflink.fn_execution.coder_impl_fast.IterableCoderImpl.encode_to_stream File
> "pyflink/fn_execution/coder_impl_fast.pyx", line 399, in
> pyflink.fn_execution.coder_impl_fast.RowCoderImpl.encode_to_stream File
> "pyflink/fn_execution/coder_impl_fast.pyx", line 389, in
> pyflink.fn_execution.coder_impl_fast.RowCoderImpl.encode_to_streamAttributeError:
> 'tuple' object has no attribute '_values'
> {code}
> Recieved this error after upgrading from Flink 1.13.1 -> 1.14.3 - no other
> changes
>
> I've reviewed the release notes - can't see anything highlighting why this
> might be the case.
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
