[GitHub] [beam] TheNeuralBit commented on pull request #11743: [BEAM-9964] Update CHANGES.md

TheNeuralBit commented on pull request #11743: URL: https://github.com/apache/beam/pull/11743#issuecomment-630390198 retest this please This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] apilloud opened a new pull request #11742: [BEAM-9698] Null array is empty array

apilloud opened a new pull request #11742: URL: https://github.com/apache/beam/pull/11742 Fixes NPE. Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] [**Choose

[GitHub] [beam] omarismail94 opened a new pull request #11743: [CHANGES.md] - Adding BEAM-9964 to CHANGES.md for Beam 2.22

omarismail94 opened a new pull request #11743: URL: https://github.com/apache/beam/pull/11743 R: @TheNeuralBit Adding work done on BEAM-9964 to CHANGES.md for Beam 2.22 release Thank you for your contribution! Follow this checklist to help

[GitHub] [beam] chamikaramj commented on pull request #11740: [BEAM-8019] Prevent Dataflow from starting multiple containers for the same image

chamikaramj commented on pull request #11740: URL: https://github.com/apache/beam/pull/11740#issuecomment-630383607 R: @lukecwik @ihji This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] omarismail94 closed pull request #11741: [CHANGES.md] - Adding BEAM-9964 to CHANGES.md for Beam 2.22

omarismail94 closed pull request #11741: URL: https://github.com/apache/beam/pull/11741 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [beam] omarismail94 commented on pull request #11741: [CHANGES.md] - Adding BEAM-9964 to CHANGES.md for Beam 2.22

omarismail94 commented on pull request #11741: URL: https://github.com/apache/beam/pull/11741#issuecomment-630383080 I messed this up LOL. Will create a new PR This is an automated message from the Apache Git Service. To

[GitHub] [beam] pabloem commented on pull request #11736: Katas - Convert task description from HTML to Markdown

pabloem commented on pull request #11736: URL: https://github.com/apache/beam/pull/11736#issuecomment-630381852 LGTM @henryken - LMK how to proceed This is an automated message from the Apache Git Service. To respond to the

[GitHub] [beam] pabloem merged pull request #11730: Python Katas - Remove answer placeholder checks

pabloem merged pull request #11730: URL: https://github.com/apache/beam/pull/11730 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [beam] omarismail94 opened a new pull request #11741: [CHANGES.md] - Adding BEAM-9964 to CHANGES.md for Beam 2.22

omarismail94 opened a new pull request #11741: URL: https://github.com/apache/beam/pull/11741 Per R: @TheNeuralBit email, adding work done on BEAM-9964 to CHANGES.md for Beam 2.22 release Thank you for your contribution! Follow this checklist to help us

[GitHub] [beam] pabloem commented on pull request #11731: [BEAM-10018] Fix timestamps in two windowing Python katas

pabloem commented on pull request #11731: URL: https://github.com/apache/beam/pull/11731#issuecomment-630381512 thanks everyone! This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [beam] pabloem merged pull request #11731: [BEAM-10018] Fix timestamps in two windowing Python katas

pabloem merged pull request #11731: URL: https://github.com/apache/beam/pull/11731 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [beam] chamikaramj opened a new pull request #11740: [BEAM-8019] Prevent Dataflow from starting multiple containers for the same image

chamikaramj opened a new pull request #11740: URL: https://github.com/apache/beam/pull/11740 **Please** add a meaningful description for your change here Thank you for your contribution! Follow this checklist to help us incorporate your contribution

[GitHub] [beam] rose-rong-liu commented on pull request #11075: [BEAM-9421] Website section that describes getting predictions using AI Platform Prediciton

rose-rong-liu commented on pull request #11075: URL: https://github.com/apache/beam/pull/11075#issuecomment-630374955 > @rose-rong-liu - any concerns? Looks good to me. Thanks for the wait! This is an automated

[GitHub] [beam] rose-rong-liu commented on a change in pull request #11075: [BEAM-9421] Website section that describes getting predictions using AI Platform Prediciton

rose-rong-liu commented on a change in pull request #11075: URL: https://github.com/apache/beam/pull/11075#discussion_r426830154 ## File path: website/www/site/content/en/documentation/patterns/ai-platform.md ## @@ -0,0 +1,79 @@ +--- +title: "AI Platform integration patterns"

[GitHub] [beam] rose-rong-liu commented on a change in pull request #11075: [BEAM-9421] Website section that describes getting predictions using AI Platform Prediciton

