[jira] [Work logged] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

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

[jira] [Work logged] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

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

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

[ https://issues.apache.org/jira/browse/BEAM-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Luckey reassigned BEAM-4087: Assignee: (was: Michael Luckey) > Gradle build does not allow to overwrite versions of

[jira] [Commented] (BEAM-8210) Python Integration tests: log test name

[ https://issues.apache.org/jira/browse/BEAM-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952305#comment-16952305 ] Kenneth Knowles commented on BEAM-8210: --- Since currently it seems phrased as a Dataflow feature

[jira] [Commented] (BEAM-8172) Add a label field to FunctionSpec proto

[ https://issues.apache.org/jira/browse/BEAM-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952312#comment-16952312 ] Chad Dombrova commented on BEAM-8172: - The goal of clarifying intent is a fine one, but I'm concerned

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Updated] (BEAM-8140) Python API: PTransform should be immutable

[ https://issues.apache.org/jira/browse/BEAM-8140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8140: -- Issue Type: Bug (was: Improvement) > Python API: PTransform should be immutable >

[jira] [Updated] (BEAM-8140) Python API: PTransform should be immutable

[ https://issues.apache.org/jira/browse/BEAM-8140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8140: -- Status: Open (was: Triage Needed) > Python API: PTransform should be immutable >

[jira] [Commented] (BEAM-8166) Support Graceful shutdown of worker harness.

[ https://issues.apache.org/jira/browse/BEAM-8166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952296#comment-16952296 ] Kenneth Knowles commented on BEAM-8166: --- Also I'm confused about what is the worker harness versus

[jira] [Work logged] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

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

[jira] [Updated] (BEAM-8360) Failure in https://builds.apache.org/job/beam_PreCommit_PythonLint_Commit/58/console

[ https://issues.apache.org/jira/browse/BEAM-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8360: -- Labels: (was: currently-failing) > Failure in >

[jira] [Updated] (BEAM-8140) Python API: PTransform should be immutable and reusable

[ https://issues.apache.org/jira/browse/BEAM-8140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8140: -- Summary: Python API: PTransform should be immutable and reusable (was: Python API: PTransform

[jira] [Updated] (BEAM-8172) Add a label field to FunctionSpec proto

[ https://issues.apache.org/jira/browse/BEAM-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8172: -- Status: Open (was: Triage Needed) > Add a label field to FunctionSpec proto >

[jira] [Commented] (BEAM-8153) PubSubIntegrationTest failing in post-commit

[ https://issues.apache.org/jira/browse/BEAM-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952301#comment-16952301 ] Kenneth Knowles commented on BEAM-8153: --- Do we need to keep the bug open? > PubSubIntegrationTest

[jira] [Updated] (BEAM-8145) Pubsub message size limit not taking size increase from base64 encoding into account

[ https://issues.apache.org/jira/browse/BEAM-8145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8145: -- Status: Open (was: Triage Needed) > Pubsub message size limit not taking size increase from

[jira] [Commented] (BEAM-8172) Add a label field to FunctionSpec proto

[ https://issues.apache.org/jira/browse/BEAM-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952300#comment-16952300 ] Kenneth Knowles commented on BEAM-8172: --- I'd suggest "debug_string" to make it clear that there is

[jira] [Updated] (BEAM-8153) PubSubIntegrationTest failing in post-commit

[ https://issues.apache.org/jira/browse/BEAM-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8153: -- Status: Open (was: Triage Needed) > PubSubIntegrationTest failing in post-commit >

[jira] [Updated] (BEAM-8179) No tabs in dot output

[ https://issues.apache.org/jira/browse/BEAM-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8179: -- Status: Open (was: Triage Needed) > No tabs in dot output > - > >

[jira] [Commented] (BEAM-8145) Pubsub message size limit not taking size increase from base64 encoding into account

[ https://issues.apache.org/jira/browse/BEAM-8145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952302#comment-16952302 ] Kenneth Knowles commented on BEAM-8145: --- [~Primevenn] [~chamikara] is this fixed? > Pubsub message

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-7981) ParDo function wrapper doesn't support Iterable output types

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

[jira] [Updated] (BEAM-8379) Cache Eviction for Interactive Beam

[ https://issues.apache.org/jira/browse/BEAM-8379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8379: -- Status: Open (was: Triage Needed) > Cache Eviction for Interactive Beam >

[jira] [Updated] (BEAM-8393) Java BigQueryIO clustering support breaks on multiple partitions

[ https://issues.apache.org/jira/browse/BEAM-8393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8393: -- Status: Open (was: Triage Needed) > Java BigQueryIO clustering support breaks on multiple

[jira] [Updated] (BEAM-8395) JavaBeamZetaSQL PreCommit is flaky

[ https://issues.apache.org/jira/browse/BEAM-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8395: -- Status: Open (was: Triage Needed) > JavaBeamZetaSQL PreCommit is flaky >

[jira] [Updated] (BEAM-8395) JavaBeamZetaSQL PreCommit is flaky

[ https://issues.apache.org/jira/browse/BEAM-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8395: -- Labels: flake (was: ) > JavaBeamZetaSQL PreCommit is flaky >

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Updated] (BEAM-8360) Failure in https://builds.apache.org/job/beam_PreCommit_PythonLint_Commit/58/console

[ https://issues.apache.org/jira/browse/BEAM-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8360: -- Status: Open (was: Triage Needed) > Failure in >

[jira] [Updated] (BEAM-8211) Set a default wait_until_finish_duration?

[ https://issues.apache.org/jira/browse/BEAM-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8211: -- Component/s: sdk-py-core > Set a default wait_until_finish_duration? >

[jira] [Commented] (BEAM-8211) Set a default wait_until_finish_duration?

[ https://issues.apache.org/jira/browse/BEAM-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952298#comment-16952298 ] Kenneth Knowles commented on BEAM-8211: --- Tagged Python here, but sounds like it could be useful more

[jira] [Updated] (BEAM-8216) GCS IO fails with uninformative 'Broken pipe' errors while attempting to write to a GCS bucket without proper permissions.

[ https://issues.apache.org/jira/browse/BEAM-8216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8216: -- Status: Open (was: Triage Needed) > GCS IO fails with uninformative 'Broken pipe' errors while

[jira] [Updated] (BEAM-8211) Set a default wait_until_finish_duration?

[ https://issues.apache.org/jira/browse/BEAM-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8211: -- Status: Open (was: Triage Needed) > Set a default wait_until_finish_duration? >

[jira] [Resolved] (BEAM-8360) Failure in https://builds.apache.org/job/beam_PreCommit_PythonLint_Commit/58/console

[ https://issues.apache.org/jira/browse/BEAM-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-8360. --- Fix Version/s: Not applicable Resolution: Fixed > Failure in >

[jira] [Updated] (BEAM-8173) Filesystems.matchSingleFileSpec throws away the actual failure exception

[ https://issues.apache.org/jira/browse/BEAM-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8173: -- Status: Open (was: Triage Needed) > Filesystems.matchSingleFileSpec throws away the actual

[jira] [Commented] (BEAM-8173) Filesystems.matchSingleFileSpec throws away the actual failure exception

[ https://issues.apache.org/jira/browse/BEAM-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952299#comment-16952299 ] Kenneth Knowles commented on BEAM-8173: --- [~chamikara] FYI filed this as a starter bug in code you

[jira] [Work logged] (BEAM-8348) Portable Python job name hard-coded to "job"

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

[jira] [Commented] (BEAM-8210) Python Integration tests: log test name

[ https://issues.apache.org/jira/browse/BEAM-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952304#comment-16952304 ] Kenneth Knowles commented on BEAM-8210: --- Seems nice to instrument this in the TestPipeline so any

[jira] [Updated] (BEAM-8210) Python Integration tests: log test name

[ https://issues.apache.org/jira/browse/BEAM-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8210: -- Component/s: sdk-py-core runner-dataflow > Python Integration tests: log test

[jira] [Updated] (BEAM-8122) Py2 version of getcallargs_forhints always returns generic hint for varargs

[ https://issues.apache.org/jira/browse/BEAM-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8122: -- Status: Open (was: Triage Needed) > Py2 version of getcallargs_forhints always returns generic

[jira] [Updated] (BEAM-8210) Python Integration tests: log test name

[ https://issues.apache.org/jira/browse/BEAM-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8210: -- Status: Open (was: Triage Needed) > Python Integration tests: log test name >

[jira] [Work logged] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

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

[jira] [Work logged] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK

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

[jira] [Resolved] (BEAM-7073) AvroUtils converting generic record to Beam Row causes class cast exception

[ https://issues.apache.org/jira/browse/BEAM-7073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vishwas resolved BEAM-7073. --- Fix Version/s: 2.14.0 2.17.0 Resolution: Fixed I have tested this fix with 2.15

[jira] [Closed] (BEAM-7073) AvroUtils converting generic record to Beam Row causes class cast exception

[ https://issues.apache.org/jira/browse/BEAM-7073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vishwas closed BEAM-7073. - > AvroUtils converting generic record to Beam Row causes class cast exception >

[jira] [Work logged] (BEAM-8176) Java BigQuery performance tests don't run

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Updated] (BEAM-8394) Add withDataSourceConfiguration() method in JdbcIO.ReadRows class

[ https://issues.apache.org/jira/browse/BEAM-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8394: -- Issue Type: New Feature (was: Task) > Add withDataSourceConfiguration() method in

[jira] [Updated] (BEAM-8394) Add withDataSourceConfiguration() method in JdbcIO.ReadRows class

[ https://issues.apache.org/jira/browse/BEAM-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8394: -- Issue Type: New Feature (was: Improvement) > Add withDataSourceConfiguration() method in

[jira] [Updated] (BEAM-8394) Add withDataSourceConfiguration() method in JdbcIO.ReadRows class

[ https://issues.apache.org/jira/browse/BEAM-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8394: -- Issue Type: Improvement (was: New Feature) > Add withDataSourceConfiguration() method in

[jira] [Updated] (BEAM-8394) Add withDataSourceConfiguration() method in JdbcIO.ReadRows class

[ https://issues.apache.org/jira/browse/BEAM-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8394: -- Status: Open (was: Triage Needed) > Add withDataSourceConfiguration() method in

[jira] [Work logged] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

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

[jira] [Updated] (BEAM-8396) Default to LOOPBACK mode for local flink (spark, ...) runner.

[ https://issues.apache.org/jira/browse/BEAM-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8396: -- Status: Open (was: Triage Needed) > Default to LOOPBACK mode for local flink (spark, ...)

[jira] [Updated] (BEAM-8177) BigQueryAvroUtils unable to convert field with record

[ https://issues.apache.org/jira/browse/BEAM-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8177: -- Status: Open (was: Triage Needed) > BigQueryAvroUtils unable to convert field with record >

[jira] [Commented] (BEAM-8177) BigQueryAvroUtils unable to convert field with record

[ https://issues.apache.org/jira/browse/BEAM-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952303#comment-16952303 ] Kenneth Knowles commented on BEAM-8177: --- [~chamikara] any ideas about this? > BigQueryAvroUtils

[jira] [Updated] (BEAM-8177) BigQueryAvroUtils unable to convert field with record

[ https://issues.apache.org/jira/browse/BEAM-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8177: -- Priority: Major (was: Trivial) > BigQueryAvroUtils unable to convert field with record >

[jira] [Updated] (BEAM-8124) Clean tests after Python 2 deprecation

[ https://issues.apache.org/jira/browse/BEAM-8124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8124: -- Status: Open (was: Triage Needed) > Clean tests after Python 2 deprecation >

[jira] [Work logged] (BEAM-8403) Race condition in request id generation of GrpcStateRequestHandler

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

[jira] [Updated] (BEAM-8404) [SQL] Update deprecated method calls

[ https://issues.apache.org/jira/browse/BEAM-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8404: -- Status: Open (was: Triage Needed) > [SQL] Update deprecated method calls >

[jira] [Work logged] (BEAM-8350) Upgrade to pylint 2.4

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

[jira] [Work logged] (BEAM-8350) Upgrade to pylint 2.4

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

[jira] [Work logged] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster.

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Updated] (BEAM-8406) TextTable support JSON format

[ https://issues.apache.org/jira/browse/BEAM-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang updated BEAM-8406: --- Status: Open (was: Triage Needed) > TextTable support JSON format > - > >

[jira] [Created] (BEAM-8406) TextTable support JSON format

Rui Wang created BEAM-8406: -- Summary: TextTable support JSON format Key: BEAM-8406 URL: https://issues.apache.org/jira/browse/BEAM-8406 Project: Beam Issue Type: New Feature Components:

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-7427) JmsCheckpointMark Avro Serialisation issue with UnboundedSource

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

[jira] [Work logged] (BEAM-8401) Upgrade to ZetaSQL 2019.10.1

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

[jira] [Work logged] (BEAM-8401) Upgrade to ZetaSQL 2019.10.1

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

[jira] [Created] (BEAM-8404) Update deprecated method calls

Kirill Kozlov created BEAM-8404: --- Summary: Update deprecated method calls Key: BEAM-8404 URL: https://issues.apache.org/jira/browse/BEAM-8404 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-8398) Upgrade Dataflow Java Client API

[ https://issues.apache.org/jira/browse/BEAM-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8398: -- Component/s: (was: sdk-java-core) runner-dataflow > Upgrade Dataflow Java

[jira] [Updated] (BEAM-8402) Create a class hierarchy to represent environments

[ https://issues.apache.org/jira/browse/BEAM-8402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8402: -- Status: Open (was: Triage Needed) > Create a class hierarchy to represent environments >

[jira] [Updated] (BEAM-8398) Upgrade Dataflow Java Client API

[ https://issues.apache.org/jira/browse/BEAM-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8398: -- Status: Open (was: Triage Needed) > Upgrade Dataflow Java Client API >

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-8401) Upgrade to ZetaSQL 2019.10.1

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-8350) Upgrade to pylint 2.4

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

[jira] [Commented] (BEAM-8101) ParDoLifecycleTest.testTeardownCalledAfterExceptionInProcessElementStateful is flaky

[ https://issues.apache.org/jira/browse/BEAM-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952091#comment-16952091 ] Andrew Pilloud commented on BEAM-8101: -- Same flake in 

[jira] [Updated] (BEAM-8399) Python HDFS implementation should support filenames of the format "hdfs://namenodehost/parent/child"

[ https://issues.apache.org/jira/browse/BEAM-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8399: -- Status: Open (was: Triage Needed) > Python HDFS implementation should support filenames of the

[jira] [Work logged] (BEAM-8404) [SQL] Update deprecated method calls

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

[jira] [Commented] (BEAM-8399) Python HDFS implementation should support filenames of the format "hdfs://namenodehost/parent/child"

[ https://issues.apache.org/jira/browse/BEAM-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16952145#comment-16952145 ] Kenneth Knowles commented on BEAM-8399: --- Just curious - how do you even resolve hdfs://parent/child?

[jira] [Work logged] (BEAM-8401) Upgrade to ZetaSQL 2019.10.1

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Created] (BEAM-8405) Python: Datastore: add support for embedded entities

Udi Meiri created BEAM-8405: --- Summary: Python: Datastore: add support for embedded entities Key: BEAM-8405 URL: https://issues.apache.org/jira/browse/BEAM-8405 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-8405) Python: Datastore: add support for embedded entities

[ https://issues.apache.org/jira/browse/BEAM-8405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri updated BEAM-8405: Status: Open (was: Triage Needed) > Python: Datastore: add support for embedded entities >

[jira] [Updated] (BEAM-8406) TextTable support JSON format

[ https://issues.apache.org/jira/browse/BEAM-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang updated BEAM-8406: --- Description: Have a JSON table implementation similar to [1]. [1]:

[jira] [Updated] (BEAM-8404) [SQL] Update deprecated method calls

[ https://issues.apache.org/jira/browse/BEAM-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirill Kozlov updated BEAM-8404: Summary: [SQL] Update deprecated method calls (was: Update deprecated method calls) > [SQL]

[jira] [Work logged] (BEAM-5967) ProtoCoder doesn't support DynamicMessage

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

[jira] [Updated] (BEAM-8368) [Python] libprotobuf-generated exception when importing apache_beam

[ https://issues.apache.org/jira/browse/BEAM-8368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-8368: -- Status: Open (was: Triage Needed) > [Python] libprotobuf-generated exception when importing

[jira] [Work logged] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster.

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8365) Add project push-down capability to IO APIs

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

[jira] [Work logged] (BEAM-8367) Python BigQuery sink should use unique IDs for mode STREAMING_INSERTS

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

[jira] [Work logged] (BEAM-8367) Python BigQuery sink should use unique IDs for mode STREAMING_INSERTS

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

  1   2   >