[GitHub] incubator-beam pull request: FileBasedSink: remove unused code

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/208 FileBasedSink: remove unused code R: @lukecwik You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam rename-parallel

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #148

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #148

See

[jira] [Created] (BEAM-208) Flaky test: org.apache.beam.runners.flink.streaming.GroupByNullKeyTest.testJob

Davor Bonaci created BEAM-208: - Summary: Flaky test: org.apache.beam.runners.flink.streaming.GroupByNullKeyTest.testJob Key: BEAM-208 URL: https://issues.apache.org/jira/browse/BEAM-208 Project: Beam

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #147

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #147

See

[1/2] incubator-beam git commit: [BEAM-50] BigQueryIO: fix autocompleting project and test it

Repository: incubator-beam Updated Branches: refs/heads/master 5f20e5361 -> bf78e9667 [BEAM-50] BigQueryIO: fix autocompleting project and test it Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e3c876c2

[GitHub] incubator-beam pull request: [BEAM-50] BigQueryIO: fix autocomplet...

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

[2/2] incubator-beam git commit: Closes #205

Closes #205 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bf78e966 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bf78e966 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/

[jira] [Commented] (BEAM-50) BigQueryIO.Write: reimplement in Java

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

[jira] [Created] (BEAM-207) Flink test flake in ReadStreamingSourceITCase

Daniel Halperin created BEAM-207: Summary: Flink test flake in ReadStreamingSourceITCase Key: BEAM-207 URL: https://issues.apache.org/jira/browse/BEAM-207 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-207) Flink test flake in ReadSourceStreamingITCase

