[jira] [Work logged] (BEAM-6865) Refactor common portable runner infrastructure for better reuse

[ https://issues.apache.org/jira/browse/BEAM-6865?focusedWorklogId=256379&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256379 ] ASF GitHub Bot logged work on BEAM-6865: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7511) KafkaTable Initialization

[ https://issues.apache.org/jira/browse/BEAM-7511?focusedWorklogId=256376&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256376 ] ASF GitHub Bot logged work on BEAM-7511: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-7470) Clean up Data Plane, rely only on instruction id and transform id

[ https://issues.apache.org/jira/browse/BEAM-7470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-7470. - Resolution: Fixed Fix Version/s: 2.14.0 > Clean up Data Plane, rely only on instruction id and tran

[jira] [Work logged] (BEAM-7470) Clean up Data Plane, rely only on instruction id and transform id

[ https://issues.apache.org/jira/browse/BEAM-7470?focusedWorklogId=256306&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256306 ] ASF GitHub Bot logged work on BEAM-7470: Author: ASF GitHub Bot

[jira] [Created] (BEAM-7516) Add a watermark manager for the fn_api_runner

Pablo Estrada created BEAM-7516: --- Summary: Add a watermark manager for the fn_api_runner Key: BEAM-7516 URL: https://issues.apache.org/jira/browse/BEAM-7516 Project: Beam Issue Type: Sub-task

[jira] [Commented] (BEAM-7515) Support TestStream on the fn_api_runner

[ https://issues.apache.org/jira/browse/BEAM-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859055#comment-16859055 ] Pablo Estrada commented on BEAM-7515: - This involves a runner-side implementation of t

[jira] [Created] (BEAM-7515) Support TestStream on the fn_api_runner

Pablo Estrada created BEAM-7515: --- Summary: Support TestStream on the fn_api_runner Key: BEAM-7515 URL: https://issues.apache.org/jira/browse/BEAM-7515 Project: Beam Issue Type: Sub-task

[jira] [Updated] (BEAM-7515) Support TestStream on the fn_api_runner

[ https://issues.apache.org/jira/browse/BEAM-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-7515: Status: Open (was: Triage Needed) > Support TestStream on the fn_api_runner > -

[jira] [Work started] (BEAM-7514) Support streaming on the Python fn_api_runner

[ https://issues.apache.org/jira/browse/BEAM-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-7514 started by Pablo Estrada. --- > Support streaming on the Python fn_api_runner > -

[jira] [Created] (BEAM-7514) Support streaming on the Python fn_api_runner

Pablo Estrada created BEAM-7514: --- Summary: Support streaming on the Python fn_api_runner Key: BEAM-7514 URL: https://issues.apache.org/jira/browse/BEAM-7514 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-7514) Support streaming on the Python fn_api_runner

[ https://issues.apache.org/jira/browse/BEAM-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-7514: Status: Open (was: Triage Needed) > Support streaming on the Python fn_api_runner > ---

[jira] [Commented] (BEAM-4374) Update existing metrics in the FN API to use new Metric Schema

[ https://issues.apache.org/jira/browse/BEAM-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859054#comment-16859054 ] Alex Amato commented on BEAM-4374: -- For Python yes, but not for Go > Update existing met

[jira] [Resolved] (BEAM-6094) Implement External environment for Portable Beam

[ https://issues.apache.org/jira/browse/BEAM-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada resolved BEAM-6094. - Resolution: Fixed Fix Version/s: Not applicable This is fixed by 7307 > Implement External

[jira] [Commented] (BEAM-4374) Update existing metrics in the FN API to use new Metric Schema

[ https://issues.apache.org/jira/browse/BEAM-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859051#comment-16859051 ] Pablo Estrada commented on BEAM-4374: - Is this resolved? > Update existing metrics in

[jira] [Resolved] (BEAM-6280) Failure in PortableRunnerTest.test_error_traceback_includes_user_code

[ https://issues.apache.org/jira/browse/BEAM-6280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada resolved BEAM-6280. - Resolution: Fixed Fix Version/s: Not applicable Thanks! > Failure in PortableRunnerTest.te

[jira] [Resolved] (BEAM-3886) Python SDK harness uses State API from ProcessBundleDescriptor

[ https://issues.apache.org/jira/browse/BEAM-3886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada resolved BEAM-3886. - Resolution: Fixed Fix Version/s: Not applicable This was fixed a while back. > Python SDK

[jira] [Resolved] (BEAM-6186) Cleanup FnApiRunner optimization phases.

[ https://issues.apache.org/jira/browse/BEAM-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada resolved BEAM-6186. - Resolution: Fixed Fix Version/s: 2.10.0 Thanks Robert. Marking as fixed. > Cleanup FnApiRu

[jira] [Created] (BEAM-7513) Row Estimation for BigQueryTable

Alireza Samadianzakaria created BEAM-7513: - Summary: Row Estimation for BigQueryTable Key: BEAM-7513 URL: https://issues.apache.org/jira/browse/BEAM-7513 Project: Beam Issue Type: New

[jira] [Work logged] (BEAM-7511) KafkaTable Initialization

[ https://issues.apache.org/jira/browse/BEAM-7511?focusedWorklogId=256292&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256292 ] ASF GitHub Bot logged work on BEAM-7511: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7511) KafkaTable Initialization

[ https://issues.apache.org/jira/browse/BEAM-7511?focusedWorklogId=256291&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256291 ] ASF GitHub Bot logged work on BEAM-7511: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6777) SDK Harness Resilience

[ https://issues.apache.org/jira/browse/BEAM-6777?focusedWorklogId=256285&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256285 ] ASF GitHub Bot logged work on BEAM-6777: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7511) KafkaTable Initialization

[ https://issues.apache.org/jira/browse/BEAM-7511?focusedWorklogId=256283&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256283 ] ASF GitHub Bot logged work on BEAM-7511: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py

[ https://issues.apache.org/jira/browse/BEAM-7512?focusedWorklogId=256278&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256278 ] ASF GitHub Bot logged work on BEAM-7512: Author: ASF GitHub Bot

[jira] [Closed] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py

[ https://issues.apache.org/jira/browse/BEAM-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik closed BEAM-7512. --- Resolution: Fixed Fix Version/s: 2.14.0 > Replace usage of assertEquals with assertEqual in synthetic_p

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6693?focusedWorklogId=256273&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256273 ] ASF GitHub Bot logged work on BEAM-6693: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7511) KafkaTable Initialization

[ https://issues.apache.org/jira/browse/BEAM-7511?focusedWorklogId=256269&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256269 ] ASF GitHub Bot logged work on BEAM-7511: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6620) Do not relocate guava

[ https://issues.apache.org/jira/browse/BEAM-6620?focusedWorklogId=256268&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256268 ] ASF GitHub Bot logged work on BEAM-6620: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6620) Do not relocate guava

[ https://issues.apache.org/jira/browse/BEAM-6620?focusedWorklogId=256267&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256267 ] ASF GitHub Bot logged work on BEAM-6620: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6620) Do not relocate guava

[ https://issues.apache.org/jira/browse/BEAM-6620?focusedWorklogId=256265&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256265 ] ASF GitHub Bot logged work on BEAM-6620: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6620) Do not relocate guava

[ https://issues.apache.org/jira/browse/BEAM-6620?focusedWorklogId=256266&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256266 ] ASF GitHub Bot logged work on BEAM-6620: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7511) KafkaTable Initialization

[ https://issues.apache.org/jira/browse/BEAM-7511?focusedWorklogId=256264&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256264 ] ASF GitHub Bot logged work on BEAM-7511: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6821) FileBasedSink is not creating file paths according to target filesystem

[ https://issues.apache.org/jira/browse/BEAM-6821?focusedWorklogId=256259&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256259 ] ASF GitHub Bot logged work on BEAM-6821: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6693?focusedWorklogId=256256&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256256 ] ASF GitHub Bot logged work on BEAM-6693: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7511) KafkaTable Initialization

[ https://issues.apache.org/jira/browse/BEAM-7511?focusedWorklogId=256254&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256254 ] ASF GitHub Bot logged work on BEAM-7511: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7101) Remove usages of deprecated assertion self.assertEquals in Python codebase.

[ https://issues.apache.org/jira/browse/BEAM-7101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859019#comment-16859019 ] Valentyn Tymofieiev commented on BEAM-7101: --- https://github.com/apache/beam/pull

[jira] [Closed] (BEAM-7101) Remove usages of deprecated assertion self.assertEquals in Python codebase.

[ https://issues.apache.org/jira/browse/BEAM-7101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev closed BEAM-7101. - Resolution: Fixed > Remove usages of deprecated assertion self.assertEquals in Python code

[jira] [Work logged] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py

[ https://issues.apache.org/jira/browse/BEAM-7512?focusedWorklogId=256251&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256251 ] ASF GitHub Bot logged work on BEAM-7512: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py

[ https://issues.apache.org/jira/browse/BEAM-7512?focusedWorklogId=256250&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256250 ] ASF GitHub Bot logged work on BEAM-7512: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py

[ https://issues.apache.org/jira/browse/BEAM-7512?focusedWorklogId=256249&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256249 ] ASF GitHub Bot logged work on BEAM-7512: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7101) Remove usages of deprecated assertion self.assertEquals in Python codebase.

[ https://issues.apache.org/jira/browse/BEAM-7101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859014#comment-16859014 ] Valentyn Tymofieiev commented on BEAM-7101: --- Currently we have usage of self.ass

[jira] [Commented] (BEAM-7101) Remove usages of deprecated assertion self.assertEquals in Python codebase.

[ https://issues.apache.org/jira/browse/BEAM-7101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859013#comment-16859013 ] Valentyn Tymofieiev commented on BEAM-7101: --- Look like we drifted into using dep

[jira] [Reopened] (BEAM-7101) Remove usages of deprecated assertion self.assertEquals in Python codebase.

[ https://issues.apache.org/jira/browse/BEAM-7101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev reopened BEAM-7101: --- > Remove usages of deprecated assertion self.assertEquals in Python codebase. > --

[jira] [Created] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py

Luke Cwik created BEAM-7512: --- Summary: Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py Key: BEAM-7512 URL: https://issues.apache.org/jira/browse/BEAM-7512 Project: Beam

[jira] [Commented] (BEAM-7478) Remote cluster submission from Flink Runner broken due to staging issues

[ https://issues.apache.org/jira/browse/BEAM-7478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859011#comment-16859011 ] Luke Cwik commented on BEAM-7478: - Thanks for the full stacktrace. Didn't provide me any a

[jira] [Commented] (BEAM-6257) Can we deprecate the side input paths through PAssert?

[ https://issues.apache.org/jira/browse/BEAM-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859006#comment-16859006 ] Kyle Weaver commented on BEAM-6257: --- Not totally fixed yet, passert for map and multimap

[jira] [Work logged] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?focusedWorklogId=256238&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256238 ] ASF GitHub Bot logged work on BEAM-7510: Author: ASF GitHub Bot

[jira] [Created] (BEAM-7511) KafkaTable Initialization

Alireza Samadianzakaria created BEAM-7511: - Summary: KafkaTable Initialization Key: BEAM-7511 URL: https://issues.apache.org/jira/browse/BEAM-7511 Project: Beam Issue Type: Bug

[jira] [Closed] (BEAM-7347) beam_Performance failed with benchmark flag config error

[ https://issues.apache.org/jira/browse/BEAM-7347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu closed BEAM-7347. -- Resolution: Fixed Fix Version/s: Not applicable > beam_Performance failed with benchmark flag config erro

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256211&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256211 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256210&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256210 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256208&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256208 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?focusedWorklogId=256206&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256206 ] ASF GitHub Bot logged work on BEAM-7510: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6673) BigQueryIO.Read should automatically produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6673?focusedWorklogId=256203&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256203 ] ASF GitHub Bot logged work on BEAM-6673: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6673) BigQueryIO.Read should automatically produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6673?focusedWorklogId=256204&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256204 ] ASF GitHub Bot logged work on BEAM-6673: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6673) BigQueryIO.Read should automatically produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6673?focusedWorklogId=256197&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256197 ] ASF GitHub Bot logged work on BEAM-6673: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6674) The JdbcIO source should produce schemas

[ https://issues.apache.org/jira/browse/BEAM-6674?focusedWorklogId=256196&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256196 ] ASF GitHub Bot logged work on BEAM-6674: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3607) Move checkNotNull arg checks to a new checkArgumentNotNull

[ https://issues.apache.org/jira/browse/BEAM-3607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858964#comment-16858964 ] Kenneth Knowles commented on BEAM-3607: --- Probably. I don't think there's any good re

[jira] [Work logged] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?focusedWorklogId=256193&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256193 ] ASF GitHub Bot logged work on BEAM-7510: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?focusedWorklogId=256191&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256191 ] ASF GitHub Bot logged work on BEAM-7510: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-6766) Sort Merge Bucket Join support in Beam

[ https://issues.apache.org/jira/browse/BEAM-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858949#comment-16858949 ] Kenneth Knowles commented on BEAM-6766: --- Wow, nice. Is there any possibility of bre

[jira] [Assigned] (BEAM-6766) Sort Merge Bucket Join support in Beam

[ https://issues.apache.org/jira/browse/BEAM-6766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-6766: - Assignee: Claire McGinty > Sort Merge Bucket Join support in Beam > -

[jira] [Work logged] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?focusedWorklogId=256184&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256184 ] ASF GitHub Bot logged work on BEAM-7510: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6904) Test all Coder structuralValue implementations

[ https://issues.apache.org/jira/browse/BEAM-6904?focusedWorklogId=256182&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256182 ] ASF GitHub Bot logged work on BEAM-6904: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6904) Test all Coder structuralValue implementations

[ https://issues.apache.org/jira/browse/BEAM-6904?focusedWorklogId=256181&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256181 ] ASF GitHub Bot logged work on BEAM-6904: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858937#comment-16858937 ] Valentyn Tymofieiev commented on BEAM-7510: --- Assigning to [~pabloem] who recentl

[jira] [Commented] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858938#comment-16858938 ] Pablo Estrada commented on BEAM-7510: - Sorry about that. I'll skip it and work on a fi

[jira] [Work logged] (BEAM-6904) Test all Coder structuralValue implementations

[ https://issues.apache.org/jira/browse/BEAM-6904?focusedWorklogId=256179&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256179 ] ASF GitHub Bot logged work on BEAM-6904: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-7510: -- Description: {noformat} 10:54:51 ==

[jira] [Commented] (BEAM-7510) test_write_to_different_file_types is flaky

[ https://issues.apache.org/jira/browse/BEAM-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858936#comment-16858936 ] Valentyn Tymofieiev commented on BEAM-7510: --- More logs available in  [https://bu

[jira] [Created] (BEAM-7510) test_write_to_different_file_types is flaky

Valentyn Tymofieiev created BEAM-7510: - Summary: test_write_to_different_file_types is flaky Key: BEAM-7510 URL: https://issues.apache.org/jira/browse/BEAM-7510 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-6904) Test all Coder structuralValue implementations

[ https://issues.apache.org/jira/browse/BEAM-6904?focusedWorklogId=256177&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256177 ] ASF GitHub Bot logged work on BEAM-6904: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-2888) Runner Comparison / Capability Matrix revamp

[ https://issues.apache.org/jira/browse/BEAM-2888?focusedWorklogId=256175&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256175 ] ASF GitHub Bot logged work on BEAM-2888: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-7499) ReifyTest.test_window fails in DirectRunner due to 'assign_context.window should not be None.'

[ https://issues.apache.org/jira/browse/BEAM-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tanay Tummalapalli updated BEAM-7499: - Component/s: test-failures > ReifyTest.test_window fails in DirectRunner due to 'assign_co

[jira] [Comment Edited] (BEAM-7499) ReifyTest.test_window fails in DirectRunner due to 'assign_context.window should not be None.'

[ https://issues.apache.org/jira/browse/BEAM-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858916#comment-16858916 ] Tanay Tummalapalli edited comment on BEAM-7499 at 6/7/19 7:06 PM: --

[jira] [Commented] (BEAM-7499) ReifyTest.test_window fails in DirectRunner due to 'assign_context.window should not be None.'

[ https://issues.apache.org/jira/browse/BEAM-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858916#comment-16858916 ] Tanay Tummalapalli commented on BEAM-7499: -- Hi [~lcwik], Thanks for fixing the te

[jira] [Resolved] (BEAM-7449) Add common pipeline patterns to docs

[ https://issues.apache.org/jira/browse/BEAM-7449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cyrus Maden resolved BEAM-7449. --- Resolution: Fixed Fix Version/s: Not applicable > Add common pipeline patterns to docs > --

[jira] [Work logged] (BEAM-6821) FileBasedSink is not creating file paths according to target filesystem

[ https://issues.apache.org/jira/browse/BEAM-6821?focusedWorklogId=256133&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256133 ] ASF GitHub Bot logged work on BEAM-6821: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6821) FileBasedSink is not creating file paths according to target filesystem

[ https://issues.apache.org/jira/browse/BEAM-6821?focusedWorklogId=256135&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256135 ] ASF GitHub Bot logged work on BEAM-6821: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6821) FileBasedSink is not creating file paths according to target filesystem

[ https://issues.apache.org/jira/browse/BEAM-6821?focusedWorklogId=256134&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256134 ] ASF GitHub Bot logged work on BEAM-6821: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7449) Add common pipeline patterns to docs

[ https://issues.apache.org/jira/browse/BEAM-7449?focusedWorklogId=256131&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256131 ] ASF GitHub Bot logged work on BEAM-7449: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6777) SDK Harness Resilience

[ https://issues.apache.org/jira/browse/BEAM-6777?focusedWorklogId=256128&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256128 ] ASF GitHub Bot logged work on BEAM-6777: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-7449) Add common pipeline patterns to docs

[ https://issues.apache.org/jira/browse/BEAM-7449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cyrus Maden updated BEAM-7449: -- Description: **I'm currently adding a section called "Common pipeline patterns" to the docs. It'll walk

[jira] [Work logged] (BEAM-6821) FileBasedSink is not creating file paths according to target filesystem

[ https://issues.apache.org/jira/browse/BEAM-6821?focusedWorklogId=256122&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256122 ] ASF GitHub Bot logged work on BEAM-6821: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6821) FileBasedSink is not creating file paths according to target filesystem

[ https://issues.apache.org/jira/browse/BEAM-6821?focusedWorklogId=256117&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256117 ] ASF GitHub Bot logged work on BEAM-6821: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256096&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256096 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256101&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256101 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256100&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256100 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256098&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256098 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256099&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256099 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7407) Create a Wordcount-on-Flink Python 3 test suite.

[ https://issues.apache.org/jira/browse/BEAM-7407?focusedWorklogId=256097&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256097 ] ASF GitHub Bot logged work on BEAM-7407: Author: ASF GitHub Bot

[jira] [Created] (BEAM-7509) [test] dependencies are used in testing/ directory and imported in non-test code

Pablo Estrada created BEAM-7509: --- Summary: [test] dependencies are used in testing/ directory and imported in non-test code Key: BEAM-7509 URL: https://issues.apache.org/jira/browse/BEAM-7509 Project: B

[jira] [Work logged] (BEAM-6821) FileBasedSink is not creating file paths according to target filesystem

[ https://issues.apache.org/jira/browse/BEAM-6821?focusedWorklogId=256088&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256088 ] ASF GitHub Bot logged work on BEAM-6821: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7428) ReadAllViaFileBasedSource does not output the timestamps of the read elements

[ https://issues.apache.org/jira/browse/BEAM-7428?focusedWorklogId=256078&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256078 ] ASF GitHub Bot logged work on BEAM-7428: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-7474) Add SDK harness containers for Py 3.6, Py 3.7

[ https://issues.apache.org/jira/browse/BEAM-7474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-7474: -- Status: Open (was: Triage Needed) > Add SDK harness containers for Py 3.6, Py 3.7 > ---

[jira] [Work logged] (BEAM-7428) ReadAllViaFileBasedSource does not output the timestamps of the read elements

[ https://issues.apache.org/jira/browse/BEAM-7428?focusedWorklogId=256062&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256062 ] ASF GitHub Bot logged work on BEAM-7428: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-7508) Expose the current key to the CombineFn

[ https://issues.apache.org/jira/browse/BEAM-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-7508: Description: One can not currently access the key during combining. Having access to the key can be useful

[jira] [Created] (BEAM-7508) Expose the current key to the CombineFn

Luke Cwik created BEAM-7508: --- Summary: Expose the current key to the CombineFn Key: BEAM-7508 URL: https://issues.apache.org/jira/browse/BEAM-7508 Project: Beam Issue Type: Improvement Co

[jira] [Closed] (BEAM-7507) StreamingDataflowWorker attempts to decode non-utf8 binary data as utf8

[ https://issues.apache.org/jira/browse/BEAM-7507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik closed BEAM-7507. --- Resolution: Fixed Fix Version/s: 2.14.0 > StreamingDataflowWorker attempts to decode non-utf8 binary da

[jira] [Work logged] (BEAM-7507) StreamingDataflowWorker attempts to decode non-utf8 binary data as utf8

[ https://issues.apache.org/jira/browse/BEAM-7507?focusedWorklogId=256026&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256026 ] ASF GitHub Bot logged work on BEAM-7507: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7368) Run Python GBK load tests on portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-7368?focusedWorklogId=256024&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-256024 ] ASF GitHub Bot logged work on BEAM-7368: Author: ASF GitHub Bot

  1   2   3   >