Re: Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #462

[Dan Halperin]

Looks like this was a transient failure in GCS (expected on occasion) that
could/would have been resolved when the work item was retried. However, it
looks like the test framework canceled the pipeline before that task was
retried. Is this the desired behavior?

Thanks,
Dan

On Wed, Jun 1, 2016 at 7:24 PM, Apache Jenkins Server <
jenk...@builds.apache.org> wrote:

> See <
> https://builds.apache.org/job/beam_PostCommit_RunnableOnService_GoogleCloudDataflow/462/changes
> >
>
>

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #462

[Apache Jenkins Server]

See 

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Parent #547

[Apache Jenkins Server]

See 

Jenkins build is back to normal : beam_PostCommit_MavenVerify #547

[Apache Jenkins Server]

See 

[2/3] incubator-beam git commit: Use Structural Value keys instead of User Values

[dhalperi]

Use Structural Value keys instead of User Values

This fixes problems with lookup by basing entirely on structural
equality.


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e3cc4fa4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e3cc4fa4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e3cc4fa4

Branch: refs/heads/master
Commit: e3cc4fa4724625f49e3e6690e878a4713615b2e1
Parents: b9a8cbe
Author: Thomas Groh 
Authored: Wed Jun 1 14:28:18 2016 -0700
Committer: Dan Halperin 
Committed: Wed Jun 1 17:56:29 2016 -0700

--
 .../beam/runners/direct/BundleFactory.java  |  4 +-
 .../direct/ExecutorServiceParallelExecutor.java |  8 +-
 .../ImmutabilityCheckingBundleFactory.java  |  4 +-
 .../direct/InMemoryWatermarkManager.java| 70 ---
 .../runners/direct/InProcessBundleFactory.java  | 25 +++---
 .../direct/InProcessEvaluationContext.java  | 10 +--
 .../direct/InProcessExecutionContext.java   |  4 +-
 ...InProcessGroupByKeyOnlyEvaluatorFactory.java |  6 +-
 .../runners/direct/InProcessPipelineRunner.java |  7 +-
 .../apache/beam/runners/direct/StepAndKey.java  |  8 +-
 .../beam/runners/direct/StructuralKey.java  | 77 
 .../direct/GroupByKeyEvaluatorFactoryTest.java  | 27 --
 .../ImmutabilityCheckingBundleFactoryTest.java  | 13 ++-
 .../direct/InMemoryWatermarkManagerTest.java| 95 +++-
 .../direct/InProcessBundleFactoryTest.java  | 54 ++-
 .../direct/InProcessEvaluationContextTest.java  | 52 ++-
 ...ocessGroupByKeyOnlyEvaluatorFactoryTest.java | 33 ---
 .../direct/InProcessPipelineRunnerTest.java | 60 +
 .../direct/InProcessTimerInternalsTest.java |  3 +-
 .../direct/ParDoInProcessEvaluatorTest.java |  2 +-
 .../direct/ParDoMultiEvaluatorFactoryTest.java  | 29 +++---
 .../direct/ParDoSingleEvaluatorFactoryTest.java | 35 +---
 .../beam/runners/direct/StructuralKeyTest.java  | 81 +
 23 files changed, 500 insertions(+), 207 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e3cc4fa4/runners/direct-java/src/main/java/org/apache/beam/runners/direct/BundleFactory.java
--
diff --git 
a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/BundleFactory.java
 
b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/BundleFactory.java
index fea4841..a0511df 100644
--- 
a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/BundleFactory.java
+++ 
b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/BundleFactory.java
@@ -44,6 +44,6 @@ public interface BundleFactory {
* {@link InProcessGroupByKeyOnly} {@link PTransform PTransforms}. Elements 
added to the bundle
* belong to the {@code output} {@link PCollection}.
*/
-  public  UncommittedBundle createKeyedBundle(
-  CommittedBundle input, Object key, PCollection output);
+  public  UncommittedBundle createKeyedBundle(
+  CommittedBundle input, StructuralKey key, PCollection output);
 }

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e3cc4fa4/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
--
diff --git 
a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
 