[ https://issues.apache.org/jira/browse/BEAM-207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-207: - Summary: Flink test flake in ReadSourceStreamingITCase (was: Flink test flake in ReadStreamingSourc

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Track Pending Elements via ...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/207 [BEAM-22] Track Pending Elements via Exploded WindowedValues Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #146

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #146

See

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Add WindowedValue#explode

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/206 [BEAM-22] Add WindowedValue#explode 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] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Add splitOffElements to InP...

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

[jira] [Closed] (BEAM-205) An 'in process' runner optimized for efficiency rather than debugging

[ https://issues.apache.org/jira/browse/BEAM-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci closed BEAM-205. - Resolution: Duplicate > An 'in process' runner optimized for efficiency rather than debugging >

[jira] [Commented] (BEAM-205) An 'in process' runner optimized for efficiency rather than debugging

[ https://issues.apache.org/jira/browse/BEAM-205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246779#comment-15246779 ] Davor Bonaci commented on BEAM-205: --- Yup, we had this in mind when designing the new Direc

[jira] [Commented] (BEAM-50) BigQueryIO.Write: reimplement in Java

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

[GitHub] incubator-beam pull request: [BEAM-50] BigQueryIO: fix autocomplet...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/205 [BEAM-50] BigQueryIO: fix autocompleting project and test it R: @peihe You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incuba

[jira] [Updated] (BEAM-206) FileBasedSink does serial renames

[ https://issues.apache.org/jira/browse/BEAM-206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-206: - Summary: FileBasedSink does serial renames (was: GcsIOChannelFactory does serial renames) > FileBa

[jira] [Created] (BEAM-206) GcsIOChannelFactory does serial renames

Daniel Halperin created BEAM-206: Summary: GcsIOChannelFactory does serial renames Key: BEAM-206 URL: https://issues.apache.org/jira/browse/BEAM-206 Project: Beam Issue Type: Bug Co

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Track Synchronized Processi...

GitHub user tgroh reopened a pull request: https://github.com/apache/incubator-beam/pull/202 [BEAM-22] Track Synchronized Processing Time Holds per-element Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure th

[GitHub] incubator-beam pull request: [BEAM-22] Track Synchronized Processi...

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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[jira] [Comment Edited] (BEAM-205) An 'in process' runner optimized for efficiency rather than debugging

[ https://issues.apache.org/jira/browse/BEAM-205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246121#comment-15246121 ] Kenneth Knowles edited comment on BEAM-205 at 4/18/16 9:07 PM: ---

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Add splitOffElements to InP...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/204 [BEAM-22] Add splitOffElements to InProcess Bundles 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-22) DirectPipelineRunner: support for unbounded collections

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

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Remove InProcessBundle

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/203 [BEAM-22] Remove InProcessBundle 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] incubator-beam pull request: [BEAM-22] Track Synchronized Processi...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/202 [BEAM-22] Track Synchronized Processing Time Holds per-element Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Remove isKeyed property of ...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/201 [BEAM-22] Remove isKeyed property of InProcess Bundles Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #145

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #145

See

[2/2] incubator-beam git commit: [BEAM-50] BigQueryIO: move write validation to validate() from apply()

[BEAM-50] BigQueryIO: move write validation to validate() from apply() If runners override the transform, validation will still happen. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3fe10227 Tree: http://g

[GitHub] incubator-beam pull request: BigQueryIO: move write validation to ...

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

[1/2] incubator-beam git commit: Closes #197

Repository: incubator-beam Updated Branches: refs/heads/master becc1ef1e -> 5f20e5361 Closes #197 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5f20e536 Tree: http://git-wip-us.apache.org/repos/asf/incu

[jira] [Updated] (BEAM-204) truncateStackTrace fails with empty stack trace

[ https://issues.apache.org/jira/browse/BEAM-204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-204: -- Assignee: Mark Shields (was: Davor Bonaci) > truncateStackTrace fails with empty stack trace > --

Jenkins build is back to stable : beam_PostCommit_MavenVerify #200

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #200

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #144

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #144

See

[jira] [Commented] (BEAM-205) An 'in process' runner optimized for efficiency rather than debugging

[ https://issues.apache.org/jira/browse/BEAM-205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246121#comment-15246121 ] Kenneth Knowles commented on BEAM-205: -- I believe the forthcoming in-process runner mee

[jira] [Commented] (BEAM-177) Integrate code coverage to build and review process

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

[GitHub] incubator-beam pull request: [BEAM-177] Upload JaCoCo coverage dat...

Github user kennknowles closed the pull request at: https://github.com/apache/incubator-beam/pull/138 --- 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 fe

[jira] [Commented] (BEAM-205) An 'in process' runner optimized for efficiency rather than debugging

[ https://issues.apache.org/jira/browse/BEAM-205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246065#comment-15246065 ] Luke Cwik commented on BEAM-205: >From my understanding, both Flink and Spark support runnin

[jira] [Resolved] (BEAM-202) Remove YYYCoderBase

[ https://issues.apache.org/jira/browse/BEAM-202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-202. Resolution: Fixed > Remove YYYCoderBase > --- > > Key: BEAM-202 >

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #199

See

Jenkins build became unstable: beam_PostCommit_MavenVerify #199

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #143

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #143

See

[jira] [Created] (BEAM-205) An 'in process' runner optimized for efficiency rather than debugging

Mark Shields created BEAM-205: - Summary: An 'in process' runner optimized for efficiency rather than debugging Key: BEAM-205 URL: https://issues.apache.org/jira/browse/BEAM-205 Project: Beam Iss

[1/2] incubator-beam git commit: [BEAM-202] Clean-up *CoderBase classes since we are on a newer version of Jackson

Repository: incubator-beam Updated Branches: refs/heads/master 56e28a90f -> becc1ef1e [BEAM-202] Clean-up *CoderBase classes since we are on a newer version of Jackson Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator

[2/2] incubator-beam git commit: [BEAM-202] This closes #194

[BEAM-202] This closes #194 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/becc1ef1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/becc1ef1 Diff: http://git-wip-us.apache.org/repos/asf/incu

[GitHub] incubator-beam pull request: [BEAM-202] Clean-up *CoderBase classe...

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

[jira] [Commented] (BEAM-202) Remove YYYCoderBase

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

[jira] [Commented] (BEAM-196) Pipeline options must be available Context in DoFn.startBundle

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

[jira] [Closed] (BEAM-158) Add support for bounded sources in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-158. --- Resolution: Fixed Merged with 56e28a90fe5b95c6d2c25149db1a3fe8c2205fb4. > Add support for bound

[GitHub] incubator-beam pull request: [BEAM-196] Pipeline options must be a...

GitHub user mxm opened a pull request: https://github.com/apache/incubator-beam/pull/200 [BEAM-196] Pipeline options must be available Context in DoFn.startBundle This gets rid of the custom Java serialization code by defaulting to serialization of the `PipelineOptions` to a byte ar

[jira] [Commented] (BEAM-204) truncateStackTrace fails with empty stack trace

[ https://issues.apache.org/jira/browse/BEAM-204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15245909#comment-15245909 ] Mark Shields commented on BEAM-204: --- Ah, and we *do* get empty stack traces if the excn is

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #142

See

[jira] [Commented] (BEAM-158) Add support for bounded sources in streaming mode

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

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #142

See

[GitHub] incubator-beam pull request: [BEAM-158] add support for bounded so...

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

[3/4] incubator-beam git commit: [flink] improve InputFormat wrapper and ReadSourceITCase

[flink] improve InputFormat wrapper and ReadSourceITCase Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6eac35e8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6eac35e8 Diff: http://git-wip

[2/4] incubator-beam git commit: [flink] improvements to UnboundedSource translation

[flink] improvements to UnboundedSource translation Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7c4f2dc1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7c4f2dc1 Diff: http://git-wip-us.a

[4/4] incubator-beam git commit: This closes #104

This closes #104 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/56e28a90 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/56e28a90 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[1/4] incubator-beam git commit: [BEAM-158] add support for bounded sources in streaming

Repository: incubator-beam Updated Branches: refs/heads/master 7646384e2 -> 56e28a90f [BEAM-158] add support for bounded sources in streaming Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/444a0bbb Tree:

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: Runners :: Google Cloud Dataflow #141

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #141

See