Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2603

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3369

See

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4346

See

[GitHub] beam pull request #3503: Split bundle processor into separate class.

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

[2/2] beam git commit: Closes #3503

Closes #3503 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/af08f535 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/af08f535 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/af08f535 Branch: refs/heads/master

[1/2] beam git commit: Split bundle processor into separate class.

Repository: beam Updated Branches: refs/heads/master 0e89df3f6 -> af08f5352 Split bundle processor into separate class. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3099e814 Tree:

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2602

See

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4344

See

[jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

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

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2601

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3368

See

beam git commit: [maven-release-plugin] rollback changes from release preparation of v2.1.0-RC1

Repository: beam Updated Branches: refs/heads/release-2.1.0 0e1eb9d97 -> 948735130 [maven-release-plugin] rollback changes from release preparation of v2.1.0-RC1 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/94873513

[beam] Git Push Summary

Repository: beam Updated Tags: refs/tags/v2.1.0-RC1 [created] b8eb20d18

beam git commit: [maven-release-plugin] prepare release v2.1.0-RC1

Repository: beam Updated Branches: refs/heads/release-2.1.0 5c4ea884d -> 0e1eb9d97 [maven-release-plugin] prepare release v2.1.0-RC1 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0e1eb9d9 Tree:

[GitHub] beam pull request #3539: [BEAM-2353] Unbundle Context and WindowedContext.

GitHub user reuvenlax opened a pull request: https://github.com/apache/beam/pull/3539 [BEAM-2353] Unbundle Context and WindowedContext. Remove the unnecessary classes, and inline the parameters. This is not a backwards-compatible change, however these classes are marked as

[jira] [Commented] (BEAM-2353) FileNamePolicy context parameters allow backwards compatibility where we really don't want any

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

[GitHub] beam pull request #3536: [BEAM-2371] Use URNs, not Java classes, in immutabi...

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

[2/2] beam git commit: This closes #3536: Use URNs, not Java classes, in immutability enforcements

This closes #3536: Use URNs, not Java classes, in immutability enforcements Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0e89df3f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0e89df3f Diff:

[1/2] beam git commit: Use URNs, not Java classes, in immutability enforcements

Repository: beam Updated Branches: refs/heads/master eeb043299 -> 0e89df3f6 Use URNs, not Java classes, in immutability enforcements Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/311547aa Tree:

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3367

See

[GitHub] beam pull request #3453: Reflect #assignsToOneWindow in WindowingStrategy

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

[1/2] beam git commit: Reflect #assignsToOneWindow in WindowingStrategy

Repository: beam Updated Branches: refs/heads/master b6b1c8b7c -> eeb043299 Reflect #assignsToOneWindow in WindowingStrategy Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c6f9fdea Tree:

[2/2] beam git commit: This closes #3453: Reflect #assignsToOneWindow in WindowingStrategy

This closes #3453: Reflect #assignsToOneWindow in WindowingStrategy Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eeb04329 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/eeb04329 Diff:

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2600

See

[jira] [Commented] (BEAM-92) Data-dependent sinks

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

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3366

See

[jira] [Commented] (BEAM-2571) Flink ValidatesRunner failing CombineTest.testSlidingWindowsCombineWithContext

[ https://issues.apache.org/jira/browse/BEAM-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081602#comment-16081602 ] Kenneth Knowles commented on BEAM-2571: --- I would hold off on making changes here. It seems Dataflow

[jira] [Resolved] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

[ https://issues.apache.org/jira/browse/BEAM-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-2371. --- Resolution: Fixed Fix Version/s: 2.2.0 I think this is adequately established. We will

[jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

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

[1/8] beam git commit: Add more utilities to ParDoTranslation

Repository: beam Updated Branches: refs/heads/master c14a3184e -> b6b1c8b7c Add more utilities to ParDoTranslation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/165dfa68 Tree:

[7/8] beam git commit: Fix null checks in TransformHierarchy

Fix null checks in TransformHierarchy Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1518d732 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1518d732 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1518d732

[8/8] beam git commit: This closes #3509: [BEAM-2371] Port DirectRunner overrides to SDK-agnostic APIs

This closes #3509: [BEAM-2371] Port DirectRunner overrides to SDK-agnostic APIs Fix null checks in TransformHierarchy Fix misleading comment in TransformHierarchy Port DirectRunner ParDo overrides to SDK-agnostic APIs Enable SplittableParDo on rehydrated ParDo transform Include

[3/8] beam git commit: Include PCollection in rehydrated PCollectionView

Include PCollection in rehydrated PCollectionView Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/de39f324 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/de39f324 Diff:

[GitHub] beam pull request #3509: [BEAM-2371] Port DirectRunner overrides to SDK-agno...

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

[4/8] beam git commit: Enable SplittableParDo on rehydrated ParDo transform

Enable SplittableParDo on rehydrated ParDo transform Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fa61ed17 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fa61ed17 Diff:

[6/8] beam git commit: Fix misleading comment in TransformHierarchy

Fix misleading comment in TransformHierarchy Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/be9a3879 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/be9a3879 Diff:

[5/8] beam git commit: Port DirectRunner ParDo overrides to SDK-agnostic APIs

Port DirectRunner ParDo overrides to SDK-agnostic APIs Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1ac4b7e6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1ac4b7e6 Diff:

[2/8] beam git commit: Rehydrate PCollections

Rehydrate PCollections Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/20ce0756 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/20ce0756 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/20ce0756 Branch:

Jenkins build is unstable: beam_PostCommit_Java_MavenInstall #4343

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2599

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3365

See

[GitHub] beam pull request #3356: [BEAM-92] Allow value-dependent files in FileBasedS...

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

[5/5] beam git commit: This closes #3356: [BEAM-92] Allow value-dependent files in FileBasedSink

This closes #3356: [BEAM-92] Allow value-dependent files in FileBasedSink Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c14a3184 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c14a3184 Diff:

[4/5] beam git commit: Adds DynamicDestinations support to FileBasedSink

Adds DynamicDestinations support to FileBasedSink Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/77ba7a35 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/77ba7a35 Diff:

[2/5] beam git commit: Adds DynamicDestinations support to FileBasedSink

http://git-wip-us.apache.org/repos/asf/beam/blob/77ba7a35/sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSink.java -- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSink.java

[1/5] beam git commit: Adds DynamicDestinations support to FileBasedSink

Repository: beam Updated Branches: refs/heads/master 9d48bd5e8 -> c14a3184e http://git-wip-us.apache.org/repos/asf/beam/blob/77ba7a35/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOTest.java -- diff --git

[3/5] beam git commit: Adds DynamicDestinations support to FileBasedSink

http://git-wip-us.apache.org/repos/asf/beam/blob/77ba7a35/sdks/java/core/src/main/java/org/apache/beam/sdk/io/DynamicFileDestinations.java -- diff --git

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #4342

See -- [...truncated 1.47 MB...] 2017-07-11T00:39:25.361 [INFO] Excluding com.google.http-client:google-http-client:jar:1.22.0 from the shaded jar.

[GitHub] beam pull request #3538: Add a test for Avro write with RVP; fix code

GitHub user bjchambers opened a pull request: https://github.com/apache/beam/pull/3538 Add a test for Avro write with RVP; fix code Add a test for AvroIO using RuntimeValueProvider Make AvroIO actually work with RuntimeValueProvider. Previously it caused the code to be

[GitHub] beam pull request #3537: TestPipeline should support errors in expand

GitHub user bjchambers opened a pull request: https://github.com/apache/beam/pull/3537 TestPipeline should support errors in expand Writing a test that expects an exception during transform application is currently not possible with TestPipeline in a NeedsRunner or

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2598

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3364

See

[jira] [Commented] (BEAM-2572) Implement an S3 filesystem for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081374#comment-16081374 ] Dmitry Demeshchuk commented on BEAM-2572: - How about the following plan, then? 1. Add an ability

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2597

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3363

See

[jira] [Commented] (BEAM-1348) Model the Fn Api

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

[2/2] beam git commit: [BEAM-1348] Remove deprecated concepts in Fn API (now replaced with Runner API concepts).

[BEAM-1348] Remove deprecated concepts in Fn API (now replaced with Runner API concepts). This closes #3482 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9d48bd5e Tree:

[1/2] beam git commit: [BEAM-1348] Remove deprecated concepts in Fn API (now replaced with Runner API concepts).

Repository: beam Updated Branches: refs/heads/master 9f904dc00 -> 9d48bd5e8 [BEAM-1348] Remove deprecated concepts in Fn API (now replaced with Runner API concepts). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/521488f8

[GitHub] beam pull request #3482: [BEAM-1348] Remove deprecated concepts in Fn API (n...

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

[jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

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

[GitHub] beam pull request #3536: [BEAM-2371] Use URNs, not Java classes, in immutabi...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/3536 [BEAM-2371] Use URNs, not Java classes, in immutability enforcements Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure

[jira] [Commented] (BEAM-2534) KafkaIO should allow gaps in message offsets

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

[jira] [Updated] (BEAM-2530) Make Beam compatible with Java 9

[ https://issues.apache.org/jira/browse/BEAM-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-2530: --- Fix Version/s: (was: 2.1.0) Not applicable > Make Beam compatible with Java 9 >

[jira] [Commented] (BEAM-2530) Make Beam compatible with Java 9

[ https://issues.apache.org/jira/browse/BEAM-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081224#comment-16081224 ] Ismaël Mejía commented on BEAM-2530: No, it was marked 2.1.0 by some confusion. I just changed it, all

[jira] [Commented] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081179#comment-16081179 ] Dmitry Demeshchuk commented on BEAM-2573: - [~altay]: I was doing exactly the option 2, yes. My

[jira] [Comment Edited] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081145#comment-16081145 ] Sourabh Bajaj edited comment on BEAM-2573 at 7/10/17 9:03 PM: -- I think the

[jira] [Commented] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081160#comment-16081160 ] Ahmet Altay commented on BEAM-2573: --- [~demeshchuk], I belive you are mixing two SDK versions. The SDK

[jira] [Comment Edited] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081145#comment-16081145 ] Sourabh Bajaj edited comment on BEAM-2573 at 7/10/17 9:03 PM: -- I think the

[jira] [Commented] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081145#comment-16081145 ] Sourabh Bajaj commented on BEAM-2573: - I think the worker is specified in

[jira] [Created] (BEAM-2579) Improve component determinism methods in StandardCoder

Thomas Groh created BEAM-2579: - Summary: Improve component determinism methods in StandardCoder Key: BEAM-2579 URL: https://issues.apache.org/jira/browse/BEAM-2579 Project: Beam Issue Type: Bug

[GitHub] beam pull request #3402: Add a SlidingWindows Test for Combine without Conte...

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

[GitHub] beam pull request #3049: Update signature for Deterministic Helper

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

[jira] [Commented] (BEAM-2571) Flink ValidatesRunner failing CombineTest.testSlidingWindowsCombineWithContext

[ https://issues.apache.org/jira/browse/BEAM-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081106#comment-16081106 ] Kenneth Knowles commented on BEAM-2571: --- Since this is longstanding, and other tests of side inputs

[jira] [Comment Edited] (BEAM-2571) Flink ValidatesRunner failing CombineTest.testSlidingWindowsCombineWithContext

[ https://issues.apache.org/jira/browse/BEAM-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081106#comment-16081106 ] Kenneth Knowles edited comment on BEAM-2571 at 7/10/17 8:40 PM: Since this

[GitHub] beam pull request #3124: Serialize all Primitive Transforms in the DirectRun...

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

[jira] [Commented] (BEAM-2530) Make Beam compatible with Java 9

[ https://issues.apache.org/jira/browse/BEAM-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081108#comment-16081108 ] Kenneth Knowles commented on BEAM-2530: --- This is still on 2.1.0 burndown. Since it is a meta-issue,

[jira] [Resolved] (BEAM-2505) When EOW != GC and the timers fire in together, the output is not marked as the final pane

[ https://issues.apache.org/jira/browse/BEAM-2505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-2505. Resolution: Fixed > When EOW != GC and the timers fire in together, the output is

[jira] [Commented] (BEAM-2505) When EOW != GC and the timers fire in together, the output is not marked as the final pane

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

[jira] [Resolved] (BEAM-2502) Processing time timers for expired windows are not ignored

[ https://issues.apache.org/jira/browse/BEAM-2502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-2502. Resolution: Fixed > Processing time timers for expired windows are not ignored >

[jira] [Resolved] (BEAM-2551) KafkaIO reader blocks indefinitely if servers are not reachable

[ https://issues.apache.org/jira/browse/BEAM-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-2551. Resolution: Fixed > KafkaIO reader blocks indefinitely if servers are not reachable

[GitHub] beam pull request #3511: [BEAM-2505, BEAM-2502] Fixes to ReduceFnRunner.onTi...

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

[3/3] beam git commit: This closes #3511

This closes #3511 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5c4ea884 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5c4ea884 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5c4ea884 Branch:

[1/3] beam git commit: Process timer firings for a window together

Repository: beam Updated Branches: refs/heads/release-2.1.0 2351c7e33 -> 5c4ea884d Process timer firings for a window together Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b1e53d6d Tree:

[2/3] beam git commit: Ignore processing time timers in expired windows

Ignore processing time timers in expired windows Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3d7b0098 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3d7b0098 Diff:

[jira] [Commented] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080997#comment-16080997 ] Dmitry Demeshchuk commented on BEAM-2573: - [~sb2nov] Thanks for the explanation! I'll wait till the

[GitHub] beam pull request #3513: [BEAM-2551] Cherrypick #3492 to 2.1.0

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

[jira] [Commented] (BEAM-2551) KafkaIO reader blocks indefinitely if servers are not reachable

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

[2/2] beam git commit: This closes #3513

This closes #3513 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2351c7e3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2351c7e3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2351c7e3 Branch:

[1/2] beam git commit: Add timeout to initialization of partition in KafkaIO

Repository: beam Updated Branches: refs/heads/release-2.1.0 7f2419f09 -> 2351c7e33 Add timeout to initialization of partition in KafkaIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/38fc2b2e Tree:

[jira] [Resolved] (BEAM-2534) KafkaIO should allow gaps in message offsets

[ https://issues.apache.org/jira/browse/BEAM-2534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-2534. Resolution: Fixed > KafkaIO should allow gaps in message offsets >

[GitHub] beam pull request #3514: [BEAM-2534] Cherry-pick #3461 into 2.1.0.

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

[1/2] beam git commit: [BEAM-2534] Handle offset gaps in Kafka messages.

Repository: beam Updated Branches: refs/heads/release-2.1.0 de7652b2a -> 7f2419f09 [BEAM-2534] Handle offset gaps in Kafka messages. KafkaIO logged a warning when there is a gap in offstes for messages. Kafka also support 'KV' store style topics where some of the messages are deleted leading

[2/2] beam git commit: This closes #3514

This closes #3514 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7f2419f0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7f2419f0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7f2419f0 Branch:

[jira] [Commented] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080974#comment-16080974 ] Sourabh Bajaj commented on BEAM-2573: - I think the plugins are working correctly if they are passing a

[jira] [Commented] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080933#comment-16080933 ] Dmitry Demeshchuk commented on BEAM-2573: - Hmm, looks like it was indeed a dependency issue which

[jira] [Commented] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080889#comment-16080889 ] Dmitry Demeshchuk commented on BEAM-2573: - Hmm, now it's getting a bit past that, but my pipeline

[jira] [Commented] (BEAM-2573) Better filesystem discovery mechanism in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080867#comment-16080867 ] Dmitry Demeshchuk commented on BEAM-2573: - So, I tried to switch to the head version of the SDK and

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2596

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3362

See

[jira] [Commented] (BEAM-934) Findbugs doesn't pass in Java8 Examples

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

  1   2   >