[GitHub] [beam] pabloem commented on issue #11151: [BEAM-9468] Hl7v2 io

pabloem commented on issue #11151: [BEAM-9468] Hl7v2 io URL: https://github.com/apache/beam/pull/11151#issuecomment-600827169 since your change is a Java change, you don't need to worry about the Python errors for now. They seem to come from upstream. -

[GitHub] [beam] pabloem commented on issue #11158: [BEAM-9533] Fixing tox.ini variants

pabloem commented on issue #11158: [BEAM-9533] Fixing tox.ini variants URL: https://github.com/apache/beam/pull/11158#issuecomment-600824455 Run Python PreCommit This is an automated message from the Apache Git Service. To res

[GitHub] [beam] lukecwik commented on issue #11162: [BEAM-9339, BEAM-2939] Drop splittable field from ParDoPayload, add splittable dofn requirement to Python SDK.

lukecwik commented on issue #11162: [BEAM-9339, BEAM-2939] Drop splittable field from ParDoPayload, add splittable dofn requirement to Python SDK. URL: https://github.com/apache/beam/pull/11162#issuecomment-600821917 R: @robertwb ---

[GitHub] [beam] lukecwik opened a new pull request #11162: [BEAM-9339, BEAM-2939] Drop splittable field from ParDoPayload, add splittable dofn requirement to Python SDK.

lukecwik opened a new pull request #11162: [BEAM-9339, BEAM-2939] Drop splittable field from ParDoPayload, add splittable dofn requirement to Python SDK. URL: https://github.com/apache/beam/pull/11162 Thank you for your contribution! Follow this checklis

[GitHub] [beam] pabloem commented on issue #10291: [BEAM-7516][BEAM-8823] FnApiRunner works with work queues, and a primitive watermark manager

pabloem commented on issue #10291: [BEAM-7516][BEAM-8823] FnApiRunner works with work queues, and a primitive watermark manager URL: https://github.com/apache/beam/pull/10291#issuecomment-600812525 Run Python PreCommit This i

[GitHub] [beam] rehmanmuradali commented on issue #11154: [BEAM-1819] Key should be available in @OnTimer methods

rehmanmuradali commented on issue #11154: [BEAM-1819] Key should be available in @OnTimer methods URL: https://github.com/apache/beam/pull/11154#issuecomment-600808846 R: @reuvenlax. This is an automated message from the Apac

[GitHub] [beam] lukecwik commented on issue #11160: [BEAM-9339] Declare capabilities in the Java SDK.

lukecwik commented on issue #11160: [BEAM-9339] Declare capabilities in the Java SDK. URL: https://github.com/apache/beam/pull/11160#issuecomment-600796683 Whats your strategy for adding all the pardo requirements? This is an

[GitHub] [beam] aaltay commented on issue #11161: [BEAM-7923] Change Transform Label Prefix Syntax

aaltay commented on issue #11161: [BEAM-7923] Change Transform Label Prefix Syntax URL: https://github.com/apache/beam/pull/11161#issuecomment-600796444 retest this please This is an automated message from the Apache Git Serv

[GitHub] [beam] KevinGG edited a comment on issue #11161: [BEAM-7923] Change Transform Label Prefix Syntax

KevinGG edited a comment on issue #11161: [BEAM-7923] Change Transform Label Prefix Syntax URL: https://github.com/apache/beam/pull/11161#issuecomment-600792357 yapf formatted. lint passed locally. R: @aaltay R: @davidyan74 R: @rohdesamuel PTAL, thx! -

[GitHub] [beam] KevinGG commented on issue #11161: [BEAM-7923] Change Transform Label Prefix Syntax

KevinGG commented on issue #11161: [BEAM-7923] Change Transform Label Prefix Syntax URL: https://github.com/apache/beam/pull/11161#issuecomment-600792357 R: @aaltay R: @davidyan74 R: @rohdesamuel PTAL, thx! Th

[GitHub] [beam] KevinGG opened a new pull request #11161: [BEAM-7923] Change Transform Label Prefix Syntax

KevinGG opened a new pull request #11161: [BEAM-7923] Change Transform Label Prefix Syntax URL: https://github.com/apache/beam/pull/11161 1. Based on user studies, changed the transform label prefix from `Cell {}:` to `[{}]:` when a pipeline is constructed in an IPython environment (i

