[beam] 03/03: Fix errorprone

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git commit f5fd0127bd5327373b134e838849c702f10cf045 Author: Etienne Chauchot AuthorDate: Tue Jan 15

[beam] branch spark-runner_structured-streaming updated (16c57c3 -> f5fd012)

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a change to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git. from 16c57c3 First attempt for ParDo primitive implementation new 7ff0a26 Serialize

[beam] 02/03: Comment schema choices

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git commit 1fe87911591940f49d2db95d3cda5a906a04fd96 Author: Etienne Chauchot AuthorDate: Tue Jan 15

[beam] 01/03: Serialize windowedValue to byte[] in source to be able to specify a binary dataset schema and deserialize windowedValue from Row to get a dataset

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git commit 7ff0a262f2ae4c57ab5e7f5e213ab17317f70a69 Author: Etienne Chauchot AuthorDate: Tue Jan 15

[beam] branch spark-runner_structured-streaming updated: Cleaning

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/spark-runner_structured-streaming by this push:

[beam] branch release-2.10.0 updated: [BEAM-6418] Execute Flink tests serially to avoid memory issues

This is an automated email from the ASF dual-hosted git repository. mxm pushed a commit to branch release-2.10.0 in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/release-2.10.0 by this push: new 6cd27b0 [BEAM-6418] Execute Flink

[beam] 04/04: Fix split bug

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git commit 707470b0469fbcf63efd985faf6185be295e7c6d Author: Etienne Chauchot AuthorDate: Tue Jan 15

[beam] 02/04: Cleaning

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git commit ca88d547d54ec9e1f5831894106dce076205acbd Author: Etienne Chauchot AuthorDate: Tue Jan 15

[beam] branch spark-runner_structured-streaming updated (f5fd012 -> 707470b)

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a change to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git. from f5fd012 Fix errorprone new f19721f Fix testMode output to comply with new binary

[beam] 01/04: Fix testMode output to comply with new binary schema

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git commit f19721f35b9249c1db712dc4c72a588105019726 Author: Etienne Chauchot AuthorDate: Tue Jan 15

[beam] 03/04: Remove bundleSize parameter and always use spark default parallelism

This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git commit 7bb19451dadea0259f6658c7ccc7f157fa0cd576 Author: Etienne Chauchot AuthorDate: Tue Jan 15

[beam] 01/01: Merge pull request #7491 from akedin/multiple-schemas-support

This is an automated email from the ASF dual-hosted git repository. anton pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit feece918d2a938efd3fed22e7ce4e127953f662d Merge: ff70ca1 de08064 Author: Anton Kedin

[beam] Diff for: [GitHub] akedin merged pull request #7491: [SQL] Multiple schemas support

diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java index 5fd08806c525..f5613c9b56bf 100644 ---

[beam] branch master updated (ff70ca1 -> feece91)

This is an automated email from the ASF dual-hosted git repository. anton pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from ff70ca1 Moving to 2.11.0-SNAPSHOT on master branch add 9ff8001 [SQL] Support multiple top-level schemas in

[beam] Diff for: [GitHub] tvalentyn closed pull request #7058: DO NOT MERGE

diff --git a/sdks/python/apache_beam/typehints/native_type_compatibility.py b/sdks/python/apache_beam/typehints/native_type_compatibility.py index 87fb2c808167..dd397e5ca6f5 100644 --- a/sdks/python/apache_beam/typehints/native_type_compatibility.py +++

[beam] branch release-2.10.0 updated (6cd27b0 -> 343e662)

This is an automated email from the ASF dual-hosted git repository. kenn pushed a change to branch release-2.10.0 in repository https://gitbox.apache.org/repos/asf/beam.git. discard 6cd27b0 [BEAM-6418] Execute Flink tests serially to avoid memory issues omit de94544 [BEAM-6294] Ensure

[beam] 01/01: Prepare for 2.10.0 release

This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch release-2.10.0 in repository https://gitbox.apache.org/repos/asf/beam.git commit 343e6629b0830509a1123484ac766207fdac4328 Author: Kenneth Knowles AuthorDate: Tue Jan 15 12:08:00 2019 -0800

