[10/55] [abbrv] beam git commit: Refactor classes into packages

http://git-wip-us.apache.org/repos/asf/beam/blob/a7f9f7d0/integration/java/nexmark/src/main/java/org/apache/beam/integration/nexmark/queries/Query3.java -- diff --git

[50/55] [abbrv] beam git commit: Move module beam-integration-java-nexmark to beam-sdks-java-nexmark

http://git-wip-us.apache.org/repos/asf/beam/blob/f4333df7/integration/java/nexmark/src/main/java/org/apache/beam/integration/nexmark/NexmarkUtils.java -- diff --git

[49/55] [abbrv] beam git commit: Move module beam-integration-java-nexmark to beam-sdks-java-nexmark

http://git-wip-us.apache.org/repos/asf/beam/blob/f4333df7/integration/java/nexmark/src/main/java/org/apache/beam/integration/nexmark/queries/AbstractSimulator.java -- diff --git

[48/55] [abbrv] beam git commit: Move module beam-integration-java-nexmark to beam-sdks-java-nexmark

http://git-wip-us.apache.org/repos/asf/beam/blob/f4333df7/integration/java/nexmark/src/main/java/org/apache/beam/integration/nexmark/queries/Query4.java -- diff --git

[29/55] [abbrv] beam git commit: Move WinningBids into the queries package

Move WinningBids into the queries package Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a39cb800 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a39cb800 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a39cb800

[01/55] [abbrv] beam git commit: NexMark

Repository: beam Updated Branches: refs/heads/master f0ce31b9d -> 64ff21f35 http://git-wip-us.apache.org/repos/asf/beam/blob/1f08970a/integration/java/src/main/java/org/apache/beam/integration/nexmark/SellerPrice.java -- diff

[19/55] [abbrv] beam git commit: Activate monitoring on NexmarkSparkRunner and on specific runners

Activate monitoring on NexmarkSparkRunner and on specific runners issue #28 Fix compilation issue after rebase + make checkstyle happy again Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a1fe33bc Tree:

[06/55] [abbrv] beam git commit: NexMark

NexMark Port unit tests, cleanup pom and add license to readme Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1f08970a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1f08970a Diff:

[41/55] [abbrv] beam git commit: Move module beam-integration-java-nexmark to beam-sdks-java-nexmark

http://git-wip-us.apache.org/repos/asf/beam/blob/f4333df7/sdks/java/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/package-info.java -- diff --git

[23/55] [abbrv] beam git commit: Improve query5, query10 and query11

Improve query5, query10 and query11 query5: Add comment on key lifting (issue #30) query10: Add comment for strange groupByKey (issue #31) query11: Replace Count.perKey by Count.perElement (issue #32) Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3817

See

[jira] [Created] (BEAM-2795) FlinkRunner: translate using SDK-agnostic means

Kenneth Knowles created BEAM-2795: - Summary: FlinkRunner: translate using SDK-agnostic means Key: BEAM-2795 URL: https://issues.apache.org/jira/browse/BEAM-2795 Project: Beam Issue Type: New

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2894

See

[jira] [Commented] (BEAM-2430) Java FnApiDoFnRunner to share across runners

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

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2893

See

[GitHub] beam pull request #3750: [BEAM-2430] DoFnRunner for processing a bundle over...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/3750 [BEAM-2430] DoFnRunner for processing a bundle over the Fn API Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Spark #2892

See

[jira] [Commented] (BEAM-2545) bigtable e2e tests failing - UNKNOWN: Stale requests/Error mutating row

[ https://issues.apache.org/jira/browse/BEAM-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16138414#comment-16138414 ] Kenneth Knowles commented on BEAM-2545: --- We've seen the last two nightly builds fail with similar

[jira] [Assigned] (BEAM-2545) bigtable e2e tests failing - UNKNOWN: Stale requests/Error mutating row

[ https://issues.apache.org/jira/browse/BEAM-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-2545: - Assignee: Chamikara Jayalath (was: Stephen Sisk) > bigtable e2e tests failing -

[GitHub] beam pull request #3743: [BEAM-2788] Use SerializablePipelineOptions to serd...

Github user huafengw closed the pull request at: https://github.com/apache/beam/pull/3743 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (BEAM-2788) Use SerializablePipelineOptions to serde PipelineOptions

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

[2/2] beam git commit: This closes 3743

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

[1/2] beam git commit: [BEAM-2788] Use SerializablePipelineOptions to serde PipelineOptions in Gearpump runner

Repository: beam Updated Branches: refs/heads/master 9b175ccc2 -> f0ce31b9d [BEAM-2788] Use SerializablePipelineOptions to serde PipelineOptions in Gearpump runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/081df6d3

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3816

See

[jira] [Commented] (BEAM-1628) Flink runner: logic around --flinkMaster is error-prone

[ https://issues.apache.org/jira/browse/BEAM-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16138333#comment-16138333 ] Maximilian Michels commented on BEAM-1628: -- [~vectorijk] Are you still working on this issue? >

[jira] [Commented] (BEAM-956) Execute ReduceFnRunner Directly in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16138331#comment-16138331 ] Maximilian Michels commented on BEAM-956: - It appears this issue has been fixed. [~aljoscha] can

[GitHub] beam pull request #3749: remove kryo Serializer hard coded settings and add ...

GitHub user kobisalant opened a pull request: https://github.com/apache/beam/pull/3749 remove kryo Serializer hard coded settings and add Serializable to se… Remove kryo Serializer hard coded settings and add Serializable to several classes. Had to add Serializable to

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Spark #2891

See -- [...truncated 324.84 KB...] 2017-08-23T12:03:57.229 [INFO] Downloading:

[jira] [Commented] (BEAM-2794) Failed to run Wordcount example following quick start guide

[ https://issues.apache.org/jira/browse/BEAM-2794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16138162#comment-16138162 ] Huafeng Wang commented on BEAM-2794: I execute the mvn archetype:generate command under the root

[jira] [Commented] (BEAM-2669) Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached

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

[GitHub] beam pull request #3748: BEAM-2669 Kryo serialization exception when DStream...

Github user kobisalant closed the pull request at: https://github.com/apache/beam/pull/3748 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (BEAM-2669) Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached

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

[GitHub] beam pull request #3748: BEAM-2669 Kryo serialization exception when DStream...

GitHub user kobisalant opened a pull request: https://github.com/apache/beam/pull/3748 BEAM-2669 Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached remove kryo Serializer hard coded settings and add Serializable implementation to

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3815

See

[jira] [Created] (BEAM-2794) Failed to run Wordcount example following quick start guide

Huafeng Wang created BEAM-2794: -- Summary: Failed to run Wordcount example following quick start guide Key: BEAM-2794 URL: https://issues.apache.org/jira/browse/BEAM-2794 Project: Beam Issue

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2890

See

<    1   2