Build failed in Jenkins: beam_PostCommit_MavenVerify #552

2016-06-02 Thread Apache Jenkins Server 
See 

--
[...truncated 2845 lines...]
[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: 
apache-beam-0.2.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.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/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/runners/direct/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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/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/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.

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

2016-06-02 Thread 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:

[GitHub] incubator-beam pull request #414: Move 'travis/' directory into 'testing/tra...

2016-06-02 Thread davorbonaci 
GitHub user davorbonaci opened a pull request:

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

Move 'travis/' directory into 'testing/travis/'

R: @dhalperi 

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

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

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

https://github.com/apache/incubator-beam/pull/414.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 #414


commit 1dd91d9a34f9d4ad7e7f659dc352b15c2f9fced8
Author: Davor Bonaci 
Date:   2016-06-02T22:09:53Z

Move 'travis/' directory into 'testing/travis/'




---
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] [Created] (BEAM-325) Add Slack details to website

2016-06-02 Thread James Malone (JIRA) 
James Malone created BEAM-325:
-

 Summary: Add Slack details to website
 Key: BEAM-325
 URL: https://issues.apache.org/jira/browse/BEAM-325
 Project: Beam
  Issue Type: Improvement
  Components: website
Reporter: James Malone
Assignee: James Malone
Priority: Minor


Need to add details on the public Slack channel to the Beam website.



--
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

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur updated BEAM-315:
--
Affects Version/s: 0.2.0-incubating

> 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, 0.2.0-incubating
>Reporter: Pawel Szczur
>Assignee: Aljoscha Krettek
> Attachments: CoGroupPipelineStringKey.java, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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-318) AvroCoder may be vulnerable to AVRO-607

2016-06-02 Thread Daniel Halperin (JIRA) 

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

Daniel Halperin updated BEAM-318:
-
Description: 
See AVRO-607

The hypothesis is that even though AvroCoder is threadsafe according to Avro's 
javadoc, an underlying bug in Avro library makes thread-unsafe access to a Java 
WeakHashMap. However I have not yet succeeded at reproducing the bug; with some 
failed attempts in the linked GitHub Pull Request history.


  was:
See AVRO-607

The hypothesis is that even though AvroCoder is threadsafe according to Avro's 
javadoc, an underlying bug in AvroCoder makes thread-unsafe access to a Java 
WeakHashMap. However I have not yet succeeded at reproducing the bug; with some 
failed attempts in the linked GitHub Pull Request history.



> AvroCoder may be vulnerable to AVRO-607
> ---
>
> Key: BEAM-318
> URL: https://issues.apache.org/jira/browse/BEAM-318
> Project: Beam
>  Issue Type: Bug
>  Components: sdk-java-core
>Reporter: Daniel Halperin
>Assignee: Daniel Halperin
>
> See AVRO-607
> The hypothesis is that even though AvroCoder is threadsafe according to 
> Avro's javadoc, an underlying bug in Avro library makes thread-unsafe access 
> to a Java WeakHashMap. However I have not yet succeeded at reproducing the 
> bug; with some failed attempts in the linked GitHub Pull Request history.



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

[jira] [Updated] (BEAM-318) AvroCoder may be vulnerable to AVRO-607

2016-06-02 Thread Daniel Halperin (JIRA) 

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

Daniel Halperin updated BEAM-318:
-
Description: 
See AVRO-607

The hypothesis is that even though AvroCoder is threadsafe according to Avro's 
javadoc, an underlying bug in AvroCoder makes thread-unsafe access to a Java 
WeakHashMap. However I have not yet succeeded at reproducing the bug; with some 
failed attempts in the linked GitHub Pull Request history.


  was:
See AVRO-607




> AvroCoder may be vulnerable to AVRO-607
> ---
>
> Key: BEAM-318
> URL: https://issues.apache.org/jira/browse/BEAM-318
> Project: Beam
>  Issue Type: Bug
>  Components: sdk-java-core
>Reporter: Daniel Halperin
>Assignee: Daniel Halperin
>
> See AVRO-607
> The hypothesis is that even though AvroCoder is threadsafe according to 
> Avro's javadoc, an underlying bug in AvroCoder makes thread-unsafe access to 
> a Java WeakHashMap. However I have not yet succeeded at reproducing the bug; 
> with some failed attempts in the linked GitHub Pull Request history.



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

[jira] [Updated] (BEAM-318) AvroCoder may be vulnerable to AVRO-607

