[jira] [Updated] (BEAM-1411) Unable to downgrade to lower guava version after upgrade to beam-0.5

[ https://issues.apache.org/jira/browse/BEAM-1411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1411: -- Fix Version/s: First stable release > Unable to downgrade to lower guava version after upgrade

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Dataflow #2445

See -- [...truncated 3.87 MB...] [INFO] 2017-03-02T07:35:47.270Z: (715e168a75870ca2): Fusing consumer PAssert$280/RunChecks into PAssert$280/GetPane/Map

[GitHub] beam pull request #2139: Update Dataflow container version for release 0.6.0

GitHub user dhalperi opened a pull request: https://github.com/apache/beam/pull/2139 Update Dataflow container version for release 0.6.0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/beam release-0.6.0-patch

[GitHub] beam-site pull request #168: Add windowing section to programming guide

GitHub user melap opened a pull request: https://github.com/apache/beam-site/pull/168 Add windowing section to programming guide R: @kennknowles You can merge this pull request into a Git repository by running: $ git pull https://github.com/melap/beam-site windowing

[jira] [Assigned] (BEAM-1476) Support MapState in Flink runner

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

[jira] [Assigned] (BEAM-1483) Support SetState in Flink runner

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

[jira] [Created] (BEAM-1588) Reuse StateNamespace.stringKey in Flink States

Jingsong Lee created BEAM-1588: -- Summary: Reuse StateNamespace.stringKey in Flink States Key: BEAM-1588 URL: https://issues.apache.org/jira/browse/BEAM-1588 Project: Beam Issue Type:

[jira] [Assigned] (BEAM-1587) Use StringBuilder to stringKey of StateNamespace instead of String.format

[ https://issues.apache.org/jira/browse/BEAM-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned BEAM-1587: -- Assignee: Jingsong Lee (was: Kenneth Knowles) > Use StringBuilder to stringKey of

[jira] [Updated] (BEAM-1587) Use StringBuilder to stringKey of StateNamespace instead of String.format

[ https://issues.apache.org/jira/browse/BEAM-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated BEAM-1587: --- Description: In Flink Runner, each State visit will call the namespace stringKey once. Since

[jira] [Created] (BEAM-1587) Use StringBuilder to stringKey of StateNamespace instead of String.format

Jingsong Lee created BEAM-1587: -- Summary: Use StringBuilder to stringKey of StateNamespace instead of String.format Key: BEAM-1587 URL: https://issues.apache.org/jira/browse/BEAM-1587 Project: Beam

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #1105

See

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1104

See

beam git commit: [maven-release-plugin] prepare branch release-0.6.0

Repository: beam Updated Branches: refs/heads/release-0.6.0 [created] c4e002bfa [maven-release-plugin] prepare branch release-0.6.0 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c4e002bf Tree:

[jira] [Resolved] (BEAM-1548) Window should not reassign windows if no WindowFn is specified

[ https://issues.apache.org/jira/browse/BEAM-1548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-1548. --- Resolution: Fixed Fix Version/s: 0.6.0 > Window should not reassign windows if no WindowFn is

[jira] [Commented] (BEAM-1548) Window should not reassign windows if no WindowFn is specified

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

[1/2] beam git commit: This closes #2101

Repository: beam Updated Branches: refs/heads/master ca678d887 -> 599a8ed65 This closes #2101 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/599a8ed6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/599a8ed6 Diff:

[jira] [Commented] (BEAM-1586) DataflowRunner mixes up cached and uploaded staged file counters

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

[GitHub] beam pull request #2138: [BEAM-1586] DataflowRunner: fix message about uploa...

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

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

[1/2] beam git commit: Fix DataflowRunner message about uploaded vs cached files

Repository: beam Updated Branches: refs/heads/master 7d22dbcab -> ca678d887 Fix DataflowRunner message about uploaded vs cached files Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/05a006a1 Tree:

[GitHub] beam pull request #2137: Update javadoc ant to include runners/ and exclude ...

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

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

[jira] [Updated] (BEAM-1586) DataflowRunner mixes up cached and uploaded staged file counters

[ https://issues.apache.org/jira/browse/BEAM-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1586: -- Affects Version/s: 0.5.0 > DataflowRunner mixes up cached and uploaded staged file counters >

[jira] [Created] (BEAM-1586) DataflowRunner mixes up cached and uploaded staged file counters

Daniel Halperin created BEAM-1586: - Summary: DataflowRunner mixes up cached and uploaded staged file counters Key: BEAM-1586 URL: https://issues.apache.org/jira/browse/BEAM-1586 Project: Beam

[jira] [Created] (BEAM-1585) Ability to add new file systems to beamFS in the python sdk

Sourabh Bajaj created BEAM-1585: --- Summary: Ability to add new file systems to beamFS in the python sdk Key: BEAM-1585 URL: https://issues.apache.org/jira/browse/BEAM-1585 Project: Beam Issue

[jira] [Created] (BEAM-1584) Support clean-up step in integration test

Mark Liu created BEAM-1584: -- Summary: Support clean-up step in integration test Key: BEAM-1584 URL: https://issues.apache.org/jira/browse/BEAM-1584 Project: Beam Issue Type: Task

[jira] [Created] (BEAM-1583) Separate GCP test required packages from general GCP dependencies

Mark Liu created BEAM-1583: -- Summary: Separate GCP test required packages from general GCP dependencies Key: BEAM-1583 URL: https://issues.apache.org/jira/browse/BEAM-1583 Project: Beam Issue

[GitHub] beam pull request #2137: Update javadoc ant to include runners/ and exclude ...

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/2137 Update javadoc ant to include runners/ and exclude modules with a wildcard R: @davorbonaci (cc: @sb2nov) You can merge this pull request into a Git repository by running: $ git pull

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2791

See

[jira] [Resolved] (BEAM-1577) Python BigqueryTornadoes Example Failed

[ https://issues.apache.org/jira/browse/BEAM-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu resolved BEAM-1577. Resolution: Fixed Fix Version/s: 0.6.0 > Python BigqueryTornadoes Example Failed >

[jira] [Closed] (BEAM-1577) Python BigqueryTornadoes Example Failed

[ https://issues.apache.org/jira/browse/BEAM-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu closed BEAM-1577. -- > Python BigqueryTornadoes Example Failed > --- > > Key:

[jira] [Commented] (BEAM-1577) Python BigqueryTornadoes Example Failed

[ https://issues.apache.org/jira/browse/BEAM-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891276#comment-15891276 ] Mark Liu commented on BEAM-1577: PR2128 is merged and new job passed:

[1/2] beam git commit: Closes #2122

Repository: beam Updated Branches: refs/heads/master afd710674 -> bc1a301b0 Closes #2122 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bc1a301b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bc1a301b Diff:

[2/2] beam git commit: Adding per-stage matching to metrics filters

Adding per-stage matching to metrics filters Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b34e50c6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b34e50c6 Diff:

[jira] [Commented] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

[ https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891188#comment-15891188 ] Amit Sela commented on BEAM-1582: - Looks like the flake happens when the entire input is re-read. We inject

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

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

[jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891145#comment-15891145 ] Ismaël Mejía commented on BEAM-1567: I just took a look and gave my comments, we will have to wait for

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #1099

See

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #2789

See

[jira] [Created] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

Amit Sela created BEAM-1582: --- Summary: ResumeFromCheckpointStreamingTest flakes with what appears as a second firing. Key: BEAM-1582 URL: https://issues.apache.org/jira/browse/BEAM-1582 Project: Beam

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1098

See

[jira] [Resolved] (BEAM-1173) TestSparkRunner should use a PipelineVisitor to determine expected assertions.

[ https://issues.apache.org/jira/browse/BEAM-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-1173. --- Resolution: Fixed Fix Version/s: 0.6.0 > TestSparkRunner should use a PipelineVisitor to

[jira] [Resolved] (BEAM-646) Get runners out of the apply()

[ https://issues.apache.org/jira/browse/BEAM-646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-646. -- Resolution: Fixed Fix Version/s: 0.6.0 > Get runners out of the apply() >

[jira] [Commented] (BEAM-646) Get runners out of the apply()

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

[jira] [Resolved] (BEAM-111) Use SDK implementation of WritableCoder

[ https://issues.apache.org/jira/browse/BEAM-111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-111. Resolution: Fixed Fix Version/s: 0.6.0 > Use SDK implementation of WritableCoder >

[1/2] beam git commit: This closes #2119

Repository: beam Updated Branches: refs/heads/master a81c45781 -> b2428ea60 This closes #2119 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b2428ea6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b2428ea6 Diff:

[jira] [Commented] (BEAM-111) Use SDK implementation of WritableCoder

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

[GitHub] beam pull request #2118: [BEAM-111] Move WritableCoder to hadoop-common

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2118 --- 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-111] Move WritableCoder to hadoop-common

Repository: beam Updated Branches: refs/heads/master b49ec3fa2 -> a81c45781 [BEAM-111] Move WritableCoder to hadoop-common Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/44624c38 Tree:

[jira] [Resolved] (BEAM-1297) Update maven build plugins and improve maven performance

[ https://issues.apache.org/jira/browse/BEAM-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1297. Resolution: Fixed Fix Version/s: Not applicable > Update maven build plugins and improve

[jira] [Closed] (BEAM-1297) Update maven build plugins and improve maven performance

[ https://issues.apache.org/jira/browse/BEAM-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed BEAM-1297. -- > Update maven build plugins and improve maven performance >

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

[ https://issues.apache.org/jira/browse/BEAM-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890953#comment-15890953 ] Amit Sela commented on BEAM-849: A continually growing file is something else, which I agree on, but in that

[jira] [Comment Edited] (BEAM-849) Redesign PipelineResult API

[ https://issues.apache.org/jira/browse/BEAM-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890885#comment-15890885 ] Amit Sela edited comment on BEAM-849 at 3/1/17 7:35 PM: I disagree with stating that

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

[ https://issues.apache.org/jira/browse/BEAM-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890885#comment-15890885 ] Amit Sela commented on BEAM-849: I disagree with stating that "Create.of(filename) + ParDo(tail file) +

[jira] [Commented] (BEAM-1562) Use a "signal" to stop streaming tests as they finish.

[ https://issues.apache.org/jira/browse/BEAM-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890861#comment-15890861 ] Eugene Kirpichov commented on BEAM-1562: See my comment on BEAM-849: as an alternative, we can use

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

[ https://issues.apache.org/jira/browse/BEAM-849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890855#comment-15890855 ] Eugene Kirpichov commented on BEAM-849: --- I disagree that "unbounded pipelines" can't finish

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #1096

See

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Flink #1801

See

[jira] [Commented] (BEAM-1297) Update maven build plugins and improve maven performance

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

[GitHub] beam pull request #1985: [BEAM-1297] Update maven build plugins and various ...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/1985 --- 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-1297] Update maven shade plugin, fix typo and remove unneeded version

Repository: beam Updated Branches: refs/heads/master 3b3d6b81a -> b49ec3fa2 [BEAM-1297] Update maven shade plugin, fix typo and remove unneeded version [BEAM-1297] Enable tiered compilation to make the JVM startup times faster This makes the build faster because every time maven forks it

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

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

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Flink #1800

See

[jira] [Closed] (BEAM-1545) Python sdk example run failed

[ https://issues.apache.org/jira/browse/BEAM-1545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay closed BEAM-1545. - Resolution: Fixed Fix Version/s: Not applicable > Python sdk example run failed >

[jira] [Commented] (BEAM-1570) broken link on website (ostatic.com)

[ https://issues.apache.org/jira/browse/BEAM-1570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890755#comment-15890755 ] Sourabh Bajaj commented on BEAM-1570: - This is fixed. > broken link on website (ostatic.com) >

[jira] [Commented] (BEAM-1545) Python sdk example run failed

[ https://issues.apache.org/jira/browse/BEAM-1545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890756#comment-15890756 ] Sourabh Bajaj commented on BEAM-1545: - This is fixed so we should close this. > Python sdk example run

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #1095

See

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #2786

See

[jira] [Commented] (BEAM-325) Add Slack details to website

[ https://issues.apache.org/jira/browse/BEAM-325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890674#comment-15890674 ] Nathan Florea commented on BEAM-325: Could I get added to the Slack as well? There is still a dearth of

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #2785

See

[jira] [Commented] (BEAM-351) Add DisplayData to KafkaIO

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

[GitHub] beam pull request #2111: [BEAM-351] Add DisplayData to KafkaIO

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2111 --- 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-351] Add DisplayData to KafkaIO

Repository: beam Updated Branches: refs/heads/master d84b06791 -> 3b3d6b81a [BEAM-351] Add DisplayData to KafkaIO Changes after review. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/52e2d3a7 Tree:

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

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

[jira] [Updated] (BEAM-760) Validation needs to exist that @NeedsRunner / @RunnableOnService tests execute

[ https://issues.apache.org/jira/browse/BEAM-760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-760: -- Fix Version/s: First stable release > Validation needs to exist that @NeedsRunner /

[jira] [Updated] (BEAM-59) IOChannelFactory rethinking/redesign

[ https://issues.apache.org/jira/browse/BEAM-59?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-59: - Fix Version/s: First stable release > IOChannelFactory rethinking/redesign >

[jira] [Updated] (BEAM-622) Add checkpointing tests for DoFnOperator and WindowDoFnOperator

[ https://issues.apache.org/jira/browse/BEAM-622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-622: -- Fix Version/s: First stable release > Add checkpointing tests for DoFnOperator and

[jira] [Updated] (BEAM-720) Run WindowedWordCount Integration Test in Flink

[ https://issues.apache.org/jira/browse/BEAM-720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-720: -- Fix Version/s: First stable release > Run WindowedWordCount Integration Test in Flink >

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

[ https://issues.apache.org/jira/browse/BEAM-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1389. -- Resolution: Fixed Fix Version/s: 0.6.0 > Remove or update Flink Runner README.md >

[jira] [Commented] (BEAM-115) Beam Runner API

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

[1/2] beam git commit: Inline rather than reference FunctionSpecs.

Repository: beam Updated Branches: refs/heads/master 79b1395c2 -> d84b06791 Inline rather than reference FunctionSpecs. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d390406e Tree:

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

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

[jira] [Closed] (BEAM-1517) Garbage collect user state in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1517. -- Resolution: Fixed Assignee: Jingsong Lee (was: Aljoscha Krettek) > Garbage collect user

[jira] [Commented] (BEAM-1517) Garbage collect user state in Flink Runner

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

[1/2] beam git commit: [BEAM-1517] Garbage collect user state in Flink Runner

Repository: beam Updated Branches: refs/heads/master d66029caf -> 79b1395c2 [BEAM-1517] Garbage collect user state in Flink Runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6e9f7ad4 Tree:

[GitHub] beam pull request #2127: [BEAM-1517] Garbage collect user state in Flink Run...

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

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

[jira] [Commented] (BEAM-1567) hashStream should be closed in PackageUtil#createPackageAttributes()

[ https://issues.apache.org/jira/browse/BEAM-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890543#comment-15890543 ] Ted Yu commented on BEAM-1567: -- [~iemejia]: Can you take a look at the PR ? Thanks > hashStream should be

[jira] [Updated] (BEAM-1562) Use a "signal" to stop streaming tests as they finish.

[ https://issues.apache.org/jira/browse/BEAM-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-1562: Description: Streaming tests use a timeout that has to take a large enough buffer to avoid slow runtimes

[jira] [Updated] (BEAM-1562) Use a "signal" to stop streaming tests as they finish.

[ https://issues.apache.org/jira/browse/BEAM-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-1562: Summary: Use a "signal" to stop streaming tests as they finish. (was: Use a "poison pill" to stop streaming

[jira] [Assigned] (BEAM-1562) Use a "poison pill" to stop streaming tests as they finish.

[ https://issues.apache.org/jira/browse/BEAM-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela reassigned BEAM-1562: --- Assignee: Amit Sela > Use a "poison pill" to stop streaming tests as they finish. >

[jira] [Commented] (BEAM-1439) Beam Example(s) exploring public document datasets

[ https://issues.apache.org/jira/browse/BEAM-1439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890149#comment-15890149 ] MOHAMMAD AFFAN ZAFAR commented on BEAM-1439: Hi, I am Final Year Student Computer Science at

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #2784

See

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #1093

See

[jira] [Updated] (BEAM-1557) Separate TestPipeline into 2 versions: one for users, and one for sdk/runner developers

[ https://issues.apache.org/jira/browse/BEAM-1557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stas Levin updated BEAM-1557: - Description: At the moment, {{TestPipeline}} enforces some usage patterns, that may be too strict for non

[jira] [Created] (BEAM-1581) JsonIO

Aviem Zur created BEAM-1581: --- Summary: JsonIO Key: BEAM-1581 URL: https://issues.apache.org/jira/browse/BEAM-1581 Project: Beam Issue Type: New Feature Components: sdk-java-extensions

[jira] [Assigned] (BEAM-1581) JsonIO / JsonSink

[ https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1581: --- Assignee: Aviem Zur (was: Davor Bonaci) > JsonIO / JsonSink > - > >

[jira] [Updated] (BEAM-1581) JsonIO / JsonSink

[ https://issues.apache.org/jira/browse/BEAM-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1581: Summary: JsonIO / JsonSink (was: JsonIO) > JsonIO / JsonSink > - > > Key:

[jira] [Resolved] (BEAM-1576) Use UnsupportedSideInputReader in GroupAlsoByWindowEvaluatorFactory.

[ https://issues.apache.org/jira/browse/BEAM-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-1576. - Resolution: Fixed Fix Version/s: 0.6.0 > Use UnsupportedSideInputReader in