[jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996435#comment-15996435 ] Aljoscha Krettek commented on BEAM-1612: My notion is actually both, I thought about it this

[jira] [Assigned] (BEAM-2158) support Arithmetic Operator

[ https://issues.apache.org/jira/browse/BEAM-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Xu reassigned BEAM-2158: -- Assignee: James Xu > support Arithmetic Operator > --- > > Key:

[jira] [Assigned] (BEAM-2149) BeamKafkaCSVTable: support column type other than string

[ https://issues.apache.org/jira/browse/BEAM-2149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Xu reassigned BEAM-2149: -- Assignee: James Xu > BeamKafkaCSVTable: support column type other than string >

[jira] [Updated] (BEAM-2149) BeamKafkaCSVTable: support column type other than string

[ https://issues.apache.org/jira/browse/BEAM-2149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Xu updated BEAM-2149: --- Description: Currently, BeamKafkaCSVTable only supports String column, need to support other types. Also,

[jira] [Commented] (BEAM-2149) BeamKafkaCSVTable: support column type other than string

[ https://issues.apache.org/jira/browse/BEAM-2149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996381#comment-15996381 ] James Xu commented on BEAM-2149: I will take this one. > BeamKafkaCSVTable: support column type other than

[jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996375#comment-15996375 ] Stephan Ewen commented on BEAM-1612: [~kenn] Ah, I think there are two notions floating around about

[jira] [Commented] (BEAM-2169) Release deploy to Nexus fail due to duplicate test jar artifact

[ https://issues.apache.org/jira/browse/BEAM-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996318#comment-15996318 ] Jean-Baptiste Onofré commented on BEAM-2169: We notice this behavior on another module too

[jira] [Created] (BEAM-2169) Release deploy to Nexus fail due to duplicate test jar artifact

Kobi Salant created BEAM-2169: - Summary: Release deploy to Nexus fail due to duplicate test jar artifact Key: BEAM-2169 URL: https://issues.apache.org/jira/browse/BEAM-2169 Project: Beam Issue

[GitHub] beam-site pull request #229: Transfer some content from Create Your Pipeline...

Github user asfgit closed the pull request at: https://github.com/apache/beam-site/pull/229 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[2/3] beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/722bdfb7 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/722bdfb7 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/722bdfb7

[3/3] beam-site git commit: This closes #229

This closes #229 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/8c9a89eb Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/8c9a89eb Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/8c9a89eb

[1/3] beam-site git commit: Transfer some content from Create Your Pipeline to the Programming Guide.

Repository: beam-site Updated Branches: refs/heads/asf-site 7b3e24f3b -> 8c9a89ebf Transfer some content from Create Your Pipeline to the Programming Guide. Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/8ea44819

[29/50] [abbrv] beam git commit: This closes #2846: BigQueryIO: Remove PipelineOptions.getJobName usages at pipeline construction time

This closes #2846: BigQueryIO: Remove PipelineOptions.getJobName usages at pipeline construction time Remove job name usages from BigQueryIO at pipeline construction time Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[33/50] [abbrv] beam git commit: Fixes PubsubIO.Write translation in Dataflow runner

Fixes PubsubIO.Write translation in Dataflow runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/415d4bb1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/415d4bb1 Diff:

[44/50] [abbrv] beam git commit: This closes #2885

This closes #2885 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ad12f631 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ad12f631 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ad12f631 Branch:

[46/50] [abbrv] beam git commit: This closes #2873: BigQueryIO: Remove tempLocation usage at pipeline construction time

This closes #2873: BigQueryIO: Remove tempLocation usage at pipeline construction time Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f3f88108 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f3f88108 Diff:

[05/50] [abbrv] beam git commit: This closes #2634

This closes #2634 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7d6f8bde Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7d6f8bde Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7d6f8bde Branch:

[21/50] [abbrv] beam git commit: Reduce visibility of DirectRunner classes

http://git-wip-us.apache.org/repos/asf/beam/blob/9edd8599/runners/direct-java/src/test/java/org/apache/beam/runners/direct/StatefulParDoEvaluatorFactoryTest.java -- diff --git

[14/50] [abbrv] beam git commit: This closes #2842

This closes #2842 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/320f9aff Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/320f9aff Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/320f9aff Branch:

[GitHub] beam pull request #2878: Forward integrate from `master` to `DSL_SQL`

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2878 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[12/50] [abbrv] beam git commit: [BEAM-59] FileChecksumMatcherTest: switch from IOChannelUtils to java file API

[BEAM-59] FileChecksumMatcherTest: switch from IOChannelUtils to java file API These are unit tests always running on local filesystem. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fb9ebb67 Tree:

[07/50] [abbrv] beam git commit: Use LinkedHashMap for step contexts in BaseExecutionContext

Use LinkedHashMap for step contexts in BaseExecutionContext This gives a performance improvement when all step contexts need to be traversed, such as for state cleanup operations. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[01/50] [abbrv] beam git commit: [BEAM-2020] Add additional CloudObject Translators

Repository: beam Updated Branches: refs/heads/DSL_SQL a6845a35f -> cf95571d9 [BEAM-2020] Add additional CloudObject Translators This closes #2805 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dc0fdcb7 Tree:

[27/50] [abbrv] beam git commit: Closes #2771

Closes #2771 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/57f449c4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/57f449c4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/57f449c4 Branch: refs/heads/DSL_SQL

[31/50] [abbrv] beam git commit: Fully general dynamic tables (including schemas) in BigQueryIO.

Fully general dynamic tables (including schemas) in BigQueryIO. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/35db7457 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/35db7457 Diff:

[48/50] [abbrv] beam git commit: This closes #2851

This closes #2851 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/34d25f40 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/34d25f40 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/34d25f40 Branch:

[49/50] [abbrv] beam git commit: This closes #2867: Inline TypedPValue

This closes #2867: Inline TypedPValue Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ff6bb353 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ff6bb353 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ff6bb353

[02/50] [abbrv] beam git commit: Introduces read/writePubsubMessages

Introduces read/writePubsubMessages Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eca553f2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/eca553f2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/eca553f2

[04/50] [abbrv] beam git commit: Removed coder and parseFn from PubsubIO.Read

Removed coder and parseFn from PubsubIO.Read Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/25dc94bc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/25dc94bc Diff:

[30/50] [abbrv] beam git commit: Fully general dynamic tables (including schemas) in BigQueryIO.

http://git-wip-us.apache.org/repos/asf/beam/blob/35db7457/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/PrepareWrite.java -- diff --git

[22/50] [abbrv] beam git commit: Reduce visibility of DirectRunner classes

Reduce visibility of DirectRunner classes Move inner classes of the DirectRunner to reduce total API Surface. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9edd8599 Tree:

[13/50] [abbrv] beam git commit: This closes #2860

This closes #2860 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0d19d3cb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0d19d3cb Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0d19d3cb Branch:

[25/50] [abbrv] beam git commit: Fix coder inference ambiguity in CombineFnsTest.

Fix coder inference ambiguity in CombineFnsTest. String.class was being encoded with both StringUtf8Coder.of() and NullableCoder.of(UserStringCoder.of()) in the same transform, and the wrong one was being chosen. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[42/50] [abbrv] beam git commit: Provides a default coder for PubsubMessage

Provides a default coder for PubsubMessage Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e57b5013 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e57b5013 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e57b5013

[26/50] [abbrv] beam git commit: Try PTransform-based coder inference before using fallback coder.

Try PTransform-based coder inference before using fallback coder. This is particularly important for fallback coders that claim to provide a coder for Object (or equivalently an unconstrained type parameter). See BEAM-1642. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[47/50] [abbrv] beam git commit: Removal of Aggregator class. Also removal from comments.

Removal of Aggregator class. Also removal from comments. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/878981fd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/878981fd Diff:

[08/50] [abbrv] beam git commit: Remove IoChannelUtils from PackageUtil

Remove IoChannelUtils from PackageUtil * Staging location as a new directory * Add GcsCreateOptions to override the default upload buffer size value Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a7d6ddc2 Tree:

[03/50] [abbrv] beam git commit: Removed coder and formatFn from PubsubIO.Write

Removed coder and formatFn from PubsubIO.Write Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/429c6131 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/429c6131 Diff:

[50/50] [abbrv] beam git commit: This closes #2878

This closes #2878 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cf95571d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cf95571d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/cf95571d Branch:

[17/50] [abbrv] beam git commit: [BEAM-1871] Move GCP specific serialization CloudObject and supporting translation code to Dataflow runner module

[BEAM-1871] Move GCP specific serialization CloudObject and supporting translation code to Dataflow runner module Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a5627b1a Tree:

[43/50] [abbrv] beam git commit: Moves PubsubMessage to upper level and renames payload

Moves PubsubMessage to upper level and renames payload Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/210e216d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/210e216d Diff:

[06/50] [abbrv] beam git commit: This closes #2849: Triggers for Java SDK post submit tests

This closes #2849: Triggers for Java SDK post submit tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3b61f6a9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3b61f6a9 Diff:

[11/50] [abbrv] beam git commit: Use Thread context ClassLoader as parent in AvroCoderTest

Use Thread context ClassLoader as parent in AvroCoderTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cda1405d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cda1405d Diff:

[16/50] [abbrv] beam git commit: [BEAM-1871] Move GCP specific serialization CloudObject and supporting translation code to Dataflow runner module

http://git-wip-us.apache.org/repos/asf/beam/blob/a5627b1a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/CloudObject.java -- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/CloudObject.java

[37/50] [abbrv] beam git commit: Convert WriteFiles/FileBasedSink from IOChannelFactory to FileSystems

Convert WriteFiles/FileBasedSink from IOChannelFactory to FileSystems This converts FileBasedSink from IOChannelFactory to FileSystems, with fallout changes on all existing Transforms that use WriteFiles. We preserve the existing semantics of most transforms, simply adding the ability for users

[28/50] [abbrv] beam git commit: Remove job name usages from BigQueryIO at pipeline construction time

Remove job name usages from BigQueryIO at pipeline construction time Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0ddf8d49 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0ddf8d49 Diff:

[38/50] [abbrv] beam git commit: This closes #2779

This closes #2779 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1bc50d62 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1bc50d62 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1bc50d62 Branch:

[32/50] [abbrv] beam git commit: This closes #2609

This closes #2609 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a1d82c20 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a1d82c20 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a1d82c20 Branch:

[15/50] [abbrv] beam git commit: Mark all PCollectionView methods internal

Mark all PCollectionView methods internal Add a note that the methods should not be considered to be accessible. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cc4ca8c0 Tree:

[18/50] [abbrv] beam git commit: [BEAM-1871] Move GCP specific serialization CloudObject and supporting translation code to Dataflow runner module

[BEAM-1871] Move GCP specific serialization CloudObject and supporting translation code to Dataflow runner module This closes #2862 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aafa1bba Tree:

[34/50] [abbrv] beam git commit: This closes #2875

This closes #2875 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b4bafd09 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b4bafd09 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b4bafd09 Branch:

[36/50] [abbrv] beam git commit: Convert WriteFiles/FileBasedSink from IOChannelFactory to FileSystems

http://git-wip-us.apache.org/repos/asf/beam/blob/17358248/sdks/java/core/src/main/java/org/apache/beam/sdk/io/TFRecordIO.java -- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/TFRecordIO.java

[23/50] [abbrv] beam git commit: Retry on correct error codes for datastoreio

Retry on correct error codes for datastoreio Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d8e2522e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d8e2522e Diff:

[40/50] [abbrv] beam git commit: [BEAM-2157] Fix HDFS Test That Failed in Other JDK Versions

[BEAM-2157] Fix HDFS Test That Failed in Other JDK Versions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8f3fbc06 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8f3fbc06 Diff:

[41/50] [abbrv] beam git commit: [BEAM-2157] Fix HDFS Test That Failed in Other JDK Versions

[BEAM-2157] Fix HDFS Test That Failed in Other JDK Versions This closes #2876 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5b0a8684 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5b0a8684 Diff:

[10/50] [abbrv] beam git commit: This closes #2858: Use LinkedHashMap for step contexts in BaseExecutionContext

This closes #2858: Use LinkedHashMap for step contexts in BaseExecutionContext Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f33039bf Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f33039bf Diff:

[20/50] [abbrv] beam git commit: This closes #2863

This closes #2863 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f55d0025 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f55d0025 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f55d0025 Branch:

[24/50] [abbrv] beam git commit: This closes #2865

This closes #2865 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9b6b9060 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9b6b9060 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9b6b9060 Branch:

[45/50] [abbrv] beam git commit: BigQueryIO: Remove tempLocation usage at pipeline construction time

BigQueryIO: Remove tempLocation usage at pipeline construction time Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d0a2249f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d0a2249f Diff:

[35/50] [abbrv] beam git commit: Convert WriteFiles/FileBasedSink from IOChannelFactory to FileSystems

http://git-wip-us.apache.org/repos/asf/beam/blob/17358248/sdks/java/core/src/test/java/org/apache/beam/sdk/io/WriteFilesTest.java -- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/WriteFilesTest.java

[19/50] [abbrv] beam git commit: This closes #2861: Use Thread context ClassLoader as parent in AvroCoderTest

This closes #2861: Use Thread context ClassLoader as parent in AvroCoderTest Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b263cb77 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b263cb77 Diff:

[2/3] beam git commit: redesign BeamSqlExpression to execute Calcite SQL expression.

redesign BeamSqlExpression to execute Calcite SQL expression. Changes: 1. revert BEAM dependency to 0.6.0 to avoid impact of changes in master branch; 2. updates as discussion during review; refine BeamSqlRowCoder Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[3/3] beam git commit: This closes #2656

This closes #2656 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a6845a35 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a6845a35 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a6845a35 Branch:

[1/3] beam git commit: redesign BeamSqlExpression to execute Calcite SQL expression.

Repository: beam Updated Branches: refs/heads/DSL_SQL aa07a1d41 -> a6845a35f http://git-wip-us.apache.org/repos/asf/beam/blob/464cc275/dsls/sql/src/main/java/org/apache/beam/dsls/sql/schema/BeamSqlRowCoder.java -- diff --git

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #3632

See

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3631

See

[jira] [Commented] (BEAM-1491) HDFSFileSource should be able to read the HADOOP_CONF_DIR(YARN_CONF_DIR) environment variable

[ https://issues.apache.org/jira/browse/BEAM-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996235#comment-15996235 ] ASF GitHub Bot commented on BEAM-1491: -- Github user 397090770 closed the pull request at:

[GitHub] beam pull request #2819: [BEAM-1491]Identify HADOOP_CONF_DIR(or YARN_CONF_DI...

Github user 397090770 closed the pull request at: https://github.com/apache/beam/pull/2819 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (BEAM-1491) HDFSFileSource should be able to read the HADOOP_CONF_DIR(YARN_CONF_DIR) environment variable

[ https://issues.apache.org/jira/browse/BEAM-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15996232#comment-15996232 ] ASF GitHub Bot commented on BEAM-1491: -- GitHub user 397090770 opened a pull request:

[GitHub] beam pull request #2890: [BEAM-1491]Identify HADOOP_CONF_DIR(or YARN_CONF_DI...

GitHub user 397090770 opened a pull request: https://github.com/apache/beam/pull/2890 [BEAM-1491]Identify HADOOP_CONF_DIR(or YARN_CONF_DIR) environment variables Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

Build failed in Jenkins: beam_PerformanceTests_Dataflow #370

See Changes: [dhalperi] Convert WriteFiles/FileBasedSink from IOChannelFactory to FileSystems [tgroh] Inline TypedPValue [lcwik] [BEAM-2157] Fix HDFS Test That Failed in Other JDK Versions

<    1   2   3   4   5