[
https://issues.apache.org/jira/browse/BEAM-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797268#comment-16797268
]
Juta Staes commented on BEAM-6711:
----------------------------------
I can't seem to figure out where to apply get_hashable_destination because I
still get the same error (running the code from my pr:
[https://github.com/apache/beam/pull/8076])
Do you have an idea on how to handle this?
I also get a new error when running
apache_beam.examples.complete.game.hourly_team_score_it_test:HourlyTeamScoreIT.test_hourly_team_score_it
related to your code changes [~pabloem]
{code:java}
Traceback (most recent call last):
File "apache_beam/runners/common.py", line 732, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 418, in
apache_beam.runners.common.SimpleInvoker.invoke_process
File "apache_beam/runners/common.py", line 831, in
apache_beam.runners.common._OutputProcessor.process_outputs
File
"/usr/local/lib/python3.5/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 1004, in process
yield (self.destination(element), element)
File
"/mnt/c/Users/Juta/Documents/02-projects/apache/beam/sdks/python/apache_beam/io/gcp/bigquery_tools.py",
line 1043, in <lambda>
AttributeError: type object 'AppendDestinationsFn' has no attribute
'_value_provider_or_static_val'
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.5/site-packages/dataflow_worker/batchworker.py",
line 649, in do_work
work_executor.execute()
File "/usr/local/lib/python3.5/site-packages/dataflow_worker/executor.py",
line 176, in execute
op.start()
File "dataflow_worker/shuffle_operations.py", line 50, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
File "dataflow_worker/shuffle_operations.py", line 51, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
File "dataflow_worker/shuffle_operations.py", line 66, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
File "dataflow_worker/shuffle_operations.py", line 67, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
File "dataflow_worker/shuffle_operations.py", line 71, in
dataflow_worker.shuffle_operations.GroupedShuffleReadOperation.start
File "apache_beam/runners/worker/operations.py", line 240, in
apache_beam.runners.worker.operations.Operation.output
File "apache_beam/runners/worker/operations.py", line 142, in
apache_beam.runners.worker.operations.SingletonConsumerSet.receive
File "dataflow_worker/shuffle_operations.py", line 234, in
dataflow_worker.shuffle_operations.BatchGroupAlsoByWindowsOperation.process
File "dataflow_worker/shuffle_operations.py", line 248, in
dataflow_worker.shuffle_operations.BatchGroupAlsoByWindowsOperation.process
File "apache_beam/runners/worker/operations.py", line 240, in
apache_beam.runners.worker.operations.Operation.output
File "apache_beam/runners/worker/operations.py", line 142, in
apache_beam.runners.worker.operations.SingletonConsumerSet.receive
File "apache_beam/runners/worker/operations.py", line 681, in
apache_beam.runners.worker.operations.CombineOperation.process
File "apache_beam/runners/worker/operations.py", line 685, in
apache_beam.runners.worker.operations.CombineOperation.process
File "apache_beam/runners/worker/operations.py", line 240, in
apache_beam.runners.worker.operations.Operation.output
File "apache_beam/runners/worker/operations.py", line 142, in
apache_beam.runners.worker.operations.SingletonConsumerSet.receive
File "apache_beam/runners/worker/operations.py", line 554, in
apache_beam.runners.worker.operations.DoOperation.process
File "apache_beam/runners/worker/operations.py", line 555, in
apache_beam.runners.worker.operations.DoOperation.process
File "apache_beam/runners/common.py", line 728, in
apache_beam.runners.common.DoFnRunner.receive
File "apache_beam/runners/common.py", line 734, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 770, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
File "apache_beam/runners/common.py", line 732, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 555, in
apache_beam.runners.common.PerWindowInvoker.invoke_process
File "apache_beam/runners/common.py", line 624, in
apache_beam.runners.common.PerWindowInvoker._invoke_per_window
File "apache_beam/runners/common.py", line 816, in
apache_beam.runners.common._OutputProcessor.process_outputs
File "apache_beam/runners/common.py", line 855, in
apache_beam.runners.common._OutputProcessor.process_outputs
File "apache_beam/runners/worker/operations.py", line 142, in
apache_beam.runners.worker.operations.SingletonConsumerSet.receive
File "apache_beam/runners/worker/operations.py", line 554, in
apache_beam.runners.worker.operations.DoOperation.process
File "apache_beam/runners/worker/operations.py", line 555, in
apache_beam.runners.worker.operations.DoOperation.process
File "apache_beam/runners/common.py", line 728, in
apache_beam.runners.common.DoFnRunner.receive
File "apache_beam/runners/common.py", line 734, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 770, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
File "apache_beam/runners/common.py", line 732, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 418, in
apache_beam.runners.common.SimpleInvoker.invoke_process
File "apache_beam/runners/common.py", line 855, in
apache_beam.runners.common._OutputProcessor.process_outputs
File "apache_beam/runners/worker/operations.py", line 142, in
apache_beam.runners.worker.operations.SingletonConsumerSet.receive
File "apache_beam/runners/worker/operations.py", line 554, in
apache_beam.runners.worker.operations.DoOperation.process
File "apache_beam/runners/worker/operations.py", line 555, in
apache_beam.runners.worker.operations.DoOperation.process
File "apache_beam/runners/common.py", line 728, in
apache_beam.runners.common.DoFnRunner.receive
File "apache_beam/runners/common.py", line 734, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 770, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
File "apache_beam/runners/common.py", line 732, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 555, in
apache_beam.runners.common.PerWindowInvoker.invoke_process
File "apache_beam/runners/common.py", line 624, in
apache_beam.runners.common.PerWindowInvoker._invoke_per_window
File "apache_beam/runners/common.py", line 816, in
apache_beam.runners.common._OutputProcessor.process_outputs
File "apache_beam/runners/common.py", line 855, in
apache_beam.runners.common._OutputProcessor.process_outputs
File "apache_beam/runners/worker/operations.py", line 142, in
apache_beam.runners.worker.operations.SingletonConsumerSet.receive
File "apache_beam/runners/worker/operations.py", line 554, in
apache_beam.runners.worker.operations.DoOperation.process
File "apache_beam/runners/worker/operations.py", line 555, in
apache_beam.runners.worker.operations.DoOperation.process
File "apache_beam/runners/common.py", line 728, in
apache_beam.runners.common.DoFnRunner.receive
File "apache_beam/runners/common.py", line 734, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 785, in
apache_beam.runners.common.DoFnRunner._reraise_augmented
File "/usr/local/lib/python3.5/site-packages/future/utils/__init__.py", line
421, in raise_with_traceback
raise exc.with_traceback(traceback)
File "apache_beam/runners/common.py", line 732, in
apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 418, in
apache_beam.runners.common.SimpleInvoker.invoke_process
File "apache_beam/runners/common.py", line 831, in
apache_beam.runners.common._OutputProcessor.process_outputs
File
"/usr/local/lib/python3.5/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 1004, in process
yield (self.destination(element), element)
File
"/mnt/c/Users/Juta/Documents/02-projects/apache/beam/sdks/python/apache_beam/io/gcp/bigquery_tools.py",
line 1043, in <lambda>
AttributeError: type object 'AppendDestinationsFn' has no attribute
'_value_provider_or_static_val' [while running
'WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/AppendDestination']
{code}
> Bigquery Tornadoes IT is broken in Python3 PostCommit test suite.
> ------------------------------------------------------------------
>
> Key: BEAM-6711
> URL: https://issues.apache.org/jira/browse/BEAM-6711
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
> Reporter: Valentyn Tymofieiev
> Assignee: Pablo Estrada
> Priority: Major
> Fix For: 2.12.0
>
> Time Spent: 6h 50m
> Remaining Estimate: 0h
>
> First failure was observed in
> https://builds.apache.org/job/beam_PostCommit_Python3_Verify/54 , after
> https://github.com/apache/beam/commit/cdea885872b3be7de9ba22f22700be89f7d53766
> was merged.
> [~pabloem], could you please take a look? I suggest we do a rollback +
> rollforward with a fix.
> {noformat}
> root: ERROR: Exception at bundle
> <apache_beam.runners.direct.bundle_factory._Bundle object at 0x7f35e5331240>,
> due to an exception.
> Traceback (most recent call last):
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify/src/sdks/python/apache_beam/runners/common.py",
> line 727, in process
> return self.do_fn_invoker.invoke_process(windowed_value)
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify/src/sdks/python/apache_beam/runners/common.py",
> line 556, in invoke_process
> windowed_value, additional_args, additional_kwargs, output_processor)
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify/src/sdks/python/apache_beam/runners/common.py",
> line 622, in _invoke_per_window
> self.process_method(*args_for_process, **kwargs_for_process))
> File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify/src/sdks/python/apache_beam/runners/common.py",
> line 823, in process_outputs
> for result in results:
> File "/home/jenkins/jenkins-slave/works
> pace/beam_PostCommit_Python3_Verify/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py",
> line 191, in process
> if destination in self._destination_to_file_writer:
> TypeError: unhashable type: 'TableReference'
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