rose-rong-liu commented on a change in pull request #11075: URL: https://github.com/apache/beam/pull/11075#discussion_r426830154 ## File path: website/www/site/content/en/documentation/patterns/ai-platform.md ## @@ -0,0 +1,79 @@ +--- +title: "AI Platform integration patterns"

[GitHub] [beam] pabloem commented on pull request #11731: [BEAM-10018] Fix timestamps in two windowing Python katas

pabloem commented on pull request #11731: URL: https://github.com/apache/beam/pull/11731#issuecomment-630369162 making sure license tests pass This is an automated message from the Apache Git Service. To respond to the

[GitHub] [beam] pabloem commented on pull request #11339: [BEAM-9468] Fhir io

pabloem commented on pull request #11339: URL: https://github.com/apache/beam/pull/11339#issuecomment-630367173 retest this please This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] pabloem commented on pull request #11339: [BEAM-9468] Fhir io

pabloem commented on pull request #11339: URL: https://github.com/apache/beam/pull/11339#issuecomment-630367484 retest this please This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] pabloem commented on pull request #11339: [BEAM-9468] Fhir io

pabloem commented on pull request #11339: URL: https://github.com/apache/beam/pull/11339#issuecomment-63037 retest this please This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] pabloem commented on pull request #11736: Katas - Convert task description from HTML to Markdown

pabloem commented on pull request #11736: URL: https://github.com/apache/beam/pull/11736#issuecomment-630363596 retest this please This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] pabloem commented on pull request #11731: [BEAM-10018] Fix timestamps in two windowing Python katas

pabloem commented on pull request #11731: URL: https://github.com/apache/beam/pull/11731#issuecomment-630363293 retest this please This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] pabloem commented on pull request #11730: Python Katas - Remove answer placeholder checks

pabloem commented on pull request #11730: URL: https://github.com/apache/beam/pull/11730#issuecomment-630362861 retest this please This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] chamikaramj commented on pull request #11651: [BEAM-8889] Upgrades gcsio to 2.1.3

chamikaramj commented on pull request #11651: URL: https://github.com/apache/beam/pull/11651#issuecomment-630351782 Run Dataflow ValidatesRunner This is an automated message from the Apache Git Service. To respond to the

[GitHub] [beam] chamikaramj commented on pull request #11651: [BEAM-8889] Upgrades gcsio to 2.1.3

chamikaramj commented on pull request #11651: URL: https://github.com/apache/beam/pull/11651#issuecomment-630351596 Retest this please This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] chamikaramj commented on pull request #11651: [BEAM-8889] Upgrades gcsio to 2.1.3

chamikaramj commented on pull request #11651: URL: https://github.com/apache/beam/pull/11651#issuecomment-630351692 Run Java PostCommit This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] aaltay commented on pull request #11075: [BEAM-9421] Website section that describes getting predictions using AI Platform Prediciton

aaltay commented on pull request #11075: URL: https://github.com/apache/beam/pull/11075#issuecomment-630349512 > tfx_bsl 0.22 is out. > @aaltay (and others as well) Do you see any further blockers or can I move forward with merge? LGTM. @rose-rong-liu - any concerns?

[GitHub] [beam] aaltay commented on pull request #11437: [BEAM-9770] Add BigQueryIO deadletter pattern

aaltay commented on pull request #11437: URL: https://github.com/apache/beam/pull/11437#issuecomment-630348471 Run Java PreCommit This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] aaltay commented on pull request #11437: [BEAM-9770] Add BigQueryIO deadletter pattern

aaltay commented on pull request #11437: URL: https://github.com/apache/beam/pull/11437#issuecomment-630348592 Run Java PreCommit This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] aaltay commented on pull request #11437: [BEAM-9770] Add BigQueryIO deadletter pattern

aaltay commented on pull request #11437: URL: https://github.com/apache/beam/pull/11437#issuecomment-630348304 Run Java PreCommit This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] aaltay commented on a change in pull request #11674: [BEAM-9958] Linkage Checker to use exclusion files as baseline

aaltay commented on a change in pull request #11674: URL: https://github.com/apache/beam/pull/11674#discussion_r426803651 ## File path: sdks/java/build-tools/beam-linkage-check.sh ## @@ -66,51 +66,61 @@ if [ ! -z "$(git diff)" ]; then exit 1 fi +ACCUMULATED_RESULT=0 +

