[beam] branch master updated (468cac6 -> d21bbaf)

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 468cac6 [BEAM-7389] Add DoFn methods sample (#9257) add 846ada6 The coder returned for typehints.List should

[beam] branch aaltay-patch-1 updated (00f07de -> e9689bf)

This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch aaltay-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git. from 00f07de fixup add e9689bf fixup No new revisions were added by this update. Summary of changes:

[beam] branch master updated (6f88601 -> 468cac6)

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 6f88601 [BEAM-7389] Add code examples for Regex page (#9262) add 468cac6 [BEAM-7389] Add DoFn methods sample

[beam] branch asf-site updated: Publishing website 2019/09/05 22:27:36 at commit 6f88601

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 6db6c24 Publishing website 2019/09/05

[beam] branch master updated (55b4815 -> 6f88601)

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 55b4815 Merge pull request #9132 [BEAM-7839] Default to UNRECOGNIZED state when a state cannot be accurately

[beam] branch aaltay-patch-1 updated (af65d51 -> 00f07de)

This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch aaltay-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git. from af65d51 Move inside _Credentials add 00f07de fixup No new revisions were added by this update. Summary

[beam] branch master updated (fba3524 -> 55b4815)

This is an automated email from the ASF dual-hosted git repository. tvalentyn pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from fba3524 Merge pull request #9421 from ibzib/sdk-worker-test add d28791e Introduce state when job state

[beam] branch master updated: [BEAM-7859] set SDK worker parallelism to 1 in word count test

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 The following commit(s) were added to refs/heads/master by this push: new 4dbfc6f [BEAM-7859] set SDK worker parallelism

[beam] branch master updated (f747159 -> 393396b)

This is an automated email from the ASF dual-hosted git repository. udim pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from f747159 Merge pull request #9486 Fix slice inference to not always assume List. add 393396b [BEAM-7060] Type

[beam] branch master updated (38dd8ce -> f747159)

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 38dd8ce Merge pull request #9473: [BEAM-8155] Add static PubsubIO.readMessagesWithCoderAndParseFn method add

[beam] branch lostluck-patch-1 created (now 3606d50)

This is an automated email from the ASF dual-hosted git repository. lostluck pushed a change to branch lostluck-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git. at 3606d50 [GoSDK] Improve singleton side input runtime error This branch includes the following new

[beam] 01/01: [GoSDK] Improve singleton side input runtime error

This is an automated email from the ASF dual-hosted git repository. lostluck pushed a commit to branch lostluck-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git commit 3606d506d64bf1f83438cb9616d9b7fa45dccd10 Author: Robert Burke AuthorDate: Thu Sep 5 13:55:30 2019 -0700

[beam] branch master updated (54a1296 -> 38dd8ce)

This is an automated email from the ASF dual-hosted git repository. chamikara pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 54a1296 Merge pull request #9483: Revert "[hotfix] Encode keys as NESTED for flink keyselector" add c9d0ff2

[beam] branch revert-9232-BEAM-7819-parse-pubsub-message_id deleted (was 23b0b73)

This is an automated email from the ASF dual-hosted git repository. udim pushed a change to branch revert-9232-BEAM-7819-parse-pubsub-message_id in repository https://gitbox.apache.org/repos/asf/beam.git. was 23b0b73 Revert "[BEAM-7819] Python - parse PubSub message_id into attributes

[beam] branch master updated (8869fce -> 54a1296)

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 8869fce Merge pull request #9481: Remove duplicate word from the Flink runner doc add be30557 Revert "[hotfix]

[beam] 13/24: Fix ExpressionEncoder generated code: typos, try catch, fqcn

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 668227b5240e08ff0de45ad7deeff1dad0a6a97d Author: Etienne Chauchot AuthorDate: Wed Sep 4

[beam] 21/24: Fix generated code: uniform exceptions catching, fix parenthesis and variable declarations

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 d8b8b428617860c65ddf856e73fd3418731f4b1f Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] 20/24: Fix equal and hashcode

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 ef694106cf61a66e823b5e7b5a233629af83d029 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] 09/24: Fix code generation in Beam coder wrapper

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 b11e1000c1dc122c2da315f7d6debf344a1d2055 Author: Etienne Chauchot AuthorDate: Mon Sep 2

[beam] 06/24: Conform to spark ExpressionEncoders: pass classTags, implement scala Product, pass children from within the ExpressionEncoder

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 23735e4bc4cc6fe7a0e56a5370499d0ce95d381d Author: Etienne Chauchot AuthorDate: Thu Aug 29