[beam] branch master updated (317a8b5 -> ff70ca1)

This is an automated email from the ASF dual-hosted git repository. kenn pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 317a8b5 Merge pull request #7499: [BEAM-6425] - Replace SSLContext.getInstance("SSL") add ff70ca1 Moving to

[beam] Diff for: [GitHub] kennknowles closed pull request #7516: Update version to 2.11.0-SNAPSHOT

diff --git a/gradle.properties b/gradle.properties index 1dcfd0180407..8d2d1685709e 100644 --- a/gradle.properties +++ b/gradle.properties @@ -23,4 +23,4 @@ offlineRepositoryRoot=offline-repository signing.gnupg.executable=gpg signing.gnupg.useLegacyGpg=true -version=2.10.0-SNAPSHOT

[beam] Diff for: [GitHub] mxm merged pull request #7514: [BEAM-6439] Move Python Validates Runner Flink test to PreCommit.

diff --git a/.test-infra/jenkins/job_PostCommit_Python_ValidatesRunner_Flink.groovy b/.test-infra/jenkins/job_PreCommit_Python_ValidatesRunner_Flink.groovy similarity index 55% rename from .test-infra/jenkins/job_PostCommit_Python_ValidatesRunner_Flink.groovy rename to

[beam] 01/01: Merge pull request #7503 from RobbeSneyders/tfrecordio

This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 0e416e2ff3bdae1932156a5ae2aca9a398a33fa4 Merge: b6e838d 166e98b Author: Ahmet Altay AuthorDate: Tue Jan 15 15:36:38 2019

[beam] branch master updated (b6e838d -> 0e416e2)

This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from b6e838d Merge pull request #7514: [BEAM-6439] Move Python Validates Runner Flink test to PreCommit add 166e98b

[beam] Diff for: [GitHub] aaltay merged pull request #7503: [BEAM-5315] Python 3 port io.tfrecordio module

diff --git a/sdks/python/apache_beam/io/tfrecordio_test.py b/sdks/python/apache_beam/io/tfrecordio_test.py index e85842436b22..49956ea6f3a6 100644 --- a/sdks/python/apache_beam/io/tfrecordio_test.py +++ b/sdks/python/apache_beam/io/tfrecordio_test.py @@ -59,15 +59,15 @@ # >>> import tensorflow

[beam] 01/01: Merge pull request #7514: [BEAM-6439] Move Python Validates Runner Flink test to PreCommit

This is an automated email from the ASF dual-hosted git repository. mxm pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit b6e838d9af07825f09b99e8cbc98b1b3a89e4944 Merge: feece91 4358d07 Author: Maximilian Michels AuthorDate: Tue Jan 15 18:06:16

[beam] branch master updated (feece91 -> b6e838d)

This is an automated email from the ASF dual-hosted git repository. mxm pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from feece91 Merge pull request #7491 from akedin/multiple-schemas-support add 4358d07 Move Python Validates Runner

[beam] 01/01: Merge pull request #7415 from angoenka/grpc_keep_alive

This is an automated email from the ASF dual-hosted git repository. goenka pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 5d00f6b42304815944dfe46ec7a2d95df510ea44 Merge: 0e416e2 d2543a2 Author: Ankur AuthorDate: Tue Jan 15 16:06:40 2019 -0800

[beam] Diff for: [GitHub] angoenka merged pull request #7415: [BEAM-6258] Set grpc keep alive on server creation

diff --git a/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/ServerFactory.java b/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/ServerFactory.java index 5970f85c1745..38cae631a975 100644 ---

[beam] Diff for: [GitHub] tweise merged pull request #7517: [BEAM-6440] Fix leakage of timer de-duplication map

diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java index dcd0f0bd7dfe..647d6ccacb0a 100644 ---

[beam] branch master updated (b83b302 -> 40b889e)

This is an automated email from the ASF dual-hosted git repository. thw pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from b83b302 Merge pull request #7523: Apply spotless across Beam add 85e84e5 [BEAM-6440] Fix leakage of timer