b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
index 70a8035..a627125 100644
--- 
a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
+++ 
b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
@@ -396,17 +396,19 @@ final class ExecutorServiceParallelExecutor implements 
InProcessExecutor {
 private boolean fireTimers() throws Exception {
   try {
 boolean firedTimers = false;
-for (Map.Entry> 
transformTimers :
+for (Map.Entry<
+   AppliedPTransform, Map> 
transformTimers :
 evaluationContext.extractFiredTimers().entrySet()) {
   AppliedPTransform transform = transformTimers.getKey();
-  for (Map.Entry keyTimers : 
transformTimers.getValue().entrySet()) {
+  for (Map.Entry keyTimers :
+  transformTimers.getValue().entrySet()) {
 for (TimeDomain domain : TimeDomain.values()) {
   Collection delivery = 
keyTimers.getValue().getTimers(domain);

[3/3] incubator-beam git commit: Closes #411

[dhalperi]

Closes #411


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1da797d8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1da797d8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1da797d8

Branch: refs/heads/master
Commit: 1da797d8f5dfae73cd7574c2d388e9ba3317a839
Parents: b9a8cbe e3cc4fa
Author: Dan Halperin 
Authored: Wed Jun 1 17:56:38 2016 -0700
Committer: Dan Halperin 
Committed: Wed Jun 1 17:56:38 2016 -0700

--
 .../beam/runners/direct/BundleFactory.java  |  4 +-
 .../direct/ExecutorServiceParallelExecutor.java |  8 +-
 .../ImmutabilityCheckingBundleFactory.java  |  4 +-
 .../direct/InMemoryWatermarkManager.java| 70 ---
 .../runners/direct/InProcessBundleFactory.java  | 25 +++---
 .../direct/InProcessEvaluationContext.java  | 10 +--
 .../direct/InProcessExecutionContext.java   |  4 +-
 ...InProcessGroupByKeyOnlyEvaluatorFactory.java |  6 +-
 .../runners/direct/InProcessPipelineRunner.java |  7 +-
 .../apache/beam/runners/direct/StepAndKey.java  |  8 +-
 .../beam/runners/direct/StructuralKey.java  | 77 
 .../direct/GroupByKeyEvaluatorFactoryTest.java  | 27 --
 .../ImmutabilityCheckingBundleFactoryTest.java  | 13 ++-
 .../direct/InMemoryWatermarkManagerTest.java| 95 +++-
 .../direct/InProcessBundleFactoryTest.java  | 54 ++-
 .../direct/InProcessEvaluationContextTest.java  | 52 ++-
 ...ocessGroupByKeyOnlyEvaluatorFactoryTest.java | 33 ---
 .../direct/InProcessPipelineRunnerTest.java | 60 +
 .../direct/InProcessTimerInternalsTest.java |  3 +-
 .../direct/ParDoInProcessEvaluatorTest.java |  2 +-
 .../direct/ParDoMultiEvaluatorFactoryTest.java  | 29 +++---
 .../direct/ParDoSingleEvaluatorFactoryTest.java | 35 +---
 .../beam/runners/direct/StructuralKeyTest.java  | 81 +
 23 files changed, 500 insertions(+), 207 deletions(-)
--

[jira] [Commented] (BEAM-323) The InProcessPipelineRunner uses user objects for State and Timer lookups

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311520#comment-15311520
 ] 

ASF GitHub Bot commented on BEAM-323:
-

Github user asfgit closed the pull request at:

https://github.com/apache/incubator-beam/pull/411


> The InProcessPipelineRunner uses user objects for State and Timer lookups
> -
>
> Key: BEAM-323
> URL: https://issues.apache.org/jira/browse/BEAM-323
> Project: Beam
>  Issue Type: Bug
>  Components: runner-direct
>Reporter: Thomas Groh
>Assignee: Thomas Groh
>Priority: Critical
>
> The runner keys state based on the user key that it was grouped by, instead 
> of the structural value of that key. This causes callbacks to be updated 
> based on java equality, so an object with a poor equals can cause the 
> Pipeline to not progress.
> Initially uncovered in https://github.com/apache/incubator-beam/pull/409



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[GitHub] incubator-beam pull request #411: [BEAM-323] In the InProcessPipelineRunner,...

[asfgit]

Github user asfgit closed the pull request at:

https://github.com/apache/incubator-beam/pull/411


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[1/3] incubator-beam git commit: Use Structural Value keys instead of User Values

[dhalperi]

Repository: incubator-beam
Updated Branches:
  refs/heads/master b9a8cbeff -> 1da797d8f


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e3cc4fa4/runners/direct-java/src/test/java/org/apache/beam/runners/direct/StructuralKeyTest.java
--
diff --git 
a/runners/direct-java/src/test/java/org/apache/beam/runners/direct/StructuralKeyTest.java
 
b/runners/direct-java/src/test/java/org/apache/beam/runners/direct/StructuralKeyTest.java
new file mode 100644
index 000..26514f0
--- /dev/null
+++ 
b/runners/direct-java/src/test/java/org/apache/beam/runners/direct/StructuralKeyTest.java
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.beam.runners.direct;
+
+import static org.hamcrest.Matchers.equalTo;
+import static org.hamcrest.Matchers.not;
+import static org.hamcrest.Matchers.theInstance;
+import static org.junit.Assert.assertArrayEquals;
+import static org.junit.Assert.assertThat;
+
+import org.apache.beam.sdk.coders.ByteArrayCoder;
+import org.apache.beam.sdk.coders.StringUtf8Coder;
+import org.apache.beam.sdk.coders.VarIntCoder;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
+
+/**
+ * Tests for {@link StructuralKey}.
+ */
+@RunWith(JUnit4.class)
+public class StructuralKeyTest {
+  @Test
+  public void getKeyEqualToOldKey() {
+assertThat(StructuralKey.of(1234, VarIntCoder.of()).getKey(), 
equalTo(1234));
+assertThat(StructuralKey.of("foobar", StringUtf8Coder.of()).getKey(), 
equalTo("foobar"));
+assertArrayEquals(StructuralKey.of(new byte[] {2, 9, -22}, 
ByteArrayCoder.of()).getKey(),
+new byte[] {2, 9, -22});
+  }
+
+  @Test
+  public void getKeyNotSameInstance() {
+byte[] original = new byte[] {1, 4, 9, 127, -22};
+StructuralKey key = StructuralKey.of(original, 
ByteArrayCoder.of());
+
+assertThat(key.getKey(), not(theInstance(original)));
+  }
+
+  @Test
+  public void objectEqualsTrueKeyEquals() {
+StructuralKey original = StructuralKey.of(1234, VarIntCoder.of());
+assertThat(StructuralKey.of(1234, VarIntCoder.of()), equalTo(original));
+  }
+
+  @Test
+  public void objectsNotEqualEncodingsEqualEquals() {
+byte[] original = new byte[] {1, 4, 9, 127, -22};
+StructuralKey key = StructuralKey.of(original, 
ByteArrayCoder.of());
+
+StructuralKey otherKey =
+StructuralKey.of(new byte[] {1, 4, 9, 127, -22}, ByteArrayCoder.of());
+assertThat(key, equalTo(otherKey));
+  }
+
+  @Test
+  public void notEqualEncodingsEqual() {
+byte[] original = new byte[] {1, 4, 9, 127, -22};
+StructuralKey key = StructuralKey.of(original, 
ByteArrayCoder.of());
+
+StructuralKey otherKey =
+StructuralKey.of(new byte[] {9, -128, 22}, ByteArrayCoder.of());
+assertThat(key, not(equalTo(otherKey)));
+  }
+}

[jira] [Created] (BEAM-323) The InProcessPipelineRunner uses user objects for State and Timer lookups

[Thomas Groh (JIRA)]

Thomas Groh created BEAM-323:


 Summary: The InProcessPipelineRunner uses user objects for State 
and Timer lookups
 Key: BEAM-323
 URL: https://issues.apache.org/jira/browse/BEAM-323
 Project: Beam
  Issue Type: Bug
  Components: runner-direct
Reporter: Thomas Groh
Assignee: Thomas Groh
Priority: Critical


The runner keys state based on the user key that it was grouped by, instead of 
the structural value of that key. This causes callbacks to be updated based on 
java equality, so an object with a poor equals can cause the Pipeline to not 
progress.

Initially uncovered in https://github.com/apache/incubator-beam/pull/409



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

incubator-beam git commit: [maven-release-plugin] prepare for next development iteration

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0-incubating 36084fad2 -> d6a3baa3b


[maven-release-plugin] prepare for next development iteration


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d6a3baa3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d6a3baa3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d6a3baa3

Branch: refs/heads/release-0.1.0-incubating
Commit: d6a3baa3b6045d288fc7408c1c2d0df24da58cba
Parents: 36084fa
Author: Davor Bonaci 
Authored: Wed Jun 1 16:05:25 2016 -0700
Committer: Davor Bonaci 
Committed: Wed Jun 1 16:05:25 2016 -0700

--
 examples/java/pom.xml   | 2 +-
 examples/java8/pom.xml  | 2 +-
 examples/pom.xml| 2 +-
 pom.xml | 4 ++--
 runners/core-java/pom.xml   | 2 +-
 runners/direct-java/pom.xml | 2 +-
 runners/flink/examples/pom.xml  | 2 +-
 runners/flink/pom.xml   | 4 ++--
 runners/flink/runner/pom.xml| 2 +-
 runners/google-cloud-dataflow-java/pom.xml  | 2 +-
 runners/pom.xml | 2 +-
 runners/spark/pom.xml   | 2 +-
 sdks/java/build-tools/pom.xml   | 2 +-
 sdks/java/core/pom.xml  | 2 +-
 sdks/java/extensions/join-library/pom.xml   | 2 +-
 sdks/java/extensions/pom.xml| 2 +-
 sdks/java/io/google-cloud-platform/pom.xml  | 2 +-
 sdks/java/io/hdfs/pom.xml   | 2 +-
 sdks/java/io/kafka/pom.xml  | 2 +-
 sdks/java/io/pom.xml| 2 +-
 sdks/java/java8tests/pom.xml| 2 +-
 sdks/java/maven-archetypes/examples/pom.xml | 2 +-
 sdks/java/maven-archetypes/pom.xml  | 2 +-
 sdks/java/maven-archetypes/starter/pom.xml  | 2 +-
 sdks/java/pom.xml   | 2 +-
 sdks/pom.xml| 2 +-
 26 files changed, 28 insertions(+), 28 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d6a3baa3/examples/java/pom.xml
--
diff --git a/examples/java/pom.xml b/examples/java/pom.xml
index 66d7564..351e0a1 100644
--- a/examples/java/pom.xml
+++ b/examples/java/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating
+0.1.0-incubating-SNAPSHOT
 ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d6a3baa3/examples/java8/pom.xml
--
diff --git a/examples/java8/pom.xml b/examples/java8/pom.xml
index 1e42382..c3073b3 100644
--- a/examples/java8/pom.xml
+++ b/examples/java8/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating
+0.1.0-incubating-SNAPSHOT
 ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d6a3baa3/examples/pom.xml
--
diff --git a/examples/pom.xml b/examples/pom.xml
index 15344f9..3657564 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating
+0.1.0-incubating-SNAPSHOT
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d6a3baa3/pom.xml
--
diff --git a/pom.xml b/pom.xml
index e13aec2..4b209bf 100644
--- a/pom.xml
+++ b/pom.xml
@@ -34,7 +34,7 @@
   http://beam.incubator.apache.org
   2016
 
-  0.1.0-incubating
+  0.1.0-incubating-SNAPSHOT
 
   
 
@@ -48,7 +48,7 @@
 
scm:git:https://git-wip-us.apache.org/repos/asf/incubator-beam.git
 
scm:git:https://git-wip-us.apache.org/repos/asf/incubator-beam.git
 
https://git-wip-us.apache.org/repos/asf?p=incubator-beam.git;a=summary
-v0.1.0-incubating-RC1
+release-0.1.0-incubating
   
 
   

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d6a3baa3/runners/core-java/pom.xml
--
diff --git a/runners/core-java/pom.xml b/runners/core-java/pom.xml
index 042286f..2a8f976 100644
--- a/runners/core-java/pom.xml
+++ b/runners/core-java/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam.runners
 parent
-0.1.0-incubating
+0.1.0-incubating-SNAPSHOT
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d6a3baa3/runners/direct-java/pom.xml
--
diff --git a/runners/direct-java/pom.xml b/runners/direct-java/pom.xml
index 2afa3e0..0c4e994 100644
--- 

[incubator-beam] Git Push Summary

[davor]

Repository: incubator-beam
Updated Tags:  refs/tags/0.1.0-incubating-1 [deleted] a5a289b6c

incubator-beam git commit: [maven-release-plugin] prepare release v0.1.0-incubating-RC1

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0-incubating 7b77e13dd -> 36084fad2


[maven-release-plugin] prepare release v0.1.0-incubating-RC1


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/36084fad
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/36084fad
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/36084fad

Branch: refs/heads/release-0.1.0-incubating
Commit: 36084fad22a5c60b24db95e3502122751ffbfaed
Parents: 7b77e13
Author: Davor Bonaci 
Authored: Wed Jun 1 15:47:47 2016 -0700
Committer: Davor Bonaci 
Committed: Wed Jun 1 15:47:47 2016 -0700

--
 examples/java/pom.xml   | 2 +-
 examples/java8/pom.xml  | 2 +-
 examples/pom.xml| 2 +-
 pom.xml | 4 ++--
 runners/core-java/pom.xml   | 2 +-
 runners/direct-java/pom.xml | 2 +-
 runners/flink/examples/pom.xml  | 2 +-
 runners/flink/pom.xml   | 4 ++--
 runners/flink/runner/pom.xml| 2 +-
 runners/google-cloud-dataflow-java/pom.xml  | 2 +-
 runners/pom.xml | 2 +-
 runners/spark/pom.xml   | 2 +-
 sdks/java/build-tools/pom.xml   | 2 +-
 sdks/java/core/pom.xml  | 2 +-
 sdks/java/extensions/join-library/pom.xml   | 2 +-
 sdks/java/extensions/pom.xml| 2 +-
 sdks/java/io/google-cloud-platform/pom.xml  | 2 +-
 sdks/java/io/hdfs/pom.xml   | 2 +-
 sdks/java/io/kafka/pom.xml  | 2 +-
 sdks/java/io/pom.xml| 2 +-
 sdks/java/java8tests/pom.xml| 2 +-
 sdks/java/maven-archetypes/examples/pom.xml | 2 +-
 sdks/java/maven-archetypes/pom.xml  | 2 +-
 sdks/java/maven-archetypes/starter/pom.xml  | 2 +-
 sdks/java/pom.xml   | 2 +-
 sdks/pom.xml| 2 +-
 26 files changed, 28 insertions(+), 28 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/36084fad/examples/java/pom.xml
--
diff --git a/examples/java/pom.xml b/examples/java/pom.xml
index 351e0a1..66d7564 100644
--- a/examples/java/pom.xml
+++ b/examples/java/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating-SNAPSHOT
+0.1.0-incubating
 ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/36084fad/examples/java8/pom.xml
--
diff --git a/examples/java8/pom.xml b/examples/java8/pom.xml
index c3073b3..1e42382 100644
--- a/examples/java8/pom.xml
+++ b/examples/java8/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating-SNAPSHOT
+0.1.0-incubating
 ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/36084fad/examples/pom.xml
--
diff --git a/examples/pom.xml b/examples/pom.xml
index 3657564..15344f9 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating-SNAPSHOT
+0.1.0-incubating
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/36084fad/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 4b209bf..e13aec2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -34,7 +34,7 @@
   http://beam.incubator.apache.org
   2016
 
-  0.1.0-incubating-SNAPSHOT
+  0.1.0-incubating
 
   
 
@@ -48,7 +48,7 @@
 
scm:git:https://git-wip-us.apache.org/repos/asf/incubator-beam.git
 
scm:git:https://git-wip-us.apache.org/repos/asf/incubator-beam.git
 
https://git-wip-us.apache.org/repos/asf?p=incubator-beam.git;a=summary
-release-0.1.0-incubating
+v0.1.0-incubating-RC1
   
 
   

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/36084fad/runners/core-java/pom.xml
--
diff --git a/runners/core-java/pom.xml b/runners/core-java/pom.xml
index 2a8f976..042286f 100644
--- a/runners/core-java/pom.xml
+++ b/runners/core-java/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam.runners
 parent
-0.1.0-incubating-SNAPSHOT
+0.1.0-incubating
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/36084fad/runners/direct-java/pom.xml
--
diff --git a/runners/direct-java/pom.xml b/runners/direct-java/pom.xml
index 0c4e994..2afa3e0 100644
--- 

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Parent #546

[Apache Jenkins Server]

See 


--
[...truncated 2678 lines...]
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 

Build failed in Jenkins: beam_PostCommit_MavenVerify #546

[Apache Jenkins Server]

See 

Changes:

[davor] [maven-release-plugin] prepare for next development iteration

--
[...truncated 2828 lines...]
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/resolver-status.properties
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-javadoc.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 

[incubator-beam] Git Push Summary

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0-incubating [created] 7b77e13dd

incubator-beam git commit: [maven-release-plugin] prepare for next development iteration

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/master 7b77e13dd -> b9a8cbeff


[maven-release-plugin] prepare for next development iteration


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b9a8cbef
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b9a8cbef
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b9a8cbef

Branch: refs/heads/master
Commit: b9a8cbeffc623b4166a0d33da5dd87a0822c76b0
Parents: 7b77e13
Author: Davor Bonaci 
Authored: Wed Jun 1 15:21:41 2016 -0700
Committer: Davor Bonaci 
Committed: Wed Jun 1 15:21:41 2016 -0700

--
 examples/java/pom.xml   | 2 +-
 examples/java8/pom.xml  | 2 +-
 examples/pom.xml| 2 +-
 pom.xml | 2 +-
 runners/core-java/pom.xml   | 2 +-
 runners/direct-java/pom.xml | 2 +-
 runners/flink/examples/pom.xml  | 2 +-
 runners/flink/pom.xml   | 4 ++--
 runners/flink/runner/pom.xml| 2 +-
 runners/google-cloud-dataflow-java/pom.xml  | 2 +-
 runners/pom.xml | 2 +-
 runners/spark/pom.xml   | 2 +-
 sdks/java/build-tools/pom.xml   | 2 +-
 sdks/java/core/pom.xml  | 2 +-
 sdks/java/extensions/join-library/pom.xml   | 2 +-
 sdks/java/extensions/pom.xml| 2 +-
 sdks/java/io/google-cloud-platform/pom.xml  | 2 +-
 sdks/java/io/hdfs/pom.xml   | 2 +-
 sdks/java/io/kafka/pom.xml  | 2 +-
 sdks/java/io/pom.xml| 2 +-
 sdks/java/java8tests/pom.xml| 2 +-
 sdks/java/maven-archetypes/examples/pom.xml | 2 +-
 sdks/java/maven-archetypes/pom.xml  | 2 +-
 sdks/java/maven-archetypes/starter/pom.xml  | 2 +-
 sdks/java/pom.xml   | 2 +-
 sdks/pom.xml| 2 +-
 26 files changed, 27 insertions(+), 27 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b9a8cbef/examples/java/pom.xml
--
diff --git a/examples/java/pom.xml b/examples/java/pom.xml
index 351e0a1..85786a4 100644
--- a/examples/java/pom.xml
+++ b/examples/java/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating-SNAPSHOT
+0.2.0-incubating-SNAPSHOT
 ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b9a8cbef/examples/java8/pom.xml
--
diff --git a/examples/java8/pom.xml b/examples/java8/pom.xml
index c3073b3..75e61d0 100644
--- a/examples/java8/pom.xml
+++ b/examples/java8/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating-SNAPSHOT
+0.2.0-incubating-SNAPSHOT
 ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b9a8cbef/examples/pom.xml
--
diff --git a/examples/pom.xml b/examples/pom.xml
index 3657564..9159dc2 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam
 parent
-0.1.0-incubating-SNAPSHOT
+0.2.0-incubating-SNAPSHOT
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b9a8cbef/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 4b209bf..2a6e584 100644
--- a/pom.xml
+++ b/pom.xml
@@ -34,7 +34,7 @@
   http://beam.incubator.apache.org
   2016
 
-  0.1.0-incubating-SNAPSHOT
+  0.2.0-incubating-SNAPSHOT
 
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b9a8cbef/runners/core-java/pom.xml
--
diff --git a/runners/core-java/pom.xml b/runners/core-java/pom.xml
index 2a8f976..bcc202a 100644
--- a/runners/core-java/pom.xml
+++ b/runners/core-java/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam.runners
 parent
-0.1.0-incubating-SNAPSHOT
+0.2.0-incubating-SNAPSHOT
 ../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b9a8cbef/runners/direct-java/pom.xml
--
diff --git a/runners/direct-java/pom.xml b/runners/direct-java/pom.xml
index 0c4e994..4c8903d 100644
--- a/runners/direct-java/pom.xml
+++ b/runners/direct-java/pom.xml
@@ -22,7 +22,7 @@
   
 org.apache.beam.runners
 parent
-0.1.0-incubating-SNAPSHOT
+0.2.0-incubating-SNAPSHOT
 ../pom.xml
   
 

Jenkins build is back to normal : beam_PostCommit_MavenVerify #545

[Apache Jenkins Server]

See 

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Parent #545

[Apache Jenkins Server]

See 

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Parent #544

[Apache Jenkins Server]

See 


--
[...truncated 2678 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 

Build failed in Jenkins: beam_PostCommit_MavenVerify #544

[Apache Jenkins Server]

See 

Changes:

[davor] Update pom.xml files formatting

--
[...truncated 2828 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/resolver-status.properties
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-javadoc.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 

[incubator-beam] Git Push Summary

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0-incubating [deleted] 70e3f94dc

incubator-beam git commit: [maven-release-plugin] prepare branch release-0.1.0-incubating

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/master 8485272f0 -> 7b77e13dd


[maven-release-plugin] prepare branch release-0.1.0-incubating


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7b77e13d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7b77e13d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7b77e13d

Branch: refs/heads/master
Commit: 7b77e13ddeaef629a52a8074cf872c6fb74e1283
Parents: 8485272
Author: Davor Bonaci 
Authored: Wed Jun 1 14:14:08 2016 -0700
Committer: Davor Bonaci 
Committed: Wed Jun 1 14:14:08 2016 -0700

--
 pom.xml | 1 +
 1 file changed, 1 insertion(+)
--


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7b77e13d/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 7b9f662..4b209bf 100644
--- a/pom.xml
+++ b/pom.xml
@@ -48,6 +48,7 @@
 
scm:git:https://git-wip-us.apache.org/repos/asf/incubator-beam.git
 
scm:git:https://git-wip-us.apache.org/repos/asf/incubator-beam.git
 
https://git-wip-us.apache.org/repos/asf?p=incubator-beam.git;a=summary
+release-0.1.0-incubating
   
 
   

[2/2] incubator-beam git commit: This closes #410

[davor]

This closes #410


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8485272f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8485272f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8485272f

Branch: refs/heads/master
Commit: 8485272f0d073a2228a12a1c5c41d1146b906783
Parents: c772f42 ff8f6bf
Author: Davor Bonaci 
Authored: Wed Jun 1 14:11:23 2016 -0700
Committer: Davor Bonaci 
Committed: Wed Jun 1 14:11:23 2016 -0700

--
 examples/java/pom.xml   | 4 +---
 examples/java8/pom.xml  | 4 +---
 examples/pom.xml| 4 +---
 pom.xml | 6 ++
 runners/core-java/pom.xml   | 4 +---
 runners/direct-java/pom.xml | 4 +---
 runners/flink/examples/pom.xml  | 6 ++
 runners/flink/pom.xml   | 4 +---
 runners/flink/runner/pom.xml| 4 +---
 runners/google-cloud-dataflow-java/pom.xml  | 4 +---
 runners/pom.xml | 4 +---
 runners/spark/pom.xml   | 7 ++-
 sdks/java/build-tools/pom.xml   | 4 +---
 sdks/java/core/pom.xml  | 4 +---
 sdks/java/extensions/join-library/pom.xml   | 4 +---
 sdks/java/extensions/pom.xml| 4 +---
 sdks/java/io/google-cloud-platform/pom.xml  | 4 +---
 sdks/java/io/hdfs/pom.xml   | 4 +---
 sdks/java/io/kafka/pom.xml  | 4 +---
 sdks/java/io/pom.xml| 4 +---
 sdks/java/java8tests/pom.xml| 4 +---
 sdks/java/maven-archetypes/examples/pom.xml | 4 +---
 sdks/java/maven-archetypes/pom.xml  | 4 +---
 sdks/java/maven-archetypes/starter/pom.xml  | 4 +---
 sdks/java/pom.xml   | 4 +---
 sdks/pom.xml| 4 +---
 26 files changed, 29 insertions(+), 82 deletions(-)
--

[GitHub] incubator-beam pull request #410: Update pom.xml files formatting

[asfgit]

Github user asfgit closed the pull request at:

https://github.com/apache/incubator-beam/pull/410


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #458

[Apache Jenkins Server]

See 

[jira] [Commented] (BEAM-320) Provide Beam keyturn binary distributions embedding runners and execution runtime

[Frances Perry (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15311053#comment-15311053
 ] 

Frances Perry commented on BEAM-320:


Ready to use distributions for common usage patterns sounds like a good idea -- 
it will make things much easier for users. 

For the Dataflow Runner, I think Google may prefer to provide a Google-built 
binary distribution based on Beam instead of providing this convenience as part 
of Beam, because for Google Cloud Platform customers, we may want to package in 
a few additional libraries for interacting with other Google Cloud Platform 
services. It doesn't sound right to complicate Beam with those dependencies. 

But I can definitely see there are some that would make sense as part of Beam. 
And in any case, we should make all of these distributions easy to find via 
documentation on the Beam site.

(Also keep in mind, that there will be multiple SDKs, so we likely want to name 
things to include both the runner and the sdk -- beam-java-spark, etc.)

> Provide Beam keyturn binary distributions embedding runners and execution 
> runtime
> -
>
> Key: BEAM-320
> URL: https://issues.apache.org/jira/browse/BEAM-320
> Project: Beam
>  Issue Type: Wish
>  Components: build-system
>Reporter: Jean-Baptiste Onofré
>Assignee: Jean-Baptiste Onofré
>
> Now, the only distribution Beam provides is the source distribution.
> For new users, it could be interesting to have ready-to-use binary 
> distribution embedding the SDK, a specific runner with the backend execution 
> runtime.
> For instance, we could provide:
> - beam-spark-xxx.tar.gz containing SDK, Spark runner, Spark
> - beam-flink-xxx.tar.gz containing SDK, Flink runner, Flink
> Thoughts ?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[GitHub] incubator-beam pull request #410: Update pom.xml files formatting

[davorbonaci]

GitHub user davorbonaci opened a pull request:

https://github.com/apache/incubator-beam/pull/410

Update pom.xml files formatting

This makes it easier to run maven-release-plugin and understand the output. 
Otherwise, the release plugin will make such changes repeatedly in a release 
branch.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/davorbonaci/beam formatting

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/410.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #410


commit 6e0e0a2b7a0d15e8a64950f274ac0eea43a1a1a9
Author: Davor Bonaci 
Date:   2016-06-01T20:13:02Z

Update pom.xml files formatting

This makes it easier to run maven-release-plugin and understand the output. 
Otherwise, the release plugin will make such changes repeatedly in a release 
branch.




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

incubator-beam git commit: [maven-release-plugin] prepare branch release-0.1.0-incubating

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0-incubating [created] 70e3f94dc


[maven-release-plugin] prepare branch release-0.1.0-incubating


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/70e3f94d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/70e3f94d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/70e3f94d

Branch: refs/heads/release-0.1.0-incubating
Commit: 70e3f94dc45cab3f38c4a2b70ebb1329bdc15456
Parents: e9c0d8d
Author: Davor Bonaci 
Authored: Wed Jun 1 13:08:09 2016 -0700
Committer: Davor Bonaci 
Committed: Wed Jun 1 13:08:09 2016 -0700

--
 examples/java/pom.xml   | 4 +---
 examples/java8/pom.xml  | 4 +---
 examples/pom.xml| 4 +---
 pom.xml | 7 +++
 runners/core-java/pom.xml   | 4 +---
 runners/direct-java/pom.xml | 4 +---
 runners/flink/examples/pom.xml  | 6 ++
 runners/flink/pom.xml   | 4 +---
 runners/flink/runner/pom.xml| 4 +---
 runners/google-cloud-dataflow-java/pom.xml  | 4 +---
 runners/pom.xml | 4 +---
 runners/spark/pom.xml   | 7 ++-
 sdks/java/build-tools/pom.xml   | 4 +---
 sdks/java/core/pom.xml  | 4 +---
 sdks/java/extensions/join-library/pom.xml   | 4 +---
 sdks/java/extensions/pom.xml| 4 +---
 sdks/java/io/google-cloud-platform/pom.xml  | 4 +---
 sdks/java/io/hdfs/pom.xml   | 4 +---
 sdks/java/io/kafka/pom.xml  | 4 +---
 sdks/java/io/pom.xml| 4 +---
 sdks/java/java8tests/pom.xml| 4 +---
 sdks/java/maven-archetypes/examples/pom.xml | 4 +---
 sdks/java/maven-archetypes/pom.xml  | 4 +---
 sdks/java/maven-archetypes/starter/pom.xml  | 4 +---
 sdks/java/pom.xml   | 4 +---
 sdks/pom.xml| 4 +---
 26 files changed, 30 insertions(+), 82 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/70e3f94d/examples/java/pom.xml
--
diff --git a/examples/java/pom.xml b/examples/java/pom.xml
index eb77c88..351e0a1 100644
--- a/examples/java/pom.xml
+++ b/examples/java/pom.xml
@@ -15,9 +15,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 -->
-http://maven.apache.org/POM/4.0.0;
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
+http://maven.apache.org/POM/4.0.0; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; 
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
 
   4.0.0
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/70e3f94d/examples/java8/pom.xml
--
diff --git a/examples/java8/pom.xml b/examples/java8/pom.xml
index b082092..c3073b3 100644
--- a/examples/java8/pom.xml
+++ b/examples/java8/pom.xml
@@ -15,9 +15,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 -->
-http://maven.apache.org/POM/4.0.0;
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
+http://maven.apache.org/POM/4.0.0; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; 
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
 
   4.0.0
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/70e3f94d/examples/pom.xml
--
diff --git a/examples/pom.xml b/examples/pom.xml
index 26b6720..3657564 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -15,9 +15,7 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 -->
-http://maven.apache.org/POM/4.0.0;
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
+http://maven.apache.org/POM/4.0.0; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; 
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
 
   4.0.0
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/70e3f94d/pom.xml

[incubator-beam] Git Push Summary

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0 [deleted] 0b669a5f3

Build failed in Jenkins: beam_PostCommit_MavenVerify #543

[Apache Jenkins Server]

See 

Changes:

[bchambers] Forward port changes to GC holds

--
[...truncated 2828 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/resolver-status.properties
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-javadoc.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Parent #543

[Apache Jenkins Server]

See 


--
[...truncated 2678 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 

[GitHub] incubator-beam pull request #407: [BEAM-122] Forward port changes to backpor...

[asfgit]

Github user asfgit closed the pull request at:

https://github.com/apache/incubator-beam/pull/407


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #457

[Apache Jenkins Server]

See 

Build failed in Jenkins: beam_PostCommit_MavenVerify #542

[Apache Jenkins Server]

See 

--
[...truncated 2829 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/resolver-status.properties
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-javadoc.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/maven-metadata-local.xml
 longer than 100 

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Parent #542

[Apache Jenkins Server]

See 


--
[...truncated 2678 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 

[jira] [Closed] (BEAM-299) MergingActiveWindowSet does not preserve invariants across persist/restore

[Mark Shields (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Mark Shields closed BEAM-299.
-
Resolution: Fixed

> MergingActiveWindowSet does not preserve invariants across persist/restore
> --
>
> Key: BEAM-299
> URL: https://issues.apache.org/jira/browse/BEAM-299
> Project: Beam
>  Issue Type: Bug
>  Components: runner-core
>Reporter: Mark Shields
>Assignee: Mark Shields
>
> Can cause a check fail on --update with Sessions windows.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

incubator-beam git commit: [maven-release-plugin] prepare release 0.1.0-incubating-1

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0 e9c0d8d05 -> 0b669a5f3


[maven-release-plugin] prepare release 0.1.0-incubating-1


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0b669a5f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0b669a5f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0b669a5f

Branch: refs/heads/release-0.1.0
Commit: 0b669a5f3efb39cb3ff8143086c3248bad14f012
Parents: e9c0d8d
Author: Davor Bonaci 
Authored: Wed Jun 1 10:12:04 2016 -0700
Committer: Davor Bonaci 
Committed: Wed Jun 1 10:12:04 2016 -0700

--
 examples/java/pom.xml   | 6 ++
 examples/java8/pom.xml  | 6 ++
 examples/pom.xml| 6 ++
 pom.xml | 9 -
 runners/core-java/pom.xml   | 6 ++
 runners/direct-java/pom.xml | 6 ++
 runners/flink/examples/pom.xml  | 8 +++-
 runners/flink/pom.xml   | 8 +++-
 runners/flink/runner/pom.xml| 6 ++
 runners/google-cloud-dataflow-java/pom.xml  | 6 ++
 runners/pom.xml | 6 ++
 runners/spark/pom.xml   | 9 +++--
 sdks/java/build-tools/pom.xml   | 6 ++
 sdks/java/core/pom.xml  | 6 ++
 sdks/java/extensions/join-library/pom.xml   | 6 ++
 sdks/java/extensions/pom.xml| 6 ++
 sdks/java/io/google-cloud-platform/pom.xml  | 6 ++
 sdks/java/io/hdfs/pom.xml   | 6 ++
 sdks/java/io/kafka/pom.xml  | 6 ++
 sdks/java/io/pom.xml| 6 ++
 sdks/java/java8tests/pom.xml| 6 ++
 sdks/java/maven-archetypes/examples/pom.xml | 6 ++
 sdks/java/maven-archetypes/pom.xml  | 6 ++
 sdks/java/maven-archetypes/starter/pom.xml  | 6 ++
 sdks/java/pom.xml   | 6 ++
 sdks/pom.xml| 6 ++
 26 files changed, 57 insertions(+), 109 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0b669a5f/examples/java/pom.xml
--
diff --git a/examples/java/pom.xml b/examples/java/pom.xml
index eb77c88..66d7564 100644
--- a/examples/java/pom.xml
+++ b/examples/java/pom.xml
@@ -15,16 +15,14 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 -->
-http://maven.apache.org/POM/4.0.0;
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
+http://maven.apache.org/POM/4.0.0; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; 
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
 
   4.0.0
 
   
 org.apache.beam
 parent
-0.1.0-incubating-SNAPSHOT
+0.1.0-incubating
 ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0b669a5f/examples/java8/pom.xml
--
diff --git a/examples/java8/pom.xml b/examples/java8/pom.xml
index b082092..1e42382 100644
--- a/examples/java8/pom.xml
+++ b/examples/java8/pom.xml
@@ -15,16 +15,14 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 -->
-http://maven.apache.org/POM/4.0.0;
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
+http://maven.apache.org/POM/4.0.0; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; 
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
 
   4.0.0
 
   
 org.apache.beam
 parent
-0.1.0-incubating-SNAPSHOT
+0.1.0-incubating
 ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0b669a5f/examples/pom.xml
--
diff --git a/examples/pom.xml b/examples/pom.xml
index 26b6720..15344f9 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -15,16 +15,14 @@
 See the License for the specific language governing permissions and
 limitations under the License.
 -->
-http://maven.apache.org/POM/4.0.0;
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
+http://maven.apache.org/POM/4.0.0; 

[incubator-beam] Git Push Summary

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0 [created] e9c0d8d05

[jira] [Commented] (BEAM-287) Add new beam groupIds

[JIRA]

[ 
https://issues.apache.org/jira/browse/BEAM-287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310598#comment-15310598
 ] 

Jean-Baptiste Onofré commented on BEAM-287:
---

Davor asked me to change this for two reasons:
- if it's maybe easier to use search.maven.org, it means that the direct 
browsing of the Maven repo is not so easy. That's why groupId have been created.
- it gives a better isolation IMHO
- it's not because other projects use an unique groupId that it's the best 
approach. Other projects use different groupIds. For instance, in Camel, Karaf, 
etc, we use several groupIds.

Honestly, either single or several groupIds is fine for me.

> Add new beam groupIds
> -
>
> Key: BEAM-287
> URL: https://issues.apache.org/jira/browse/BEAM-287
> Project: Beam
>  Issue Type: Task
>  Components: build-system
>Reporter: Jean-Baptiste Onofré
>Assignee: Jean-Baptiste Onofré
> Fix For: 0.1.0-incubating
>
>
> Now, all beam modules use the same groupId: {{org.apache.beam}}.
> If it's convenient when using {{search.maven.org}}, browsing the repository 
> is not easy as all artifacts are in the same location.
> As proposed initially, I will introduce new groupIds (like 
> {{org.apache.beam.io}}, {{org.apache.beam.runner}}, etc). We discussed about 
> that with [~davor] last week.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[incubator-beam] Git Push Summary

[davor]

Repository: incubator-beam
Updated Branches:
  refs/heads/release-0.1.0-incubating [deleted] 962d8da06

[jira] [Commented] (BEAM-321) Hash encoded keys in Flink batch mode

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310556#comment-15310556
 ] 

ASF GitHub Bot commented on BEAM-321:
-

GitHub user aljoscha opened a pull request:

https://github.com/apache/incubator-beam/pull/409

[BEAM-321] Fix Flink Comparators

`KvCoderComparator` and `CoderComparator` were hashing the key directly
while doing comparisons on the encoded form. This lead to
inconsistencies in GroupByKey results with large numbers of elements per
key.

This changes the comparators to hash on the encoded form and also adds a
test case to verify correct behavior. 

I made the test a `RunnableOnService` test that verifies that runners use 
the encoded form of a value for hashing/comparison. In the test, I use a bogus 
key that returns garbage from `equals()` and `hashCode()`. The result of the 
test is correct if only the encoded form is used for hashing/comparison.

R: @tgroh for the test, do you think there's a better way of doing it?
CC: @tgroh the newly introduced test hangs on the 
`InProcessPipelineRunner`, see `InProcessGroupByKeyTest` that I added for 
quickly checking this
CC: @francesperry is this new test in line with the Beam model

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/aljoscha/incubator-beam flink/fix-comparator

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/409.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #409


commit 8b269b542032c887ea149c50245de8d07a94fd51
Author: Aljoscha Krettek 
Date:   2016-06-01T09:56:18Z

[BEAM-321] Fix Flink Comparators

KvCoderComparator and CoderComparator were hashing the key directly
while doing comparisons on the encoded form. This lead to
inconsistencies in GroupByKey results with large numbers of elements per
key.

This changes the comparators to hash on the encoded form and also adds a
test case to verify correct behavior.

commit 6866fd740af07a214ef5a9be39983260878ecb8d
Author: Aljoscha Krettek 
Date:   2016-06-01T09:58:48Z

Fix typo in KvCoderComperator, is now KvCoderComparator

commit 6334b87ef3d2a90c540cf89aadab013dcded1483
Author: Aljoscha Krettek 
Date:   2016-06-01T15:54:37Z

move to RunnableOnService test

commit 85defbc67323e10a87835d2514f45ad238e47842
Author: Aljoscha Krettek 
Date:   2016-06-01T16:14:51Z

make test class package private




> Hash encoded keys in Flink batch mode
> -
>
> Key: BEAM-321
> URL: https://issues.apache.org/jira/browse/BEAM-321
> Project: Beam
>  Issue Type: Sub-task
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Maximilian Michels
>Assignee: Aljoscha Krettek
> Fix For: 0.1.0-incubating
>
>
> Right now, hashing of keys happens on the value itself not on the encoded 
> representation. This is at odds with the Beam specification and can lead to 
> incorrect results.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[GitHub] incubator-beam pull request #409: [BEAM-321] Fix Flink Comparators

[aljoscha]

GitHub user aljoscha opened a pull request:

https://github.com/apache/incubator-beam/pull/409

[BEAM-321] Fix Flink Comparators

`KvCoderComparator` and `CoderComparator` were hashing the key directly
while doing comparisons on the encoded form. This lead to
inconsistencies in GroupByKey results with large numbers of elements per
key.

This changes the comparators to hash on the encoded form and also adds a
test case to verify correct behavior. 

I made the test a `RunnableOnService` test that verifies that runners use 
the encoded form of a value for hashing/comparison. In the test, I use a bogus 
key that returns garbage from `equals()` and `hashCode()`. The result of the 
test is correct if only the encoded form is used for hashing/comparison.

R: @tgroh for the test, do you think there's a better way of doing it?
CC: @tgroh the newly introduced test hangs on the 
`InProcessPipelineRunner`, see `InProcessGroupByKeyTest` that I added for 
quickly checking this
CC: @francesperry is this new test in line with the Beam model

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/aljoscha/incubator-beam flink/fix-comparator

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/incubator-beam/pull/409.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #409


commit 8b269b542032c887ea149c50245de8d07a94fd51
Author: Aljoscha Krettek 
Date:   2016-06-01T09:56:18Z

[BEAM-321] Fix Flink Comparators

KvCoderComparator and CoderComparator were hashing the key directly
while doing comparisons on the encoded form. This lead to
inconsistencies in GroupByKey results with large numbers of elements per
key.

This changes the comparators to hash on the encoded form and also adds a
test case to verify correct behavior.

commit 6866fd740af07a214ef5a9be39983260878ecb8d
Author: Aljoscha Krettek 
Date:   2016-06-01T09:58:48Z

Fix typo in KvCoderComperator, is now KvCoderComparator

commit 6334b87ef3d2a90c540cf89aadab013dcded1483
Author: Aljoscha Krettek 
Date:   2016-06-01T15:54:37Z

move to RunnableOnService test

commit 85defbc67323e10a87835d2514f45ad238e47842
Author: Aljoscha Krettek 
Date:   2016-06-01T16:14:51Z

make test class package private




---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[jira] [Commented] (BEAM-287) Add new beam groupIds

[Maximilian Michels (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310445#comment-15310445
 ] 

Maximilian Michels commented on BEAM-287:
-

All Apache big data projects I know of use flat group ids, e.g. 
org.apache.flink, org.apache.spark, org.apache.hadoop, org.apache.zookeeper, 
etc. It makes the discovering Maven modules very easy: 
http://search.maven.org/#search|ga|1|org.apache.hadoop

That's how I imagine people using the Flink Runner:

{noformat}

org.apache.beam
flink-runner

{noformat}

I just sawed, this was already changed in the master (issue is still open and 
PR hasn't been linked here for some reason). So this is how it looks now:

{noformat}

org.apache.beam.runners
flink

{noformat}

I remember that the last discussion we had was in favor of flat groupIds: 
http://mail-archives.apache.org/mod_mbox/beam-dev/201603.mbox/%3c56e75f8e.1040...@nanthrax.net%3e
 Did I miss any new discussions about that?

> Add new beam groupIds
> -
>
> Key: BEAM-287
> URL: https://issues.apache.org/jira/browse/BEAM-287
> Project: Beam
>  Issue Type: Task
>  Components: build-system
>Reporter: Jean-Baptiste Onofré
>Assignee: Jean-Baptiste Onofré
> Fix For: 0.1.0-incubating
>
>
> Now, all beam modules use the same groupId: {{org.apache.beam}}.
> If it's convenient when using {{search.maven.org}}, browsing the repository 
> is not easy as all artifacts are in the same location.
> As proposed initially, I will introduce new groupIds (like 
> {{org.apache.beam.io}}, {{org.apache.beam.runner}}, etc). We discussed about 
> that with [~davor] last week.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Updated] (BEAM-322) Compare encoded keys in streaming mode

[Aljoscha Krettek (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aljoscha Krettek updated BEAM-322:
--
Description: Right now, hashing of keys happens on the value itself not on 
the encoded representation. This is at odds with the Beam specification and can 
lead to incorrect results.

> Compare encoded keys in streaming mode
> --
>
> Key: BEAM-322
> URL: https://issues.apache.org/jira/browse/BEAM-322
> Project: Beam
>  Issue Type: Sub-task
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Maximilian Michels
> Fix For: 0.1.0-incubating
>
>
> Right now, hashing of keys happens on the value itself not on the encoded 
> representation. This is at odds with the Beam specification and can lead to 
> incorrect results.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Updated] (BEAM-321) Hash encoded keys in Flink batch mode

[Aljoscha Krettek (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aljoscha Krettek updated BEAM-321:
--
Description: Right now, hashing of keys happens on the value itself not on 
the encoded representation. This is at odds with the Beam specification and can 
lead to incorrect results.

> Hash encoded keys in Flink batch mode
> -
>
> Key: BEAM-321
> URL: https://issues.apache.org/jira/browse/BEAM-321
> Project: Beam
>  Issue Type: Sub-task
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Maximilian Michels
>Assignee: Aljoscha Krettek
> Fix For: 0.1.0-incubating
>
>
> Right now, hashing of keys happens on the value itself not on the encoded 
> representation. This is at odds with the Beam specification and can lead to 
> incorrect results.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Updated] (BEAM-321) Hash encoded keys in Flink batch mode

[Aljoscha Krettek (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aljoscha Krettek updated BEAM-321:
--
Summary: Hash encoded keys in Flink batch mode  (was: Compare encoded keys 
in batch mode)

> Hash encoded keys in Flink batch mode
> -
>
> Key: BEAM-321
> URL: https://issues.apache.org/jira/browse/BEAM-321
> Project: Beam
>  Issue Type: Sub-task
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Maximilian Michels
>Assignee: Aljoscha Krettek
> Fix For: 0.1.0-incubating
>
>




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

[Maximilian Michels (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310297#comment-15310297
 ] 

Maximilian Michels commented on BEAM-315:
-

I agree. Nice find [~aljoscha]!

> Flink Runner compares keys unencoded which may produce incorrect results
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (BEAM-321) Compare encoded keys in batch mode

[Maximilian Michels (JIRA)]

Maximilian Michels created BEAM-321:
---

 Summary: Compare encoded keys in batch mode
 Key: BEAM-321
 URL: https://issues.apache.org/jira/browse/BEAM-321
 Project: Beam
  Issue Type: Sub-task
  Components: runner-flink
Affects Versions: 0.1.0-incubating
Reporter: Maximilian Michels
Assignee: Aljoscha Krettek
 Fix For: 0.1.0-incubating






--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (BEAM-322) Compare encoded keys in streaming mode

[Maximilian Michels (JIRA)]

Maximilian Michels created BEAM-322:
---

 Summary: Compare encoded keys in streaming mode
 Key: BEAM-322
 URL: https://issues.apache.org/jira/browse/BEAM-322
 Project: Beam
  Issue Type: Sub-task
  Components: runner-flink
Affects Versions: 0.1.0-incubating
Reporter: Maximilian Michels
 Fix For: 0.1.0-incubating






--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Updated] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

[Maximilian Michels (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Maximilian Michels updated BEAM-315:

Summary: Flink Runner compares keys unencoded which may produce incorrect 
results  (was: Flink Runner compares keys unencoded which may produce incorrect 
results (batch))

> Flink Runner compares keys unencoded which may produce incorrect results
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Updated] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results (batch)

[Maximilian Michels (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Maximilian Michels updated BEAM-315:

Summary: Flink Runner compares keys unencoded which may produce incorrect 
results (batch)  (was: Flink Runner compares keys unencoded which may produce 
incorrect results)

> Flink Runner compares keys unencoded which may produce incorrect results 
> (batch)
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

[Aljoscha Krettek (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310277#comment-15310277
 ] 

Aljoscha Krettek commented on BEAM-315:
---

I think we should make this issue into two issues. Leave this one as an issue 
for batch, I already have a fix for this. Then create a new issue for the 
streaming side, which is a bit more complicated. This way, we can correctly 
track progress.

What do you say [~mxm]?

> Flink Runner compares keys unencoded which may produce incorrect results
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Updated] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

[Maximilian Michels (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Maximilian Michels updated BEAM-315:

Summary: Flink Runner compares keys unencoded which may produce incorrect 
results  (was: GroupByKey/CoGroupByKey doesn't group correctly with 
FlinkPipelineRunner)

> Flink Runner compares keys unencoded which may produce incorrect results
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Updated] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly with FlinkPipelineRunner

[Maximilian Michels (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Maximilian Michels updated BEAM-315:

Summary: GroupByKey/CoGroupByKey doesn't group correctly with 
FlinkPipelineRunner  (was: GroupByKey/CoGroupByKey doesn't group correctly in 
batch mode of FlinkPipelineRunner)

> GroupByKey/CoGroupByKey doesn't group correctly with FlinkPipelineRunner
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Build failed in Jenkins: beam_PostCommit_MavenVerify #541

[Apache Jenkins Server]

See 

--
[...truncated 2828 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/resolver-status.properties
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-javadoc.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Parent #541

[Apache Jenkins Server]

See 


--
[...truncated 2678 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 

Build failed in Jenkins: beam_PostCommit_MavenVerify #540

[Apache Jenkins Server]

See 

Changes:

[aljoscha.krettek] [BEAM-295] Remove erroneous close() calls in Flink Create 
Sources

--
[...truncated 2828 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/0.1.0-incubating-SNAPSHOT/google-cloud-platform-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/google-cloud-platform/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/kafka-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/io/kafka/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/resolver-status.properties
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-javadoc.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-test-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-sources.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT-src.zip
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/google-cloud-dataflow-java-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/0.1.0-incubating-SNAPSHOT/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Parent #540

[Apache Jenkins Server]

See 


--
[...truncated 2678 lines...]
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/flink-core-1.0.0-tests.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-core/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/force-shading/1.0.0/force-shading-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/flink-connector-kafka-base_2.10-1.0.0.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/flink/flink-connector-kafka-base_2.10/1.0.0/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/ant-parent-1.8.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/ant/ant-parent/1.8.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/kafka-clients-0.8.2.1.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.1/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar.sha1
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.1.0-incubating-SNAPSHOT/.repository/org/apache/kafka/kafka-clients/0.8.2.2/_remote.repositories
 longer than 100 characters.
[WARNING] Entry: 

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

[Pawel Szczur (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310079#comment-15310079
 ] 

Pawel Szczur commented on BEAM-315:
---

Of course, feel free to use it. Super happy I could help.

> GroupByKey/CoGroupByKey doesn't group correctly in batch mode of 
> FlinkPipelineRunner
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Comment Edited] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

[Pawel Szczur (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310079#comment-15310079
 ] 

Pawel Szczur edited comment on BEAM-315 at 6/1/16 10:16 AM:


Thanks for quick fix! Of course, feel free to use it. Super happy I could help.


was (Author: pawelszc...@gmail.com):
Of course, feel free to use it. Super happy I could help.

> GroupByKey/CoGroupByKey doesn't group correctly in batch mode of 
> FlinkPipelineRunner
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Resolved] (BEAM-295) Flink Create Functions call Collector.close()

[Aljoscha Krettek (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aljoscha Krettek resolved BEAM-295.
---
   Resolution: Fixed
Fix Version/s: 0.1.0-incubating

> Flink Create Functions call Collector.close()
> -
>
> Key: BEAM-295
> URL: https://issues.apache.org/jira/browse/BEAM-295
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Reporter: Aljoscha Krettek
>Assignee: Aljoscha Krettek
> Fix For: 0.1.0-incubating
>
>
> {{Collector.close()}} should only be called internally, by Flink. Calling 
> close() in the user function, as we do in {{FlinkCreateFunction}} and 
> {{FlinkStreamingCreateFunction}} will lead to downstream operations being 
> closed twice, which can lead to faulty behavior.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Commented] (BEAM-295) Flink Create Functions call Collector.close()

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15310069#comment-15310069
 ] 

ASF GitHub Bot commented on BEAM-295:
-

Github user aljoscha closed the pull request at:

https://github.com/apache/incubator-beam/pull/347


> Flink Create Functions call Collector.close()
> -
>
> Key: BEAM-295
> URL: https://issues.apache.org/jira/browse/BEAM-295
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Reporter: Aljoscha Krettek
>Assignee: Aljoscha Krettek
> Fix For: 0.1.0-incubating
>
>
> {{Collector.close()}} should only be called internally, by Flink. Calling 
> close() in the user function, as we do in {{FlinkCreateFunction}} and 
> {{FlinkStreamingCreateFunction}} will lead to downstream operations being 
> closed twice, which can lead to faulty behavior.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[2/2] incubator-beam git commit: This closes #347

[aljoscha]

This closes #347


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e9c0d8d0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e9c0d8d0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e9c0d8d0

Branch: refs/heads/master
Commit: e9c0d8d056a7ecfba447ea9bfeda4366ff44dcff
Parents: a829d9c 971ea4d
Author: Aljoscha Krettek 
Authored: Wed Jun 1 12:07:07 2016 +0200
Committer: Aljoscha Krettek 
Committed: Wed Jun 1 12:07:07 2016 +0200

--
 .../wrappers/streaming/io/FlinkStreamingCreateFunction.java| 2 --
 1 file changed, 2 deletions(-)
--

[GitHub] incubator-beam pull request: [BEAM-295] Remove erroneous close() calls in Fl...

[aljoscha]

Github user aljoscha closed the pull request at:

https://github.com/apache/incubator-beam/pull/347


---
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 enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[1/2] incubator-beam git commit: [BEAM-295] Remove erroneous close() calls in Flink Create Sources

[aljoscha]

Repository: incubator-beam
Updated Branches:
  refs/heads/master a829d9caf -> e9c0d8d05


[BEAM-295] Remove erroneous close() calls in Flink Create Sources

Collector.close() should only be called by internal Flink components,
not by user functions.


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/971ea4de
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/971ea4de
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/971ea4de

Branch: refs/heads/master
Commit: 971ea4de225f6efdd9ff862a6ff74ed05299f8a4
Parents: a829d9c
Author: Aljoscha Krettek 
Authored: Wed May 18 17:46:34 2016 +0200
Committer: Aljoscha Krettek 
Committed: Wed Jun 1 12:06:43 2016 +0200

--
 .../wrappers/streaming/io/FlinkStreamingCreateFunction.java| 2 --
 1 file changed, 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/971ea4de/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
--
diff --git 
a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
 
b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
index 8cd8351..0d72f65 100644
--- 
a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
+++ 
b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java
@@ -52,7 +52,5 @@ public class FlinkStreamingCreateFunction implements 
FlatMapFunction

[jira] [Commented] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

[Aljoscha Krettek (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309976#comment-15309976
 ] 

Aljoscha Krettek commented on BEAM-315:
---

I played around this morning and finally found the problem thanks to 
[~frances]'s remark.

The problem is that the Flink {{KvCoderComparator}} (this is used to do 
comparisons/hasing for shuffle and sorting) uses the hash of the key instead of 
the hash of the encoded key while using the encoded key for doing comparisons. 
I already fixed it, but I want to include a test for this as well. 
[~pawelszc...@gmail.com], can I include a modified version of your program as a 
test?

> GroupByKey/CoGroupByKey doesn't group correctly in batch mode of 
> FlinkPipelineRunner
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Assigned] (BEAM-315) GroupByKey/CoGroupByKey doesn't group correctly in batch mode of FlinkPipelineRunner

[Aljoscha Krettek (JIRA)]

 [ 
https://issues.apache.org/jira/browse/BEAM-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aljoscha Krettek reassigned BEAM-315:
-

Assignee: Aljoscha Krettek

> GroupByKey/CoGroupByKey doesn't group correctly in batch mode of 
> FlinkPipelineRunner
> 
>
> Key: BEAM-315
> URL: https://issues.apache.org/jira/browse/BEAM-315
> Project: Beam
>  Issue Type: Bug
>  Components: runner-flink
>Affects Versions: 0.1.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java
>
>
> Same keys are processed multiple times.
> A repo to reproduce the bug:
> https://github.com/orian/cogroup-wrong-grouping
> Discussion:
> http://mail-archives.apache.org/mod_mbox/incubator-beam-user/201605.mbox/%3CCAB2uKkG2xHsWpLFUkYnt8eEzdxU%3DB_nu6crTwVi-ZuUpugxkPQ%40mail.gmail.com%3E
> Notice: I haven't tested other runners (didn't manage to configure Spark).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (BEAM-320) Provide Beam keyturn binary distributions embedding runners and execution runtime

[JIRA]

Jean-Baptiste Onofré created BEAM-320:
-

 Summary: Provide Beam keyturn binary distributions embedding 
runners and execution runtime
 Key: BEAM-320
 URL: https://issues.apache.org/jira/browse/BEAM-320
 Project: Beam
  Issue Type: Wish
  Components: build-system
Reporter: Jean-Baptiste Onofré
Assignee: Jean-Baptiste Onofré


Now, the only distribution Beam provides is the source distribution.

For new users, it could be interesting to have ready-to-use binary distribution 
embedding the SDK, a specific runner with the backend execution runtime.

For instance, we could provide:
- beam-spark-xxx.tar.gz containing SDK, Spark runner, Spark
- beam-flink-xxx.tar.gz containing SDK, Flink runner, Flink

Thoughts ?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (BEAM-319) Attach src distribution artifact to be take by deploy

[JIRA]

Jean-Baptiste Onofré created BEAM-319:
-

 Summary: Attach src distribution artifact to be take by deploy
 Key: BEAM-319
 URL: https://issues.apache.org/jira/browse/BEAM-319
 Project: Beam
  Issue Type: Bug
  Components: build-system
Reporter: Jean-Baptiste Onofré
Assignee: Jean-Baptiste Onofré
 Fix For: 0.1.0-incubating






--
This message was sent by Atlassian JIRA
(v6.3.4#6332)