[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=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=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) > --- > >

[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

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

[ https://issues.apache.org/jira/browse/BEAM-6872?focusedWorklogId=225943=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=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=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=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=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=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=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=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=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=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=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=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=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=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=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=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=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

[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

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

[ https://issues.apache.org/jira/browse/BEAM-6872?focusedWorklogId=225883=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=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

[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

[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=16814926#comment-16814926 ] Reuven Lax commented on BEAM-7042: -- All tests appear to pass. However we probably should try and vendor

[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=16814923#comment-16814923 ] Michael Luckey commented on BEAM-7042: -- Yah... somehow that answer was expected :( So best we can do

[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

[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:

[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=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=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=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=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=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

[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

[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=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

[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=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=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=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=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=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

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

[ https://issues.apache.org/jira/browse/BEAM-6527?focusedWorklogId=225781=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=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=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=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=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

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

[ https://issues.apache.org/jira/browse/BEAM-6872?focusedWorklogId=225756=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=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=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=16814710#comment-16814710 ] Valentyn Tymofieiev commented on BEAM-6853: --- Possible reason: there is a typo in the option name

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

[ https://issues.apache.org/jira/browse/BEAM-6769?focusedWorklogId=225747=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=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=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=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=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=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=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=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=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=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=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=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=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=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=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=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=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=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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225647 ] 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=16814548#comment-16814548 ] Reuven Lax commented on BEAM-7042: -- It was added because some things were breaking without it. I don't

[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=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=16814534#comment-16814534 ] Ahmet Altay commented on BEAM-2572: --- There is a Google Summer of Code proposal, and a student is

[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

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

[ https://issues.apache.org/jira/browse/BEAM-6493?focusedWorklogId=225627=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=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

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

[ https://issues.apache.org/jira/browse/BEAM-6493?focusedWorklogId=225628=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]

[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=16814505#comment-16814505 ] Matt Morgis commented on BEAM-2572: --- Is anyone working on this? It is now needed to run TFX (on Kubeflow

[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=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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225622 ] 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=225612=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225612 ] 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=225613=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225613 ] 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=225609=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225609 ] 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=225608=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225608 ] 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=225603=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225603 ] ASF GitHub Bot logged work on BEAM-7042: Author: ASF GitHub Bot

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

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

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

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

  1   2   >