[GitHub] [beam] mwalenia commented on issue #10985: [BEAM-9396] Match Docker image names between Jenkins jobs and Gradle tasks

mwalenia commented on issue #10985: [BEAM-9396] Match Docker image names between Jenkins jobs and Gradle tasks URL: https://github.com/apache/beam/pull/10985#issuecomment-592379776 Run Python Load Tests ParDo Flink Batch

[GitHub] [beam] mwalenia commented on issue #10985: [BEAM-9396] Match Docker image names between Jenkins jobs and Gradle tasks

mwalenia commented on issue #10985: [BEAM-9396] Match Docker image names between Jenkins jobs and Gradle tasks URL: https://github.com/apache/beam/pull/10985#issuecomment-592364965 run seed job This is an automated message

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592297867 @rohdesamuel precommit is still failing. This is an automated

[GitHub] [beam] ananvay commented on issue #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2

ananvay commented on issue #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2 URL: https://github.com/apache/beam/pull/10998#issuecomment-592291950 Thanks a lot Ankur!! Overall LGTM, a few minor comments to track the changes made here. Perhaps we should have a bug

[GitHub] [beam] angoenka commented on issue #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2

angoenka commented on issue #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2 URL: https://github.com/apache/beam/pull/10998#issuecomment-592290433 Run Seed Job This is an automated message from the Apache Git

[GitHub] [beam] angoenka commented on issue #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2

angoenka commented on issue #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2 URL: https://github.com/apache/beam/pull/10998#issuecomment-592289884 Run Seed Job This is an automated message from the Apache Git

[GitHub] [beam] angoenka commented on issue #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2

angoenka commented on issue #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2 URL: https://github.com/apache/beam/pull/10998#issuecomment-592288401 R: @ananvay @markflyhigh This is an automated message from

[GitHub] [beam] angoenka opened a new pull request #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2

angoenka opened a new pull request #10998: [BEAM-9287] Add Postcommit tests for dataflow runner v2 URL: https://github.com/apache/beam/pull/10998 with hardcoded image for now **Please** add a meaningful description for your change here Thank

[GitHub] [beam] aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592282786 Run Python PreCommit This is an automated message from the Apache Git

[GitHub] [beam] angoenka commented on issue #10997: [BEAM-9402] Remove options overwrite

angoenka commented on issue #10997: [BEAM-9402] Remove options overwrite URL: https://github.com/apache/beam/pull/10997#issuecomment-592277859 R: @HuangLED @rohdesamuel This is an automated message from the Apache Git

[GitHub] [beam] angoenka opened a new pull request #10997: [BEAM-9402] Remove options overwrite

angoenka opened a new pull request #10997: [BEAM-9402] Remove options overwrite URL: https://github.com/apache/beam/pull/10997 The option does not allow addition of user provided option like in case of validates runner tests. This means that the test always tries to run against

[GitHub] [beam] ihji commented on issue #10621: [BEAM-9056] Staging artifacts from environment

ihji commented on issue #10621: [BEAM-9056] Staging artifacts from environment URL: https://github.com/apache/beam/pull/10621#issuecomment-592272245 had to force push to fix conflicts. This is an automated message from the

[GitHub] [beam] ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment

ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment URL: https://github.com/apache/beam/pull/10621#discussion_r385469800 ## File path: sdks/python/apache_beam/runners/portability/stager.py ## @@ -331,22 +389,23 @@ def

[GitHub] [beam] ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment

ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment URL: https://github.com/apache/beam/pull/10621#discussion_r385469821 ## File path: sdks/python/apache_beam/runners/portability/stager.py ## @@ -377,34 +436,33 @@ def

[GitHub] [beam] ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment

ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment URL: https://github.com/apache/beam/pull/10621#discussion_r385469668 ## File path:

[GitHub] [beam] ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment

ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment URL: https://github.com/apache/beam/pull/10621#discussion_r385469838 ## File path: sdks/python/apache_beam/runners/portability/stager.py ## @@ -547,21 +601,22 @@ def

[GitHub] [beam] ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment

ihji commented on a change in pull request #10621: [BEAM-9056] Staging artifacts from environment URL: https://github.com/apache/beam/pull/10621#discussion_r385469751 ## File path: runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunner.java

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592262649 Run Python PreCommit This is an automated message from the Apache

