Build failed in Jenkins: beam_PerformanceTests_Spark #1422

See Changes: [ehudm] Add support for Pub/Sub messages with attributes. [ehudm] Address review comment from PR #4744. -- [...truncated 95.97 KB...]

Jenkins build is back to normal : beam_PerformanceTests_JDBC #282

See

Build failed in Jenkins: beam_PerformanceTests_Python #978

See Changes: [ehudm] Add support for Pub/Sub messages with attributes. [ehudm] Address review comment from PR #4744. -- [...truncated 1.05 KB...] Commit

Build failed in Jenkins: beam_PostCommit_Python_Verify #4352

See Changes: [ehudm] Address review comment from PR #4744. -- [...truncated 1.01 MB...] copying apache_beam/runners/dataflow/test_dataflow_runner.py ->

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1035

See Changes: [ehudm] Add support for Pub/Sub messages with attributes. [ehudm] Address review comment from PR #4744. -- [...truncated

Build failed in Jenkins: beam_PostCommit_Python_Verify #4351

See Changes: [ehudm] Add support for Pub/Sub messages with attributes. -- [...truncated 1.02 MB...] copying apache_beam/runners/direct/clock.py ->

[beam] branch master updated (2fd60a2 -> c285f51)

This is an automated email from the ASF dual-hosted git repository. chamikara pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 2fd60a2 Merge pull request #4744: [BEAM-3744] Add support for Pub/Sub messages with attributes add f3a862a

[beam] 01/01: Merge pull request #4794: [BEAM-3744] Address review comment from PR #4744

This is an automated email from the ASF dual-hosted git repository. chamikara pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit c285f51e9a8eaffcb60a048b7caa94d6534814c9 Merge: 2fd60a2 f3a862a Author: Chamikara Jayalath

[beam] 01/01: Merge pull request #4744: [BEAM-3744] Add support for Pub/Sub messages with attributes

This is an automated email from the ASF dual-hosted git repository. chamikara pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 2fd60a2724b7ad470ffaea2ab23608d4bb5f19f0 Merge: 15018c9 91b05c3 Author: Chamikara Jayalath

[beam] branch master updated (15018c9 -> 2fd60a2)

This is an automated email from the ASF dual-hosted git repository. chamikara pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 15018c9 Merge pull request #4787 add 91b05c3 Add support for Pub/Sub messages with attributes. new

[jira] [Assigned] (BEAM-3255) Update release process to use Gradle