[GitHub] [beam] ibzib commented on a change in pull request #11106: Fixing apache_beam.io.gcp.bigquery_test:PubSubBigQueryIT. at head

ibzib commented on a change in pull request #11106: Fixing apache_beam.io.gcp.bigquery_test:PubSubBigQueryIT. at head URL: https://github.com/apache/beam/pull/11106#discussion_r394550642 ## File path: sdks/python/apache_beam/options/pipeline_options.py ## @@ -1048,7 +1048,

[GitHub] [beam] pabloem commented on issue #11151: [BEAM-9468] Hl7v2 io

pabloem commented on issue #11151: [BEAM-9468] Hl7v2 io URL: https://github.com/apache/beam/pull/11151#issuecomment-600786892 ("retest this please" is a code phrase for jenkins to run precommits on the PR) This is an automat

[GitHub] [beam] amaliujia commented on issue #11081: [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch

amaliujia commented on issue #11081: [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch URL: https://github.com/apache/beam/pull/11081#issuecomment-600786357 Run Python 2 PostCommit This is an automa

[GitHub] [beam] pabloem commented on issue #11151: [BEAM-9468] Hl7v2 io

pabloem commented on issue #11151: [BEAM-9468] Hl7v2 io URL: https://github.com/apache/beam/pull/11151#issuecomment-600786687 retest this please This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [beam] lukecwik commented on a change in pull request #11160: [BEAM-9339] Declare capabilities in the Java SDK.

lukecwik commented on a change in pull request #11160: [BEAM-9339] Declare capabilities in the Java SDK. URL: https://github.com/apache/beam/pull/11160#discussion_r394546436 ## File path: runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Environ

[GitHub] [beam] pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner

pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner URL: https://github.com/apache/beam/pull/11153#issuecomment-600783232 Run Python2_PVR_Flink PreCommit This is an automated message from the Ap

[GitHub] [beam] robertwb commented on issue #11160: [BEAM-9339] Declare capabilities in the Java SDK.

robertwb commented on issue #11160: [BEAM-9339] Declare capabilities in the Java SDK. URL: https://github.com/apache/beam/pull/11160#issuecomment-600779129 R: @lukecwik This is an automated message from the Apache Git Servi

[GitHub] [beam] robertwb opened a new pull request #11160: [BEAM-9339] Declare capabilities in the Java SDK.

robertwb opened a new pull request #11160: [BEAM-9339] Declare capabilities in the Java SDK. URL: https://github.com/apache/beam/pull/11160 Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily

[GitHub] [beam] aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery

aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery URL: https://github.com/apache/beam/pull/10815#discussion_r394512504 ## File path: sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.

[GitHub] [beam] aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery

aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery URL: https://github.com/apache/beam/pull/10815#discussion_r394530430 ## File path: sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.

[GitHub] [beam] aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery

aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery URL: https://github.com/apache/beam/pull/10815#discussion_r394512250 ## File path: sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.

[GitHub] [beam] aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery

aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery URL: https://github.com/apache/beam/pull/10815#discussion_r394515283 ## File path: sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394535755 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery

aromanenko-dev commented on a change in pull request #10815: [BEAM-9279] Make HBase.ReadAll based on Reads instead of HBaseQuery URL: https://github.com/apache/beam/pull/10815#discussion_r394534093 ## File path: sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseRea

[GitHub] [beam] lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394535077 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy ###

[GitHub] [beam] amaliujia commented on issue #11081: [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch

amaliujia commented on issue #11081: [DO NOT MERGE] Run all PostCommit and PreCommit Tests against Release Branch URL: https://github.com/apache/beam/pull/11081#issuecomment-600772383 Run Release Gradle Build This is an autom

[GitHub] [beam] suztomo commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600770827 @aromanenko-dev Thank you. This is an automated message

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394527172 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] lukecwik commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1

lukecwik commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1 URL: https://github.com/apache/beam/pull/11157#issuecomment-600767230 Run Portable_Python PreCommit -

[GitHub] [beam] lukecwik commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1

lukecwik commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1 URL: https://github.com/apache/beam/pull/11157#issuecomment-600767320 Run Python PreCommit --