[GitHub] [beam] lukecwik commented on issue #10980: Address leftover styling comments from PR/10892

lukecwik commented on issue #10980: Address leftover styling comments from PR/10892 URL: https://github.com/apache/beam/pull/10980#issuecomment-592250235 pinging for update This is an automated message from the Apache Git

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592244984 retest this please This is an automated message from the Apache Git

[GitHub] [beam] sunjincheng121 commented on issue #10945: [BEAM-9295] Add Flink 1.10 build target and Make FlinkRunner compatible with Flink 1.10

sunjincheng121 commented on issue #10945: [BEAM-9295] Add Flink 1.10 build target and Make FlinkRunner compatible with Flink 1.10 URL: https://github.com/apache/beam/pull/10945#issuecomment-592244965 Test failure is not caused by the current PR.

[GitHub] [beam] chunyang commented on a change in pull request #10979: [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK

chunyang commented on a change in pull request #10979: [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK URL: https://github.com/apache/beam/pull/10979#discussion_r385442046 ## File path: sdks/python/apache_beam/io/gcp/bigquery.py ## @@ -1361,87 +1369,18

[beam] branch master updated (59e71c8 -> f0930f9)

This is an automated email from the ASF dual-hosted git repository. ibzib pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 59e71c8 Merge pull request #10996 from robinyqiu/tmp new 02abb18 [BEAM-9300] convert struct literal in ZetaSQL

[GitHub] [beam] ibzib merged pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL

ibzib merged pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [beam] kennknowles commented on a change in pull request #10972: [WIP] Add DeduplicationByUniqueId transform

kennknowles commented on a change in pull request #10972: [WIP] Add DeduplicationByUniqueId transform URL: https://github.com/apache/beam/pull/10972#discussion_r385438853 ## File path: sdks/python/apache_beam/runners/portability/fn_api_runner_test.py ## @@ -543,6 +545,15

[GitHub] [beam] robinyqiu commented on issue #10967: [BEAM-9300] convert struct literal in ZetaSQL

robinyqiu commented on issue #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967#issuecomment-592235477 LGTM. This is an automated message from the Apache Git Service. To

[GitHub] [beam] kennknowles commented on a change in pull request #10940: [BEAM-9288] Not bundle conscrypt in gRPC vendor

kennknowles commented on a change in pull request #10940: [BEAM-9288] Not bundle conscrypt in gRPC vendor URL: https://github.com/apache/beam/pull/10940#discussion_r385434469 ## File path: buildSrc/src/main/groovy/org/apache/beam/gradle/VendorJavaPlugin.groovy ## @@

[GitHub] [beam] ibzib commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL

ibzib commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967#discussion_r385430202 ## File path:

[GitHub] [beam] aaltay commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test

aaltay commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test URL: https://github.com/apache/beam/pull/10914#discussion_r385430114 ## File path: sdks/python/apache_beam/examples/streaming_wordcount_debugging.py ## @@

[GitHub] [beam] robertwb commented on a change in pull request #10972: [WIP] Add DeduplicationByUniqueId transform

robertwb commented on a change in pull request #10972: [WIP] Add DeduplicationByUniqueId transform URL: https://github.com/apache/beam/pull/10972#discussion_r385429733 ## File path: sdks/python/apache_beam/runners/sdf_utils.py ## @@ -244,3 +247,47 @@ def

[GitHub] [beam] robertwb commented on a change in pull request #10972: [WIP] Add DeduplicationByUniqueId transform

robertwb commented on a change in pull request #10972: [WIP] Add DeduplicationByUniqueId transform URL: https://github.com/apache/beam/pull/10972#discussion_r385429185 ## File path: sdks/python/apache_beam/runners/portability/fn_api_runner_test.py ## @@ -543,6 +545,15 @@

[GitHub] [beam] ibzib commented on issue #10995: [BEAM-9401] bind Flink MiniCluster to localhost

ibzib commented on issue #10995: [BEAM-9401] bind Flink MiniCluster to localhost URL: https://github.com/apache/beam/pull/10995#issuecomment-592228747 @mxm `FlinkSubmissionTest.testDetachedSubmissionBatch` failed:

[GitHub] [beam] pabloem commented on a change in pull request #10979: [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK

pabloem commented on a change in pull request #10979: [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK URL: https://github.com/apache/beam/pull/10979#discussion_r384799264 ## File path: sdks/python/apache_beam/io/gcp/bigquery_test.py ## @@ -1025,6

[GitHub] [beam] pabloem commented on a change in pull request #10979: [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK

pabloem commented on a change in pull request #10979: [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK URL: https://github.com/apache/beam/pull/10979#discussion_r384769744 ## File path: sdks/python/apache_beam/io/gcp/bigquery.py ## @@ -1361,87 +1369,18

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-59222 retest this please This is an automated message from the Apache Git

[GitHub] [beam] lukecwik commented on issue #10992: [WIP][BEAM-2939] Add support for reporting the watermark in SplittableDoFns.

lukecwik commented on issue #10992: [WIP][BEAM-2939] Add support for reporting the watermark in SplittableDoFns. URL: https://github.com/apache/beam/pull/10992#issuecomment-592224753 CC: @boyuanzz @robertwb @mxm This is an

[GitHub] [beam] lukecwik commented on issue #10989: [BEAM-9397] Pass all supported StartBundleContext/FinishBundleContext except output receiver parameters to start bundle/finish bundle methods.

lukecwik commented on issue #10989: [BEAM-9397] Pass all supported StartBundleContext/FinishBundleContext except output receiver parameters to start bundle/finish bundle methods. URL: https://github.com/apache/beam/pull/10989#issuecomment-59901 Run Java PreCommit

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-59533 retest this please This is an automated message from the Apache Git

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592220334 retest this please This is an automated message from the Apache Git

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592219819 Run Python2_PVR_Flink PreCommit This is an automated message from

[beam] branch master updated: Bump Dataflow Java worker container version

' +'dataflow.container_version' : 'beam-master-20200227' ] }

[GitHub] [beam] boyuanzz merged pull request #10996: Bump Dataflow Java worker container version

boyuanzz merged pull request #10996: Bump Dataflow Java worker container version URL: https://github.com/apache/beam/pull/10996 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [beam] robinyqiu commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL

robinyqiu commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967#discussion_r384855068 ## File path:

[GitHub] [beam] robinyqiu opened a new pull request #10996: Bump Dataflow Java worker container version

robinyqiu opened a new pull request #10996: Bump Dataflow Java worker container version URL: https://github.com/apache/beam/pull/10996 r: @boyuanzz Post-Commit Tests Status (on master branch)

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592203342 retest this please This is an automated message from the Apache Git

[GitHub] [beam] iemejia removed a comment on issue #10974: [BEAM-9384] Add SchemaRegistry.getSchemaCoder to get SchemaCoders for registered types

iemejia removed a comment on issue #10974: [BEAM-9384] Add SchemaRegistry.getSchemaCoder to get SchemaCoders for registered types URL: https://github.com/apache/beam/pull/10974#issuecomment-592202769 Run Java PreCommit This

[GitHub] [beam] ibzib commented on issue #10995: [BEAM-9401] bind Flink MiniCluster to localhost

ibzib commented on issue #10995: [BEAM-9401] bind Flink MiniCluster to localhost URL: https://github.com/apache/beam/pull/10995#issuecomment-592202965 Run PortableJar_Flink PostCommit This is an automated message from the

[GitHub] [beam] iemejia commented on issue #10974: [BEAM-9384] Add SchemaRegistry.getSchemaCoder to get SchemaCoders for registered types

iemejia commented on issue #10974: [BEAM-9384] Add SchemaRegistry.getSchemaCoder to get SchemaCoders for registered types URL: https://github.com/apache/beam/pull/10974#issuecomment-592202769 Run Java PreCommit This is an

[GitHub] [beam] ibzib opened a new pull request #10995: [BEAM-9401] bind Flink MiniCluster to localhost

ibzib opened a new pull request #10995: [BEAM-9401] bind Flink MiniCluster to localhost URL: https://github.com/apache/beam/pull/10995 cc @aaltay Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly

[GitHub] [beam] ibzib commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL

ibzib commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967#discussion_r385396445 ## File path:

[GitHub] [beam] ibzib commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL

ibzib commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967#discussion_r385395591 ## File path:

[GitHub] [beam] amaliujia commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL

