[GitHub] incubator-beam pull request #1089: [BEAM-742] Replicate triggers to runners-...

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

[jira] [Commented] (BEAM-741) Values transform does not use the correct output coder when values is an Iterable

[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572443#comment-15572443 ] Andrew Martin commented on BEAM-741: [~kenn] After investigating further, it seems like the coder for

[jira] [Created] (BEAM-747) Text checksum verifier is not resilient to eventually consistent filesystems

Daniel Halperin created BEAM-747: Summary: Text checksum verifier is not resilient to eventually consistent filesystems Key: BEAM-747 URL: https://issues.apache.org/jira/browse/BEAM-747 Project: Beam

[jira] [Resolved] (BEAM-257) fix ConcurrentModificationException in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghu Angadi resolved BEAM-257. --- Resolution: Fixed Fix Version/s: 0.1.0-incubating

[jira] [Updated] (BEAM-748) Issues with local processes in MongoDbIO and JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-748: - Description: Hey JB, Can you take a look at these issues? Causing flakes in precommit testing.

[jira] [Comment Edited] (BEAM-688) Repeated 'mvn install' fails on beam-sdks-java-maven-archetypes-starter with undeclared dependency error

[ https://issues.apache.org/jira/browse/BEAM-688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572415#comment-15572415 ] Ven Bijjam edited comment on BEAM-688 at 10/13/16 4:30 PM: --- I am seeing this on

[jira] [Commented] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST

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

[1/2] incubator-beam git commit: Update to compile in eclipse again

Repository: incubator-beam Updated Branches: refs/heads/eclipse2 [created] 83f0b6436 Update to compile in eclipse again Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a8cbd246 Tree:

[2/2] incubator-beam git commit: Attempt to add eclipse-jdt profile to a travis build

Attempt to add eclipse-jdt profile to a travis build Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/83f0b643 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/83f0b643 Diff:

[jira] [Commented] (BEAM-591) Better handling watermark in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572540#comment-15572540 ] Raghu Angadi commented on BEAM-591: --- PubSubIO does advance the watermark to current time if there haven't

[jira] [Updated] (BEAM-593) Support unblocking run() in FlinkRunner and cancel() and waitUntilFinish() in FlinkRunnerResult

[ https://issues.apache.org/jira/browse/BEAM-593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He updated BEAM-593: Summary: Support unblocking run() in FlinkRunner and cancel() and waitUntilFinish() in FlinkRunnerResult (was:

[jira] [Reopened] (BEAM-741) Values transform does not use the correct output coder when values is an Iterable

[ https://issues.apache.org/jira/browse/BEAM-741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Martin reopened BEAM-741: > Values transform does not use the correct output coder when values is an > Iterable >

[jira] [Created] (BEAM-748) Issues with local processes in MongoDbIO and JdbcIO

Daniel Halperin created BEAM-748: Summary: Issues with local processes in MongoDbIO and JdbcIO Key: BEAM-748 URL: https://issues.apache.org/jira/browse/BEAM-748 Project: Beam Issue Type: Bug

[GitHub] incubator-beam pull request #1094: Build in eclipse/eclipse-jdt

GitHub user dkulp opened a pull request: https://github.com/apache/incubator-beam/pull/1094 Build in eclipse/eclipse-jdt This just updates the code to build with eclipse-jdt (again) and adds the travis.xml changes back in . You can merge this pull request into a Git repository by

[jira] [Commented] (BEAM-688) Repeated 'mvn install' fails on beam-sdks-java-maven-archetypes-starter with undeclared dependency error

[ https://issues.apache.org/jira/browse/BEAM-688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572415#comment-15572415 ] Venkata Bijjam commented on BEAM-688: - I am seeing this on the initial build itself. I downloaded the

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Branches: refs/heads/eclipse2 [deleted] 83f0b6436

[jira] [Created] (BEAM-749) Syntax highlight on website

Frances Perry created BEAM-749: -- Summary: Syntax highlight on website Key: BEAM-749 URL: https://issues.apache.org/jira/browse/BEAM-749 Project: Beam Issue Type: Bug Components:

[GitHub] incubator-beam pull request #662: [BEAM-115] WIP: JSON Schema definition of ...

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

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

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

[jira] [Commented] (BEAM-520) Update Python SDK example tests to use assert_that

[ https://issues.apache.org/jira/browse/BEAM-520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573085#comment-15573085 ] Ven Bijjam commented on BEAM-520: - I would like to work on this. How do I get started? > Update Python SDK

[jira] [Updated] (BEAM-520) Update Python SDK example tests to use assert_that

[ https://issues.apache.org/jira/browse/BEAM-520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-520: - Assignee: (was: Frances Perry) > Update Python SDK example tests to use assert_that >

[jira] [Updated] (BEAM-520) Update Python SDK example tests to use assert_that

[ https://issues.apache.org/jira/browse/BEAM-520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay updated BEAM-520: - Assignee: Frances Perry > Update Python SDK example tests to use assert_that >

[jira] [Updated] (BEAM-595) Support non-blocking run() in SparkRunner and cancel() and waitUntilFinish() in Spark EvaluationContext

[ https://issues.apache.org/jira/browse/BEAM-595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He updated BEAM-595: Summary: Support non-blocking run() in SparkRunner and cancel() and waitUntilFinish() in Spark EvaluationContext

[jira] [Commented] (BEAM-748) Issues with local processes in MongoDbIO and JdbcIO

[ https://issues.apache.org/jira/browse/BEAM-748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573247#comment-15573247 ] Jean-Baptiste Onofré commented on BEAM-748: --- Yup, let me take a look. > Issues with local

[GitHub] incubator-beam pull request #1097: [BEAM-443] Update Beam batch examples to ...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/1097 [BEAM-443] Update Beam batch examples to call waitUntilFinish() You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (BEAM-147) Introduce an easy API pipeline metrics

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

[GitHub] incubator-beam pull request #1099: Move the step output ids to use a flat na...

GitHub user lukecwik opened a pull request: https://github.com/apache/incubator-beam/pull/1099 Move the step output ids to use a flat namespace. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[GitHub] incubator-beam pull request #1096: [BEAM-595] avoid throwing Exception in wa...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/1096 [BEAM-595] avoid throwing Exception in waitUntilFinish in SparkRunner You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (BEAM-570) Update AvroSource to support more compression types

[ https://issues.apache.org/jira/browse/BEAM-570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573243#comment-15573243 ] Konstantinos Katsiapis commented on BEAM-570: - Thanks Frances, PR

[GitHub] incubator-beam pull request #1024: [BEAM-147] Prototype of Metrics API for J...

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

[4/5] incubator-beam git commit: Initial Metrics API for Beam Java

Initial Metrics API for Beam Java This includes a simple Counter metric and a Distribution metric that reports the SUM, COUNT, MIN, MAX and MEAN of the reported values. The API is labeled @Experimental since metrics will only be reported and queryable with the DirectRunner, and the API may

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

Closes #1024 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3c731707 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3c731707 Diff:

[3/5] incubator-beam git commit: Initial Metrics API for Beam Java

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8524ed95/sdks/java/core/src/test/java/org/apache/beam/sdk/metrics/MetricsMapTest.java -- diff --git

[1/5] incubator-beam git commit: Implement Metrics in the DirectRunner

Repository: incubator-beam Updated Branches: refs/heads/master e969f3d38 -> 3c731707b Implement Metrics in the DirectRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/834933c5 Tree:

[2/5] incubator-beam git commit: Add the ability to query metrics on PipelineResult

Add the ability to query metrics on PipelineResult All runners currently implement this by throwing an UnsupportedOperationException. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/51fee39b Tree:

[jira] [Updated] (BEAM-147) Introduce an easy API for pipeline metrics

[ https://issues.apache.org/jira/browse/BEAM-147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Chambers updated BEAM-147: -- Summary: Introduce an easy API for pipeline metrics (was: Introduce an easy API pipeline metrics) >

[jira] [Commented] (BEAM-520) Update Python SDK example tests to use assert_that

[ https://issues.apache.org/jira/browse/BEAM-520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573113#comment-15573113 ] Ahmet Altay commented on BEAM-520: -- Ven, thank you for your interest. A partial cleanup was already done

[jira] [Commented] (BEAM-361) Batch Pub/Sub sink does not set idLabel

[ https://issues.apache.org/jira/browse/BEAM-361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573234#comment-15573234 ] Ven Bijjam commented on BEAM-361: - I am thinking along these lines:: in {code}PubsubUnboundedSource{code}

[jira] [Commented] (BEAM-596) Support cancel() and waitUntilFinish() in DirectRunner

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

[GitHub] incubator-beam pull request #1098: [BEAM-596] Replace DirectResult#awaitComp...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/1098 [BEAM-596] Replace DirectResult#awaitCompletion with waitUntilFinish Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[jira] [Commented] (BEAM-595) Support non-blocking run() in SparkRunner and cancel() and waitUntilFinish() in Spark EvaluationContext

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

[jira] [Commented] (BEAM-742) Move trigger state machines to runners-core, convert triggers to AST

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

[14/17] incubator-beam git commit: Restore prior trigger files, for temporary compatibility

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a64acb2f/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTimeTest.java -- diff --git

[05/17] incubator-beam git commit: Rename runners-core Trigger to TriggerStateMachine

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/69b1efda/runners/core-java/src/main/java/org/apache/beam/runners/core/reactors/Repeatedly.java -- diff --git

[12/17] incubator-beam git commit: Move triggers to runners-core

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e4398e1e/runners/core-java/src/main/java/org/apache/beam/runners/core/reactors/FinishedTriggersSet.java -- diff --git

[08/17] incubator-beam git commit: Move triggers to runners-core

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e4398e1e/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTimeTest.java -- diff --git

[jira] [Comment Edited] (BEAM-361) Batch Pub/Sub sink does not set idLabel

[ https://issues.apache.org/jira/browse/BEAM-361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573234#comment-15573234 ] Ven Bijjam edited comment on BEAM-361 at 10/13/16 9:29 PM: --- I am thinking along

[jira] [Commented] (BEAM-443) PipelineResult needs waitToFinish() and cancel()

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

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1522

See -- [INFO] [INFO]

[jira] [Commented] (BEAM-361) Batch Pub/Sub sink does not set idLabel

[ https://issues.apache.org/jira/browse/BEAM-361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573125#comment-15573125 ] Ven Bijjam commented on BEAM-361: - Hi I would like to take this up. But I am not sure how to contribute as

[jira] [Comment Edited] (BEAM-361) Batch Pub/Sub sink does not set idLabel

[ https://issues.apache.org/jira/browse/BEAM-361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573234#comment-15573234 ] Ven Bijjam edited comment on BEAM-361 at 10/13/16 9:30 PM: --- I am thinking along

[jira] [Comment Edited] (BEAM-361) Batch Pub/Sub sink does not set idLabel

[ https://issues.apache.org/jira/browse/BEAM-361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573234#comment-15573234 ] Ven Bijjam edited comment on BEAM-361 at 10/13/16 9:29 PM: --- I am thinking along

[15/17] incubator-beam git commit: Restore prior trigger files, for temporary compatibility

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a64acb2f/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Trigger.java -- diff --git

[13/17] incubator-beam git commit: Move triggers to runners-core

Move triggers to runners-core This commit is effectively a "git hint" that all the files in runners-core are moved from prior files. The moved files will be replaced. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[16/17] incubator-beam git commit: Restore prior trigger files, for temporary compatibility

Restore prior trigger files, for temporary compatibility Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a64acb2f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a64acb2f Diff:

[GitHub] incubator-beam pull request #1083: [BEAM-742] Replicate triggers to runners-...

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

[04/17] incubator-beam git commit: Rename runners-core Trigger to TriggerStateMachine

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/69b1efda/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterProcessingTimeStateMachine.java -- diff --git

[01/17] incubator-beam git commit: Rename runners-core Trigger to TriggerStateMachine

Repository: incubator-beam Updated Branches: refs/heads/master 73226168a -> e969f3d38 http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/69b1efda/runners/core-java/src/test/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachineTest.java

[03/17] incubator-beam git commit: Rename runners-core Trigger to TriggerStateMachine

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/69b1efda/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineRunner.java -- diff --git

[11/17] incubator-beam git commit: Move triggers to runners-core

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e4398e1e/runners/core-java/src/test/java/org/apache/beam/runners/core/reactors/AfterPaneTest.java -- diff --git

[17/17] incubator-beam git commit: This closes #1083

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

[07/17] incubator-beam git commit: Move triggers to runners-core

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e4398e1e/sdks/java/core/src/test/java/org/apache/beam/sdk/util/TriggerTester.java -- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/TriggerTester.java

Re: Build failed in Jenkins: beam_PostCommit_MavenVerify #1522

FYI I am watching the subsequent results. This error was caused by the JVM on the Jenkins worker getting OOM-killed, did not seem to relate to recent changes. But I'll watch to make sure. On Thu, Oct 13, 2016 at 3:35 PM Apache Jenkins Server < jenk...@builds.apache.org> wrote: > See < >

[1/2] incubator-beam git commit: KafkaIO reader should set consumedOffset even before reading the first record.

Repository: incubator-beam Updated Branches: refs/heads/master 3c731707b -> 93d2e374c KafkaIO reader should set consumedOffset even before reading the first record. * Distinguish between uninitialized consumed offset and consumed offset for an empty partition. * Add test to verify we

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1525

See

[GitHub] incubator-beam pull request #1071: KafkaIO reader should set consumedOffset ...

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

[GitHub] incubator-beam pull request #1009: [BEAM-551] Add ValueProvider class (Take ...

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

[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions

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

[GitHub] incubator-beam pull request #1100: Windowed side inputs

GitHub user robertwb opened a pull request: https://github.com/apache/incubator-beam/pull/1100 Windowed side inputs 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:

Jenkins build became unstable: beam_PostCommit_MavenVerify #1525

See

[1/2] incubator-beam git commit: Add DoFn.StateId annotation and validation on fields

Repository: incubator-beam Updated Branches: refs/heads/master 5bfeb958d -> a0f649eac Add DoFn.StateId annotation and validation on fields Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/add34518 Tree:

[jira] [Updated] (BEAM-747) Text checksum verifier is not resilient to eventually consistent filesystems

[ https://issues.apache.org/jira/browse/BEAM-747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-747: - Description: Example 1:

Re: Jenkins build became unstable: beam_PostCommit_MavenVerify #1525

Filed https://issues.apache.org/jira/browse/BEAM-747 On Thu, Oct 13, 2016 at 5:33 PM, Apache Jenkins Server < jenk...@builds.apache.org> wrote: > See > >

[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state

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

[GitHub] incubator-beam pull request #1086: [BEAM-25] Add DoFn.StateId annotation and...

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

[jira] [Comment Edited] (BEAM-697) TextIO.Write.Bound.withHeader() and withFooter() do not use the current value of validate for the returned Bound instance

[ https://issues.apache.org/jira/browse/BEAM-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574335#comment-15574335 ] Daniel Halperin edited comment on BEAM-697 at 10/14/16 5:55 AM: Thanks for

[jira] [Commented] (BEAM-697) TextIO.Write.Bound.withHeader() and withFooter() do not use the current value of validate for the returned Bound instance

[ https://issues.apache.org/jira/browse/BEAM-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574335#comment-15574335 ] Daniel Halperin commented on BEAM-697: -- Thanks for this. Mirroring from discussion on that PR, prefer

Re: Jenkins build became unstable: beam_PostCommit_MavenVerify #1525

Thx ! Regards JB On 10/14/2016 07:52 AM, Dan Halperin wrote: Filed https://issues.apache.org/jira/browse/BEAM-747 On Thu, Oct 13, 2016 at 5:33 PM, Apache Jenkins Server > wrote: See

[GitHub] incubator-beam pull request #908: Fix inconsistent in formatting flink logs

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

[1/2] incubator-beam git commit: Fix inconsistent in formatting logs: leaveCompositeTransform always decrement depth, but enterCompositeTransform increment depth only on ENTER_TRANSFORM

Repository: incubator-beam Updated Branches: refs/heads/master 13b45895e -> 73226168a Fix inconsistent in formatting logs: leaveCompositeTransform always decrement depth, but enterCompositeTransform increment depth only on ENTER_TRANSFORM Project:

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

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

[jira] [Commented] (BEAM-593) Support cancel() and waitUntilFinish() in FlinkRunnerResult

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

[GitHub] incubator-beam pull request #1093: [BEAM-593] avoid throwing Exception in wa...

GitHub user mxm opened a pull request: https://github.com/apache/incubator-beam/pull/1093 [BEAM-593] avoid throwing Exception in waitUntilFinish The current implementation of Flink's `PipelineResult` assumes that the pipeline has already been processed. Hence, we can return