[jira] [Commented] (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:comment-tabpanel=16813669#comment-16813669 ] Reuven Lax commented on BEAM-7042: -- question for [~romain.manni-bucau]. The Antlr dependency went in in

[jira] [Work logged] (BEAM-3342) Create a Cloud Bigtable Python connector

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

[jira] [Work logged] (BEAM-7046) fix http_proxy warnings from grpc in tests

[ https://issues.apache.org/jira/browse/BEAM-7046?focusedWorklogId=225318=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225318 ] ASF GitHub Bot logged work on BEAM-7046: 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=225197=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225197 ] 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=225198=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225198 ] 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=225199=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225199 ] ASF GitHub Bot logged work on BEAM-6942: Author: ASF GitHub Bot

[jira] [Commented] (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:comment-tabpanel=16813806#comment-16813806 ] Romain Manni-Bucau commented on BEAM-7042: -- [~reuvenlax] no, dont mix consumer and producer.

[jira] [Work logged] (BEAM-7038) coder changes are incompatible with dataflow update operation

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

[jira] [Resolved] (BEAM-7038) coder changes are incompatible with dataflow update operation

[ https://issues.apache.org/jira/browse/BEAM-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud resolved BEAM-7038. -- Resolution: Fixed > coder changes are incompatible with dataflow update operation >

[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=225339=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225339 ] ASF GitHub Bot logged work on BEAM-7029: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5328) Java starter archetype does not contain dependency versions

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

[jira] [Work logged] (BEAM-7038) coder changes are incompatible with dataflow update operation

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

[jira] [Work logged] (BEAM-7038) coder changes are incompatible with dataflow update operation

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

[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 ] Andrew Pilloud updated BEAM-7042: - Fix Version/s: (was: 2.12.0) 2.13.0 > [regression]

[jira] [Work logged] (BEAM-7036) Spark portable runner: stage files to run on 'remote' cluster

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

[jira] [Work logged] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?focusedWorklogId=225311=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225311 ] ASF GitHub Bot logged work on BEAM-6695: 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=225310=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225310 ] ASF GitHub Bot logged work on BEAM-6872: Author: ASF GitHub Bot

[jira] [Assigned] (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 ] Andrew Pilloud reassigned BEAM-7042: Assignee: Reuven Lax > [regression] org.apache.beam:beam-sdks-java-core:jar:2.12.0

[jira] [Work logged] (BEAM-6867) Data race in Side Input Metrics code

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

[jira] [Work logged] (BEAM-6934) Unexpected TestStream behavior when testing stateful DoFn (DirectRunner)

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

[jira] [Commented] (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:comment-tabpanel=16813875#comment-16813875 ] Reuven Lax commented on BEAM-7042: -- Given that Antlr has been part of core since 2.10, I don't think this

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

[ https://issues.apache.org/jira/browse/BEAM-6527?focusedWorklogId=225193=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225193 ] ASF GitHub Bot logged work on BEAM-6527: 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=225196=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225196 ] ASF GitHub Bot logged work on BEAM-6872: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7038) coder changes are incompatible with dataflow update operation

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

[jira] [Commented] (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:comment-tabpanel=16813864#comment-16813864 ] Andrew Pilloud commented on BEAM-7042: -- Hello, I'm about to cut RC3. Is this really a release

[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=225201=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225201 ] ASF GitHub Bot logged work on BEAM-7041: Author: ASF GitHub Bot

[jira] [Commented] (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:comment-tabpanel=16813819#comment-16813819 ] Raghu Angadi commented on BEAM-6991: [~aromanenko], you are right, the error is appropriate here.

[jira] [Created] (BEAM-7046) fix http_proxy warnings from grpc in tests

Udi Meiri created BEAM-7046: --- Summary: fix http_proxy warnings from grpc in tests Key: BEAM-7046 URL: https://issues.apache.org/jira/browse/BEAM-7046 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-7035) Clear() method of OutputTimer is inconsistent

[ https://issues.apache.org/jira/browse/BEAM-7035?focusedWorklogId=225239=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225239 ] ASF GitHub Bot logged work on BEAM-7035: 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=225275=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225275 ] 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=225276=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225276 ] 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=225277=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225277 ] ASF GitHub Bot logged work on BEAM-7029: 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=225308=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225308 ] ASF GitHub Bot logged work on BEAM-6872: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6892) Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user.

[ https://issues.apache.org/jira/browse/BEAM-6892?focusedWorklogId=225332=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225332 ] ASF GitHub Bot logged work on BEAM-6892: 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=225330=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225330 ] ASF GitHub Bot logged work on BEAM-6527: 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=225343=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225343 ] ASF GitHub Bot logged work on BEAM-6942: 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=225236=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225236 ] ASF GitHub Bot logged work on BEAM-7029: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-5328) Java starter archetype does not contain dependency versions

[ https://issues.apache.org/jira/browse/BEAM-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813808#comment-16813808 ] Luke Cwik commented on BEAM-5328: - To finish BEAM-5328, you also want to ensure that your test runs via

[jira] [Work logged] (BEAM-6747) Adding ExternalTransform in JavaSDK

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

[jira] [Created] (BEAM-7045) Element counters in the Web UI graph representations for transforms for Python streaming jobs in Google Cloud Dataflow

Efim Muratov created BEAM-7045: -- Summary: Element counters in the Web UI graph representations for transforms for Python streaming jobs in Google Cloud Dataflow Key: BEAM-7045 URL:

[jira] [Work logged] (BEAM-7038) coder changes are incompatible with dataflow update operation

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

[jira] [Work logged] (BEAM-7038) coder changes are incompatible with dataflow update operation

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

[jira] [Work logged] (BEAM-7046) fix http_proxy warnings from grpc in tests

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

[jira] [Resolved] (BEAM-6934) Unexpected TestStream behavior when testing stateful DoFn (DirectRunner)

[ https://issues.apache.org/jira/browse/BEAM-6934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada resolved BEAM-6934. - Resolution: Fixed Fix Version/s: 2.13.0 > Unexpected TestStream behavior when testing

[jira] [Commented] (BEAM-6934) Unexpected TestStream behavior when testing stateful DoFn (DirectRunner)

[ https://issues.apache.org/jira/browse/BEAM-6934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813940#comment-16813940 ] Pablo Estrada commented on BEAM-6934: - This code snippet has been added as a unit test, and fixed.

[jira] [Work logged] (BEAM-3072) Improve error handling at staging time time for DataflowRunner

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

[jira] [Work logged] (BEAM-6695) Latest transform for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6695?focusedWorklogId=225349=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225349 ] ASF GitHub Bot logged work on BEAM-6695: 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=225398=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225398 ] ASF GitHub Bot logged work on BEAM-7041: Author: ASF GitHub Bot

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

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

[jira] [Commented] (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:comment-tabpanel=16814034#comment-16814034 ] Romain Manni-Bucau commented on BEAM-7042: -- [~reuvenlax] as mentionned it is a regression so a

[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=225352=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225352 ] ASF GitHub Bot logged work on BEAM-7029: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7046) fix http_proxy warnings from grpc in tests

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

[jira] [Commented] (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:comment-tabpanel=16813947#comment-16813947 ] Kenneth Knowles commented on BEAM-7042: --- Vendoring == an empty project with a bundled + relocated

[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=225353=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225353 ] 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=225368=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225368 ] ASF GitHub Bot logged work on BEAM-6935: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-7038) coder changes are incompatible with dataflow update operation

[ https://issues.apache.org/jira/browse/BEAM-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813026#comment-16813026 ] Ahmet Altay commented on BEAM-7038: --- I was able run a passing update tests after reverting the changes

[jira] [Commented] (BEAM-6807) Implement an Azure blobstore filesystem for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-6807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813137#comment-16813137 ] Ayush Chauhan commented on BEAM-6807: - hi [~pabloem], I would love to implement this in GSoC can you

[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=224784=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224784 ] ASF GitHub Bot logged work on BEAM-6942: 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=224841=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224841 ] 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=224842=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224842 ] ASF GitHub Bot logged work on BEAM-7029: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5381) Dataflow runner creates duplicate CoGBK step IDs

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

[jira] [Work logged] (BEAM-5381) Dataflow runner creates duplicate CoGBK step IDs

[ https://issues.apache.org/jira/browse/BEAM-5381?focusedWorklogId=224796=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224796 ] ASF GitHub Bot logged work on BEAM-5381: 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=224783=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224783 ] ASF GitHub Bot logged work on BEAM-6942: Author: ASF GitHub Bot

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

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

[jira] [Commented] (BEAM-3039) DatastoreIO.Write fails multiple mutations of same entity

[ https://issues.apache.org/jira/browse/BEAM-3039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813066#comment-16813066 ] Kyle Xiong commented on BEAM-3039: -- Any plan to fix this issue? Thanks! > DatastoreIO.Write fails

[jira] [Comment Edited] (BEAM-3039) DatastoreIO.Write fails multiple mutations of same entity

[ https://issues.apache.org/jira/browse/BEAM-3039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813066#comment-16813066 ] Kyle Xiong edited comment on BEAM-3039 at 4/9/19 7:13 AM: -- Any plan to implement

[jira] [Comment Edited] (BEAM-6974) [beam_PreCommit_Java_Cron] [:beam-sdks-java-io-cassandra:test][Flake] Test fails in native code

[ https://issues.apache.org/jira/browse/BEAM-6974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813082#comment-16813082 ] Etienne Chauchot edited comment on BEAM-6974 at 4/9/19 7:40 AM: [~kenn] it

[jira] [Commented] (BEAM-6974) [beam_PreCommit_Java_Cron] [:beam-sdks-java-io-cassandra:test][Flake] Test fails in native code

[ https://issues.apache.org/jira/browse/BEAM-6974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16813082#comment-16813082 ] Etienne Chauchot commented on BEAM-6974: [~kenn] it makes total sense to me. [~apilloud] thanks

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

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

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

[ https://issues.apache.org/jira/browse/BEAM-6677?focusedWorklogId=224963=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224963 ] ASF GitHub Bot logged work on BEAM-6677: 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=224985=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224985 ] 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=224990=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224990 ] 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=224987=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224987 ] 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=224986=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224986 ] 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=224988=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224988 ] 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=224989=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224989 ] ASF GitHub Bot logged work on BEAM-7029: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6936) Add a Jenkins job running Java examples on Java 11 Dataflow

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

[jira] [Work logged] (BEAM-6936) Add a Jenkins job running Java examples on Java 11 Dataflow

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

[jira] [Work logged] (BEAM-6936) Add a Jenkins job running Java examples on Java 11 Dataflow

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

[jira] [Work logged] (BEAM-6936) Add a Jenkins job running Java examples on Java 11 Dataflow

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

[jira] [Work logged] (BEAM-6936) Add a Jenkins job running Java examples on Java 11 Dataflow

[ https://issues.apache.org/jira/browse/BEAM-6936?focusedWorklogId=224879=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224879 ] ASF GitHub Bot logged work on BEAM-6936: 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=224930=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224930 ] 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=224928=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224928 ] ASF GitHub Bot logged work on BEAM-7029: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

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

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

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

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

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

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

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

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

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

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

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

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

Romain Manni-Bucau created BEAM-7042: Summary: [regression] org.apache.beam:beam-sdks-java-core:jar:2.12.0 dependencies are way fatter and conflicting than before Key: BEAM-7042 URL:

[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=224993=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224993 ] ASF GitHub Bot logged work on BEAM-4087: Author: ASF GitHub Bot

[jira] [Created] (BEAM-7040) Spotless doesn't check build.gradle files

Lukasz Gajowy created BEAM-7040: --- Summary: Spotless doesn't check build.gradle files Key: BEAM-7040 URL: https://issues.apache.org/jira/browse/BEAM-7040 Project: Beam Issue Type: Bug

[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=224902=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224902 ] ASF GitHub Bot logged work on BEAM-4087: 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=224949=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-224949 ] ASF GitHub Bot logged work on BEAM-7029: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6677) Provide Portable Flink cluster setup

[ https://issues.apache.org/jira/browse/BEAM-6677?focusedWorklogId=225003=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225003 ] ASF GitHub Bot logged work on BEAM-6677: 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=225013=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225013 ] ASF GitHub Bot logged work on BEAM-6942: Author: ASF GitHub Bot

[jira] [Created] (BEAM-7043) Add New DynamoDB Sink

Cam Mach created BEAM-7043: -- Summary: Add New DynamoDB Sink Key: BEAM-7043 URL: https://issues.apache.org/jira/browse/BEAM-7043 Project: Beam Issue Type: New Feature Components:

[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=225042=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225042 ] 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=225057=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-225057 ] ASF GitHub Bot logged work on BEAM-7041: Author: ASF GitHub Bot

[jira] [Commented] (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:comment-tabpanel=16813547#comment-16813547 ] Reuven Lax commented on BEAM-7042: -- though I'm a bit confused as to why antlr depends on jsonp at all :P

  1   2   >