[GitHub] [beam] coheigea opened a new pull request #11159: BEAM-8924 - Update Apache Tika to 1.24

coheigea opened a new pull request #11159: BEAM-8924 - Update Apache Tika to 1.24 URL: https://github.com/apache/beam/pull/11159 This task is to update Tika due to multiple CVE notices (e.g. CVE-2020-1950, CVE-2020-1951) Thi

[GitHub] [beam] pabloem opened a new pull request #11158: Fixing tox.ini variants

pabloem opened a new pull request #11158: Fixing tox.ini variants URL: https://github.com/apache/beam/pull/11158 r: @udim Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]

[GitHub] [beam] pabloem commented on issue #10291: [BEAM-7516][BEAM-8823] FnApiRunner works with work queues, and a primitive watermark manager

pabloem commented on issue #10291: [BEAM-7516][BEAM-8823] FnApiRunner works with work queues, and a primitive watermark manager URL: https://github.com/apache/beam/pull/10291#issuecomment-600760789 Run Python PreCommit This i

[GitHub] [beam] pabloem merged pull request #11147: [BEAM-7923] Support dict and iterable PCollections in show

pabloem merged pull request #11147: [BEAM-7923] Support dict and iterable PCollections in show URL: https://github.com/apache/beam/pull/11147 This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [beam] aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600752336 Run SQL Postcommit This is an automated message f

[GitHub] [beam] aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600752230 Run Spark ValidatesRunner This is an automated me

[GitHub] [beam] aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600752160 Run Dataflow ValidatesRunner This is an automated

[GitHub] [beam] aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600752021 retest this please This is an automated message f

[GitHub] [beam] aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600751766 Run BigQueryIO Streaming Performance Test Java Th

[GitHub] [beam] aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600751588 Run Java HadoopFormatIO Performance Test This is

[GitHub] [beam] aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

aromanenko-dev commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600751410 Run Java PostCommit This is an automated message

[GitHub] [beam] pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner

pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner URL: https://github.com/apache/beam/pull/11153#issuecomment-600749448 Run Portable_Python PreCommit This is an automated message from the Apac

[GitHub] [beam] jaketf commented on issue #11151: [BEAM-9468] Hl7v2 io

jaketf commented on issue #11151: [BEAM-9468] Hl7v2 io URL: https://github.com/apache/beam/pull/11151#issuecomment-600748606 R: @pabloem This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [beam] pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner

pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner URL: https://github.com/apache/beam/pull/11153#issuecomment-600741439 Run Python PreCommit This is an automated message from the Apache Git Se

[GitHub] [beam] pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner

pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner URL: https://github.com/apache/beam/pull/11153#issuecomment-600741147 Run Python2_PVR_Flink PreCommit This is an automated message from the Ap

[GitHub] [beam] pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner

pabloem commented on issue #11153: [BEAM-9537] Adding a new module for FnApiRunner URL: https://github.com/apache/beam/pull/11153#issuecomment-600740277 Run Portable_Python PreCommit This is an automated message from the Apac

[GitHub] [beam] lukecwik commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1

lukecwik commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1 URL: https://github.com/apache/beam/pull/11157#issuecomment-60073 Run Portable_Python PreCommit -

[GitHub] [beam] lostluck commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1

lostluck commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1 URL: https://github.com/apache/beam/pull/11157#issuecomment-600735726 LGTM for Go. --

[GitHub] [beam] lostluck commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1

lostluck commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1 URL: https://github.com/apache/beam/pull/11157#issuecomment-600735069 Run Go Postcommit -

[GitHub] [beam] lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394484244 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy ###

[GitHub] [beam] pulasthi edited a comment on issue #10888: [BEAM-7304] Twister2 Beam runner

pulasthi edited a comment on issue #10888: [BEAM-7304] Twister2 Beam runner URL: https://github.com/apache/beam/pull/10888#issuecomment-600731539 No worries, I assumed that might have been the case. Thanks for the update This

[GitHub] [beam] pulasthi commented on issue #10888: [BEAM-7304] Twister2 Beam runner

pulasthi commented on issue #10888: [BEAM-7304] Twister2 Beam runner URL: https://github.com/apache/beam/pull/10888#issuecomment-600731539 No worries, I assumed that might have been the case. This is an automated message from

