[jira] [Created] (BEAM-2088) Add SocketIO

Jean-Baptiste Onofré created BEAM-2088: -- Summary: Add SocketIO Key: BEAM-2088 URL: https://issues.apache.org/jira/browse/BEAM-2088 Project: Beam Issue Type: New Feature Compone

[jira] [Resolved] (BEAM-1505) Provide XML format utils extension

[ https://issues.apache.org/jira/browse/BEAM-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-1505. Resolution: Implemented Fix Version/s: Not applicable Available here: https:/

[jira] [Assigned] (BEAM-1857) Add Neo4jIO

[ https://issues.apache.org/jira/browse/BEAM-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-1857: -- Assignee: (was: Jean-Baptiste Onofré) > Add Neo4jIO > --- > >

[jira] [Assigned] (BEAM-2009) support JdbcIO as source/sink

[ https://issues.apache.org/jira/browse/BEAM-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-2009: -- Assignee: (was: Jean-Baptiste Onofré) > support JdbcIO as source/sink >

[jira] [Commented] (BEAM-2074) SourceDStream's rate control mechanism may not work

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

[GitHub] beam pull request #2733: [BEAM-2074,BEAM-2073] Fixed SourceDStream's rate co...

GitHub user staslev opened a pull request: https://github.com/apache/beam/pull/2733 [BEAM-2074,BEAM-2073] Fixed SourceDStream's rate control usage. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR tit

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Dataflow #2944

See -- [...truncated 2.09 MB...] [INFO] Closing reader after reading 9 records. [WARNING] ByteKeyRangeTracker{range=ByteKeyRange{startKey=[6b657930303030303

[jira] [Commented] (BEAM-2087) conda python breaks the python tests

[ https://issues.apache.org/jira/browse/BEAM-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986067#comment-15986067 ] Davor Bonaci commented on BEAM-2087: Thanks [~holdenk]. > conda python breaks the pyth

[jira] [Assigned] (BEAM-2087) conda python breaks the python tests

[ https://issues.apache.org/jira/browse/BEAM-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2087: -- Assignee: Ahmet Altay (was: Davor Bonaci) > conda python breaks the python tests >

[GitHub] beam pull request #2732: Simplify Travis CI config for quick lightweight sig...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2732 Simplify Travis CI config for quick lightweight signal Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Commented] (BEAM-2086) TestDataflowRunner relies on metrics which are not present in streaming jobs

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

[GitHub] beam pull request #2731: [BEAM-2086] Remove TestDataflowRunner reliance on m...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2731 [BEAM-2086] Remove TestDataflowRunner reliance on metrics in streaming Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[jira] [Commented] (BEAM-2057) Test metrics are reported to Spark Metrics sink.

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

[GitHub] beam pull request #2730: [BEAM-2057] Add a test for metrics reporting in Spa...

GitHub user holdenk opened a pull request: https://github.com/apache/beam/pull/2730 [BEAM-2057] Add a test for metrics reporting in Spark Add a test for metrics reporting in Spark You can merge this pull request into a Git repository by running: $ git pull https://github.com/ho

[jira] [Created] (BEAM-2087) conda python breaks the python tests

holdenk created BEAM-2087: - Summary: conda python breaks the python tests Key: BEAM-2087 URL: https://issues.apache.org/jira/browse/BEAM-2087 Project: Beam Issue Type: Improvement Component

[jira] [Commented] (BEAM-1763) TestPipeline should ensure that all assertions succeeded

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

[GitHub] beam pull request #2729: [BEAM-1763] Verify PAssert execution in runners whi...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2729 [BEAM-1763] Verify PAssert execution in runners which support metrics. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure th

[jira] [Commented] (BEAM-2004) Verify PAssert execution in TestApexRunner

[ https://issues.apache.org/jira/browse/BEAM-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986034#comment-15986034 ] Thomas Weise commented on BEAM-2004: [~aviemzur] I'm not working on this and I don't th

[jira] [Assigned] (BEAM-2004) Verify PAssert execution in TestApexRunner

[ https://issues.apache.org/jira/browse/BEAM-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned BEAM-2004: -- Assignee: (was: Thomas Weise) > Verify PAssert execution in TestApexRunner > ---

Jenkins build is unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #2943

See

[jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner

[ https://issues.apache.org/jira/browse/BEAM-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986007#comment-15986007 ] Davor Bonaci commented on BEAM-1542: [~guymolinari], I was tracking your work and thank

[jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner

[ https://issues.apache.org/jira/browse/BEAM-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985996#comment-15985996 ] Guy Molinari commented on BEAM-1542: [~davor] Davor, Mairbek, myself (and others)

[jira] [Commented] (BEAM-2004) Verify PAssert execution in TestApexRunner

[ https://issues.apache.org/jira/browse/BEAM-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985987#comment-15985987 ] Aviem Zur commented on BEAM-2004: - Adding this back to First stable release. [~thw] is the

[jira] [Commented] (BEAM-59) Switch from IOChannelFactory to FileSystems

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

[jira] [Updated] (BEAM-2004) Verify PAssert execution in TestApexRunner

[ https://issues.apache.org/jira/browse/BEAM-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-2004: Fix Version/s: First stable release > Verify PAssert execution in TestApexRunner > --

[GitHub] beam pull request #2728: [BEAM-59] Add FileSystems#matchNewResource

GitHub user dhalperi opened a pull request: https://github.com/apache/beam/pull/2728 [BEAM-59] Add FileSystems#matchNewResource The new FileSystems API needs a way to generate a ResourceId for a resource that does not exist. This does not come up in sources, because we typica

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #3487

See

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1794

See

[GitHub] beam pull request #2725: Revert "Replace OutputTimeFn UDF with TimestampComb...

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

[4/4] beam git commit: This closes #2725: Revert "Replace OutputTimeFn UDF with TimestampCombiner enum"

This closes #2725: Revert "Replace OutputTimeFn UDF with TimestampCombiner enum" Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b82cd244 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b82cd244 Diff: http://git-wip-us.ap

[2/4] beam git commit: Revert "Replace OutputTimeFn UDF with TimestampCombiner enum"

http://git-wip-us.apache.org/repos/asf/beam/blob/83d41fcc/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SortingFlinkCombineRunner.java -- diff --git a/runners/flink/src/main/java/org/apache/beam/r

[1/4] beam git commit: Revert "Replace OutputTimeFn UDF with TimestampCombiner enum"

Repository: beam Updated Branches: refs/heads/master 3bcbba121 -> b82cd2446 http://git-wip-us.apache.org/repos/asf/beam/blob/83d41fcc/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowingStrategy.java -- diff --git a

[3/4] beam git commit: Revert "Replace OutputTimeFn UDF with TimestampCombiner enum"

Revert "Replace OutputTimeFn UDF with TimestampCombiner enum" This reverts commit f38e4271334fced94e8dc1dc97f47b60fa810586. It will require a synchronous Dataflow worker container bump. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam

[GitHub] beam pull request #2726: Revert "Make WindowedValueCoder an Interface"

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2726 --- 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: Revert "Make WindowedValueCoder an Interface"

Repository: beam Updated Branches: refs/heads/master bb12a56e6 -> 3bcbba121 Revert "Make WindowedValueCoder an Interface" This reverts commit 691269565b537370c133598c2c32bd3f87eb8c29. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/bea

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

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

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3486

See

[jira] [Commented] (BEAM-2020) Move CloudObject to Dataflow runner

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

[GitHub] beam pull request #2727: [BEAM-2020] Add CloudObjectTranslators for Proto, A...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2727 [BEAM-2020] Add CloudObjectTranslators for Proto, Avro, Serializable Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[GitHub] beam pull request #2726: Revert "Make WindowedValueCoder an Interface"

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2726 Revert "Make WindowedValueCoder an Interface" This reverts commit 691269565b537370c133598c2c32bd3f87eb8c29. Be sure to do all of the following to help us incorporate your contribution quick

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3485

See

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3484

See

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3483

See

[GitHub] beam pull request #2725: Revert "Replace OutputTimeFn UDF with TimestampComb...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2725 Revert "Replace OutputTimeFn UDF with TimestampCombiner enum" This reverts commit f38e4271334fced94e8dc1dc97f47b60fa810586. It will require a synchronous Dataflow worker container bump.

[jira] [Commented] (BEAM-2086) TestDataflowRunner relies on metrics which are not present in streaming jobs

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

[GitHub] beam pull request #2721: [BEAM-2086] Remove TestDataflowRunner reliance on m...

Github user kennknowles closed the pull request at: https://github.com/apache/beam/pull/2721 --- 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 #2723: FileBasedSink: fix typos

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

Repository: beam Updated Branches: refs/heads/master 330bc1a6d -> bb12a56e6 FileBasedSink: fix typos Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0d64ae2c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0d64ae2c Di

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

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

[jira] [Commented] (BEAM-2020) Move CloudObject to Dataflow runner

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

[GitHub] beam pull request #2716: [BEAM-2020] Add Registrars for Coder Cloud Object T...

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

Repository: beam Updated Branches: refs/heads/master a0b077f5e -> 330bc1a6d This closes #2716 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/330bc1a6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/330bc1a6 Diff: htt

[2/2] beam git commit: Add Registrars for Coder Cloud Object Translators

Add Registrars for Coder Cloud Object Translators This permits registration of a Translator for an arbitrary coder. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d835a6ea Tree: http://git-wip-us.apache.org/repos/asf/beam/tree

[GitHub] beam pull request #2603: [BEAM-2019] Count.globally() requires default value...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2603 --- 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-2019) Count.globally() requires default values for non-GlobalWindows

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

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

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

[1/2] beam git commit: update JavaDoc for Count.globally

Repository: beam Updated Branches: refs/heads/master 412b610ed -> a0b077f5e update JavaDoc for Count.globally Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ea230f1a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ea

[jira] [Commented] (BEAM-59) Switch from IOChannelFactory to FileSystems

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

[GitHub] beam pull request #2724: [BEAM-59] Move IOChannelUtils.constructName to File...

GitHub user dhalperi opened a pull request: https://github.com/apache/beam/pull/2724 [BEAM-59] Move IOChannelUtils.constructName to FileBasedSink R: @peihe OR @reuvenlax OR @kennknowles You can merge this pull request into a Git repository by running: $ git pull https://github

[GitHub] beam pull request #2723: FileBasedSink: fix typos

GitHub user dhalperi opened a pull request: https://github.com/apache/beam/pull/2723 FileBasedSink: fix typos Trivial PR: R: anyone You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/beam filebasedsink-trivial Alte

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3482

See

[jira] [Commented] (BEAM-1871) Thin Java SDK Core

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

[GitHub] beam pull request #2722: [BEAM-1871] Move several options/auth classes aroun...

GitHub user lukecwik opened a pull request: https://github.com/apache/beam/pull/2722 [BEAM-1871] Move several options/auth classes around in gcp-core Note that I kept a duplicate of GcsOptions because of its direct usage within the Dataflow Worker Be sure to do all of the f

[4/5] beam git commit: Factor out URN registration logic.

Factor out URN registration logic. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/87a475e4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/87a475e4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/87a475e4 Branch:

[GitHub] beam pull request #2595: [Beam-115] More complete translation of the graph t...

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

[5/5] beam git commit: Closes #2595

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

[3/5] beam git commit: Translate WindowInto through the Runner API.

Translate WindowInto through the Runner API. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a95fc199 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a95fc199 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a95fc19

[1/5] beam git commit: Translate flatten to Runner API.

Repository: beam Updated Branches: refs/heads/master 26c61f414 -> 412b610ed Translate flatten to Runner API. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d096b19a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d09

[2/5] beam git commit: Per-transform runner api dispatch.

Per-transform runner api dispatch. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/97c9b174 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/97c9b174 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/97c9b174 Branch:

[jira] [Commented] (BEAM-1316) DoFn#startBundle should not be able to output

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

[GitHub] beam pull request #2715: [BEAM-1316] start bundle should not output any elem...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2715 --- 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-1316] start bundle should not output any elements

Repository: beam Updated Branches: refs/heads/master 3961ce46c -> 26c61f414 [BEAM-1316] start bundle should not output any elements Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1360c21d Tree: http://git-wip-us.apache.org/

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

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

[GitHub] beam pull request #2696: Do not depend on message id in DataflowRunner

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2696 --- 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: Do not depend on message id in DataflowRunner

Repository: beam Updated Branches: refs/heads/master 650ee8ea6 -> 3961ce46c Do not depend on message id in DataflowRunner This field is deprecated and causing messages to be repeated. Hash message to avoid printing duplicate messages. Project: http://git-wip-us.apache.org/repos/asf/beam/repo

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

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

[jira] [Created] (BEAM-2086) TestDataflowRunner relies on metrics which are not present in streaming jobs

Kenneth Knowles created BEAM-2086: - Summary: TestDataflowRunner relies on metrics which are not present in streaming jobs Key: BEAM-2086 URL: https://issues.apache.org/jira/browse/BEAM-2086 Project: B

[jira] [Commented] (BEAM-2086) TestDataflowRunner relies on metrics which are not present in streaming jobs

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

[GitHub] beam pull request #2721: [BEAM-2086] Remove TestDataflowRunner reliance on m...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2721 [BEAM-2086] Remove TestDataflowRunner reliance on metrics in streaming Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[jira] [Commented] (BEAM-1871) Thin Java SDK Core

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

[GitHub] beam pull request #2713: [BEAM-1871] Clean-up org.apache.beam.sdk.util, move...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2713 --- 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/3] beam git commit: [BEAM-1871] Clean-up org.apache.beam.sdk.util, move BitSetCoder from util to coder

[BEAM-1871] Clean-up org.apache.beam.sdk.util, move BitSetCoder from util to coder Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/11a20ffb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/11a20ffb Diff: http://git-wip-us

[1/3] beam git commit: [BEAM-1871] Re-add BitSetCoder to sdk/util for Dataflow worker.

Repository: beam Updated Branches: refs/heads/master a32371eb3 -> 650ee8ea6 [BEAM-1871] Re-add BitSetCoder to sdk/util for Dataflow worker. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7d76e100 Tree: http://git-wip-us.apa

[3/3] beam git commit: [BEAM-1871] Clean-up org.apache.beam.sdk.util, move BitSetCoder from util to coder

[BEAM-1871] Clean-up org.apache.beam.sdk.util, move BitSetCoder from util to coder This closes #2713 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/650ee8ea Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/650ee8ea Diff

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #1789

See

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3481

See

[GitHub] beam pull request #2720: [BEAM-2021] Rename StandardCoder to StructuredCoder

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2720 [BEAM-2021] Rename StandardCoder to StructuredCoder Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatte

[jira] [Commented] (BEAM-2021) Fix Java's Coder class hierarchy

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

[jira] [Commented] (BEAM-528) Add @experimental annotations

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

[GitHub] beam pull request #2719: [BEAM-528] Add extra message to deprecated annotati...

GitHub user mariapython opened a pull request: https://github.com/apache/beam/pull/2719 [BEAM-528] Add extra message to deprecated annotation Augment deprecated decorator so that it can give a message/instructions. You can merge this pull request into a Git repository by running:

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3480

See

[jira] [Commented] (BEAM-539) Error when writing to the root of a GCS location

[ https://issues.apache.org/jira/browse/BEAM-539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985701#comment-15985701 ] Chamikara Jayalath commented on BEAM-539: - We currently write temp files to a siblin

[jira] [Commented] (BEAM-775) Remove Aggregators from the Java SDK

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

[GitHub] beam pull request #2718: [BEAM-775] Remove Aggregators from the Java SDK

GitHub user pabloem opened a pull request: https://github.com/apache/beam/pull/2718 [BEAM-775] Remove Aggregators from the Java SDK Removing from internal SDK usage and DoFn contexts so users can not create them. Some failures in Apex code remain. All else seems to be `mvn clean

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1788

See

[GitHub] beam pull request #2709: Dummy change to trigger jenkins

GitHub user jasonkuster reopened a pull request: https://github.com/apache/beam/pull/2709 Dummy change to trigger jenkins 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:

[GitHub] beam pull request #2709: Dummy change to trigger jenkins

Github user jasonkuster closed the pull request at: https://github.com/apache/beam/pull/2709 --- 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_MavenInstall #3479

See

[jira] [Resolved] (BEAM-1327) Replace OutputTimeFn with enum

[ https://issues.apache.org/jira/browse/BEAM-1327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1327. --- Resolution: Fixed > Replace OutputTimeFn with enum > -- > >

[jira] [Commented] (BEAM-1327) Replace OutputTimeFn with enum

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

  1   2   3   >