2016-06-02 Thread Daniel Halperin (JIRA) 

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

Daniel Halperin updated BEAM-318:
-
Summary: AvroCoder may be vulnerable to AVRO-607  (was: AvroCoder is 
vulnerable to AVRO-607)

> AvroCoder may be vulnerable to AVRO-607
> ---
>
> Key: BEAM-318
> URL: https://issues.apache.org/jira/browse/BEAM-318
> Project: Beam
>  Issue Type: Bug
>  Components: sdk-java-core
>Reporter: Daniel Halperin
>Assignee: Daniel Halperin
>
> See AVRO-607



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

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

2016-06-02 Thread 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 #551

2016-06-02 Thread Apache Jenkins Server 
See 

--
[...truncated 2846 lines...]
[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: 
apache-beam-0.2.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.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/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/runners/direct/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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/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/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/0.1.0-incubating-SNAPSHOT/_remote.repositories
 longer than 100 characters.
[WARNING] Entry:

[GitHub] incubator-beam pull request #412: [DNR] Set TarLongFileMode in the Assembly ...

2016-06-02 Thread tgroh 
GitHub user tgroh opened a pull request:

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

[DNR] Set TarLongFileMode in the Assembly Plugin

Be sure to do all of the following to help us incorporate your contribution
quickly and easily:

 - [ ] Make sure the PR title is formatted like:
   `[BEAM-] Description of pull request`
 - [ ] Make sure tests pass via `mvn clean verify`. (Even better, enable
   Travis-CI on your fork and ensure the whole test matrix passes).
 - [ ] Replace `` in the title with the actual Jira issue
   number, if there is one.
 - [ ] If this contribution is large, please file an Apache
   [Individual Contributor License 
Agreement](https://www.apache.org/licenses/icla.txt).

---

Default TAR files aren't capable of handling long names, and this may be
causing issues with the assembly plugin in jenkins.

THIS IS AN EXPLORATORY CHANGE AND NOT SUITABLE FOR MERGE OR REVIEW AT THE 
CURRENT TIME.



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

$ git pull https://github.com/tgroh/incubator-beam tarLongMode

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

https://github.com/apache/incubator-beam/pull/412.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 #412


commit 75101a734ff3e9d3e0128236e4cf6d12927d087f
Author: Thomas Groh 
Date:   2016-06-02T17:09:13Z

Set TarLongFileMode in the Assembly Plugin

Default TAR files aren't capable of handling long names, and this may be
causing issues with the assembly plugin in jenkins.




---
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] [Comment Edited] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur edited comment on BEAM-315 at 6/2/16 5:04 PM:
---

So, I've started digging into the {{FlinkBatchTransformTranslators}}. The only 
thing I've found: the items leave {{FlinkPartialReduceFunction}} groupped 
correctly (in respect to shard). Then they arrive to {{FlinkReduceFunction}} in 
groups but not all values of a given key at once.

I'm not sure how Flink shuffles/sorts the data. The direction you've looked: 
hashCode/comparator seems good, but I think the bug is outside the 
{{KvCoderComparator}}.



was (Author: pawelszc...@gmail.com):
So, I've started digging into the {{FlinkBatchTransformTranslators}}. The only 
thing I've found: the items leave {{FlinkPartialReduceFunction}} groupped 
correctly. Then they arrive to {{FlinkReduceFunction}} in groups but not all 
values of a given key at once.

I'm not sure how Flink shuffles/sorts the data. The direction you've looked: 
hashCode/comparator seems good, but I think the bug is outside the 
{{KvCoderComparator}}.

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur commented on BEAM-315:
---

So, I've started digging into the {{FlinkBatchTransformTranslators}}. The only 
thing I've found: the items leave {{FlinkPartialReduceFunction}} groupped 
correctly. Then they arrive to {{FlinkReduceFunction}} in groups but not all 
values of a given key at once.

I'm not sure how Flink shuffles/sorts the data. The direction you've looked: 
hashCode/comparator seems good, but I think the bug is outside the 
{{KvCoderComparator}}.

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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

2016-06-02 Thread Aljoscha Krettek (JIRA) 

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

Aljoscha Krettek commented on BEAM-315:
---

Thanks for the updates! I'll keep investigating.

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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-324) Improve TypeDescriptor inference of DoFn's created inside a generic PTransform