[GitHub] [beam] tvalentyn merged pull request #11726: [BEAM-9819] Updates google-apitools and httplib2

tvalentyn merged pull request #11726: URL: https://github.com/apache/beam/pull/11726 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [beam] amaliujia commented on pull request #11737: [BEAM-9984] Support BIT_OR aggregation function in Beam SQL

amaliujia commented on pull request #11737: URL: https://github.com/apache/beam/pull/11737#issuecomment-630338159 retest this please This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] tvalentyn merged pull request #11733: [BEAM-8019] Python3 fix - convert dict.keys() to list before indexing

tvalentyn merged pull request #11733: URL: https://github.com/apache/beam/pull/11733 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [beam] tvalentyn commented on pull request #11733: [BEAM-8019] Python3 fix - convert dict.keys() to list before indexing

tvalentyn commented on pull request #11733: URL: https://github.com/apache/beam/pull/11733#issuecomment-630331086 LGTM This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [beam] lukecwik commented on a change in pull request #11739: [BEAM-10024] Mark testOutputTimestampDefault with UsesUnboundedPColle…

lukecwik commented on a change in pull request #11739: URL: https://github.com/apache/beam/pull/11739#discussion_r426758985 ## File path: sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java ## @@ -3539,6 +3539,7 @@ public void onTimer() {}

[GitHub] [beam] lukecwik commented on a change in pull request #11739: [BEAM-10024] Mark testOutputTimestampDefault with UsesUnboundedPColle…

lukecwik commented on a change in pull request #11739: URL: https://github.com/apache/beam/pull/11739#discussion_r426758985 ## File path: sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java ## @@ -3539,6 +3539,7 @@ public void onTimer() {}

[GitHub] [beam] ibzib commented on pull request #11739: [BEAM-10024] Mark testOutputTimestampDefault with UsesUnboundedPColle…

ibzib commented on pull request #11739: URL: https://github.com/apache/beam/pull/11739#issuecomment-630299564 Run Spark ValidatesRunner This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] ibzib opened a new pull request #11739: [BEAM-10024] Mark testOutputTimestampDefault with UsesUnboundedPColle…

ibzib opened a new pull request #11739: URL: https://github.com/apache/beam/pull/11739 …ctions annotation. **Please** add a meaningful description for your change here Thank you for your contribution! Follow this checklist to help us

[GitHub] [beam] reuvenlax commented on pull request #11350: [BEAM-1589] Added @OnWindowExpiration annotation.

reuvenlax commented on pull request #11350: URL: https://github.com/apache/beam/pull/11350#issuecomment-630299108 run dataflow validatesrunner This is an automated message from the Apache Git Service. To respond to the

[GitHub] [beam] DariuszAniszewski commented on a change in pull request #11360: [BEAM-9722] added SnowflakeIO with Read operation

DariuszAniszewski commented on a change in pull request #11360: URL: https://github.com/apache/beam/pull/11360#discussion_r426750619 ## File path: sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeIO.java ## @@ -0,0 +1,735 @@ +/* + * Licensed to

[GitHub] [beam] reuvenlax commented on pull request #11350: [BEAM-1589] Added @OnWindowExpiration annotation.

reuvenlax commented on pull request #11350: URL: https://github.com/apache/beam/pull/11350#issuecomment-630293579 run dataflow validatesrunner This is an automated message from the Apache Git Service. To respond to the

[GitHub] [beam] reuvenlax commented on pull request #11350: [BEAM-1589] Added @OnWindowExpiration annotation.

reuvenlax commented on pull request #11350: URL: https://github.com/apache/beam/pull/11350#issuecomment-630293482 retest this please This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] TheNeuralBit commented on pull request #11575: [BEAM-9699] Add test verifying we can use ZetaSQL in Python SqlTransform

TheNeuralBit commented on pull request #11575: URL: https://github.com/apache/beam/pull/11575#issuecomment-630291142 Run Python2_PVR_Flink PreCommit This is an automated message from the Apache Git Service. To respond to the

[GitHub] [beam] pawelpasterz commented on a change in pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

pawelpasterz commented on a change in pull request #11691: URL: https://github.com/apache/beam/pull/11691#discussion_r426728593 ## File path: .test-infra/jenkins/job_PreCommit_SQL_Java11.groovy ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [beam] mwalenia commented on pull request #11566: [BEAM-9723] Add DLP integration transforms

