[jira] [Commented] (BEAM-168) IntervalBoundedExponentialBackOff change broke Beam-on-Dataflow

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

[GitHub] incubator-beam pull request: [BEAM-168] Remove uses of deprecated ...

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/229 [BEAM-168] Remove uses of deprecated API You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam remove-deprecate

[jira] [Commented] (BEAM-141) Remove StateSampler from Java SDK

[ https://issues.apache.org/jira/browse/BEAM-141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253419#comment-15253419 ] Davor Bonaci commented on BEAM-141: --- Fixed? > Remove StateSampler from Java SDK > ---

[jira] [Commented] (BEAM-157) CombineTest.testGlobalCombineWithDefaultsAndTriggers is broken

[ https://issues.apache.org/jira/browse/BEAM-157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253418#comment-15253418 ] Davor Bonaci commented on BEAM-157: --- Fixed? > CombineTest.testGlobalCombineWithDefaultsAn

[jira] [Updated] (BEAM-218) Add a documentation landing page at /docs/ subdirectory

[ https://issues.apache.org/jira/browse/BEAM-218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-218: -- Assignee: Devin Donnelly (was: James Malone) > Add a documentation landing page at /docs/ subdirectory >

[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=15253417#comment-15253417 ] Davor Bonaci commented on BEAM-204: --- Fixed? > truncateStackTrace fails with empty stack t

[jira] [Updated] (BEAM-216) Create Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-216: -- Assignee: Sriharsha Chintalapani > Create Storm Runner > > > Key: BE

[jira] [Commented] (BEAM-216) Create Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253415#comment-15253415 ] Davor Bonaci commented on BEAM-216: --- It would be great to share some design plans with the

[3/3] incubator-beam git commit: This closes #222

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

[1/3] incubator-beam git commit: Fix how this SDK identifies itself to the Cloud Dataflow service

Repository: incubator-beam Updated Branches: refs/heads/master 10e628471 -> 7465edb73 Fix how this SDK identifies itself to the Cloud Dataflow service * Use Beam SDK naming, instead of Dataflow SDK. * Fix version lookup, so it correctly identifies the version. Project: http://git-wip-us.apac

[2/3] incubator-beam git commit: Rename DataflowReleaseInfo to ReleaseInfo

Rename DataflowReleaseInfo to ReleaseInfo Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/390c5a8b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/390c5a8b Diff: http://git-wip-us.apache.org/

[GitHub] incubator-beam pull request: Fix how this SDK identifies itself to...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/222 --- 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-134) Investigate use of AutoValue

[ https://issues.apache.org/jira/browse/BEAM-134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15253352#comment-15253352 ] Davor Bonaci commented on BEAM-134: --- Done? > Investigate use of AutoValue > -

[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=15253206#comment-15253206 ] ASF GitHub Bot commented on BEAM-50: Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request: [BEAM-50] Fix BigQuery.Write tempFile...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/192 --- 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: [BEAM-50] Fix BigQuery.Write tempFilePrefix concatenation

Repository: incubator-beam Updated Branches: refs/heads/master a5548f915 -> 10e628471 [BEAM-50] Fix BigQuery.Write tempFilePrefix concatenation Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8f92b988 Tre

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

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

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

See

Jenkins build is unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #181

See

[jira] [Closed] (BEAM-215) Create should be implemented as a BoundedSource

[ https://issues.apache.org/jira/browse/BEAM-215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh closed BEAM-215. Resolution: Fixed closed by https://github.com/apache/incubator-beam/commit/a5548f915df1449ab4e2d7841ef6d696a

[GitHub] incubator-beam pull request: [BEAM-215] Implement Create as An Off...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/183 --- 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/3] incubator-beam git commit: Implement Create as An OffsetBasedSource

Implement Create as An OffsetBasedSource This removes the requirement to implement a primtiive Create for runners that support Reads from a Bounded Source. Remove Dataflow Runner references to Create.Values Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-w

[3/3] incubator-beam git commit: Closes #183

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

[1/3] incubator-beam git commit: Factor common setup in EncodabilityEnforcementFactoryTest

Repository: incubator-beam Updated Branches: refs/heads/master 640e2588f -> a5548f915 Factor common setup in EncodabilityEnforcementFactoryTest Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/59fd4b3c Tre

[1/5] incubator-beam git commit: Closes #142

Repository: incubator-beam Updated Branches: refs/heads/master 4c01c7d30 -> 640e2588f Closes #142 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/640e2588 Tree: http://git-wip-us.apache.org/repos/asf/incu

[5/5] incubator-beam git commit: KafkaIO: unbounded source for reading from Apache Kafka

KafkaIO: unbounded source for reading from Apache Kafka Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7b175dff Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7b175dff Diff: http://git-wip-

[3/5] incubator-beam git commit: Kafka: various fixes

Kafka: various fixes *) package renaming *) move it out of contrib to I/O module *) get it running as part of the normal travis build, and remove specialization *) remove examples, to be added in a separate PR. Either there should be an addition to an existing example to handle "multip

[2/5] incubator-beam git commit: Kafka: various fixes

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/92106605/contrib/kafka/src/test/java/com/google/cloud/dataflow/contrib/kafka/KafkaIOTest.java -- diff --git a/contrib/kafka/src/test/java/com/google/cloud/dataflow/contrib

[GitHub] incubator-beam pull request: [BEAM-52] Kafka IO

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

[4/5] incubator-beam git commit: KafkaIO: unbounded source for reading from Apache Kafka

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7b175dff/contrib/kafka/src/test/java/com/google/cloud/dataflow/contrib/kafka/KafkaIOTest.java -- diff --git a/contrib/kafka/src/test/java/com/google/cloud/dataflow/contrib

[2/3] incubator-beam git commit: Expose IsmFormat.Footer constants as public

Expose IsmFormat.Footer constants as public Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0a15bf5e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0a15bf5e Diff: http://git-wip-us.apache.or

[GitHub] incubator-beam pull request: Fixes for recently broken APIs.

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/228 --- 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/3] incubator-beam git commit: Convert BaseExecutionContext.getOrCreateStepContext to use specific interface instead of com.google.base.Supplier