2016-06-02 Thread Ben Chambers (JIRA) 
Ben Chambers created BEAM-324:
-

 Summary: Improve TypeDescriptor inference of DoFn's created inside 
a generic PTransform
 Key: BEAM-324
 URL: https://issues.apache.org/jira/browse/BEAM-324
 Project: Beam
  Issue Type: Bug
  Components: beam-model
Reporter: Ben Chambers
Assignee: Frances Perry
Priority: Minor


Commit 
https://github.com/apache/incubator-beam/commit/aa7f07fa5b22f3656d52dc9e1d4557bceb87c013
 introduced the ability to infer a {{TypeDescriptor}} from an object created 
inside a concrete instance of a {{PTransform}} and used it to simplify 
{{SimpleFunction}} usage.

We should probably look at using the same mechanism elsewhere, such as when 
inferring the output type of a {{ParDo}}.



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

[jira] [Updated] (BEAM-261) Apache Apex Runner

2016-06-02 Thread Kenneth Knowles (JIRA) 

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

Kenneth Knowles updated BEAM-261:
-
Assignee: Thomas Weise

> Apache Apex Runner
> --
>
> Key: BEAM-261
> URL: https://issues.apache.org/jira/browse/BEAM-261
> Project: Beam
>  Issue Type: Wish
>  Components: runner-ideas
>Reporter: Suminda Dharmasena
>Assignee: Thomas Weise
>
> Like Spark, Flink and GearPump, Apache Apex also does have advantages. Is it 
> possible to have a runner for Apache Apex?



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

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

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur edited comment on BEAM-315 at 6/2/16 2:20 PM:
---

One more finding: the reproduction of the bug depends on the total size of data 
not number of keys or elements per key. I've just modified the example by 
adding 5KB blob to each item and it fails with considerably smaller number of 
elements. May it be related to a mechanism used for keeping the data off the 
memory.

After taking a look at data it looks weird:
In a given shard there are sub-shards of data. Take a look at 
execution_split_sorted, the columns are: worker, key, number of values.

If you search, you will notice that a pairs of (worker, number of values) 
appear multiple times.


was (Author: pawelszc...@gmail.com):
One more finding: the reproduction of the bug depends on the total size of data 
not number of keys or elements per key. I've just modified the example by 
adding 5KB blob to each item and it fails with considerably smaller number of 
elements. May it be related to a mechanism used for keeping the data off the 
memory.

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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) Flink Runner compares keys unencoded which may produce incorrect results

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur edited comment on BEAM-315 at 6/2/16 1:54 PM:
---

One more finding: the reproduction of the bug depends on the total size of data 
not number of keys or elements per key. I've just modified the example by 
adding 5KB blob to each item and it fails with considerably smaller number of 
elements. May it be related to a mechanism used for keeping the data off the 
memory.


was (Author: pawelszc...@gmail.com):
One more finding: the reproduction of the bug depends on the sum size of data 
not number of keys or elements per key. I've just modified the example by 
adding 5KB blob to each item and it fails with considerably smaller number of 
elements. May it be related to a mechanism used for keeping the data off the 
memory.

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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) Flink Runner compares keys unencoded which may produce incorrect results

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur edited comment on BEAM-315 at 6/2/16 1:53 PM:
---

One more finding: the reproduction of the bug depends on the sum size of data 
not number of keys or elements per key. I've just modified the example by 
adding 5KB blob to each item and it fails with considerably smaller number of 
elements. May it be related to a mechanism used for keeping the data off the 
memory.


was (Author: pawelszc...@gmail.com):
One more finding: the reproduction of error depends on the sum size of data not 
number of keys or elements per key. I've just modified the example by adding 
5KB blob to each item and it fails with considerably smaller number of 
elements. May it be related to a mechanism used for keeping the data off the 
memory.

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur commented on BEAM-315:
---

One more finding: the reproduction of error depends on the sum size of data not 
number of keys or elements per key. I've just modified the example by adding 
5KB blob to each item and it fails with considerably smaller number of 
elements. May it be related to a mechanism used for keeping the data off the 
memory.

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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 #550

2016-06-02 Thread Apache Jenkins Server 
See 