[beam] Diff for: [GitHub] kennknowles closed pull request #7528: DO NOT MERGE - dummy PR to see if spotlessCheck on Jenkins succeeds against two different codebases

diff --git a/another-README.md b/another-README.md new file mode 100644 index ..cef141ea4c99 --- /dev/null +++ b/another-README.md @@ -0,0 +1,112 @@ + + +# Apache Beam + +[Apache Beam](http://beam.apache.org/) is a unified model for defining both batch and streaming data-parallel

[beam] branch master updated (40b889e -> be1b166)

This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 40b889e Merge pull request #7517: [BEAM-6440] Fix leakage of timer de-duplication map add 6cea24f Add ANTLR

[beam] Diff for: [GitHub] reuvenlax merged pull request #7500: [BEAM-4076] Add antlr4 to beam

diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy index dcc78a5416ab..eb8a57d639e5 100644 --- a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy +++

[beam] branch master updated (0e416e2 -> 5d00f6b)

This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 0e416e2 Merge pull request #7503 from RobbeSneyders/tfrecordio add d2543a2 [BEAM-6258] Set keep alive ping to

[beam] Diff for: [GitHub] aaltay merged pull request #7519: [BEAM-6318] Increase the amount of pip download retries to 10 from a default 5

diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy index 4b45b17b8126..d7c73b4a6e3b 100644 --- a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy +++

[beam] 01/01: Merge pull request #7519 from tvalentyn/pip_retries

This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 189141051eca74e5dc5428a1958092453e754727 Merge: 5d00f6b 3ecda6b Author: Ahmet Altay AuthorDate: Tue Jan 15 16:17:44 2019

[beam] branch master updated (5d00f6b -> 1891410)

This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 5d00f6b Merge pull request #7415 from angoenka/grpc_keep_alive add 3ecda6b Increase the amount of pip download

[beam] Diff for: [GitHub] boyuanzz closed pull request #7524: [DO NOT MERGE] Run all PostCommit Tests against Release Branch

diff --git a/empty_file.txt b/empty_file.txt new file mode 100644 index ..e69de29bb2d1 diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle index c4c721f28168..f913502ac760 100644 ---

[beam] Diff for: [GitHub] boyuanzz closed pull request #7525: [DO NOT MERGE] Run all PostCommit Tests against Release Branch

diff --git a/empty_file.txt b/empty_file.txt new file mode 100644 index ..e69de29bb2d1 With regards, Apache Git Services

[beam] branch master updated (1891410 -> b83b302)

This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 1891410 Merge pull request #7519 from tvalentyn/pip_retries add 2662f2b Apply spotless. new b83b302

[beam] 01/01: Merge pull request #7523: Apply spotless across Beam

This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit b83b302ef97767e4ca245ea24e8bd40a6692e72c Merge: 1891410 2662f2b Author: reuvenlax AuthorDate: Tue Jan 15 18:09:44 2019

[beam] 01/01: Merge pull request #7517: [BEAM-6440] Fix leakage of timer de-duplication map

This is an automated email from the ASF dual-hosted git repository. thw pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 40b889e2f633482ccef688ecfee250c2c268a364 Merge: b83b302 85e84e5 Author: Thomas Weise AuthorDate: Tue Jan 15 18:20:57 2019

[beam] 01/01: Merge pull request #7499: [BEAM-6425] - Replace SSLContext.getInstance("SSL")

This is an automated email from the ASF dual-hosted git repository. iemejia pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 317a8b50f46c37ce0af50a1b9cce2437253e42a7 Merge: d7a0a3f 6480962 Author: Ismaël Mejía AuthorDate: Tue Jan 15 10:48:36

[beam] Diff for: [GitHub] iemejia merged pull request #7499: [BEAM-6425] - Replace SSLContext.getInstance("SSL")

diff --git a/sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/SSLUtils.java b/sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/SSLUtils.java index 5b062ed39579..9a778a349d13 100644 ---

[beam] branch master updated (d7a0a3f -> 317a8b5)

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 d7a0a3f [BEAM-6427]INTERSECT ALL is not compatible with SQL standard. add 6480962 BEAM-6425 - Replace