Repository: incubator-beam Updated Branches: refs/heads/master 6dd5d7041 -> 4c01c7d30 Convert BaseExecutionContext.getOrCreateStepContext to use specific interface instead of com.google.base.Supplier Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-u

[3/3] incubator-beam git commit: This closes #228

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

[jira] [Created] (BEAM-219) Use super.populateDisplayData consistently

Scott Wegner created BEAM-219: - Summary: Use super.populateDisplayData consistently Key: BEAM-219 URL: https://issues.apache.org/jira/browse/BEAM-219 Project: Beam Issue Type: Sub-task

[GitHub] incubator-beam pull request: Fixes for recently broken APIs.

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/228 Fixes for recently broken APIs. You can merge this pull request into a Git repository by running: $ git pull https://github.com/swegner/incubator-beam ismformat-constants Alternativel

[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=15252963#comment-15252963 ] ASF GitHub Bot commented on BEAM-22: Github user asfgit closed the pull request at:

[2/2] incubator-beam git commit: This closes #227

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

[1/2] incubator-beam git commit: Wrap Exceptions thrown in StartBundle in the InProcessPipelineRunner

Repository: incubator-beam Updated Branches: refs/heads/master c3567f1e7 -> 6dd5d7041 Wrap Exceptions thrown in StartBundle in the InProcessPipelineRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a

[GitHub] incubator-beam pull request: [BEAM-22] Wrap Exceptions thrown in S...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/227 --- 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] [Updated] (BEAM-209) PCollection-to-batched-gcs-files PTransform

