[jira] [Commented] (BEAM-5627) Several IO tests fail in Python 3 when accessing a temporary file with TypeError: a bytes-like object is required, not 'str'
[
https://issues.apache.org/jira/browse/BEAM-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647198#comment-16647198
]
Ruoyun Huang commented on BEAM-5627:
Valentyn is right, there are a lot of them in the tests.
I will take care of
[filesystems_test.py|https://github.com/apache/beam/pull/6610/files#diff-9bc1968a10d6ef5df1a1690027a774b0]
and
[io/sources_test.py|https://github.com/apache/beam/pull/6610/files#diff-aa300c32e00d2cbf44349027b526271f]
(apparently they will affect internal test, will need extra efforts anyway).
> Several IO tests fail in Python 3 when accessing a temporary file with
> TypeError: a bytes-like object is required, not 'str'
> --
>
> Key: BEAM-5627
> URL: https://issues.apache.org/jira/browse/BEAM-5627
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
>Reporter: Valentyn Tymofieiev
>Assignee: Rakesh Kumar
>Priority: Major
> Fix For: Not applicable
>
> Time Spent: 2h
> Remaining Estimate: 0h
>
> ERROR: test_split_at_fraction_exhaustive
> (apache_beam.io.source_test_utils_test.SourceTestUtilsTest)
> --
> Traceback (most recent call last):
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/source_test_utils_test.py",
> line 120, in test_split_at_fraction_exhaustive
> source = self._create_source(data)
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/source_test_utils_test.py",
> line 43, in _create_source
> source = LineSource(self._create_file_with_data(data))
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/source_test_utils_test.py",
> line 35, in _create_file_with_data
> f.write(line + '\n')
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/target/.tox/py3/lib/python3.5/tempfile.py",
> line 622, in func_wrapper
> return func(*args, **kwargs)
> TypeError: a bytes-like object is required, not 'str'
> Also similar:
> ==
> ERROR: test_file_sink_writing
> (apache_beam.io.filebasedsink_test.TestFileBasedSink)
> --
> Traceback (most recent call last):
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink_test.py", line 121, in
> test_file_sink_writing
> init_token, writer_results = self._common_init(sink)
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink_test.py", line 103, in _common_init
> writer1 = sink.open_writer(init_token, '1')
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/options/value_provider.py", line 133, in _f
> return fnc(self, *args, **kwargs)
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink.py", line 185, in open_writer
> return FileBasedSinkWriter(self, os.path.join(init_result, uid) + suffix)
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink.py", line 385, in __init__
> self.temp_handle = self.sink.open(temp_shard_path)
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink_test.py", line 82, in open
> file_handle.write('[start]')
> TypeError: a bytes-like object is required, not 'str'
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Commented] (BEAM-5703) Migrate Python streaming and portable integration tests to use a staged dataflow worker jar
[ https://issues.apache.org/jira/browse/BEAM-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647182#comment-16647182 ] Ruoyun Huang commented on BEAM-5703: Now I assume this is the central place of integration test : [https://github.com/apache/beam/blob/master/sdks/python/scripts/run_integration_test.sh] Let me know if there are more others. > Migrate Python streaming and portable integration tests to use a staged > dataflow worker jar > --- > > Key: BEAM-5703 > URL: https://issues.apache.org/jira/browse/BEAM-5703 > Project: Beam > Issue Type: Sub-task > Components: sdk-py-core >Reporter: Henning Rohde >Assignee: Ruoyun Huang >Priority: Major > -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Resolved] (BEAM-5427) Fix sample code (AverageFn) in Combine.java
[ https://issues.apache.org/jira/browse/BEAM-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang resolved BEAM-5427. Resolution: Fixed Fix Version/s: 2.8.0 > Fix sample code (AverageFn) in Combine.java > --- > > Key: BEAM-5427 > URL: https://issues.apache.org/jira/browse/BEAM-5427 > Project: Beam > Issue Type: Improvement > Components: examples-java >Reporter: Ruoyun Huang >Assignee: Ruoyun Huang >Priority: Minor > Fix For: 2.8.0 > > Time Spent: 3h 50m > Remaining Estimate: 0h > > Sample code missing coder. > In its current state, job run fails with Coder missing error. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (BEAM-5618) Several tests fail on Python 3 with: unsupported operand type(s) for +: 'int' and 'EmptySideInput'
[ https://issues.apache.org/jira/browse/BEAM-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang reassigned BEAM-5618: -- Assignee: (was: Ruoyun Huang) > Several tests fail on Python 3 with: unsupported operand type(s) for +: 'int' > and 'EmptySideInput' > -- > > Key: BEAM-5618 > URL: https://issues.apache.org/jira/browse/BEAM-5618 > Project: Beam > Issue Type: Sub-task > Components: sdk-py-core >Reporter: Valentyn Tymofieiev >Priority: Major > > ERROR: test_do_with_side_input_as_arg > (apache_beam.transforms.ptransform_test.PTransformTest) > -- > Traceback (most recent call last): > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/runners/common.py", > line 677, in process > self.do_fn_invoker.invoke_process(windowed_value) > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/runners/common.py", > line 529, in invoke_process > windowed_value, additional_args, additional_kwargs, output_processor) > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/runners/common.py", > line 598, in _invoke_per_window > windowed_value, self.process_method(*args_for_process)) > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 135, in > lambda x, addon: [x + addon], pvalue.AsSingleton(side)) > TypeError: unsupported operand type(s) for +: 'int' and 'EmptySideInput' -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (BEAM-5618) Several tests fail on Python 3 with: unsupported operand type(s) for +: 'int' and 'EmptySideInput'
[ https://issues.apache.org/jira/browse/BEAM-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang reassigned BEAM-5618: -- Assignee: Ruoyun Huang > Several tests fail on Python 3 with: unsupported operand type(s) for +: 'int' > and 'EmptySideInput' > -- > > Key: BEAM-5618 > URL: https://issues.apache.org/jira/browse/BEAM-5618 > Project: Beam > Issue Type: Sub-task > Components: sdk-py-core >Reporter: Valentyn Tymofieiev >Assignee: Ruoyun Huang >Priority: Major > > ERROR: test_do_with_side_input_as_arg > (apache_beam.transforms.ptransform_test.PTransformTest) > -- > Traceback (most recent call last): > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/runners/common.py", > line 677, in process > self.do_fn_invoker.invoke_process(windowed_value) > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/runners/common.py", > line 529, in invoke_process > windowed_value, additional_args, additional_kwargs, output_processor) > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/runners/common.py", > line 598, in _invoke_per_window > windowed_value, self.process_method(*args_for_process)) > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 135, in > lambda x, addon: [x + addon], pvalue.AsSingleton(side)) > TypeError: unsupported operand type(s) for +: 'int' and 'EmptySideInput' -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (BEAM-5627) Several IO tests fail in Python 3 when accessing a temporary file with TypeError: a bytes-like object is required, not 'str'
[
https://issues.apache.org/jira/browse/BEAM-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642591#comment-16642591
]
Ruoyun Huang commented on BEAM-5627:
Rakesh FYI.
Fixed this issue in a few modules while I am already fixing some other issues.
[https://github.com/apache/beam/pull/6610]
> Several IO tests fail in Python 3 when accessing a temporary file with
> TypeError: a bytes-like object is required, not 'str'
> --
>
> Key: BEAM-5627
> URL: https://issues.apache.org/jira/browse/BEAM-5627
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
>Reporter: Valentyn Tymofieiev
>Assignee: Rakesh Kumar
>Priority: Major
> Time Spent: 10m
> Remaining Estimate: 0h
>
> ERROR: test_split_at_fraction_exhaustive
> (apache_beam.io.source_test_utils_test.SourceTestUtilsTest)
> --
> Traceback (most recent call last):
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/source_test_utils_test.py",
> line 120, in test_split_at_fraction_exhaustive
> source = self._create_source(data)
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/source_test_utils_test.py",
> line 43, in _create_source
> source = LineSource(self._create_file_with_data(data))
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/source_test_utils_test.py",
> line 35, in _create_file_with_data
> f.write(line + '\n')
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/target/.tox/py3/lib/python3.5/tempfile.py",
> line 622, in func_wrapper
> return func(*args, **kwargs)
> TypeError: a bytes-like object is required, not 'str'
> Also similar:
> ==
> ERROR: test_file_sink_writing
> (apache_beam.io.filebasedsink_test.TestFileBasedSink)
> --
> Traceback (most recent call last):
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink_test.py", line 121, in
> test_file_sink_writing
> init_token, writer_results = self._common_init(sink)
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink_test.py", line 103, in _common_init
> writer1 = sink.open_writer(init_token, '1')
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/options/value_provider.py", line 133, in _f
> return fnc(self, *args, **kwargs)
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink.py", line 185, in open_writer
> return FileBasedSinkWriter(self, os.path.join(init_result, uid) + suffix)
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink.py", line 385, in __init__
> self.temp_handle = self.sink.open(temp_shard_path)
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/
>apache_beam/io/filebasedsink_test.py", line 82, in open
> file_handle.write('[start]')
> TypeError: a bytes-like object is required, not 'str'
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Commented] (BEAM-5626) Several IO tests fail in Python 3 with RuntimeError('dictionary changed size during iteration',)}
[
https://issues.apache.org/jira/browse/BEAM-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642563#comment-16642563
]
Ruoyun Huang commented on BEAM-5626:
Fixed in the module as reported. Not sure if the same error exists in other
places.
Shall we mark this JIRA as fixed for now?
> Several IO tests fail in Python 3 with RuntimeError('dictionary changed size
> during iteration',)}
> -
>
> Key: BEAM-5626
> URL: https://issues.apache.org/jira/browse/BEAM-5626
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
>Reporter: Valentyn Tymofieiev
>Assignee: Ruoyun Huang
>Priority: Major
> Time Spent: 4h
> Remaining Estimate: 0h
>
> ERROR: test_delete_dir
> (apache_beam.io.hadoopfilesystem_test.HadoopFileSystemTest)
> --
> Traceback (most recent call last):
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/hadoopfilesystem_test.py",
> line 506, in test_delete_dir
> self.fs.delete([url_t1])
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/hadoopfilesystem.py",
> line 370, in delete
> raise BeamIOError("Delete operation failed", exceptions)
> apache_beam.io.filesystem.BeamIOError: Delete operation failed with
> exceptions {'hdfs://test_dir/new_dir1': RuntimeError('dictionary changed size
> during iteration', )}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Assigned] (BEAM-5622) Several tests fail on Python 3 with: Runtime type violation detected
[ https://issues.apache.org/jira/browse/BEAM-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang reassigned BEAM-5622: -- Assignee: (was: Ruoyun Huang) > Several tests fail on Python 3 with: Runtime type violation detected > > > Key: BEAM-5622 > URL: https://issues.apache.org/jira/browse/BEAM-5622 > Project: Beam > Issue Type: Sub-task > Components: sdk-py-core >Reporter: Valentyn Tymofieiev >Priority: Major > > == > FAIL: test_combine_runtime_type_check_violation_using_decorators > (apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase) > -- > Traceback (most recent call last): > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 1543, in test_combine_runtime_type_check_violation_using_decorators > "Runtime type violation detected within " > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 911, in assertStartswith > '"%s" does not start with "%s"' % (msg, prefix)) > AssertionError: False is not true : "Runtime type violation detected within > Mul/CombinePerKey: Type-hint for return type violated. Expected an instance > of , instead found > 25252525252525252525252525252525252525252525252525, an instance of 'str'>." does not start with "Runtime type violation detected within > Mul/CombinePerKey: Type-hint for return type violated. Expected an instance > of , instead found" > == > FAIL: test_combine_runtime_type_check_violation_using_methods > (apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase) > -- > Traceback (most recent call last): > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 1597, in test_combine_runtime_type_check_violation_using_methods > "Runtime type violation detected within " > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 911, in assertStartswith > '"%s" does not start with "%s"' % (msg, prefix)) > AssertionError: False is not true : "Runtime type violation detected within > ParDo(SortJoin/KeyWithVoid): Type-hint for argument: 'v' violated. Expected > an instance of , instead found 0, an instance of . > [while running 'SortJoin/KeyWithVoid']" does not start with "Runtime type > violation detected within ParDo(SortJoin/KeyWithVoid): Type-hint for > argument: 'v' violated. Expected an instance of , instead found > 0, an instance of ." -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (BEAM-5626) Several IO tests fail in Python 3 with RuntimeError('dictionary changed size during iteration',)}
[
https://issues.apache.org/jira/browse/BEAM-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruoyun Huang reassigned BEAM-5626:
--
Assignee: Ruoyun Huang
> Several IO tests fail in Python 3 with RuntimeError('dictionary changed size
> during iteration',)}
> -
>
> Key: BEAM-5626
> URL: https://issues.apache.org/jira/browse/BEAM-5626
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
>Reporter: Valentyn Tymofieiev
>Assignee: Ruoyun Huang
>Priority: Major
>
> ERROR: test_delete_dir
> (apache_beam.io.hadoopfilesystem_test.HadoopFileSystemTest)
> --
> Traceback (most recent call last):
> File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/hadoopfilesystem_test.py",
> line 506, in test_delete_dir
> self.fs.delete([url_t1])
>File
> "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/io/hadoopfilesystem.py",
> line 370, in delete
> raise BeamIOError("Delete operation failed", exceptions)
> apache_beam.io.filesystem.BeamIOError: Delete operation failed with
> exceptions {'hdfs://test_dir/new_dir1': RuntimeError('dictionary changed size
> during iteration', )}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Assigned] (BEAM-5622) Several tests fail on Python 3 with: Runtime type violation detected
[ https://issues.apache.org/jira/browse/BEAM-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang reassigned BEAM-5622: -- Assignee: Ruoyun Huang > Several tests fail on Python 3 with: Runtime type violation detected > > > Key: BEAM-5622 > URL: https://issues.apache.org/jira/browse/BEAM-5622 > Project: Beam > Issue Type: Sub-task > Components: sdk-py-core >Reporter: Valentyn Tymofieiev >Assignee: Ruoyun Huang >Priority: Major > > == > FAIL: test_combine_runtime_type_check_violation_using_decorators > (apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase) > -- > Traceback (most recent call last): > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 1543, in test_combine_runtime_type_check_violation_using_decorators > "Runtime type violation detected within " > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 911, in assertStartswith > '"%s" does not start with "%s"' % (msg, prefix)) > AssertionError: False is not true : "Runtime type violation detected within > Mul/CombinePerKey: Type-hint for return type violated. Expected an instance > of , instead found > 25252525252525252525252525252525252525252525252525, an instance of 'str'>." does not start with "Runtime type violation detected within > Mul/CombinePerKey: Type-hint for return type violated. Expected an instance > of , instead found" > == > FAIL: test_combine_runtime_type_check_violation_using_methods > (apache_beam.transforms.ptransform_test.PTransformTypeCheckTestCase) > -- > Traceback (most recent call last): > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 1597, in test_combine_runtime_type_check_violation_using_methods > "Runtime type violation detected within " > File > "/usr/local/google/home/valentyn/projects/beam/clean_head/beam/sdks/python/apache_beam/transforms/ptransform_test.py", > line 911, in assertStartswith > '"%s" does not start with "%s"' % (msg, prefix)) > AssertionError: False is not true : "Runtime type violation detected within > ParDo(SortJoin/KeyWithVoid): Type-hint for argument: 'v' violated. Expected > an instance of , instead found 0, an instance of . > [while running 'SortJoin/KeyWithVoid']" does not start with "Runtime type > violation detected within ParDo(SortJoin/KeyWithVoid): Type-hint for > argument: 'v' violated. Expected an instance of , instead found > 0, an instance of ." -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Issue Comment Deleted] (BEAM-5427) Fix sample code (AverageFn) in Combine.java
[ https://issues.apache.org/jira/browse/BEAM-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang updated BEAM-5427: --- Comment: was deleted (was: PR created: https://github.com/apache/beam/pull/6432) > Fix sample code (AverageFn) in Combine.java > --- > > Key: BEAM-5427 > URL: https://issues.apache.org/jira/browse/BEAM-5427 > Project: Beam > Issue Type: Improvement > Components: examples-java >Reporter: Ruoyun Huang >Assignee: Ruoyun Huang >Priority: Minor > Time Spent: 20m > Remaining Estimate: 0h > > Sample code missing coder. > In its current state, job run fails with Coder missing error. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (BEAM-5427) Fix sample code (AverageFn) in Combine.java
[ https://issues.apache.org/jira/browse/BEAM-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang updated BEAM-5427: --- Description: Sample code missing coder. In its current state, job run fails with Coder missing error. was:Sample code missing coder. > Fix sample code (AverageFn) in Combine.java > --- > > Key: BEAM-5427 > URL: https://issues.apache.org/jira/browse/BEAM-5427 > Project: Beam > Issue Type: Improvement > Components: examples-java >Reporter: Ruoyun Huang >Assignee: Ruoyun Huang >Priority: Minor > Time Spent: 20m > Remaining Estimate: 0h > > Sample code missing coder. > In its current state, job run fails with Coder missing error. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Assigned] (BEAM-5427) Fix sample code (AverageFn) in Combine.java
[ https://issues.apache.org/jira/browse/BEAM-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruoyun Huang reassigned BEAM-5427: -- Assignee: Ruoyun Huang (was: Reuven Lax) > Fix sample code (AverageFn) in Combine.java > --- > > Key: BEAM-5427 > URL: https://issues.apache.org/jira/browse/BEAM-5427 > Project: Beam > Issue Type: Improvement > Components: examples-java >Reporter: Ruoyun Huang >Assignee: Ruoyun Huang >Priority: Minor > Time Spent: 20m > Remaining Estimate: 0h > > Sample code missing coder. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (BEAM-5427) Fix sample code (AverageFn) in Combine.java
[ https://issues.apache.org/jira/browse/BEAM-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16619936#comment-16619936 ] Ruoyun Huang commented on BEAM-5427: PR created: https://github.com/apache/beam/pull/6432 > Fix sample code (AverageFn) in Combine.java > --- > > Key: BEAM-5427 > URL: https://issues.apache.org/jira/browse/BEAM-5427 > Project: Beam > Issue Type: Improvement > Components: examples-java >Reporter: Ruoyun Huang >Assignee: Reuven Lax >Priority: Minor > > Sample code missing coder. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (BEAM-5427) Fix sample code (AverageFn) in Combine.java
Ruoyun Huang created BEAM-5427: -- Summary: Fix sample code (AverageFn) in Combine.java Key: BEAM-5427 URL: https://issues.apache.org/jira/browse/BEAM-5427 Project: Beam Issue Type: Improvement Components: examples-java Reporter: Ruoyun Huang Assignee: Reuven Lax Sample code missing coder. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
