[
https://issues.apache.org/jira/browse/BEAM-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526060#comment-17526060
]
Benjamin Gonzalez commented on BEAM-14351:
------------------------------------------
Hi [~apilloud], the test was passing, the last successful run (tracked down in
Spark_Examples suite) was in
[https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Spark/264/testReport/apache_beam.examples.cookbook.coders_it_test/CodersIT/,]
the first failure is in
[https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Spark/265/]
maybe this commit could be related
[https://github.com/apache/beam/commit/777cf4ab9d4809f34210e56e645cc7ee62092532]
> Example 'JsonCoder' object has no attribute 'to_type_hint'
> ----------------------------------------------------------
>
> Key: BEAM-14351
> URL: https://issues.apache.org/jira/browse/BEAM-14351
> Project: Beam
> Issue Type: Bug
> Components: examples-python
> Reporter: Andrew Pilloud
> Assignee: Benjamin Gonzalez
> Priority: P1
>
> This test wasn't running due to BEAM-14336, I'm not sure it ever ran
> successfully. It is a hard failure in
> beam_PostCommit_Python_Examples_Dataflow
> apache_beam.examples.cookbook.coders_it_test.CodersIT.test_coders_output_files_on_small_input:
> https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/293/testReport/junit/apache_beam.examples.cookbook.coders_it_test/CodersIT/test_coders_output_files_on_small_input/
> {code}
> self = <apache_beam.examples.cookbook.coders_it_test.CodersIT
> testMethod=test_coders_output_files_on_small_input>
> @pytest.mark.no_xdist
> @pytest.mark.examples_postcommit
> def test_coders_output_files_on_small_input(self):
> test_pipeline = TestPipeline(is_integration_test=True)
> # Setup the files with expected content.
> OUTPUT_FILE_DIR = \
> 'gs://temp-storage-for-end-to-end-tests/py-it-cloud/output'
> output = '/'.join([OUTPUT_FILE_DIR, str(uuid.uuid4()), 'result'])
> INPUT_FILE_DIR = \
> 'gs://temp-storage-for-end-to-end-tests/py-it-cloud/input'
> input = '/'.join([INPUT_FILE_DIR, str(uuid.uuid4()), 'input.txt'])
> create_content_input_file(
> input, '\n'.join(map(json.dumps, self.SAMPLE_RECORDS)))
> extra_opts = {'input': input, 'output': output}
> > coders.run(test_pipeline.get_full_options_as_args(**extra_opts))
> apache_beam/examples/cookbook/coders_it_test.py:93:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
> apache_beam/examples/cookbook/coders.py:87: in run
> p
> apache_beam/transforms/ptransform.py:1092: in __ror__
> return self.transform.__ror__(pvalueish, self.label)
> apache_beam/transforms/ptransform.py:614: in __ror__
> result = p.apply(self, pvalueish, label)
> apache_beam/pipeline.py:662: in apply
> return self.apply(transform, pvalueish)
> apache_beam/pipeline.py:708: in apply
> pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
> apache_beam/runners/dataflow/dataflow_runner.py:141: in apply
> return super().apply(transform, input, options)
> apache_beam/runners/runner.py:185: in apply
> return m(transform, input, options)
> apache_beam/runners/runner.py:215: in apply_PTransform
> return transform.expand(input)
> apache_beam/io/textio.py:690: in expand
> self._source.output_type_hint())
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _
> self = <apache_beam.io.textio._TextSource object at 0x7fef4d8071c0>
> def output_type_hint(self):
> try:
> > return self._coder.to_type_hint()
> E AttributeError: 'JsonCoder' object has no attribute 'to_type_hint'
> apache_beam/io/textio.py:409: AttributeError
> {code}
> cc: [~tvalentyn]
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
