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

[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] [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:

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3363

See

[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

[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

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2597

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

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:

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3364

See

[GitHub] beam pull request #3526: BEAM-934 Findbugs doesn't pass in Java8 Examples

Github user eralmas7 closed the pull request at: https://github.com/apache/beam/pull/3526 --- 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 #3526: BEAM-934 Findbugs doesn't pass in Java8 Examples

GitHub user eralmas7 reopened a pull request: https://github.com/apache/beam/pull/3526 BEAM-934 Findbugs doesn't pass in Java8 Examples Maven Build result: ... [INFO] --- maven-install-plugin:2.5.2:install (default-install) @ beam-examples-java8 --- [INFO]

[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=16080595#comment-16080595 ] ASF GitHub Bot commented on BEAM-934: - Github user eralmas7 closed the pull request at:

[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=16080644#comment-16080644 ] Kenneth Knowles commented on BEAM-2571: --- Ouch. I don't see any way around just always adapting it.

[jira] [Commented] (BEAM-2231) ApiSurface should be lazy

[ https://issues.apache.org/jira/browse/BEAM-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080713#comment-16080713 ] Innocent commented on BEAM-2231: Thank you for your reply, will further check tonight. > ApiSurface should

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2596

See

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

[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

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

[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

[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

[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

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

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

[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

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

[jira] [Created] (BEAM-2576) Move non-core transform payloads out of Runner API proto

Kenneth Knowles created BEAM-2576: - Summary: Move non-core transform payloads out of Runner API proto Key: BEAM-2576 URL: https://issues.apache.org/jira/browse/BEAM-2576 Project: Beam Issue

[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=16080596#comment-16080596 ] ASF GitHub Bot commented on BEAM-934: - GitHub user eralmas7 reopened a pull request:

[jira] [Created] (BEAM-2577) IO tests should exercise Runtime Values where supported

Ben Chambers created BEAM-2577: -- Summary: IO tests should exercise Runtime Values where supported Key: BEAM-2577 URL: https://issues.apache.org/jira/browse/BEAM-2577 Project: Beam Issue Type:

[jira] [Commented] (BEAM-2577) IO tests should exercise Runtime Values where supported

[ https://issues.apache.org/jira/browse/BEAM-2577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080633#comment-16080633 ] Ben Chambers commented on BEAM-2577: I looked for other places in the codebase that did this testing to

[jira] [Commented] (BEAM-1939) Serialize more coders via URN + Class name

[ https://issues.apache.org/jira/browse/BEAM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080705#comment-16080705 ] Innocent commented on BEAM-1939: Thank you for your comment will look at it later today. > Serialize more

[jira] [Commented] (BEAM-2404) BigQueryIO reading stalls if no data is returned by query

[ https://issues.apache.org/jira/browse/BEAM-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080563#comment-16080563 ] Andre commented on BEAM-2404: - Sorry guys, got distracted with other stuff. It looks like the problem is

[jira] [Reopened] (BEAM-2404) BigQueryIO reading stalls if no data is returned by query

[ https://issues.apache.org/jira/browse/BEAM-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andre reopened BEAM-2404: - reopening > BigQueryIO reading stalls if no data is returned by query >

[GitHub] beam pull request #3534: Beam-933 Findbugs doesn't pass in Java Examples

GitHub user eralmas7 opened a pull request: https://github.com/apache/beam/pull/3534 Beam-933 Findbugs doesn't pass in Java Examples [INFO] --- maven-failsafe-plugin:2.20:integration-test (default) @ beam-examples-java --- [INFO] Tests are skipped. [INFO] [INFO] ---

[jira] [Updated] (BEAM-2578) Unable to run DebuggingWordCountTest on Windows

[ https://issues.apache.org/jira/browse/BEAM-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Almas Shaikh updated BEAM-2578: --- Summary: Unable to run DebuggingWordCountTest on Windows (was: Unable to run DebuggingWordCountTest)

[jira] [Updated] (BEAM-2578) DebuggingWordCountTest Fails on Windows

[ https://issues.apache.org/jira/browse/BEAM-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Almas Shaikh updated BEAM-2578: --- Summary: DebuggingWordCountTest Fails on Windows (was: Unable to run DebuggingWordCountTest on

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

[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=16080774#comment-16080774 ] ASF GitHub Bot commented on BEAM-934: - GitHub user eralmas7 reopened a pull request:

[GitHub] beam pull request #3535: BEAM-2578 DebuggingWordCountTest Fails on Windows

GitHub user eralmas7 opened a pull request: https://github.com/apache/beam/pull/3535 BEAM-2578 DebuggingWordCountTest Fails on Windows [INFO] --- maven-failsafe-plugin:2.20:integration-test (default) @ beam-examples-java --- [INFO] Tests are skipped. [INFO] [INFO] ---

[GitHub] beam pull request #3526: BEAM-934 Findbugs doesn't pass in Java8 Examples

GitHub user eralmas7 reopened a pull request: https://github.com/apache/beam/pull/3526 BEAM-934 Findbugs doesn't pass in Java8 Examples Maven Build result: ... [INFO] --- maven-install-plugin:2.5.2:install (default-install) @ beam-examples-java8 --- [INFO]

[GitHub] beam pull request #3526: BEAM-934 Findbugs doesn't pass in Java8 Examples

Github user eralmas7 closed the pull request at: https://github.com/apache/beam/pull/3526 --- 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=16080623#comment-16080623 ] Aljoscha Krettek commented on BEAM-2571: [~kenn] with some super ugly debugging I think I found at

[jira] [Created] (BEAM-2578) Unable to run DebuggingWordCountTest

Almas Shaikh created BEAM-2578: -- Summary: Unable to run DebuggingWordCountTest Key: BEAM-2578 URL: https://issues.apache.org/jira/browse/BEAM-2578 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-2578) DebuggingWordCountTest Fails on Windows

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

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3362

See

[jira] [Assigned] (BEAM-2564) Add integration test for string operators

[ https://issues.apache.org/jira/browse/BEAM-2564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Xu reassigned BEAM-2564: -- Assignee: James Xu > Add integration test for string operators >

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2594

See

[jira] [Commented] (BEAM-2230) Core SDK ApiSurface should be only org.apache.beam.sdk and should be defined outside of the general ApiSurface class

[ https://issues.apache.org/jira/browse/BEAM-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16080710#comment-16080710 ] Innocent commented on BEAM-2230: Create a v0 pull request for this https://github.com/apache/beam/pull/3533

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2600

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3367

See

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

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

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

See

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

[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

[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

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3369

See

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4346

See

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

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

[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

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

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

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3368

See

[beam] Git Push Summary

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

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2601

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2603

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

Jenkins build is unstable: beam_PostCommit_Java_MavenInstall #4343

See

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

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

[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

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

[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

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

[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

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3365

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2599

See

[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

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.

[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

[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

  1   2   >