--
[...truncated 2845 lines...]
[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: 
apache-beam-0.2.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.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/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/runners/direct/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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/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/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.

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

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur edited comment on BEAM-315 at 6/2/16 9:49 AM:
---

I'm adding a full log from an erroneous execution and analysis.

The analysis was to grep which key was processed on which shard. It seems that 
each key was processed on only one shard. I've re-run the test multiple times 
with same results.

Thus I think the problem is sorting the data in a shard.


was (Author: pawelszc...@gmail.com):
I'm adding a full log from an erroneous execution and analysis.

The analysis was to grep which key was processed on which shared. It seems that 
each key was processed on only one shard. I've re-run the test multiple times 
with same results.

Thus I think the problem is sorting the data in shard.

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur updated BEAM-315:
--
Attachment: execution_split_sorted.log

> 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, execution.log, 
> execution_split.log, execution_split_sorted.log
>
>
> 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

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur updated BEAM-315:
--
Attachment: execution.log
execution_split.log

I'm adding a full log from an erroneous execution and analysis.

The analysis was to grep which key was processed on which shared. It seems that 
each key was processed on only one shard. I've re-run the test multiple times 
with same results.

Thus I think the problem is sorting the data in shard.

> 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, execution.log, 
> execution_split.log
>
>
> 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

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur commented on BEAM-315:
---

As far as I understand the issue there are 3 places it may originate from:
 1. windowing (all items should end up in one global pane)
 2. shuffle (is windowing considered during shuffle?)
 3. sorting items in a given shard (is sorting considered?)

Am I correct?

> 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] [Comment Edited] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur edited comment on BEAM-315 at 6/2/16 8:50 AM:
---

I thought about it. From your description I guess this should not be a real 
problem. As long as the corresponding values are compared using the same 
comparison function. In fact I think this was done on purpose to speed up the 
execution. 

First the values are shuffled according to hash function of the key and all the 
KV ends up in a correct buckets, then we need to sort them. I guess we compare 
encoded keys because there's no guarantee that pure keys have comparator 
defined and we have predefined bytes comparator.


was (Author: pawelszc...@gmail.com):
I thought about it. From your description I guess this should not be a real 
problem. As long as the corresponding values are compared. In fact I think this 
was done on purpose to speed up the execution. 

First the values are shuffled according to hash function of the key and all the 
KV ends up in a correct buckets, then we need to sort them. I guess we compare 
encoded keys because there's no guarantee that pure keys have comparator 
defined and we have predefined bytes comparator.

> 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] [Comment Edited] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur edited comment on BEAM-315 at 6/2/16 8:34 AM:
---

I thought about it. From your description I guess this should not be a real 
problem. As long as the corresponding values are compared. In fact I think this 
was done on purpose to speed up the execution. 

First the values are shuffled according to hash function of the key and all the 
KV ends up in a correct buckets, then we need to sort them. I guess we compare 
encoded keys because there's no guarantee that pure keys have comparator 
defined and we have predefined bytes comparator.


was (Author: pawelszc...@gmail.com):
I thought about it. From your description I guess this should not be a real 
problem. As long as the corresponding values are compared. In fact I think this 
was done on purpose to speed up the execution. First the values are shuffle 
according to hash function of the key and all the KV ends up in a correct 
buckets, then we need to sort.

> 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] [Commented] (BEAM-315) Flink Runner compares keys unencoded which may produce incorrect results

2016-06-02 Thread Pawel Szczur (JIRA) 

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

Pawel Szczur commented on BEAM-315:
---

I thought about it. From your description I guess this should not be a real 
problem. As long as the corresponding values are compared. In fact I think this 
was done on purpose to speed up the execution. First the values are shuffle 
according to hash function of the key and all the KV ends up in a correct 
buckets, then we need to sort.

> 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)

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #463

2016-06-02 Thread Apache Jenkins Server 
See

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

2016-06-02 Thread 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 #549

2016-06-02 Thread Apache Jenkins Server 
See 

--
[...truncated 2845 lines...]
[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: 
apache-beam-0.2.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.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/google-cloud-dataflow-java/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/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/runners/direct/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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-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/direct/0.1.0-incubating-SNAPSHOT/direct-0.1.0-incubating-SNAPSHOT.jar
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/direct/maven-metadata-local.xml
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-0.1.0-incubating-SNAPSHOT.pom
 longer than 100 characters.
[WARNING] Entry: 
apache-beam-0.2.0-incubating-SNAPSHOT/.repository/org/apache/beam/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-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/flink-parent/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/runners/flink-parent/0.1.0-incubating-SNAPSHOT/flink-parent-0.1.0-incubating-SNAPSHOT-src.tar.gz
 longer than 100 characters.