mwalenia commented on pull request #11566: URL: https://github.com/apache/beam/pull/11566#issuecomment-630269549 R: @tysonjh and @santhh can you both take a look? Thanks! This is an automated message from the Apache Git

[GitHub] [beam] TheNeuralBit commented on pull request #11272: [BEAM-9641] Support ZetaSQL DATE type as a Beam LogicalType

TheNeuralBit commented on pull request #11272: URL: https://github.com/apache/beam/pull/11272#issuecomment-630259464 Run Java PreCommit This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] kamilwu commented on pull request #11075: [BEAM-9421] Website section that describes getting predictions using AI Platform Prediciton

kamilwu commented on pull request #11075: URL: https://github.com/apache/beam/pull/11075#issuecomment-630232198 tfx_bsl 0.22 is out. @aaltay (and others as well) Do you see any further blockers or can I move forward with merge?

[GitHub] [beam] iemejia edited a comment on pull request #11406: [BEAM-9748] Refactor Reparallelize as an alternative Reshuffle implementation

iemejia edited a comment on pull request #11406: URL: https://github.com/apache/beam/pull/11406#issuecomment-630227373 I had forgotten about this one. Suggestions applied. Can you PTAL again @lukecwik @jkff . Thanks! This

[GitHub] [beam] iemejia commented on pull request #11406: [BEAM-9748] Refactor Reparallelize as an alternative Reshuffle implementation

iemejia commented on pull request #11406: URL: https://github.com/apache/beam/pull/11406#issuecomment-630227373 I had forgotten about this one. Suggestions made, can you PTAL again @lukecwik @jkff . Thanks! This is an

[GitHub] [beam] kamilwu commented on pull request #11738: [BEAM-9936] Create SDK harness containers with Python 3.8

kamilwu commented on pull request #11738: URL: https://github.com/apache/beam/pull/11738#issuecomment-630226429 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [beam] kamilwu commented on pull request #11738: [BEAM-9936] Create SDK harness containers with Python 3.8

kamilwu commented on pull request #11738: URL: https://github.com/apache/beam/pull/11738#issuecomment-630222904 Run Python Dataflow ValidatesContainer This is an automated message from the Apache Git Service. To respond to

[GitHub] [beam] kamilwu opened a new pull request #11738: [BEAM-9936] Create SDK harness containers with Python 3.8

kamilwu opened a new pull request #11738: URL: https://github.com/apache/beam/pull/11738 Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] [**Choose

[GitHub] [beam] kamilwu commented on a change in pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

kamilwu commented on a change in pull request #11691: URL: https://github.com/apache/beam/pull/11691#discussion_r426658334 ## File path: .test-infra/jenkins/job_PreCommit_SQL_Java11.groovy ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one +

[GitHub] [beam] mxm merged pull request #11678: [BEAM-6733] Add pipeline option to flush bundle data before checkpointing

mxm merged pull request #11678: URL: https://github.com/apache/beam/pull/11678 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [beam] mxm commented on pull request #11678: [BEAM-6733] Add pipeline option to flush bundle data before checkpointing

mxm commented on pull request #11678: URL: https://github.com/apache/beam/pull/11678#issuecomment-630185373 After more test runs, it looks like the effect of finishing the bundle before the checkpoint is marginal / non-existent. However, we will have to run more experiments to change it

[GitHub] [beam] rehmanmuradali commented on a change in pull request #11350: [BEAM-1589] Added @OnWindowExpiration annotation.

rehmanmuradali commented on a change in pull request #11350: URL: https://github.com/apache/beam/pull/11350#discussion_r426618269 ## File path: runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java

[GitHub] [beam] rehmanmuradali commented on a change in pull request #11350: [BEAM-1589] Added @OnWindowExpiration annotation.

rehmanmuradali commented on a change in pull request #11350: URL: https://github.com/apache/beam/pull/11350#discussion_r426618001 ## File path: runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java

[GitHub] [beam] darshanj commented on a change in pull request #11610: [BEAM-9825] | Implement Intersect,Union,Except transforms

darshanj commented on a change in pull request #11610: URL: https://github.com/apache/beam/pull/11610#discussion_r426597425 ## File path: sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SetFns.java ## @@ -0,0 +1,618 @@ +/* + * Licensed to the Apache Software

[GitHub] [beam] henryken commented on a change in pull request #11734: [BEAM-9679] Add Core Transforms section / GroupByKey lesson to the Go SDK katas

