[beam] branch master updated (24804e9 -> 93818ab)

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 24804e9 Merge pull request #3978: [BEAM-230] Remove deprecated WindowedValue.valueInEmptyWindows new 01d74b3

[beam] 02/03: [BEAM-3186] Correctly use deserialized timerService in Flink Runner

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 6808b8855f90f69098bd37d2353da7d3ca329eb3 Author: Dawid Wysakowicz AuthorDate: Thu Feb 1 13:47:30

[beam] 01/03: Remove erroneous cast in FlinkStreamingTransformTranslators

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 01d74b3b8381c04ffba3879281897ea2ef6fbcc5 Author: Dawid Wysakowicz AuthorDate: Mon Feb 5 11:36:33

[jira] [Closed] (BEAM-3186) In-flight data loss when restoring from savepoint

[ https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-3186. -- Resolution: Fixed > In-flight data loss when restoring from savepoint >

[jira] [Closed] (BEAM-3589) Flink runner breaks with ClassCastException on UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-3589. -- Resolution: Fixed > Flink runner breaks with ClassCastException on UnboundedSource >

Build failed in Jenkins: beam_PerformanceTests_JDBC #229

See -- [...truncated 12.64 KB...] /home/jenkins/jenkins-slave/workspace/beam_PerformanceTests_AvroIOIT/runs/bbf3bfde/beam/.test-infra/kubernetes/postgres/pkb-config.yml

Build failed in Jenkins: beam_PerformanceTests_JDBC #232

See -- GitHub pull request #4585 of commit 1e38bea87d0bd8d6c629f58410765cf3c2809216, no merge conflicts. Setting status of 1e38bea87d0bd8d6c629f58410765cf3c2809216 to PENDING

[beam] branch release-2.3.0 updated (7da24e6 -> befa911)

This is an automated email from the ASF dual-hosted git repository. jbonofre pushed a change to branch release-2.3.0 in repository https://gitbox.apache.org/repos/asf/beam.git. from 7da24e6 [BEAM-3551] Define compiler -parameters flag in the default options new 73f4d99 Remove

[beam] 02/02: [BEAM-3186] Correctly use deserialized timerService in Flink Runner

This is an automated email from the ASF dual-hosted git repository. jbonofre pushed a commit to branch release-2.3.0 in repository https://gitbox.apache.org/repos/asf/beam.git commit befa91180a0935ac4ae667084908db8a43746279 Author: Dawid Wysakowicz AuthorDate: Thu Feb 1

[jira] [Commented] (BEAM-3186) In-flight data loss when restoring from savepoint

[ https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352248#comment-16352248 ] Aljoscha Krettek commented on BEAM-3186: [~jbonofre] This was fixed on master in these commits:

Jenkins build is back to normal : beam_PerformanceTests_JDBC #231

See

[beam] 03/03: Merge pull request #4563: Fixes Flink timer service restore

This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 93818abf901dd996aa30445457153811b13ece43 Merge: 24804e9 6808b88 Author: Aljoscha Krettek

Jenkins build is back to normal : beam_PerformanceTests_JDBC #228

See

[jira] [Commented] (BEAM-3589) Flink runner breaks with ClassCastException on UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352250#comment-16352250 ] Aljoscha Krettek commented on BEAM-3589: [~jbonofre] This was now fixed as part of another fix in

[jira] [Updated] (BEAM-3589) Flink runner breaks with ClassCastException on UnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-3589: --- Fix Version/s: 2.3.0 > Flink runner breaks with ClassCastException on UnboundedSource >

Build failed in Jenkins: beam_PerformanceTests_Python #877

See Changes: [aljoscha.krettek] Remove erroneous cast in FlinkStreamingTransformTranslators [aljoscha.krettek] [BEAM-3186] Correctly use deserialized timerService in Flink Runner

[jira] [Commented] (BEAM-3186) In-flight data loss when restoring from savepoint

[ https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352322#comment-16352322 ] Jean-Baptiste Onofré commented on BEAM-3186: [~aljoscha] thanks, I cherry-pick on release-2.3.0

Build failed in Jenkins: beam_PerformanceTests_JDBC #230

See Changes: [mingmxu] var_pop and var_samp [robertwb] Fix (and test) FnApiRunner in grpc mode. [lcwik] [BEAM-2862] Add PTransform overrides specific to execution of [klk] Key StateTable off id, not

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #4884

See

[beam] 01/02: Remove erroneous cast in FlinkStreamingTransformTranslators

This is an automated email from the ASF dual-hosted git repository. jbonofre pushed a commit to branch release-2.3.0 in repository https://gitbox.apache.org/repos/asf/beam.git commit 73f4d997b1489ec5e4c11cbed9538f8ed4e38caa Author: Dawid Wysakowicz AuthorDate: Mon Feb 5

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #4885

See

[jira] [Commented] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352390#comment-16352390 ] Jean-Baptiste Onofré commented on BEAM-3587: Using 2.3.0-SNAPSHOT artifacts provided by Maven

Build failed in Jenkins: beam_PerformanceTests_JDBC #234

See -- GitHub pull request #4585 of commit 4d2fed623eddef9f3a8bb1981e1911bdcb2001b3, no merge conflicts. Setting status of 4d2fed623eddef9f3a8bb1981e1911bdcb2001b3 to PENDING

[jira] [Commented] (BEAM-3186) In-flight data loss when restoring from savepoint

[ https://issues.apache.org/jira/browse/BEAM-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352336#comment-16352336 ] Jean-Baptiste Onofré commented on BEAM-3186: Cherry-pick done on the release-2.3.0 branch.

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #5866

See

Build failed in Jenkins: beam_PerformanceTests_JDBC #233

See -- [...truncated 282 B...] [EnvInject] - Loading node environment variables. Building remotely on beam2 (beam) in workspace

[jira] [Commented] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352564#comment-16352564 ] Jean-Baptiste Onofré commented on BEAM-3587: I cloned the test repo:

[jira] [Assigned] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-3587: -- Assignee: Jean-Baptiste Onofré (was: Ben Sidhom) > User reports TextIO failure

[jira] [Created] (BEAM-3617) Performance degradation on the direct runner

Jean-Baptiste Onofré created BEAM-3617: -- Summary: Performance degradation on the direct runner Key: BEAM-3617 URL: https://issues.apache.org/jira/browse/BEAM-3617 Project: Beam Issue

[jira] [Commented] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352587#comment-16352587 ] Jean-Baptiste Onofré commented on BEAM-3587: As we have: {code}

[jira] [Updated] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-3587: --- Attachment: screen1.png > User reports TextIO failure in FlinkRunner on master >

Build failed in Jenkins: beam_PerformanceTests_JDBC #236

See -- [...truncated 52.95 KB...] Error from server (AlreadyExists): error when creating

[jira] [Updated] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-3587: --- Component/s: (was: runner-flink) website > User reports TextIO

[jira] [Updated] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-3587: --- Fix Version/s: (was: 2.3.0) > User reports TextIO failure in FlinkRunner on master

[jira] [Updated] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-3587: --- Priority: Minor (was: Blocker) > User reports TextIO failure in FlinkRunner on master

Build failed in Jenkins: beam_PerformanceTests_JDBC #235

See -- [...truncated 85.13 KB...] 2018-02-05 15:47:50,986 14bbe231 MainThread beam_integration_benchmark(1/1) INFO Retrying exception running IssueRetryableCommand:

[jira] [Updated] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-3587: --- Attachment: screen2.png > User reports TextIO failure in FlinkRunner on master >

[jira] [Commented] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352590#comment-16352590 ] Jean-Baptiste Onofré commented on BEAM-3587: I created a PR on the user example to fix the

[jira] [Comment Edited] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352587#comment-16352587 ] Jean-Baptiste Onofré edited comment on BEAM-3587 at 2/5/18 4:10 PM: As

[jira] [Commented] (BEAM-3587) User reports TextIO failure in FlinkRunner on master

[ https://issues.apache.org/jira/browse/BEAM-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352612#comment-16352612 ] Jean-Baptiste Onofré commented on BEAM-3587: It's not a problem in Beam codebase itself, so not

[beam] branch master updated: Adjust gradle build dirs and hints to help IntelliJ (#4583)

This is an automated email from the ASF dual-hosted git repository. lcwik 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 af7920d Adjust gradle build dirs and hints to

[jira] [Assigned] (BEAM-3602) Add source set for generated Java gRPC code

[ https://issues.apache.org/jira/browse/BEAM-3602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Sidhom reassigned BEAM-3602: Assignee: Kenneth Knowles (was: Ben Sidhom) > Add source set for generated Java gRPC code >

[jira] [Commented] (BEAM-3602) Add source set for generated Java gRPC code

[ https://issues.apache.org/jira/browse/BEAM-3602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352643#comment-16352643 ] Ben Sidhom commented on BEAM-3602: -- This should be fixed by https://github.com/apache/beam/pull/4583. >

[jira] [Resolved] (BEAM-3602) Add source set for generated Java gRPC code

[ https://issues.apache.org/jira/browse/BEAM-3602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-3602. - Resolution: Fixed Fix Version/s: 2.4.0 > Add source set for generated Java gRPC code >

[jira] [Created] (BEAM-3618) Remove extraneous "return" statement

Colm O hEigeartaigh created BEAM-3618: - Summary: Remove extraneous "return" statement Key: BEAM-3618 URL: https://issues.apache.org/jira/browse/BEAM-3618 Project: Beam Issue Type:

[jira] [Updated] (BEAM-3616) Ensure coders are updatable partially in a cluster (aka add versions to coders)

[ https://issues.apache.org/jira/browse/BEAM-3616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Romain Manni-Bucau updated BEAM-3616: - Component/s: sdk-py-core sdk-go > Ensure coders are updatable partially

[jira] [Created] (BEAM-3616) Ensure coders are updatable partially in a cluster (aka add versions to coders)

Romain Manni-Bucau created BEAM-3616: Summary: Ensure coders are updatable partially in a cluster (aka add versions to coders) Key: BEAM-3616 URL: https://issues.apache.org/jira/browse/BEAM-3616

[jira] [Assigned] (BEAM-3318) ConcurrentModificationException in populating Display Data

[ https://issues.apache.org/jira/browse/BEAM-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-3318: - Assignee: (was: Thomas Groh) > ConcurrentModificationException in populating Display Data >

[jira] [Assigned] (BEAM-3408) PackageUtil should retry check for whether file is already staged

[ https://issues.apache.org/jira/browse/BEAM-3408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-3408: - Assignee: (was: Thomas Groh) > PackageUtil should retry check for whether file is already

[jira] [Updated] (BEAM-2718) Add bundle retry logic to the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] María GH updated BEAM-2718: --- Fix Version/s: (was: Not applicable) 2.3.0 > Add bundle retry logic to the DirectRunner

[jira] [Assigned] (BEAM-2769) Java SDK support for submitting a Portable Pipeline

[ https://issues.apache.org/jira/browse/BEAM-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-2769: - Assignee: (was: Thomas Groh) > Java SDK support for submitting a Portable Pipeline >

Build failed in Jenkins: beam_PostCommit_Python_Verify #4152

See Changes: [ccy] [BEAM-3566] Replace apply_* hooks in DirectRunner with [ccy] Address reviewer comments -- [...truncated 1.52 MB...]

[jira] [Updated] (BEAM-3526) Support for checkpointMark finalize in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-3526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghu Angadi updated BEAM-3526: --- Fix Version/s: 2.4.0 > Support for checkpointMark finalize in KafkaIO >

[jira] [Closed] (BEAM-3526) Support for checkpointMark finalize in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-3526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghu Angadi closed BEAM-3526. -- Resolution: Fixed > Support for checkpointMark finalize in KafkaIO >

[jira] [Created] (BEAM-3620) Deprecate older Kafka clients

Raghu Angadi created BEAM-3620: -- Summary: Deprecate older Kafka clients Key: BEAM-3620 URL: https://issues.apache.org/jira/browse/BEAM-3620 Project: Beam Issue Type: Improvement

[jira] [Resolved] (BEAM-3564) Handle an Unpopulated "Environment" field in Environments

[ https://issues.apache.org/jira/browse/BEAM-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-3564. --- Resolution: Fixed Fix Version/s: Not applicable > Handle an Unpopulated "Environment" field in

[beam] 01/01: Merge pull request #4529 from [BEAM-3566] Replace apply_* hooks in DirectRunner with PTransformOverrides

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 commit 8e2092ba28ad31517d65b3085840e6e9a46c83bf Merge: 8edc18e e1a96eb Author: Robert Bradshaw AuthorDate:

[beam] branch master updated (8edc18e -> 8e2092b)

This is an automated email from the ASF dual-hosted git repository. robertwb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8edc18e Merge pull request #4595: [BEAM-3601] Switch to Java 8 futures add 16e5fef [BEAM-3566] Replace

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

Charles Chen created BEAM-3619: -- Summary: Add tests for Python DirectRunner implementation of PubSub I/O Key: BEAM-3619 URL: https://issues.apache.org/jira/browse/BEAM-3619 Project: Beam Issue

[jira] [Commented] (BEAM-849) Redesign PipelineResult API

[ https://issues.apache.org/jira/browse/BEAM-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16353111#comment-16353111 ] Thomas Groh commented on BEAM-849: -- This should be strongly informed by and should in turn inform the

[jira] [Updated] (BEAM-2769) Java SDK support for submitting a Portable Pipeline

[ https://issues.apache.org/jira/browse/BEAM-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-2769: -- Summary: Java SDK support for submitting a Portable Pipeline (was: Java SDK support for portable

[jira] [Updated] (BEAM-3146) Fn Execution APIs should not depend on the Java SDK

[ https://issues.apache.org/jira/browse/BEAM-3146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-3146: -- Description: Runners should be able to interact with the Fn API with complete ignorance of the

[jira] [Assigned] (BEAM-3146) Fn Execution APIs should not depend on the Java SDK

[ https://issues.apache.org/jira/browse/BEAM-3146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-3146: - Assignee: (was: Thomas Groh) > Fn Execution APIs should not depend on the Java SDK >

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #4889

See

[jira] [Commented] (BEAM-3529) Side Input callbacks should fire after a window has expired in addition to when the trigger would fire

[ https://issues.apache.org/jira/browse/BEAM-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16353096#comment-16353096 ] Thomas Groh commented on BEAM-3529: --- Yes; note that the simple test implementation uses {{TestStream}},

[jira] [Assigned] (BEAM-3528) Populate Environment in Side Input SDKFunctionSpecs in ParDoTranslation

[ https://issues.apache.org/jira/browse/BEAM-3528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh reassigned BEAM-3528: - Assignee: (was: Thomas Groh) > Populate Environment in Side Input SDKFunctionSpecs in

[jira] [Resolved] (BEAM-2430) Java FnApiDoFnRunner to share across runners

[ https://issues.apache.org/jira/browse/BEAM-2430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-2430. --- Resolution: Done Fix Version/s: 2.3.0 I claim that a {{FnApiDoFnRunner}} is the wrong

Build failed in Jenkins: beam_PerformanceTests_Python #879

See Changes: [Pablo] Moving User metrics to be in the PTransform proto for Fn API. [ccy] [BEAM-3566] Replace apply_* hooks in DirectRunner with [ccy] Address reviewer comments [jiangkai] Covariance

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #5867

See

[jira] [Commented] (BEAM-3617) Performance degradation on the direct runner

[ https://issues.apache.org/jira/browse/BEAM-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352800#comment-16352800 ] Jean-Baptiste Onofré commented on BEAM-3617: I just ran nexmark ({{mvn exec:java

[beam] branch master updated (cb38392 -> 7904112)

This is an automated email from the ASF dual-hosted git repository. robertwb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from cb38392 Match Maven Java SDK harness jar name format add 4d06e82 [BEAM-3183] Allow a callable as input to

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #4886

See

[jira] [Resolved] (BEAM-3618) Remove extraneous "return" statement

[ https://issues.apache.org/jira/browse/BEAM-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-3618. - Resolution: Fixed > Remove extraneous "return" statement > > >

[jira] [Assigned] (BEAM-3182) [Nexmark][SQL] Implement supported queries

[ https://issues.apache.org/jira/browse/BEAM-3182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-3182: Assignee: Andrew Pilloud (was: Anton Kedin) > [Nexmark][SQL] Implement supported queries >

[jira] [Commented] (BEAM-3617) Performance degradation on the direct runner

[ https://issues.apache.org/jira/browse/BEAM-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352829#comment-16352829 ] Kenneth Knowles commented on BEAM-3617: --- Good idea to check this. I added it to the spreadsheet and

[beam] 01/01: Merge pull request #4590 [BEAM-3183] Allow a callable as input to runner.run().

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 commit 79041126519ad64c4f357fb8ddcc7ae67a7b2203 Merge: cb38392 4d06e82 Author: Robert Bradshaw AuthorDate:

[beam] branch master updated (af7920d -> 2aca6ce)

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from af7920d Adjust gradle build dirs and hints to help IntelliJ (#4583) add 7c19700 BEAM-3618 - Remove extraneous

[beam] 01/01: BEAM-3618 - Remove extraneous "return" statement

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 2aca6ce2b69d76b9c1f8127d8647f9b1c7589219 Merge: af7920d 7c19700 Author: Lukasz Cwik AuthorDate: Mon Feb

[jira] [Created] (BEAM-3621) HCatalog failing frequently on fetch of org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde

Kenneth Knowles created BEAM-3621: - Summary: HCatalog failing frequently on fetch of org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde Key: BEAM-3621 URL: https://issues.apache.org/jira/browse/BEAM-3621

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #835

See -- [...truncated 130.35 KB...] File "/usr/lib/python2.7/pickle.py", line 562, in save_tuple save(element) File "/usr/lib/python2.7/pickle.py",

Build failed in Jenkins: beam_PostCommit_Python_Verify #4153

See -- [...truncated 1.52 MB...] windowed_value, self.process_method(windowed_value.value)) File

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Apex #3397

See

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #5876

See

[jira] [Updated] (BEAM-3599) kinesis.ShardReadersPoolTest.shouldInterruptKinesisReadingAndStopShortly is flaky

[ https://issues.apache.org/jira/browse/BEAM-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3599: -- Priority: Critical (was: Major) >

[jira] [Updated] (BEAM-3599) kinesis.ShardReadersPoolTest.shouldInterruptKinesisReadingAndStopShortly is flaky

[ https://issues.apache.org/jira/browse/BEAM-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3599: -- Labels: flake (was: ) >

[jira] [Updated] (BEAM-3317) KinesisReaderTest is Flaky due to overadvanced watermarks

[ https://issues.apache.org/jira/browse/BEAM-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3317: -- Summary: KinesisReaderTest is Flaky due to overadvanced watermarks (was: KenisisReaderTest is

[jira] [Updated] (BEAM-3598) kinesis.ShardReadersPoolTest.shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping is flaky

[ https://issues.apache.org/jira/browse/BEAM-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3598: -- Priority: Critical (was: Major) >

[jira] [Updated] (BEAM-3598) kinesis.ShardReadersPoolTest.shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping is flaky

[ https://issues.apache.org/jira/browse/BEAM-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3598: -- Labels: flake (was: ) >

[jira] [Updated] (BEAM-3317) KinesisReaderTest is Flaky due to overadvanced watermarks

[ https://issues.apache.org/jira/browse/BEAM-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3317: -- Labels: flake sickbay (was: sickbay) > KinesisReaderTest is Flaky due to overadvanced

[jira] [Updated] (BEAM-3317) KinesisReaderTest is Flaky due to overadvanced watermarks

[ https://issues.apache.org/jira/browse/BEAM-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3317: -- Priority: Critical (was: Major) > KinesisReaderTest is Flaky due to overadvanced watermarks >

[jira] [Assigned] (BEAM-3599) kinesis.ShardReadersPoolTest.shouldInterruptKinesisReadingAndStopShortly is flaky

[ https://issues.apache.org/jira/browse/BEAM-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3599: - Assignee: Kenneth Knowles (was: Reuven Lax) >

[jira] [Assigned] (BEAM-3317) KinesisReaderTest is Flaky due to overadvanced watermarks

[ https://issues.apache.org/jira/browse/BEAM-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3317: - Assignee: Kenneth Knowles (was: Reuven Lax) > KinesisReaderTest is Flaky due to

[jira] [Commented] (BEAM-3228) org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16353283#comment-16353283 ] Kenneth Knowles commented on BEAM-3228: --- I haven't seen this one in a bit. >

[jira] [Resolved] (BEAM-3228) org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-3228. --- Resolution: Fixed Fix Version/s: 2.3.0 >

[jira] [Updated] (BEAM-3228) org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3228: -- Labels: flake (was: ) > org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky >

[jira] [Updated] (BEAM-3228) org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3228: -- Priority: Critical (was: Major) > org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky >

[jira] [Assigned] (BEAM-3228) org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3228: - Assignee: Kenneth Knowles > org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky >

[jira] [Assigned] (BEAM-3228) org.apache.beam.sdk.io.kinesis.KinesisMockReadTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-3228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3228: - Assignee: Ismaël Mejía (was: Kenneth Knowles) >

[jira] [Assigned] (BEAM-3605) Kinesis ShardReadersPoolTest shouldForgetClosedShardIterator failure

[ https://issues.apache.org/jira/browse/BEAM-3605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3605: - Assignee: Kenneth Knowles (was: Paweł Kaczmarczyk) > Kinesis ShardReadersPoolTest

[jira] [Assigned] (BEAM-3598) kinesis.ShardReadersPoolTest.shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping is flaky

[ https://issues.apache.org/jira/browse/BEAM-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3598: - Assignee: Kenneth Knowles (was: Reuven Lax) >

  1   2   >