amaliujia commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967#discussion_r385394145 ## File path:

[GitHub] [beam] amaliujia commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL

amaliujia commented on a change in pull request #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967#discussion_r385393357 ## File path:

[GitHub] [beam] Tesio commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test

Tesio commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test URL: https://github.com/apache/beam/pull/10914#discussion_r385392760 ## File path: sdks/python/apache_beam/examples/streaming_wordcount_debugging.py ## @@

[GitHub] [beam] amaliujia commented on issue #10967: [BEAM-9300] convert struct literal in ZetaSQL

amaliujia commented on issue #10967: [BEAM-9300] convert struct literal in ZetaSQL URL: https://github.com/apache/beam/pull/10967#issuecomment-592193913 Nice! Will take a look soon This is an automated message from the

[GitHub] [beam] iemejia removed a comment on issue #10974: [BEAM-9384] Add SchemaRegistry.getSchemaCoder to get SchemaCoders for registered types

iemejia removed a comment on issue #10974: [BEAM-9384] Add SchemaRegistry.getSchemaCoder to get SchemaCoders for registered types URL: https://github.com/apache/beam/pull/10974#issuecomment-592191994 retest this please This

[beam] branch master updated: [BEAM-9373] Spark/Flink tests fix string concat

This is an automated email from the ASF dual-hosted git repository. ibzib pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 41e9520 [BEAM-9373] Spark/Flink tests fix string

[GitHub] [beam] iemejia commented on issue #10974: [BEAM-9384] Add SchemaRegistry.getSchemaCoder to get SchemaCoders for registered types

iemejia commented on issue #10974: [BEAM-9384] Add SchemaRegistry.getSchemaCoder to get SchemaCoders for registered types URL: https://github.com/apache/beam/pull/10974#issuecomment-592191994 retest this please This is an

[GitHub] [beam] ibzib merged pull request #10954: [BEAM-9373] Spark/Flink tests fix string concat

ibzib merged pull request #10954: [BEAM-9373] Spark/Flink tests fix string concat URL: https://github.com/apache/beam/pull/10954 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [beam] chamikaramj commented on issue #10954: [BEAM-9373] Spark/Flink tests fix string concat

chamikaramj commented on issue #10954: [BEAM-9373] Spark/Flink tests fix string concat URL: https://github.com/apache/beam/pull/10954#issuecomment-592191722 LGTM. Thanks. This is an automated message from the Apache Git

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592187719 Run PythonLint PreCommit This is an automated message from the

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592187646 retest this please This is an automated message from the Apache Git

[GitHub] [beam] iemejia commented on issue #10993: [BEAM-9400] Linkage Checker 1.1.4

iemejia commented on issue #10993: [BEAM-9400] Linkage Checker 1.1.4 URL: https://github.com/apache/beam/pull/10993#issuecomment-592184693 Thanks Tomo ! Eager to see the performance improvements in action! This is an

[GitHub] [beam] iemejia merged pull request #10993: [BEAM-9400] Linkage Checker 1.1.4

iemejia merged pull request #10993: [BEAM-9400] Linkage Checker 1.1.4 URL: https://github.com/apache/beam/pull/10993 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[beam] branch master updated (921a9a8 -> f4f12b1)