[beam] 16/24: Add try catch around reflexion call in lazy init of beam coder

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 723c004dcdf82073568dc1a758d8d7453a6af954 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] 18/24: Remove lazy init of beam coder because there is no generic way on instanciating a beam coder

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 c4a44649013b04d04eeca3756ff181f59632fab7 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] 05/24: Fix scala Product in Encoders to avoid StackEverflow

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 a5d49f5dea33a862cc89ca8ef62c9a389a2902fd Author: Etienne Chauchot AuthorDate: Thu Aug 29

[beam] 11/24: Fix call to scala Fucntion1 in coder lazy init

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 2c94eef2f1d2677bf64851a8c22520c44557170f Author: Etienne Chauchot AuthorDate: Wed Sep 4

[beam] 10/24: Lazy init coder because coder instance cannot be interpolated by catalyst

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 a758985ad24183bbdba3c11ea51b7020bc0865cf Author: Etienne Chauchot AuthorDate: Mon Sep 2

[beam] 07/24: Fix visibility of serializer and deserializer

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 e96af88096a6798ff0de2f24a95273334b3d9c7d Author: Etienne Chauchot AuthorDate: Thu Aug 29

[beam] 24/24: Improve exceptions catching

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 cfdf4a4ee43091a281d6dcff021f290d698ed2a7 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] branch spark-runner_structured-streaming updated (c350188 -> cfdf4a4)

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 c350188 Use "sparkMaster" in local mode to obtain number of shuffle partitions +

[beam] 12/24: Fix warning in coder construction by reflexion

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 cbd7c2bdd7ad96317b4a7545a28d35f467b05795 Author: Etienne Chauchot AuthorDate: Wed Sep 4

[beam] 23/24: Apply spotless and checkstyle and add javadocs

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 b87912300c863af606933a03ca790e8e94ed05f1 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] 01/24: Wrap Beam Coders into Spark Encoders using ExpressionEncoder: serialization part

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 031754c73bcd72302f10730c8266e5ead0714bc1 Author: Etienne Chauchot AuthorDate: Mon Aug 26

[beam] 14/24: Fix getting the output value in code generation

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 959664f8092e5bb06c7a78dae78a12ac2559d413 Author: Etienne Chauchot AuthorDate: Wed Sep 4

[beam] 03/24: Fix EncoderHelpers.fromBeamCoder() visibility

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 84f2cbd9b30a72ecc827e9c03de533b8e65190b2 Author: Etienne Chauchot AuthorDate: Tue Aug 27

[beam] 02/24: Wrap Beam Coders into Spark Encoders using ExpressionEncoder: deserialization part

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 d613d6bc28d63df6631367270f8474caf6f24059 Author: Etienne Chauchot AuthorDate: Mon Aug 26

[beam] 17/24: Cast coder instanciated by reflection

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 91e923c0dde332ea8615aa320b1c48d8c1167fc3 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] 08/24: Add a simple spark native test to test Beam coders wrapping into Spark Encoders

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 2bf4cd9bac0e0dfa03d3499f5d84b0d51781d8ba Author: Etienne Chauchot AuthorDate: Fri Aug 30

[beam] 19/24: Remove example code

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 43513041ded40c7d1ae0f6cf1adc81975aaa92c3 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] 15/24: Fix beam coder lazy init using reflexion

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 8bbf991e4bded15e447f8bee7ef9e70ce9ff3ad4 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] 04/24: type erasure: spark encoders require a Class, pass Object and cast to Class

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 95fd2727f9e2ad00144e790a8dd324d60867d35c Author: Etienne Chauchot AuthorDate: Thu Aug 29

[beam] 22/24: Add an assert of equality in the encoders test

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 0fe6f9be8e7376f4481e09a13e2fdd0bed121a61 Author: Etienne Chauchot AuthorDate: Thu Sep 5

[beam] branch revert-9464-hotfix created (now be30557)

This is an automated email from the ASF dual-hosted git repository. dmvk pushed a change to branch revert-9464-hotfix in repository https://gitbox.apache.org/repos/asf/beam.git. at be30557 Revert "[hotfix] Encode keys as NESTED for flink keyselector" No new revisions were added by this

[beam] branch asf-site updated: Publishing website 2019/09/05 12:43:13 at commit 8869fce

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 a8f93eb Publishing website 2019/09/05

[beam] branch master updated (9983115 -> 8869fce)

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 9983115 Merge pull request #9426: [BEAM-8088] Track PCollection boundedness in Python SDK add 7bf6c61 [hotfix]

[beam] branch master updated (ce4cd3b -> 9983115)

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 ce4cd3b Merge pull request #9464: [hotfix] Encode keys as NESTED for flink keyselector add 79d4bf2 Track

[beam] branch master updated (7e1eddf -> ce4cd3b)

This is an automated email from the ASF dual-hosted git repository. dmvk pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 7e1eddf [BEAM-7909] fix python container image name (#9478) add 4a0eaf3 [hotfix] Encode keys as NESTED for flink