[jira] [Commented] (BEAM-36) TimestampedValueInMultipleWindows should use a more compact set representation

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

[GitHub] incubator-beam pull request: [BEAM-22] Add ExecutorServiceParallel...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/53 [BEAM-22] Add ExecutorServiceParallelExecutor as an InProcessExecutor This is responsible for scheduling transform evaluations and communicating results back to the evaluation context. The

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[1/2] incubator-beam git commit: Fix versions and artifact names in runner poms

Repository: incubator-beam Updated Branches: refs/heads/master a91e11500 -> a13dd2910 Fix versions and artifact names in runner poms Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c168533e Tree:

[GitHub] incubator-beam pull request: Fix versions and artifact names in ru...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/51 --- 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

Build failed in Jenkins: beam_MavenVerify #9

See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu ubuntu ubuntu-us golang-ppa) in workspace

Build failed in Jenkins: beam_MavenVerify #8

See Changes: [dhalperi] Update README.md : Fixing Streaming 101 and 102 links [dhalperi] Implement InProcessEvaluationContext [ansela] [BEAM-11] Spark runner directory structure and pom setup. [ansela] [BEAM-11] set coder for pipeline

[19/23] incubator-beam git commit: [BEAM-11] second iteration of package reorganisation

[BEAM-11] second iteration of package reorganisation Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eb0341d4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eb0341d4 Diff:

[jira] [Commented] (BEAM-11) Integrate Spark runner with Beam

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

[15/23] incubator-beam git commit: [BEAM-11] second iteration of package reorganisation

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/eb0341d4/runners/spark/src/test/java/org/apache/beam/runners/spark/streaming/KafkaStreamingTest.java -- diff --git

[18/23] incubator-beam git commit: [BEAM-11] second iteration of package reorganisation

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/eb0341d4/runners/spark/src/main/java/org/apache/beam/runners/spark/TransformTranslator.java -- diff --git

[12/23] incubator-beam git commit: [BEAM-11] Add Spark runner to runners module

[BEAM-11] Add Spark runner to runners module Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bde9933d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bde9933d Diff:

[13/23] incubator-beam git commit: [BEAM-11] add Spark runner to included runners

[BEAM-11] add Spark runner to included runners Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b49e3c95 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b49e3c95 Diff:

[21/23] incubator-beam git commit: [BEAM-11] Replaced license headers to ASF license

[BEAM-11] Replaced license headers to ASF license Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6ef36411 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6ef36411 Diff:

[17/23] incubator-beam git commit: [BEAM-11] second iteration of package reorganisation

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/eb0341d4/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java -- diff --git

[05/23] incubator-beam git commit: [BEAM-11] Spark runner directory structure and pom setup.

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/41c4ca6a/runners/spark/src/test/java/com/cloudera/dataflow/spark/NumShardsTest.java -- diff --git

[06/23] incubator-beam git commit: [BEAM-11] Spark runner directory structure and pom setup.

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/41c4ca6a/runners/spark/src/main/java/org/apache/beam/runners/spark/io/hadoop/ShardNameTemplateHelper.java -- diff --git

[11/23] incubator-beam git commit: [BEAM-11] Spark runner directory structure and pom setup.

[BEAM-11] Spark runner directory structure and pom setup. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/41c4ca6a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/41c4ca6a Diff:

[10/23] incubator-beam git commit: [BEAM-11] Spark runner directory structure and pom setup.

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/41c4ca6a/runners/spark/src/main/java/com/cloudera/dataflow/spark/ShardNameTemplateHelper.java -- diff --git

[14/23] incubator-beam git commit: [BEAM-11] relocate Guava used by Dataflow (v19) since it conflicts with version used by Hadoop (v11)

[BEAM-11] relocate Guava used by Dataflow (v19) since it conflicts with version used by Hadoop (v11) Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/95ebf890 Tree:

[2/3] incubator-beam git commit: Implement InProcessEvaluationContext

Implement InProcessEvaluationContext This is the primary "global state" object for the evaluation of a Pipeline using the InProcessPipelineRunner, and is responsible for properly routing information about the state of the pipeline to transform evaluators. Remove the InProcessEvaluationContext

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: Update README.md : Fixing Streaming 1...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/50 --- 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

[1/2] incubator-beam git commit: Update README.md : Fixing Streaming 101 and 102 links

Repository: incubator-beam Updated Branches: refs/heads/master 071e4dd67 -> 7f9270ee2 Update README.md : Fixing Streaming 101 and 102 links Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7644e918 Tree:

[09/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java -- diff --git

[03/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SourceInputFormat.java -- diff --git

[07/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/WordCountJoin2ITCase.java -- diff --git

[10/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkMultiOutputDoFnFunction.java -- diff --git

[05/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/src/main/java/org/apache/beam/runners/flink/io/ConsoleIO.java -- diff --git

[12/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/pom.xml -- diff --git a/runners/flink/pom.xml b/runners/flink/pom.xml index c8c5d84..31713cd 100644 --- a/runners/flink/pom.xml +++

[06/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java -- diff --git

[04/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java -- diff --git

[11/13] incubator-beam git commit: [flink] restructure and cleanup Maven layout

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/071e4dd6/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java -- diff --git

[GitHub] incubator-beam pull request: Update README.md : Fixing Streaming 1...

GitHub user Xrampino opened a pull request: https://github.com/apache/incubator-beam/pull/50 Update README.md : Fixing Streaming 101 and 102 links You can merge this pull request into a Git repository by running: $ git pull https://github.com/Xrampino/incubator-beam patch-1