This is an automated email from the ASF dual-hosted git repository. iemejia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 921a9a8 [BEAM-8201] Pass all other endpoints through provisioning service. (#10843) add 8ccd27f Linkage

[GitHub] [beam] rohdesamuel opened a new pull request #10994: Teststreamservice merge

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

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592181684 Run Python PreCommit This is an automated message from the Apache

[GitHub] [beam] suztomo commented on issue #10993: [BEAM-9400] Linkage Checker 1.1.4

suztomo commented on issue #10993: [BEAM-9400] Linkage Checker 1.1.4 URL: https://github.com/apache/beam/pull/10993#issuecomment-592181422 R: @lukecwik @iemejia This is an automated message from the Apache Git Service. To

[GitHub] [beam] suztomo opened a new pull request #10993: [BEAM-9400] Linkage Checker 1.1.4

suztomo opened a new pull request #10993: [BEAM-9400] Linkage Checker 1.1.4 URL: https://github.com/apache/beam/pull/10993 Linkage Checker 1.1.4 has more efficient dependency graph resolution. It fixed a bug where exclusion elements did not take effect in grandchildren.

[GitHub] [beam] lukecwik opened a new pull request #10992: [WIP][BEAM-2939] Add support for reporting the watermark in SplittableDoFns.

lukecwik opened a new pull request #10992: [WIP][BEAM-2939] Add support for reporting the watermark in SplittableDoFns. URL: https://github.com/apache/beam/pull/10992 This exposes 3 methods using new DoFn style semantics: `GetInitialWatermarkEstimatorState` `NewWatermarkEstimator`

[GitHub] [beam] youngoli commented on issue #10991: [BEAM-3301] Refactor DoFn validation & allow specifying main inputs.

youngoli commented on issue #10991: [BEAM-3301] Refactor DoFn validation & allow specifying main inputs. URL: https://github.com/apache/beam/pull/10991#issuecomment-592171160 Run Go PostCommit This is an automated message

[GitHub] [beam] youngoli commented on issue #10991: [BEAM-3301] Refactor DoFn validation & allow specifying main inputs.

youngoli commented on issue #10991: [BEAM-3301] Refactor DoFn validation & allow specifying main inputs. URL: https://github.com/apache/beam/pull/10991#issuecomment-592171327 R: @lostluck This is an automated message from

[GitHub] [beam] youngoli opened a new pull request #10991: [BEAM-3301] Refactor DoFn validation & allow specifying main inputs.

youngoli opened a new pull request #10991: [BEAM-3301] Refactor DoFn validation & allow specifying main inputs. URL: https://github.com/apache/beam/pull/10991 The current version of this validation is a bit permissive because it doesn't require the number of main inputs to be specified.

[GitHub] [beam] chadrik commented on issue #10822: [BEAM-7746] Minor typing updates / fixes

chadrik commented on issue #10822: [BEAM-7746] Minor typing updates / fixes URL: https://github.com/apache/beam/pull/10822#issuecomment-592164134 Do we think this is safe to merge? I've been watching master for something that looks like it could solve the current test problems, and

[GitHub] [beam] aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592154205 retest this please This is an automated message from the Apache Git

[GitHub] [beam] aaltay commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test

aaltay commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test URL: https://github.com/apache/beam/pull/10914#discussion_r385343245 ## File path: sdks/python/apache_beam/examples/streaming_wordcount_debugging.py ## @@

[GitHub] [beam] aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592149918 retest this please This is an automated message from the Apache Git

[GitHub] [beam] aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592149742 Run PythonLint PreCommit This is an automated message from the Apache

[GitHub] [beam] yifanzou commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

yifanzou commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592138186 > > The linter failed due to "ERROR: Could not install packages due to an EnvironmentError: [Errno 28] No space left on device" >

[GitHub] [beam] pabloem commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

pabloem commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592136551 Run PythonLint PreCommit This is an automated message from the Apache

[GitHub] [beam] rohdesamuel commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

rohdesamuel commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592136428 Run PythonLint PreCommit This is an automated message from the

[GitHub] [beam] Tesio commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test

Tesio commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test URL: https://github.com/apache/beam/pull/10914#discussion_r385313258 ## File path: sdks/python/apache_beam/examples/streaming_wordcount_debugging.py ## @@

[GitHub] [beam] chunyang commented on issue #10979: [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK

chunyang commented on issue #10979: [BEAM-8841] Support writing data to BigQuery via Avro in Python SDK URL: https://github.com/apache/beam/pull/10979#issuecomment-592120245 The PreCommit failures look like they're being fixed by #10982 . The failing Python 3.7 PostCommit integration

[GitHub] [beam] kennknowles commented on a change in pull request #10990: disable coder inference for rows

kennknowles commented on a change in pull request #10990: disable coder inference for rows URL: https://github.com/apache/beam/pull/10990#discussion_r385304944 ## File path:

[GitHub] [beam] kennknowles commented on a change in pull request #10990: disable coder inference for rows

kennknowles commented on a change in pull request #10990: disable coder inference for rows URL: https://github.com/apache/beam/pull/10990#discussion_r385303509 ## File path:

[GitHub] [beam] aaltay commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test

aaltay commented on a change in pull request #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test URL: https://github.com/apache/beam/pull/10914#discussion_r385304557 ## File path: sdks/python/apache_beam/examples/streaming_wordcount_debugging.py ## @@

[GitHub] [beam] aaltay commented on issue #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test

aaltay commented on issue #10914: [BEAM-8078] streaming_wordcount_debugging.py is missing a test URL: https://github.com/apache/beam/pull/10914#issuecomment-592118125 > > As a high level comment do we need an integration test for `streaming_wordcount_debugging_it_test.py`? Integration

[GitHub] [beam] chadrik commented on issue #10822: [BEAM-7746] Minor typing updates / fixes

chadrik commented on issue #10822: [BEAM-7746] Minor typing updates / fixes URL: https://github.com/apache/beam/pull/10822#issuecomment-592117791 Run PythonLint PreCommit This is an automated message from the Apache Git

[GitHub] [beam] robertwb merged pull request #10843: [BEAM-8201] Pass all other endpoints through provisioning service.

robertwb merged pull request #10843: [BEAM-8201] Pass all other endpoints through provisioning service. URL: https://github.com/apache/beam/pull/10843 This is an automated message from the Apache Git Service. To respond to

[beam] branch master updated (8b69513 -> 921a9a8)

This is an automated email from the ASF dual-hosted git repository. robertwb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8b69513 Merge pull request #10987 from lukecwik/beam5524 add 921a9a8 [BEAM-8201] Pass all other endpoints

[GitHub] [beam] robertwb commented on issue #10843: [BEAM-8201] Pass all other endpoints through provisioning service.

robertwb commented on issue #10843: [BEAM-8201] Pass all other endpoints through provisioning service. URL: https://github.com/apache/beam/pull/10843#issuecomment-592116771 Thanks. I see JavaPortabilityApiJava11 is failing everywhere (and seems to be irrelevent).

[GitHub] [beam] amaliujia edited a comment on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia edited a comment on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592113465 Run PythonLint PreCommit trying to hit another Jenkins.

[GitHub] [beam] amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

amaliujia commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592113465 Run PythonLint PreCommit This is an automated message from the

[GitHub] [beam] lukecwik commented on issue #10989: [BEAM-9397] Pass all supported StartBundleContext/FinishBundleContext except output receiver parameters to start bundle/finish bundle methods.

lukecwik commented on issue #10989: [BEAM-9397] Pass all supported StartBundleContext/FinishBundleContext except output receiver parameters to start bundle/finish bundle methods. URL: https://github.com/apache/beam/pull/10989#issuecomment-592111413 Run RAT PreCommit

[GitHub] [beam] lukecwik commented on issue #10989: [BEAM-9397] Pass all supported StartBundleContext/FinishBundleContext except output receiver parameters to start bundle/finish bundle methods.

lukecwik commented on issue #10989: [BEAM-9397] Pass all supported StartBundleContext/FinishBundleContext except output receiver parameters to start bundle/finish bundle methods. URL: https://github.com/apache/beam/pull/10989#issuecomment-592111375 Run Java PreCommit

[GitHub] [beam] reuvenlax opened a new pull request #10990: disable coder inference for rows

reuvenlax opened a new pull request #10990: disable coder inference for rows URL: https://github.com/apache/beam/pull/10990 This is an automated message from the Apache Git Service. To respond to the message, please log on

[beam] branch asf-site updated: Publishing website 2020/02/27 18:32:09 at commit 8b69513

This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/asf-site by this push: new 6a74a84 Publishing website 2020/02/27

[GitHub] [beam] lukecwik merged pull request #10987: [BEAM-5524] Fix minor issue in style guide.

lukecwik merged pull request #10987: [BEAM-5524] Fix minor issue in style guide. URL: https://github.com/apache/beam/pull/10987 This is an automated message from the Apache Git Service. To respond to the message, please log

[beam] branch master updated: [BEAM-5524] Fix minor issue in style guide.

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 7cd1353 [BEAM-5524] Fix minor issue in style

[GitHub] [beam] aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors

aaltay commented on issue #10982: [BEAM-9392] Fix Multi TestStream assertion errors URL: https://github.com/apache/beam/pull/10982#issuecomment-592107642 > The linter failed due to "ERROR: Could not install packages due to an EnvironmentError: [Errno 28] No space left on device"

  1   2   >