[ https://issues.apache.org/jira/browse/BEAM-209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-209: - Assignee: (was: Daniel Halperin) > PCollection-to-batched-gcs-files PTransform > ---

[GitHub] incubator-beam pull request: [BEAM-141] Remove StateSampler from t...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/224 --- 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-141) Remove StateSampler from Java SDK

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

[1/2] incubator-beam git commit: Remove StateSampler from the SDK

Repository: incubator-beam Updated Branches: refs/heads/master 0e420f16c -> c3567f1e7 Remove StateSampler from the SDK Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6c7ed126 Tree: http://git-wip-us.apac

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

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

[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=15252842#comment-15252842 ] ASF GitHub Bot commented on BEAM-22: GitHub user tgroh opened a pull request: https:

[GitHub] incubator-beam pull request: [BEAM-22] Wrap Exceptions thrown in S...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/227 [BEAM-22] Wrap Exceptions thrown in StartBundle in the InProcessPipelineRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [

[jira] [Commented] (BEAM-213) Fix README to use refactored package names

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

[GitHub] incubator-beam pull request: [BEAM-213] Fix README to use refactor...

GitHub user amitsela opened a pull request: https://github.com/apache/incubator-beam/pull/226 [BEAM-213] Fix README to use refactored package names Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR tit

[jira] [Created] (BEAM-218) Add a documentation landing page at /docs/ subdirectory

Devin Donnelly created BEAM-218: --- Summary: Add a documentation landing page at /docs/ subdirectory Key: BEAM-218 URL: https://issues.apache.org/jira/browse/BEAM-218 Project: Beam Issue Type: Ta

[jira] [Commented] (BEAM-213) Fix README to use refactored package names

[ https://issues.apache.org/jira/browse/BEAM-213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15252532#comment-15252532 ] Amit Sela commented on BEAM-213: No need to change runner to fully qualified name when runni

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

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #178

See

[GitHub] incubator-beam pull request: [INFRA-11644] Mergebot initial commit

GitHub user jasonkuster opened a pull request: https://github.com/apache/incubator-beam/pull/225 [INFRA-11644] Mergebot initial commit Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is formatt

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

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #177

See

[GitHub] incubator-beam pull request: [BEAM-141] Remove StateSampler from t...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/224 [BEAM-141] Remove StateSampler from the SDK Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is forma

[jira] [Commented] (BEAM-141) Remove StateSampler from Java SDK

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

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

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #176

See

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

[ https://issues.apache.org/jira/browse/BEAM-208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15252173#comment-15252173 ] Maximilian Michels commented on BEAM-208: - Thanks! > Flaky test: org.apache.beam.ru

[jira] [Updated] (BEAM-215) Create should be implemented as a BoundedSource

[ https://issues.apache.org/jira/browse/BEAM-215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-215: -- Assignee: Thomas Groh (was: Davor Bonaci) > Create should be implemented as a BoundedSource > ---

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

[ https://issues.apache.org/jira/browse/BEAM-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci closed BEAM-208. - Resolution: Fixed > Flaky test: org.apache.beam.runners.flink.streaming.GroupByNullKeyTest.testJob > ---

[jira] [Updated] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction

[ https://issues.apache.org/jira/browse/BEAM-217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-217: -- Assignee: Eugene Kirpichov (was: Davor Bonaci) > BoundedSource.splitAtFraction should be splitAfterFracti

[jira] [Commented] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction

[ https://issues.apache.org/jira/browse/BEAM-217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15252158#comment-15252158 ] Davor Bonaci commented on BEAM-217: --- SGTM > BoundedSource.splitAtFraction should be split

[jira] [Commented] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction

[ https://issues.apache.org/jira/browse/BEAM-217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15252160#comment-15252160 ] Davor Bonaci commented on BEAM-217: --- Eugene, do you want to make this change in Beam? > B

[jira] [Commented] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction

[ https://issues.apache.org/jira/browse/BEAM-217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15252132#comment-15252132 ] Luke Cwik commented on BEAM-217: The TextSource supports variable length delimiters which ar

Jenkins build is back to normal : beam_PostCommit_MavenVerify #233

See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Parent #233

See

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

[ https://issues.apache.org/jira/browse/BEAM-208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15252131#comment-15252131 ] Thomas Groh commented on BEAM-208: -- This is resolved (but I can't press a button to mark it

[jira] [Commented] (BEAM-129) Support pubsub IO

[ https://issues.apache.org/jira/browse/BEAM-129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15252128#comment-15252128 ] Mark Shields commented on BEAM-129: --- Quick update since I saw the change go by: I'm workin

[GitHub] incubator-beam pull request: [BEAM-208] Remove use of System.curre...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/210 --- 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-208) Flaky test: org.apache.beam.runners.flink.streaming.GroupByNullKeyTest.testJob

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

[1/2] incubator-beam git commit: Remove use of System.currentTimeMillis in Flink Test

Repository: incubator-beam Updated Branches: refs/heads/master dba1a349c -> 0e420f16c Remove use of System.currentTimeMillis in Flink Test This will stop tests failing if the DoFn executes within ~25 seconds of an hour boundary. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[2/2] incubator-beam git commit: [BEAM-208] This closes #210

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

[GitHub] incubator-beam pull request: Fix AutoValue coverage exclusion for ...

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

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

[1/2] incubator-beam git commit: Fix AutoValue coverage exclusion for coveralls

Repository: incubator-beam Updated Branches: refs/heads/master 506023bf5 -> dba1a349c Fix AutoValue coverage exclusion for coveralls Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/747487ba Tree: http://g

[jira] [Commented] (BEAM-215) Create should be implemented as a BoundedSource

[ https://issues.apache.org/jira/browse/BEAM-215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15252038#comment-15252038 ] Eugene Kirpichov commented on BEAM-215: --- Note that for this to interact well with Data

[jira] [Updated] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction

[ https://issues.apache.org/jira/browse/BEAM-217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-217: -- Priority: Minor (was: Major) > BoundedSource.splitAtFraction should be splitAfterFraction > -

[jira] [Created] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction

Eugene Kirpichov created BEAM-217: - Summary: BoundedSource.splitAtFraction should be splitAfterFraction Key: BEAM-217 URL: https://issues.apache.org/jira/browse/BEAM-217 Project: Beam Issue T

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #175

See

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

See

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Parent #232

See -- Established TCP socket on 36456 maven32-agent.jar already up to date maven32-interceptor.jar already up to date maven3-interceptor-commons.jar already up to date

Build failed in Jenkins: beam_PostCommit_MavenVerify #232

See -- [...truncated 2946 lines...] [INFO] Deleting [INFO] [INFO] --- jacoco-maven-plugin:0.7.5.2015052419

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

[ https://issues.apache.org/jira/browse/BEAM-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-208: Assignee: Thomas Groh (was: Maximilian Michels) > Flaky test: org.apache.beam.runners.flink.s

[jira] [Updated] (BEAM-129) Support pubsub IO

[ https://issues.apache.org/jira/browse/BEAM-129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-129: Assignee: (was: Maximilian Michels) > Support pubsub IO > - > >

[jira] [Updated] (BEAM-128) The transform BigQueryIO.Read is currently not supported.

[ https://issues.apache.org/jira/browse/BEAM-128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-128: Assignee: (was: Maximilian Michels) > The transform BigQueryIO.Read is currently not suppo

[jira] [Updated] (BEAM-103) Make UnboundedSourceWrapper parallel

[ https://issues.apache.org/jira/browse/BEAM-103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-103: Assignee: Kostas Kloudas (was: Maximilian Michels) > Make UnboundedSourceWrapper parallel > -

[jira] [Updated] (BEAM-102) Side Inputs for Streaming

[ https://issues.apache.org/jira/browse/BEAM-102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-102: Assignee: (was: Maximilian Michels) > Side Inputs for Streaming >