[GitHub] [beam] lostluck commented on issue #11143: [BEAM-9526] Add missing unmarshalling in top.LargestPerKey.

lostluck commented on issue #11143: [BEAM-9526] Add missing unmarshalling in top.LargestPerKey. URL: https://github.com/apache/beam/pull/11143#issuecomment-600727682 Thanks! LGTM This is an automated message from the Apache G

[GitHub] [beam] lostluck merged pull request #11143: [BEAM-9526] Add missing unmarshalling in top.LargestPerKey.

lostluck merged pull request #11143: [BEAM-9526] Add missing unmarshalling in top.LargestPerKey. URL: https://github.com/apache/beam/pull/11143 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [beam] lukecwik commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1

lukecwik commented on issue #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1 URL: https://github.com/apache/beam/pull/11157#issuecomment-600726404 R: @lostluck @amaliujia --

[GitHub] [beam] lukecwik opened a new pull request #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1

lukecwik opened a new pull request #11157: [BEAM-9540] Rename beam:source:runner:0.1/beam:sink:runner:0.1 to beam:runner:source:v1/beam:runner:sink:v1 URL: https://github.com/apache/beam/pull/11157 Thank you for your contribution! Follow this checklist t

[GitHub] [beam] mxm commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mxm commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600723203 Unsubscribing but feel free to `@mxm` mention me. This is an

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394466904 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394460130 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] lukecwik commented on issue #11126: [BEAM-9430, BEAM-2939] Migrate from ProcessContext#updateWatermark to WatermarkEstimators

lukecwik commented on issue #11126: [BEAM-9430, BEAM-2939] Migrate from ProcessContext#updateWatermark to WatermarkEstimators URL: https://github.com/apache/beam/pull/11126#issuecomment-600715890 R: @ihji CC: @chamikaramj ---

[GitHub] [beam] lukecwik commented on issue #11150: [BEAM-9535] Remove unused ParDoPayload.Parameters.

lukecwik commented on issue #11150: [BEAM-9535] Remove unused ParDoPayload.Parameters. URL: https://github.com/apache/beam/pull/11150#issuecomment-600708978 Checkstyle and spotless are complaining. This is an automated messag

[GitHub] [beam] iemejia commented on issue #10888: [BEAM-7304] Twister2 Beam runner

iemejia commented on issue #10888: [BEAM-7304] Twister2 Beam runner URL: https://github.com/apache/beam/pull/10888#issuecomment-600687874 Not finished yet, sorry I had to deal first with the unintended consequences of the whole coronavirus lockdown. I will get to it ASAP. Sorry again.

[GitHub] [beam] lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394427922 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy ###

[GitHub] [beam] lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394427660 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy ###

[GitHub] [beam] lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

lukecwik commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394426074 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy ###

[GitHub] [beam] lukecwik commented on issue #11154: [BEAM-1819] Key should be available in @OnTimer methods

lukecwik commented on issue #11154: [BEAM-1819] Key should be available in @OnTimer methods URL: https://github.com/apache/beam/pull/11154#issuecomment-600679857 Could we ensure that the FnApiDoFnRunner implementation for the key is completed as well? -

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394419843 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394420883 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394420078 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394420523 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on a change in pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#discussion_r394408735 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

[GitHub] [beam] lukecwik commented on issue #11126: [BEAM-9430, BEAM-2939] Migrate from ProcessContext#updateWatermark to WatermarkEstimators

lukecwik commented on issue #11126: [BEAM-9430, BEAM-2939] Migrate from ProcessContext#updateWatermark to WatermarkEstimators URL: https://github.com/apache/beam/pull/11126#issuecomment-600676765 Run Java PreCommit This is an

[GitHub] [beam] chamikaramj commented on issue #8457: [BEAM-3342] Create a Cloud Bigtable IO connector for Python

chamikaramj commented on issue #8457: [BEAM-3342] Create a Cloud Bigtable IO connector for Python URL: https://github.com/apache/beam/pull/8457#issuecomment-600674160 Sorry about the dalay. Will take a look this week. This is

[GitHub] [beam] mxm commented on issue #11154: [BEAM-1819] Key should be available in @OnTimer methods

