[jira] [Work logged] (BEAM-7005) Create GroupByKey streaming load test job for Java SDK

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

[jira] [Work logged] (BEAM-7005) Create GroupByKey streaming load test job for Java SDK

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

[jira] [Updated] (BEAM-7054) PortableRunner on Flink cluster crashes

[ https://issues.apache.org/jira/browse/BEAM-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rein Houthooft updated BEAM-7054: - Description: h2. Setup 2-node cluster: `master` and `worker`. `master` runs Flink JobManager, `wo

[jira] [Updated] (BEAM-7054) PortableRunner on Flink cluster crashes

[ https://issues.apache.org/jira/browse/BEAM-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rein Houthooft updated BEAM-7054: - Description: h2. Setup 2-node cluster: `master` and `worker`. `master` runs Flink JobManager, `wo

[jira] [Created] (BEAM-7054) PortableRunner on Flink cluster crashes

Rein Houthooft created BEAM-7054: Summary: PortableRunner on Flink cluster crashes Key: BEAM-7054 URL: https://issues.apache.org/jira/browse/BEAM-7054 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-7041) JdbcIO should not wrap the provided datasource if it's already a pollable one

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

[jira] [Work logged] (BEAM-7041) JdbcIO should not wrap the provided datasource if it's already a pollable one

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

[jira] [Closed] (BEAM-7010) MAX/MIN(STRING)

[ https://issues.apache.org/jira/browse/BEAM-7010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang closed BEAM-7010. -- Resolution: Fixed Fix Version/s: Not applicable > MAX/MIN(STRING) > --- > > K

[jira] [Closed] (BEAM-7024) Calcite BINARY to Beam Schema BYTES missing in CalciteUtils

[ https://issues.apache.org/jira/browse/BEAM-7024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang closed BEAM-7024. -- Resolution: Fixed Fix Version/s: Not applicable > Calcite BINARY to Beam Schema BYTES missing in CalciteU

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6962) Add wordcount_xlang to Python post-commit

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6772) Select transform has non-intuitive semantics

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

[jira] [Work logged] (BEAM-6962) Add wordcount_xlang to Python post-commit

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

[jira] [Work logged] (BEAM-6962) Add wordcount_xlang to Python post-commit

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

[jira] [Work logged] (BEAM-6962) Add wordcount_xlang to Python post-commit

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

[jira] [Work logged] (BEAM-7008) adding UTF8 String coder to Java SDK ModelCoders

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

[jira] [Work logged] (BEAM-4461) Create a library of useful transforms that use schemas

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

[jira] [Work logged] (BEAM-5663) Add tox suites for various Python 3 versions (3.5, 3.6, 3.7)

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

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

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

[jira] [Updated] (BEAM-7053) Spark portable runner: passing options from Python causes exceptions

[ https://issues.apache.org/jira/browse/BEAM-7053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7053: -- Issue Type: Bug (was: Improvement) > Spark portable runner: passing options from Python causes exceptio

[jira] [Created] (BEAM-7053) Spark portable runner: passing options from Python causes exceptions

Kyle Weaver created BEAM-7053: - Summary: Spark portable runner: passing options from Python causes exceptions Key: BEAM-7053 URL: https://issues.apache.org/jira/browse/BEAM-7053 Project: Beam Is

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-4087) Gradle build does not allow to overwrite versions of provided dependencies

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

[jira] [Updated] (BEAM-7052) portableWordCountTask raises IOError

[ https://issues.apache.org/jira/browse/BEAM-7052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7052: -- Description: Got this error when trying to run (Python) portableWordCountTask on the Spark portable run

[jira] [Updated] (BEAM-7052) portableWordCountTask raises IOError

[ https://issues.apache.org/jira/browse/BEAM-7052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7052: -- Summary: portableWordCountTask raises IOError (was: wordcount.py raises IOError on portable runner) >

[jira] [Updated] (BEAM-7052) wordcount.py raises IOError on portable runner

[ https://issues.apache.org/jira/browse/BEAM-7052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7052: -- Issue Type: Bug (was: Improvement) > wordcount.py raises IOError on portable runner > -

[jira] [Created] (BEAM-7052) wordcount.py raises IOError on portable runner

Kyle Weaver created BEAM-7052: - Summary: wordcount.py raises IOError on portable runner Key: BEAM-7052 URL: https://issues.apache.org/jira/browse/BEAM-7052 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-7008) adding UTF8 String coder to Java SDK ModelCoders

[ https://issues.apache.org/jira/browse/BEAM-7008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee updated BEAM-7008: -- Component/s: (was: sdk-py-core) > adding UTF8 String coder to Java SDK ModelCoders > ---

[jira] [Updated] (BEAM-7008) adding UTF8 String coder to Java SDK ModelCoders

[ https://issues.apache.org/jira/browse/BEAM-7008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Heejong Lee updated BEAM-7008: -- Summary: adding UTF8 String coder to Java SDK ModelCoders (was: standardize UTF-8 string coder encoding

[jira] [Commented] (BEAM-7042) beam-sdks-java-core leaks antlr4 dependency

[ https://issues.apache.org/jira/browse/BEAM-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814926#comment-16814926 ] Reuven Lax commented on BEAM-7042: -- All tests appear to pass. However we probably should

[jira] [Commented] (BEAM-7042) beam-sdks-java-core leaks antlr4 dependency

[ https://issues.apache.org/jira/browse/BEAM-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814923#comment-16814923 ] Michael Luckey commented on BEAM-7042: -- Yah... somehow that answer was expected :( S

[jira] [Created] (BEAM-7051) LIMIT COUNT OFFSET does not behave properly

Rui Wang created BEAM-7051: -- Summary: LIMIT COUNT OFFSET does not behave properly Key: BEAM-7051 URL: https://issues.apache.org/jira/browse/BEAM-7051 Project: Beam Issue Type: Bug Componen

[jira] [Created] (BEAM-7050) Antipattern will break legacy dataflow python pipelines if a new cy_combiner is added and used in the python counter_factory

Alex Amato created BEAM-7050: Summary: Antipattern will break legacy dataflow python pipelines if a new cy_combiner is added and used in the python counter_factory Key: BEAM-7050 URL: https://issues.apache.org/jira/br

[jira] [Work logged] (BEAM-5663) Add tox suites for various Python 3 versions (3.5, 3.6, 3.7)

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

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-6935) Spark Portable Runner: Support side inputs

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

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

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

[jira] [Updated] (BEAM-7037) Spark portable runner: run wordcount.py

[ https://issues.apache.org/jira/browse/BEAM-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7037: -- Description: So far, the Spark portable runner has only been run successfully on Java, which hardly make

[jira] [Updated] (BEAM-7037) Spark portable runner: run wordcount.py

[ https://issues.apache.org/jira/browse/BEAM-7037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7037: -- Summary: Spark portable runner: run wordcount.py (was: Spark portable runner: run on Python) > Spark p

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Created] (BEAM-7049) BeamUnionRel should work on mutiple input

Rui Wang created BEAM-7049: -- Summary: BeamUnionRel should work on mutiple input Key: BEAM-7049 URL: https://issues.apache.org/jira/browse/BEAM-7049 Project: Beam Issue Type: Improvement C

[jira] [Work logged] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

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

[jira] [Work logged] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Resolved] (BEAM-6991) EOS: Streaming job fails on job restart with withEOS specified

[ https://issues.apache.org/jira/browse/BEAM-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghu Angadi resolved BEAM-6991. Resolution: Not A Problem Fix Version/s: Not applicable I am closing this as 'Working as Inte

[jira] [Work logged] (BEAM-6527) Parallel tox (unit) tests run on Jenkins

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

[jira] [Work logged] (BEAM-5663) Add tox suites for various Python 3 versions (3.5, 3.6, 3.7)

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

[jira] [Work logged] (BEAM-6894) ExternalTransform.expand() does not create the proper AppliedPTransform sub-graph

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

[jira] [Work logged] (BEAM-6894) ExternalTransform.expand() does not create the proper AppliedPTransform sub-graph

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

[jira] [Work logged] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

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

[jira] [Created] (BEAM-7048) Fetch GCP-Datastore entity by id inside of a Dataflow transform

Alex Indaco created BEAM-7048: - Summary: Fetch GCP-Datastore entity by id inside of a Dataflow transform Key: BEAM-7048 URL: https://issues.apache.org/jira/browse/BEAM-7048 Project: Beam Issue T

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

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

[jira] [Work logged] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

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

[jira] [Commented] (BEAM-6853) Make Java and python portable options same

[ https://issues.apache.org/jira/browse/BEAM-6853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814710#comment-16814710 ] Valentyn Tymofieiev commented on BEAM-6853: --- Possible reason: there is a typo in

[jira] [Work logged] (BEAM-6769) BigQuery IO does not support bytes in Python 3

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

[jira] [Work logged] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

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

[jira] [Work logged] (BEAM-6527) Parallel tox (unit) tests run on Jenkins

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

[jira] [Work logged] (BEAM-6493) examples in Kotlin

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

[jira] [Work logged] (BEAM-6441) cut_release_branch.sh should not push to master without verification and a PR

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

[jira] [Work logged] (BEAM-6056) Migrate gRPC to use vendoring library and vendoring format

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-7024) Calcite BINARY to Beam Schema BYTES missing in CalciteUtils

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

[jira] [Work logged] (BEAM-7024) Calcite BINARY to Beam Schema BYTES missing in CalciteUtils

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

[jira] [Work logged] (BEAM-6056) Migrate gRPC to use vendoring library and vendoring format

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

[jira] [Work logged] (BEAM-7041) JdbcIO should not wrap the provided datasource if it's already a pollable one

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-6872) Add hook for user-defined JVM initialization in workers

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

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Assigned] (BEAM-6732) Add "withResults()" for JdbcIO.write()

[ https://issues.apache.org/jira/browse/BEAM-6732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-6732: -- Assignee: Alexey Romanenko > Add "withResults()" for JdbcIO.write() > -

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Work logged] (BEAM-6441) cut_release_branch.sh should not push to master without verification and a PR

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

[jira] [Work logged] (BEAM-6441) cut_release_branch.sh should not push to master without verification and a PR

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

[jira] [Commented] (BEAM-7042) beam-sdks-java-core leaks antlr4 dependency

[ https://issues.apache.org/jira/browse/BEAM-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814548#comment-16814548 ] Reuven Lax commented on BEAM-7042: -- It was added because some things were breaking withou

[jira] [Work logged] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

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

[jira] [Commented] (BEAM-2572) Implement an S3 filesystem for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814534#comment-16814534 ] Ahmet Altay commented on BEAM-2572: --- There is a Google Summer of Code proposal, and a st

[jira] [Assigned] (BEAM-7042) beam-sdks-java-core leaks antlr4 dependency

[ https://issues.apache.org/jira/browse/BEAM-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-7042: -- Assignee: Michael Luckey (was: Reuven Lax) > beam-sdks-java-core leaks antlr4 dependency > ---

[jira] [Updated] (BEAM-7042) beam-sdks-java-core leaks antlr4 dependency

[ https://issues.apache.org/jira/browse/BEAM-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7042: --- Description: beam-sdks-java-core brings antlr4 and its transitive deps which is quite unlikely and has

[jira] [Work logged] (BEAM-6493) examples in Kotlin

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

[jira] [Work logged] (BEAM-6493) examples in Kotlin

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

[jira] [Updated] (BEAM-7042) beam-sdks-java-core leaks antlr4 dependency

[ https://issues.apache.org/jira/browse/BEAM-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7042: --- Description: Current sdk brings antlr4 and its transitive deps which is quite unlikely and has a huge

[jira] [Work logged] (BEAM-6493) examples in Kotlin

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

[jira] [Updated] (BEAM-7042) beam-sdks-java-core leaks antlr4 dependency

[ https://issues.apache.org/jira/browse/BEAM-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7042: --- Summary: beam-sdks-java-core leaks antlr4 dependency (was: [regression] org.apache.beam:beam-sdks-jav

[jira] [Updated] (BEAM-7042) [regression] org.apache.beam:beam-sdks-java-core:jar:2.12.0 dependencies are way fatter and conflicting than before

[ https://issues.apache.org/jira/browse/BEAM-7042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7042: --- Fix Version/s: (was: 2.13.0) 2.12.0 > [regression] org.apache.beam:beam-sdks-ja

[jira] [Commented] (BEAM-2572) Implement an S3 filesystem for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814505#comment-16814505 ] Matt Morgis commented on BEAM-2572: --- Is anyone working on this? It is now needed to run

[jira] [Work logged] (BEAM-7042) [regression] org.apache.beam:beam-sdks-java-core:jar:2.12.0 dependencies are way fatter and conflicting than before

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

[jira] [Work logged] (BEAM-7042) [regression] org.apache.beam:beam-sdks-java-core:jar:2.12.0 dependencies are way fatter and conflicting than before

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

  1   2   >