henryken commented on a change in pull request #11734: URL: https://github.com/apache/beam/pull/11734#discussion_r426566629 ## File path: learning/katas/go/Core Transforms/GroupByKey/GroupByKey/test/task_test.go ## @@ -0,0 +1,57 @@ +// Licensed to the Apache Software

[GitHub] [beam] pawelpasterz commented on pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

pawelpasterz commented on pull request #11691: URL: https://github.com/apache/beam/pull/11691#issuecomment-630113471 R: @kamilwu Please, take a look, thanks! This is an automated message from the Apache Git Service. To

[GitHub] [beam] kamilwu commented on pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

kamilwu commented on pull request #11691: URL: https://github.com/apache/beam/pull/11691#issuecomment-630105861 Run SQL_Java11 PreCommit This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] DariuszAniszewski commented on a change in pull request #11360: [BEAM-9722] added SnowflakeIO with Read operation

DariuszAniszewski commented on a change in pull request #11360: URL: https://github.com/apache/beam/pull/11360#discussion_r426541056 ## File path: sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeIO.java ## @@ -0,0 +1,643 @@ +/* + * Licensed to

[GitHub] [beam] kamilwu commented on pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

kamilwu commented on pull request #11691: URL: https://github.com/apache/beam/pull/11691#issuecomment-630098899 Run seed job This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [beam] kamilwu commented on pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

kamilwu commented on pull request #11691: URL: https://github.com/apache/beam/pull/11691#issuecomment-630084314 Run SQL_Java11 PreCommit This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] kamilwu commented on pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

kamilwu commented on pull request #11691: URL: https://github.com/apache/beam/pull/11691#issuecomment-630084037 Run SQL_Java11 PreCommit This is an automated message from the Apache Git Service. To respond to the

[GitHub] [beam] kamilwu commented on pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

kamilwu commented on pull request #11691: URL: https://github.com/apache/beam/pull/11691#issuecomment-630081360 Run SQL_Java11 PreCommit This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] kamilwu commented on pull request #11691: [BEAM-2530] Sql precommit compile and run on java 11

kamilwu commented on pull request #11691: URL: https://github.com/apache/beam/pull/11691#issuecomment-630073218 Run Seed Job This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [beam] mxm commented on pull request #11678: [BEAM-6733] Add pipeline option to flush bundle data before checkpointing

mxm commented on pull request #11678: URL: https://github.com/apache/beam/pull/11678#issuecomment-630065308 Run Python2_PVR_Flink PreCommit This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [beam] henryken commented on a change in pull request #11734: [BEAM-9679] Add Core Transforms section / GroupByKey lesson to the Go SDK katas

henryken commented on a change in pull request #11734: URL: https://github.com/apache/beam/pull/11734#discussion_r426455910 ## File path: learning/katas/go/Core Transforms/GroupByKey/GroupByKey/pkg/task/task.go ## @@ -0,0 +1,27 @@ +// Licensed to the Apache Software

[GitHub] [beam] mwalenia commented on a change in pull request #11331: [BEAM-9646] Add Google Cloud vision integration transform

mwalenia commented on a change in pull request #11331: URL: https://github.com/apache/beam/pull/11331#discussion_r426451999 ## File path: sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateImages.java ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

[GitHub] [beam] mwalenia commented on pull request #11566: [BEAM-9723] Add DLP integration transforms

mwalenia commented on pull request #11566: URL: https://github.com/apache/beam/pull/11566#issuecomment-630008248 Run Java PreCommit This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] reuvenlax commented on a change in pull request #11350: [BEAM-1589] Added @OnWindowExpiration annotation.

reuvenlax commented on a change in pull request #11350: URL: https://github.com/apache/beam/pull/11350#discussion_r426413338 ## File path: runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java ## @@

[GitHub] [beam] darshanj commented on pull request #11610: [BEAM-9825] | Implement Intersect,Union,Except transforms

darshanj commented on pull request #11610: URL: https://github.com/apache/beam/pull/11610#issuecomment-629979195 Failed org.apache.beam.examples.WordCountIT > testE2EWordCount FAILED Task :runners:google-cloud-dataflow-java:examples-streaming:windmillPreCommit FAILED @amaliujia

[GitHub] [beam] mwalenia merged pull request #11692: [BEAM-2530] Implement Zeta SQL precommit compile tests and run on java 11

mwalenia merged pull request #11692: URL: https://github.com/apache/beam/pull/11692 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

<    1   2