[ https://issues.apache.org/jira/browse/BEAM-3255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Myrvold reassigned BEAM-3255: -- Assignee: Alan Myrvold > Update release process to use Gradle >

[jira] [Created] (BEAM-3776) StateMerging.mergeWatermarks sets a late watermark hold for late merging windows that depend only on the window

Sam Whittle created BEAM-3776: - Summary: StateMerging.mergeWatermarks sets a late watermark hold for late merging windows that depend only on the window Key: BEAM-3776 URL:

Build failed in Jenkins: beam_PerformanceTests_Spark #1421

See Changes: [rangadi] Upate Readme and JavaDoc for KafkaIO. [tgroh] Revert "extracting the scheduled executor service in a factory variable [rangadi] Mention support for older versions.

Build failed in Jenkins: beam_PerformanceTests_Python #977

See Changes: [rangadi] Upate Readme and JavaDoc for KafkaIO. [tgroh] Revert "extracting the scheduled executor service in a factory variable [rangadi] Mention support for older versions.

Build failed in Jenkins: beam_PerformanceTests_JDBC #281

See Changes: [rangadi] Upate Readme and JavaDoc for KafkaIO. [tgroh] Revert "extracting the scheduled executor service in a factory variable [rangadi] Mention support for older versions.

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #6110

See

[jira] [Commented] (BEAM-3754) KAFKA - Can't set commitOffsetsInFinalizeEnabled to false with KafkaIO.readBytes()

[ https://issues.apache.org/jira/browse/BEAM-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384330#comment-16384330 ] Raghu Angadi commented on BEAM-3754: Just saw this. You are correct. Thanks for reporting it. They

Jenkins build is back to normal : beam_PostCommit_Python_ValidatesRunner_Dataflow #1034

See

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Flink #5141

See

[jira] [Resolved] (BEAM-3770) The problem of kafkaIO sdk for data latency

[ https://issues.apache.org/jira/browse/BEAM-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghu Angadi resolved BEAM-3770. Resolution: Not A Bug > The problem of kafkaIO sdk for data latency >

[jira] [Commented] (BEAM-3770) The problem of kafkaIO sdk for data latency

[ https://issues.apache.org/jira/browse/BEAM-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384259#comment-16384259 ] Raghu Angadi commented on BEAM-3770: This is being discussed on user mailing list :

[beam] 01/01: Merge pull request #4787

This is an automated email from the ASF dual-hosted git repository. tgroh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 15018c93fd7e6c97c0628631fd5a847dd18cbf66 Merge: 8c134a1 d68a78b Author: Thomas Groh

[beam] branch master updated (8c134a1 -> 15018c9)

This is an automated email from the ASF dual-hosted git repository. tgroh pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8c134a1 Merge pull request #4778: [BEAM-3620] Update Readme and JavaDoc for KafkaIO add d68a78b Revert

[jira] [Commented] (BEAM-3775) Failure in beam_PostCommit_Java_ValidatesRunner_Dataflow/

[ https://issues.apache.org/jira/browse/BEAM-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384247#comment-16384247 ] María GH commented on BEAM-3775: Build 5000 was a fluke, as I can see the issue in previous builds, like 

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #6109

See Changes: [rangadi] Upate Readme and JavaDoc for KafkaIO. [rangadi] Mention support for older versions. -- [...truncated 1.30 MB...]

[jira] [Commented] (BEAM-3775) Failure in beam_PostCommit_Java_ValidatesRunner_Dataflow/

[ https://issues.apache.org/jira/browse/BEAM-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384222#comment-16384222 ] Alan Myrvold commented on BEAM-3775: All the recent results are timeout. The last success was

Build failed in Jenkins: beam_PostRelease_NightlySnapshot #66

See -- [...truncated 520.00 KB...] [INFO] Downloading from central: https://repo.maven.apache.org/maven2/org/apache/maven/maven/2.2.1/maven-2.2.1.pom [INFO] Downloaded

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #1033

See -- [...truncated 126.05 KB...] { "@type": "kind:pair", "component_encodings": [

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #5140

See Changes: [rangadi] Upate Readme and JavaDoc for KafkaIO. [rangadi] Mention support for older versions. -- [...truncated 154.84 KB...]

[beam] branch master updated (90e9ee1 -> 8c134a1)

This is an automated email from the ASF dual-hosted git repository. iemejia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 90e9ee1 Bump Python dev version. add e3eb3da Upate Readme and JavaDoc for KafkaIO. add 67bfa18 Mention

[beam] 01/01: Merge pull request #4778: [BEAM-3620] Update Readme and JavaDoc for KafkaIO

This is an automated email from the ASF dual-hosted git repository. iemejia pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 8c134a12a5239bc65db69764d067ca13a4797a08 Merge: 90e9ee1 67bfa18 Author: Ismaël Mejía AuthorDate: Fri

Build failed in Jenkins: beam_PostRelease_NightlySnapshot #65

See -- [...truncated 34.98 KB...] [INFO] Downloading from central:

[jira] [Updated] (BEAM-2882) S3 artifact server proxy

[ https://issues.apache.org/jira/browse/BEAM-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde updated BEAM-2882: Priority: Minor (was: Major) > S3 artifact server proxy > > >

[jira] [Updated] (BEAM-2880) Artifact server proxies

[ https://issues.apache.org/jira/browse/BEAM-2880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Rohde updated BEAM-2880: Priority: Minor (was: Major) > Artifact server proxies > --- > >

[jira] [Created] (BEAM-3775) Failure in beam_PostCommit_Java_ValidatesRunner_Dataflow/

María GH created BEAM-3775: -- Summary: Failure in beam_PostCommit_Java_ValidatesRunner_Dataflow/ Key: BEAM-3775 URL: https://issues.apache.org/jira/browse/BEAM-3775 Project: Beam Issue Type: Bug

Build failed in Jenkins: beam_PostRelease_NightlySnapshot #64

See -- [...truncated 515.14 KB...] [INFO] Downloading from central: https://repo.maven.apache.org/maven2/org/codehaus/plexus/plexus-utils/2.0.4/plexus-utils-2.0.4.pom

[beam-site] 02/03: Explicitly define section id due to kramdown id generation changes

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit d64339ef6412ce2d144026c74537932282ce6da2 Author: melissa AuthorDate: Tue Feb 20

[beam-site] 03/03: This closes #388

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit d1f996720f233fca378ad08f23bbfd37354c9032 Merge: 1333c13 d64339e Author: Mergebot

[beam-site] branch mergebot updated (70d586b -> d1f9967)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git. discard 70d586b This closes #388 discard f446425 Explicitly define section id due to kramdown id generation

[beam-site] 01/03: Update Gemfile.lock

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 01f13309aefab7ded5ee0480f7c385c86674fc67 Author: Kenneth Knowles AuthorDate: Wed Feb 14

[jira] [Commented] (BEAM-3671) Need Python 3.x interpreter in Jenkins machines

[ https://issues.apache.org/jira/browse/BEAM-3671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16384006#comment-16384006 ] Alan Myrvold commented on BEAM-3671: Python 3.4.3 appears installed on each beam worker. > Need Python

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #6108

See -- [...truncated 1.30 MB...] 2018-03-02T19:07:53.748 [INFO] Excluding com.sun.jersey.contribs:jersey-guice:jar:1.9 from the shaded jar. 2018-03-02T19:07:53.748

[jira] [Created] (BEAM-3774) Update BigQuery jobs to explicitly specify the region

Chamikara Jayalath created BEAM-3774: Summary: Update BigQuery jobs to explicitly specify the region Key: BEAM-3774 URL: https://issues.apache.org/jira/browse/BEAM-3774 Project: Beam

Build failed in Jenkins: beam_PerformanceTests_Spark #1420

See -- [...truncated 92.69 KB...] 'apache-beam-testing:bqjob_r3b984bd90bc5f619_0161e7f0dc46_1': Invalid schema update. Field timestamp has changed type from TIMESTAMP to

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #5139

See -- [...truncated 154.74 KB...] 2018-03-02T18:13:02.195 [INFO] Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.071 s - in

Build failed in Jenkins: beam_PerformanceTests_Python #976

See -- [...truncated 790.84 KB...] [INFO] --- maven-enforcer-plugin:3.0.0-M1:enforce (enforce-banned-dependencies) @ beam-runners-flink_2.11 --- [INFO] [INFO] ---

Build failed in Jenkins: beam_PerformanceTests_JDBC #280

See -- [...truncated 737.71 KB...] [INFO] Excluding com.google.cloud.datastore:datastore-v1-proto-client:jar:1.4.0 from the shaded jar. [INFO] Excluding

[jira] [Comment Edited] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383882#comment-16383882 ] Pawel Bartoszek edited comment on BEAM-3726 at 3/2/18 6:06 PM: --- Another thing

Jenkins build is back to normal : beam_PerformanceTests_TextIOIT #220

See

[jira] [Comment Edited] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383882#comment-16383882 ] Pawel Bartoszek edited comment on BEAM-3726 at 3/2/18 5:57 PM: --- Another thing

[jira] [Comment Edited] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383882#comment-16383882 ] Pawel Bartoszek edited comment on BEAM-3726 at 3/2/18 5:51 PM: --- Another thing

[jira] [Commented] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383882#comment-16383882 ] Pawel Bartoszek commented on BEAM-3726: --- Another think I noticed (I might be completely wrong here)

[jira] [Commented] (BEAM-3757) Shuffle read failed using python 2.2.0

[ https://issues.apache.org/jira/browse/BEAM-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383846#comment-16383846 ] Jonathan Delfour commented on BEAM-3757: I have created a support ticket with google team, they

[jira] [Created] (BEAM-3773) [SQL] Investigate JDBC interface for Beam SQL

Anton Kedin created BEAM-3773: - Summary: [SQL] Investigate JDBC interface for Beam SQL Key: BEAM-3773 URL: https://issues.apache.org/jira/browse/BEAM-3773 Project: Beam Issue Type: Improvement

[jira] [Assigned] (BEAM-3772) BigQueryIO - Can't use DynamicDestination with CREATE_IF_NEEDED for unbounded PCollection and FILE_LOADS

[ https://issues.apache.org/jira/browse/BEAM-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath reassigned BEAM-3772: Assignee: Eugene Kirpichov (was: Chamikara Jayalath) > BigQueryIO - Can't use

[jira] [Created] (BEAM-3772) BigQueryIO - Can't use DynamicDestination with CREATE_IF_NEEDED for unbounded PCollection and FILE_LOADS

Benjamin BENOIST created BEAM-3772: -- Summary: BigQueryIO - Can't use DynamicDestination with CREATE_IF_NEEDED for unbounded PCollection and FILE_LOADS Key: BEAM-3772 URL:

[jira] [Commented] (BEAM-3619) Add tests for Python DirectRunner implementation of PubSub I/O

[ https://issues.apache.org/jira/browse/BEAM-3619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383807#comment-16383807 ] Udi Meiri commented on BEAM-3619: - [https://github.com/apache/beam/pull/4744] will add a fake Pubsub client

[jira] [Created] (BEAM-3771) Unable to write using AvroIO without schema

Darshan Mehta created BEAM-3771: --- Summary: Unable to write using AvroIO without schema Key: BEAM-3771 URL: https://issues.apache.org/jira/browse/BEAM-3771 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383763#comment-16383763 ] Pawel Bartoszek commented on BEAM-3726: ---   [~iemejia] I managed to catch this exception by running

[jira] [Updated] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-3726: -- Attachment: KinesisIO-state.txt > Kinesis Reader: java.lang.IllegalArgumentException: Attempting

[jira] [Commented] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383736#comment-16383736 ] Pawel Bartoszek commented on BEAM-3726: --- [~iemejia]  I have looked into PubSubIO implementation and

[jira] [Updated] (BEAM-3768) Compile error for Flink translation

[ https://issues.apache.org/jira/browse/BEAM-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-3768: --- Issue Type: Bug (was: Test) > Compile error for Flink translation >

[jira] [Commented] (BEAM-3768) Compile error for Flink translation

[ https://issues.apache.org/jira/browse/BEAM-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383585#comment-16383585 ] Aljoscha Krettek commented on BEAM-3768: [~robertwb] & [~rmannibucau] I commented on the PR:

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #6107

See -- [...truncated 1.30 MB...] 2018-03-02T13:49:47.337 [INFO] Excluding asm:asm:jar:3.1 from the shaded jar. 2018-03-02T13:49:47.337 [INFO] Excluding

[jira] [Updated] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-3726: -- Description: When the job is restored from savepoint Kinesis Reader throws almost always 

[jira] [Commented] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards

[ https://issues.apache.org/jira/browse/BEAM-3726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16383570#comment-16383570 ] Pawel Bartoszek commented on BEAM-3726: --- [~iemejia] we upgraded to Beam 2.3 and Flink 1.4 and still

Build failed in Jenkins: beam_PerformanceTests_Spark #1419

See Changes: [robertwb] [maven-release-plugin] prepare branch release-2.4.0 [robertwb] [maven-release-plugin] prepare for next development iteration [robertwb] Bump Python dev version.

Build failed in Jenkins: beam_PerformanceTests_TextIOIT #219

See Changes: [robertwb] [maven-release-plugin] prepare branch release-2.4.0 [robertwb] [maven-release-plugin] prepare for next development iteration [robertwb] Bump Python dev version.

Build failed in Jenkins: beam_PerformanceTests_Python #975

See Changes: [robertwb] [maven-release-plugin] prepare branch release-2.4.0 [robertwb] [maven-release-plugin] prepare for next development iteration [robertwb] Bump Python dev version.

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #5138

See -- [...truncated 154.90 KB...] 2018-03-02T12:08:04.046 [INFO] Running org.apache.beam.runners.core.StateNamespacesTest 2018-03-02T12:08:04.051 [INFO]

Build failed in Jenkins: beam_PostRelease_NightlySnapshot #63

See Changes: [rmannibucau] extracting the scheduled executor service in a factory variable in SDF [sidhom] Run NeedsRunner tests from direct runner gradle build [ccy] Fix issue from incomplete

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #6105

See Changes: [robertwb] [maven-release-plugin] prepare for next development iteration -- [...truncated 2.52 MB...] 2018-03-02T09:08:10.422 [INFO]

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #6104

See Changes: [robertwb] [maven-release-plugin] prepare branch release-2.4.0 -- [...truncated 1.30 MB...] 2018-03-02T09:04:40.747 [INFO] Excluding

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #6106

See Changes: [robertwb] Bump Python dev version. -- [...truncated 1.30 MB...] 2018-03-02T09:02:58.416 [INFO] Excluding asm:asm:jar:3.1 from the shaded

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #5137

See Changes: [robertwb] [maven-release-plugin] prepare for next development iteration [robertwb] Bump Python dev version. -- [...truncated

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #5136

See Changes: [robertwb] [maven-release-plugin] prepare branch release-2.4.0 -- [...truncated 154.93 KB...] 2018-03-02T08:03:38.524 [INFO]

[beam] branch master updated: Bump Python dev version.

This is an automated email from the ASF dual-hosted git repository. robertwb pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 90e9ee1 Bump Python dev version. 90e9ee1 is