mxm commented on issue #11154: [BEAM-1819] Key should be available in @OnTimer methods URL: https://github.com/apache/beam/pull/11154#issuecomment-600671323 retest this please This is an automated message from the Apache Git

[GitHub] [beam] suztomo commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600669458 @iemejia Thank you. Sonatype is unhealthy now. I'll check later today. ``` 10:51:05 > Could not get

[GitHub] [beam] iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-60013 Run SQL Postcommit This is an automated message from

[GitHub] [beam] iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600666508 Run Dataflow ValidatesRunner This is an automated me

[GitHub] [beam] iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600666460 Run BigQueryIO Streaming Performance Test Java This

[GitHub] [beam] iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600666561 Run Spark ValidatesRunner This is an automated messa

[GitHub] [beam] iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600666394 Run Java HadoopFormatIO Performance Test This is an

[GitHub] [beam] iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600666341 Run Java PostCommit This is an automated message from th

[GitHub] [beam] iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

iemejia commented on issue #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156#issuecomment-600666184 bang This is an automated message from the Apache Git Se

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600658641 Run Load Tests Java Combine Portable Flink Streaming Th

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600656596 run seed job This is an automated message from the Apac

[GitHub] [beam] suztomo opened a new pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies

suztomo opened a new pull request #11156: [BEAM-9444] Use GCP Libraries BOM for Google Cloud Dependencies URL: https://github.com/apache/beam/pull/11156 - To use BOM, declaring the BOM dependency with "platform" ([Gradle: Importing Maven BOMs](https://docs.gradle.org/current/userguide/pla

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600613470 Run Load Tests Java Combine Portable Flink Streaming Th

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600613410 Run Load Tests Java Combine Portable Flink Batch This i

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600602288 Run Load Tests Java Combine Portable Flink Streaming Th

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600602229 Run Load Tests Java Combine Portable Flink Batch This i

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600586885 run seed job This is an automated message from the Apac

[GitHub] [beam] mwalenia merged pull request #11155: [BEAM-9539] Fix copy-pasted comment in load-tests' build.gradle

mwalenia merged pull request #11155: [BEAM-9539] Fix copy-pasted comment in load-tests' build.gradle URL: https://github.com/apache/beam/pull/11155 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [beam] piotr-szuberski opened a new pull request #11155: [BEAM-9539] Fix copy-pasted comment in load-tests' build.gradle

piotr-szuberski opened a new pull request #11155: [BEAM-9539] Fix copy-pasted comment in load-tests' build.gradle URL: https://github.com/apache/beam/pull/11155 There was a comment copy-pasted from nexmark in load-tests' build.gradle file R: @mwalenia

[GitHub] [beam] mxm commented on issue #11154: [BEAM-1819] Key should be available in @OnTimer methods

mxm commented on issue #11154: [BEAM-1819] Key should be available in @OnTimer methods URL: https://github.com/apache/beam/pull/11154#issuecomment-600576899 retest this please This is an automated message from the Apache Git

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600573249 Run Load Tests Java Combine Portable Flink Streaming Th

[GitHub] [beam] rehmanmuradali opened a new pull request #11154: [BEAM-1819] Key should be available in @OnTimer methods

rehmanmuradali opened a new pull request #11154: [BEAM-1819] Key should be available in @OnTimer methods URL: https://github.com/apache/beam/pull/11154 Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickl

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600564536 Run Load Tests Java Combine Portable Flink Streaming Th

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600564484 Run Load Tests Java Combine Portable Flink Batch This i

[GitHub] [beam] mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java

mwalenia commented on issue #10386: [BEAM-8972] Add Jenkins job with Combine test for portable Java URL: https://github.com/apache/beam/pull/10386#issuecomment-600559891 run seed job This is an automated message from the Apac

[GitHub] [beam] aromanenko-dev edited a comment on issue #10078: [BEAM-8542] Change write to async in AWS SNS IO & remove retry logic

aromanenko-dev edited a comment on issue #10078: [BEAM-8542] Change write to async in AWS SNS IO & remove retry logic URL: https://github.com/apache/beam/pull/10078#issuecomment-600547079 @Akshay-Iyangar Sure, I'm ok if these changes don't break current user API.

<    4   5   6   7   8   9   10   11   12   13   >