Jenkins build is unstable: beam_PostCommit_Java_MavenInstall #2557

See

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Dataflow #2219

See Changes: [younghee.kwon] Improve DirectRunner performance by tuning BoundedReadEvaluator. [altay] Removes deprecated fileio.TextFileSink. -- [...truncated 27

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Flink #1562

See

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Spark #870

See Changes: [altay] Removes deprecated fileio.TextFileSink. -- [...truncated 26 lines...] Modules changed, recalculating dependency graph Established TCP socket on 4

[jira] [Commented] (BEAM-1406) Remove deprecated fileio.TextFileSink

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

[GitHub] beam pull request #1932: [BEAM-1406] Removes deprecated fileio.TextFileSink

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

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

This closes #1932 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9dad73c2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9dad73c2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9dad73c2 Branch: refs/heads/maste

[1/2] beam git commit: Removes deprecated fileio.TextFileSink.

Repository: beam Updated Branches: refs/heads/master 232869747 -> 9dad73c29 Removes deprecated fileio.TextFileSink. Users should be using textio.WriteToText() transform instead of fileio.TextFileSink. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Spark #869

See Changes: [younghee.kwon] Improve DirectRunner performance by tuning BoundedReadEvaluator. -- [...truncated 26 lines...] Modules changed, recalculating dependency

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2556

See Changes: [younghee.kwon] Improve DirectRunner performance by tuning BoundedReadEvaluator. -- [...truncated 26 lines...] Modules changed, recalculating dependency graph Esta

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Flink #1561

See Changes: [younghee.kwon] Improve DirectRunner performance by tuning BoundedReadEvaluator. -- [...truncated 26 lines...] Modules changed, recalculating dependency

[GitHub] beam pull request #1933: [BEAM-1410] Improve DirectRunner performance by tun...

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

[jira] [Commented] (BEAM-1410) Reduce sdk-py DirectRunner running time and memory consumption

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

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

This closes #1933 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/23286974 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/23286974 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/23286974 Branch: refs/heads/maste

[1/2] beam git commit: Improve DirectRunner performance by tuning BoundedReadEvaluator.

Repository: beam Updated Branches: refs/heads/master f90558c34 -> 232869747 Improve DirectRunner performance by tuning BoundedReadEvaluator. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d34145ad Tree: http://git-wip-us.ap

[jira] [Commented] (BEAM-1410) Reduce sdk-py DirectRunner running time and memory consumption

[ https://issues.apache.org/jira/browse/BEAM-1410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855386#comment-15855386 ] ASF GitHub Bot commented on BEAM-1410: -- GitHub user yk5 opened a pull request: ht

[GitHub] beam pull request #1933: [BEAM-1410] Improve DirectRunner performance by tun...

GitHub user yk5 opened a pull request: https://github.com/apache/beam/pull/1933 [BEAM-1410] Improve DirectRunner performance by tuning BoundedReadEvaluator. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure t

[jira] [Created] (BEAM-1410) Reduce sdk-py DirectRunner running time and memory consumption

Younghee Kwon created BEAM-1410: --- Summary: Reduce sdk-py DirectRunner running time and memory consumption Key: BEAM-1410 URL: https://issues.apache.org/jira/browse/BEAM-1410 Project: Beam Issu

[jira] [Commented] (BEAM-1331) Add documentation from reading compressed text sources

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

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

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

[1/2] beam git commit: Add snippet for reading from compressed text sources

Repository: beam Updated Branches: refs/heads/master a26fd1ff3 -> f90558c34 Add snippet for reading from compressed text sources Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/98e513bc Tree: http://git-wip-us.apache.org/rep

[GitHub] beam pull request #1845: [BEAM-1331] Add snippet for reading from compressed...

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

[jira] [Resolved] (BEAM-722) Add Display Data to the Python SDK

[ https://issues.apache.org/jira/browse/BEAM-722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-722. -- Resolution: Fixed Fix Version/s: Not applicable > Add Display Data to the Python SDK >

[jira] [Resolved] (BEAM-614) File compression/decompression should support auto detection

[ https://issues.apache.org/jira/browse/BEAM-614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-614. -- Resolution: Fixed Fix Version/s: Not applicable > File compression/decompression should support aut

[jira] [Resolved] (BEAM-525) Verify that ParDo with multiple outputs with tags un declared in with_outputs() work

[ https://issues.apache.org/jira/browse/BEAM-525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-525. -- Resolution: Fixed Fix Version/s: Not applicable > Verify that ParDo with multiple outputs with tags

[jira] [Resolved] (BEAM-8) Import Python SDK

[ https://issues.apache.org/jira/browse/BEAM-8?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-8. Resolution: Fixed Fix Version/s: Not applicable > Import Python SDK > - > >

[jira] [Resolved] (BEAM-1090) High memory usage error

[ https://issues.apache.org/jira/browse/BEAM-1090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-1090. --- Resolution: Fixed Assignee: Ahmet Altay Fix Version/s: Not applicable > High memory usa

[jira] [Assigned] (BEAM-1116) Support for new Timer API in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned BEAM-1116: -- Assignee: Jingsong Lee > Support for new Timer API in Flink runner > ---

[jira] [Updated] (BEAM-1408) outputWithTimestamp() accepts timestamps that will fail preconditions

[ https://issues.apache.org/jira/browse/BEAM-1408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy Xu updated BEAM-1408: -- Description: We have accidentally created events with *wrong* timestamps in the future which are accepted by out

[jira] [Assigned] (BEAM-1409) The DirectRunner should forbid elements outside of representable time.

[ https://issues.apache.org/jira/browse/BEAM-1409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1409: -- Assignee: Davor Bonaci (was: Thomas Groh) > The DirectRunner should forbid elements outside of

[GitHub] beam pull request #1925: Add git .mailmap file

Github user kennknowles closed the pull request at: https://github.com/apache/beam/pull/1925 --- 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: Add some more RunnableOnService tests for stateful ParDo

Repository: beam Updated Branches: refs/heads/master 0c24286e1 -> a26fd1ff3 Add some more RunnableOnService tests for stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6c00e912 Tree: http://git-wip-us.apache.org

[2/2] beam git commit: This closes #1748: Add some more RunnableOnService tests for stateful ParDo

This closes #1748: Add some more RunnableOnService tests for stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a26fd1ff Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a26fd1ff Diff: http://git-wip-us.apache.

[GitHub] beam pull request #1932: [BEAM-1406] Removes deprecated fileio.TextFileSink

GitHub user chamikaramj opened a pull request: https://github.com/apache/beam/pull/1932 [BEAM-1406] Removes deprecated fileio.TextFileSink Users should be using textio.WriteToText() transform instead of fileio.TextFileSink. You can merge this pull request into a Git repository

[jira] [Commented] (BEAM-1406) Remove deprecated fileio.TextFileSink

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

[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state

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

[jira] [Created] (BEAM-1409) The DirectRunner should forbid elements outside of representable time.

Thomas Groh created BEAM-1409: - Summary: The DirectRunner should forbid elements outside of representable time. Key: BEAM-1409 URL: https://issues.apache.org/jira/browse/BEAM-1409 Project: Beam

[GitHub] beam pull request #1748: [BEAM-25] Some more RunnableOnService tests for sta...

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

[jira] [Commented] (BEAM-1409) The DirectRunner should forbid elements outside of representable time.

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

[GitHub] beam pull request #1931: [BEAM-1409] Check that Elements, Timers have permit...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/1931 [BEAM-1409] Check that Elements, Timers have permitted Timestamps Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR tit

[GitHub] beam pull request #1930: Add support repeated template invocations for BQIO....

GitHub user sammcveety opened a pull request: https://github.com/apache/beam/pull/1930 Add support repeated template invocations for BQIO.Write You can merge this pull request into a Git repository by running: $ git pull https://github.com/sammcveety/incubator-beam add_side_i

[jira] [Commented] (BEAM-1407) Support multiple Kafka client in KakaIO

[ https://issues.apache.org/jira/browse/BEAM-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854963#comment-15854963 ] Xu Mingmin commented on BEAM-1407: -- Thanks! will add a design doc soon. > Support multipl

[jira] [Resolved] (BEAM-1388) Update default configuration of retry decorator so that wait times are more practical

[ https://issues.apache.org/jira/browse/BEAM-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath resolved BEAM-1388. -- Resolution: Fixed Fix Version/s: Not applicable > Update default configuration of

[GitHub] beam pull request #1827: [BEAM-27] Allow absolute timers

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

[jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers

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

[2/2] beam git commit: This closes #1827: Allow absolute timers

This closes #1827: Allow absolute timers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0c24286e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0c24286e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0c24286e B

[1/2] beam git commit: Allow absolute timers

Repository: beam Updated Branches: refs/heads/master f4e109767 -> 0c24286e1 Allow absolute timers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a93c5c05 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a93c5c05 Diff:

[jira] [Updated] (BEAM-1407) Support multiple Kafka client in KakaIO

[ https://issues.apache.org/jira/browse/BEAM-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-1407: - Description: enhance KafkaIO to work with Kafka client 0.9 and 0.10, (maybe 0.8 as well ?), 1). to fully l

[jira] [Commented] (BEAM-1407) Support multiple Kafka client in KakaIO

[ https://issues.apache.org/jira/browse/BEAM-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854947#comment-15854947 ] Davor Bonaci commented on BEAM-1407: Here you go -- enjoy! Please let me know if I can

[jira] [Assigned] (BEAM-1407) Support multiple Kafka client in KakaIO

[ https://issues.apache.org/jira/browse/BEAM-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1407: -- Assignee: Xu Mingmin (was: Davor Bonaci) > Support multiple Kafka client in KakaIO > --

[1/2] beam git commit: [BEAM-65] ProcessFn: support setup/teardown

Repository: beam Updated Branches: refs/heads/master 224e44765 -> f4e109767 [BEAM-65] ProcessFn: support setup/teardown Previously, ProcessFn did not explicitly invoke the underlying fn's @Setup and @Teardown methods - it was assuming that those methods would get invoked on that fn externally.

[2/2] beam git commit: This closes #1895: ProcessFn: support setup/teardown

This closes #1895: ProcessFn: support setup/teardown Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f4e10976 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f4e10976 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff

[GitHub] beam pull request #1895: [BEAM-65] ProcessFn: create invoker in setup()

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

[jira] [Assigned] (BEAM-1405) Spark runner should not close the spark context when set to reuse it

[ https://issues.apache.org/jira/browse/BEAM-1405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-1405: -- Assignee: Jean-Baptiste Onofré (was: Ismaël Mejía) > Spark runner should not cl

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

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

[GitHub] beam pull request #1929: [BEAM-362] Move a few more remnants of internal sta...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/1929 [BEAM-362] Move a few more remnants of internal state to runners/core-java Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[jira] [Updated] (BEAM-1407) Support multiple Kafka client in KakaIO

[ https://issues.apache.org/jira/browse/BEAM-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-1407: - Summary: Support multiple Kafka client in KakaIO (was: Support Kafka client 0.10 in KakaIO) > Support mul

[jira] [Created] (BEAM-1408) outputWithTimestamp() accepts timestamps that will fail preconditions

Andy Xu created BEAM-1408: - Summary: outputWithTimestamp() accepts timestamps that will fail preconditions Key: BEAM-1408 URL: https://issues.apache.org/jira/browse/BEAM-1408 Project: Beam Issue Typ

[jira] [Commented] (BEAM-65) SplittableDoFn

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

[jira] [Commented] (BEAM-425) Create Elasticsearch IO

[ https://issues.apache.org/jira/browse/BEAM-425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854912#comment-15854912 ] Jean-Baptiste Onofré commented on BEAM-425: --- We already have a branch with a elast

[jira] [Assigned] (BEAM-425) Create Elasticsearch IO

[ https://issues.apache.org/jira/browse/BEAM-425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-425: - Assignee: Jean-Baptiste Onofré (was: Etienne Chauchot) > Create Elasticsearch IO >

[jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java

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

[GitHub] beam pull request #1858: [BEAM-362] Move state-oriented remnants of OldDoFn ...

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

[jira] [Created] (BEAM-1407) Support Kafka client 0.10 in KakaIO

Xu Mingmin created BEAM-1407: Summary: Support Kafka client 0.10 in KakaIO Key: BEAM-1407 URL: https://issues.apache.org/jira/browse/BEAM-1407 Project: Beam Issue Type: Improvement Comp

[06/15] beam git commit: Delete long-deprecated StateContexts methods

Delete long-deprecated StateContexts methods Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b12e5ffb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b12e5ffb Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b12e5ff

[14/15] beam git commit: Move StateInternals to runners/core-java

Move StateInternals to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/144b1df8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/144b1df8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/144b1df8 B

[05/15] beam git commit: Move WindowingInternals to runners/core-java

Move WindowingInternals to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/949ab3ac Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/949ab3ac Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/949ab3a

[08/15] beam git commit: Move StateNamespace and related to runners/core-java

http://git-wip-us.apache.org/repos/asf/beam/blob/e77e7f0d/sdks/java/core/src/test/java/org/apache/beam/sdk/util/state/StateNamespacesTest.java -- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/state/StateNamesp

[04/15] beam git commit: Move StateInternalsFactory to runners/core-java

Move StateInternalsFactory to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2e6c1310 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2e6c1310 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2e6c

[09/15] beam git commit: Move StateNamespace and related to runners/core-java

Move StateNamespace and related to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e77e7f0d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e77e7f0d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff

[11/15] beam git commit: Move TimerInternals to runners/core-java

Move TimerInternals to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b086d2fd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b086d2fd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b086d2fd B

[01/15] beam git commit: Move TimerInternalsFactory to runners/core-java

Repository: beam Updated Branches: refs/heads/master e0189f352 -> 224e44765 Move TimerInternalsFactory to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/92b33bc7 Tree: http://git-wip-us.apache.org/repos/as

[jira] [Commented] (BEAM-1407) Support Kafka client 0.10 in KakaIO

[ https://issues.apache.org/jira/browse/BEAM-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854892#comment-15854892 ] Xu Mingmin commented on BEAM-1407: -- [~davor], can you assign this task to me? > Support K

[15/15] beam git commit: This closes #1858: Move state-oriented remnants of OldDoFn to runners/core-java

This closes #1858: Move state-oriented remnants of OldDoFn to runners/core-java Upgrade Dataflow container version to beam-master-20170203 Move StateNamespace and related to runners/core-java Move StateInternals to runners/core-java Move StateTable to runners/core-java Move TimerInternal

[02/15] beam git commit: Move InMemoryStateInternals to runners/core-java

Move InMemoryStateInternals to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/af391b88 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/af391b88 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/af3

[13/15] beam git commit: Move StateTable to runners/core-java

Move StateTable to runners/core-java Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4e4391c8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4e4391c8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4e4391c8 Branc

[12/15] beam git commit: Upgrade Dataflow container version to beam-master-20170203

Upgrade Dataflow container version to beam-master-20170203 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fd7e6149 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fd7e6149 Diff: http://git-wip-us.apache.org/repos/asf/bea

[03/15] beam git commit: Eliminate use of InMemoryStateInternals in the Java SDK

Eliminate use of InMemoryStateInternals in the Java SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2b6698d1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2b6698d1 Diff: http://git-wip-us.apache.org/repos/asf/beam/d

[07/15] beam git commit: Remove comment-only uses that block runners/core-java migrations

Remove comment-only uses that block runners/core-java migrations Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1d7c6b06 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1d7c6b06 Diff: http://git-wip-us.apache.org/repos/a

[10/15] beam git commit: Move TimerInternals to runners/core-java

http://git-wip-us.apache.org/repos/asf/beam/blob/b086d2fd/sdks/java/core/src/main/java/org/apache/beam/sdk/util/TimerInternals.java -- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/TimerInternals.java b/sdks/

[jira] [Commented] (BEAM-588) All runners should support ProfilingOptions

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

[GitHub] beam pull request #1928: [BEAM-588] Add MemoryReporter to python-sdk

GitHub user yk5 opened a pull request: https://github.com/apache/beam/pull/1928 [BEAM-588] Add MemoryReporter to python-sdk Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[jira] [Created] (BEAM-1406) Remove deprecated fileio.TextFileSink

Chamikara Jayalath created BEAM-1406: Summary: Remove deprecated fileio.TextFileSink Key: BEAM-1406 URL: https://issues.apache.org/jira/browse/BEAM-1406 Project: Beam Issue Type: Improvem

[jira] [Commented] (BEAM-1404) Coveralls should not mark the build as "failed"

[ https://issues.apache.org/jira/browse/BEAM-1404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854766#comment-15854766 ] Davor Bonaci commented on BEAM-1404: This is just a config number inside Coveralls, the

[jira] [Commented] (BEAM-1389) Remove or update Flink Runner README.md

[ https://issues.apache.org/jira/browse/BEAM-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854761#comment-15854761 ] Davor Bonaci commented on BEAM-1389: Website is much more visible; I'd suggest that ove

[jira] [Resolved] (BEAM-1395) SparkGroupAlsoByWindowFn not sorting grouped elements by timestamp

[ https://issues.apache.org/jira/browse/BEAM-1395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-1395. - Resolution: Fixed Fix Version/s: 0.6.0 > SparkGroupAlsoByWindowFn not sorting grouped elements by ti

[jira] [Commented] (BEAM-1395) SparkGroupAlsoByWindowFn not sorting grouped elements by timestamp

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

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

This closes #1922 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e0189f35 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e0189f35 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e0189f35 Branch: refs/heads/maste

[GitHub] beam pull request #1922: [BEAM-1395] SparkGroupAlsoByWindowFn not sorting gr...

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

[1/2] beam git commit: [BEAM-1395] Remove chunking.

Repository: beam Updated Branches: refs/heads/master 1e49ee8f2 -> e0189f352 [BEAM-1395] Remove chunking. fixup! formatting. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/71197ae6 Tree: http://git-wip-us.apache.org/repos/a

[jira] [Commented] (BEAM-1388) Update default configuration of retry decorator so that wait times are more practical

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

[GitHub] beam pull request #1916: [BEAM-1388] Updates default values used by retry de...

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

[1/2] beam git commit: Updates default values used by retry decorator.

Repository: beam Updated Branches: refs/heads/master d18db9344 -> 1e49ee8f2 Updates default values used by retry decorator. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/50d00cb4 Tree: http://git-wip-us.apache.org/repos/as

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

This closes #1916 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1e49ee8f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1e49ee8f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1e49ee8f Branch: refs/heads/maste

[jira] [Commented] (BEAM-1369) some unit tests in python take longer than 10s to run

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

[GitHub] beam pull request #1923: [BEAM-1369] Reduce test times for two retry based t...

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

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

This closes #1923 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d18db934 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d18db934 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d18db934 Branch: refs/heads/maste

[1/2] beam git commit: Reduce test times for two retry based tests

Repository: beam Updated Branches: refs/heads/master 7564486f5 -> d18db9344 Reduce test times for two retry based tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ade9c33d Tree: http://git-wip-us.apache.org/repos/asf/be

[jira] [Updated] (BEAM-440) Create.values() returns a type-unsafe Coder

[ https://issues.apache.org/jira/browse/BEAM-440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-440: - Labels: backward-incompatible newbie starter (was: newbie starter) > Create.values() returns a type

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2211

See

  1   2   >