[jira] [Resolved] (BEAM-1651) Add code style xml to the project repository

[ https://issues.apache.org/jira/browse/BEAM-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-1651. - Resolution: Fixed Fix Version/s: First stable release > Add code style xml to the project

[jira] [Commented] (BEAM-1712) TestPipeline.run doesn't actually waitUntilFinish

[ https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923602#comment-15923602 ] Kenneth Knowles commented on BEAM-1712: --- Since TestPipeline is coupled with automatically configuring

[jira] [Commented] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers

[ https://issues.apache.org/jira/browse/BEAM-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923595#comment-15923595 ] Raghu Angadi commented on BEAM-1573: Thanks [~peay]. Please go ahead a send github PR, I does not need

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1500

See

[GitHub] beam pull request #2240: TestFlinkRunner calls waitUntilFinish()

Github user jkff closed the pull request at: https://github.com/apache/beam/pull/2240 --- 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-1712) TestPipeline.run doesn't actually waitUntilFinish

[ https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923351#comment-15923351 ] Eugene Kirpichov commented on BEAM-1712: As an intermediate step to unifying everything under

[jira] [Commented] (BEAM-1712) TestPipeline.run doesn't actually waitUntilFinish

[ https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923347#comment-15923347 ] Kenneth Knowles commented on BEAM-1712: --- I don't think it will yield correct behavior to always

[GitHub] beam pull request #2241: Sync gearpump-runner branch with master

GitHub user manuzhang opened a pull request: https://github.com/apache/beam/pull/2241 Sync gearpump-runner branch with master 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] [Updated] (BEAM-1712) TestPipeline.run doesn't actually waitUntilFinish

[ https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-1712: --- Priority: Major (was: Blocker) > TestPipeline.run doesn't actually waitUntilFinish >

[jira] [Commented] (BEAM-1712) TestPipeline.run doesn't actually waitUntilFinish

[ https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923329#comment-15923329 ] Eugene Kirpichov commented on BEAM-1712: OK, seems like that is in fact what happens. So this bug

[jira] [Commented] (BEAM-1712) TestPipeline.run doesn't actually waitUntilFinish

[ https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923326#comment-15923326 ] Eugene Kirpichov commented on BEAM-1712: An optimistic interpretation is probably that Flink runner

[jira] [Commented] (BEAM-1712) TestPipeline.run doesn't actually waitUntilFinish

[ https://issues.apache.org/jira/browse/BEAM-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923321#comment-15923321 ] Eugene Kirpichov commented on BEAM-1712:

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Flink #1918

See

[jira] [Created] (BEAM-1712) TestPipeline.run doesn't actually waitUntilFinish

Eugene Kirpichov created BEAM-1712: -- Summary: TestPipeline.run doesn't actually waitUntilFinish Key: BEAM-1712 URL: https://issues.apache.org/jira/browse/BEAM-1712 Project: Beam Issue Type:

Build failed in Jenkins: beam_PostCommit_Java_Version_Test_MavenInstall #3

See -- [...truncated 1.38 MB...] test_pipeline_state_matcher_given_state (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest) Test

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.8 (latest),beam #17

See Changes: [klk] Bump Dataflow ROS timeout to 120 minutes [davor] HadoopInputFormatIO with junits [robertwb] Auto-generated runner api proto bindings.

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 8 (on Ubuntu only),beam #17

See -- [...truncated 483.48 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.35 sec - in

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » OpenJDK 7 (on Ubuntu only),beam #17

See -- [...truncated 483.47 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.321 sec - in

Build failed in Jenkins: beam_PostCommit_Java_Version_Test_MavenInstall #2

See -- [...truncated 1.27 MB...] 2017-03-13T23:53:10.734 [INFO] 2017-03-13T23:53:10.734 [INFO] --- findbugs-maven-plugin:3.0.4:findbugs (findbugs) @

[jira] [Created] (BEAM-1711) Document extra features on quick start guide

Ahmet Altay created BEAM-1711: - Summary: Document extra features on quick start guide Key: BEAM-1711 URL: https://issues.apache.org/jira/browse/BEAM-1711 Project: Beam Issue Type: Bug

Build failed in Jenkins: beam_PostCommit_Java_Version_Test_MavenInstall #1

See -- [...truncated 1.39 MB...] test_pipeline_state_matcher_given_state (apache_beam.tests.pipeline_verifiers_test.PipelineVerifiersTest) Test

Jenkins build is back to normal : beam_SeedJob #160

See

[jira] [Updated] (BEAM-1657) DirectRunner should not call close twice in UnboundedSourceExecutorFactory

[ https://issues.apache.org/jira/browse/BEAM-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-1657: -- Description: At the end of the processElement, in `finishRead` there is a 5% chance we decide to `close`

[jira] [Created] (BEAM-1710) The DirectRunner should interact more directly with SplittableDoFn

Thomas Groh created BEAM-1710: - Summary: The DirectRunner should interact more directly with SplittableDoFn Key: BEAM-1710 URL: https://issues.apache.org/jira/browse/BEAM-1710 Project: Beam

[jira] [Updated] (BEAM-1710) The DirectRunner should interact more directly with SplittableDoFn

[ https://issues.apache.org/jira/browse/BEAM-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-1710: -- Issue Type: Improvement (was: Bug) > The DirectRunner should interact more directly with SplittableDoFn

[GitHub] beam pull request #2239: Improve tox installation for python sdk

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/2239 Improve tox installation for python sdk 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-1530) BigQueryIO should support value-dependent windows

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

[GitHub] beam pull request #2238: [BEAM-1530] Cleanup BigQueryIO, and allow for value...

GitHub user reuvenlax opened a pull request: https://github.com/apache/beam/pull/2238 [BEAM-1530] Cleanup BigQueryIO, and allow for value-based tables BigQueryIO now conforms to best practices. BigQueryIO.Write takes in a user type, which the user can convert to a

Build failed in Jenkins: beam_PostCommit_Python_Verify #1499

See Changes: [altay] Better error on missing gcp dependencies. [altay] Filling up TBDs in setup.py [davor] [BEAM-1651] Add IntelliJ code style xml to the project repository [davor] [BEAM-1651]

[jira] [Commented] (BEAM-1656) DirectRunner should not call finalize twice in UnboundedSourceExecutorFactory

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

[GitHub] beam pull request #2237: [BEAM-1656] Stop Double-finalizing checkpoints in t...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2237 [BEAM-1656] Stop Double-finalizing checkpoints in the DirectRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[jira] [Commented] (BEAM-1653) Error when using PubsubIO with the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15923050#comment-15923050 ] Thomas Groh commented on BEAM-1653: --- This is caused by a second call to finalizeCheckpoint() after

[jira] [Commented] (BEAM-1651) Add code style xml to the project repository

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

[3/3] beam git commit: This closes #2195

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

[1/3] beam git commit: [BEAM-1651] Add IntelliJ code style xml to the project repository

Repository: beam Updated Branches: refs/heads/master ebd2ee01e -> 9ad01fb15 [BEAM-1651] Add IntelliJ code style xml to the project repository [BEAM-1651] Change to use equivalent Eclipse code formatter profile xml Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/3] beam git commit: [BEAM-1651] Test code style

[BEAM-1651] Test code style Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/329d1652 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/329d1652 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/329d1652 Branch:

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2895

See

[GitHub] beam pull request #2236: Filling up TBDs in setup.py

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

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

[jira] [Updated] (BEAM-1495) Move ParDo.Bound as ParDo.BoundMulti into the core runners construction module

[ https://issues.apache.org/jira/browse/BEAM-1495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-1495: -- Fix Version/s: (was: 0.6.0) Not applicable > Move ParDo.Bound as ParDo.BoundMulti

[jira] [Updated] (BEAM-1709) Implement Single-output ParDo as Multi-output ParDo

[ https://issues.apache.org/jira/browse/BEAM-1709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-1709: -- Description: Runners who want a primitive Single-output ParDo should implement an override to do so.

[jira] [Created] (BEAM-1709) Implement Single-output ParDo as Multi-output ParDo

Thomas Groh created BEAM-1709: - Summary: Implement Single-output ParDo as Multi-output ParDo Key: BEAM-1709 URL: https://issues.apache.org/jira/browse/BEAM-1709 Project: Beam Issue Type: Bug

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Flink #1914

See

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Flink #1913

See

[jira] [Created] (BEAM-1708) Better error messages when GCP features are not installed

Sourabh Bajaj created BEAM-1708: --- Summary: Better error messages when GCP features are not installed Key: BEAM-1708 URL: https://issues.apache.org/jira/browse/BEAM-1708 Project: Beam Issue

[GitHub] beam pull request #2233: Better error on missing gcp dependencies.

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2233 --- 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: Better error on missing gcp dependencies.

Repository: beam Updated Branches: refs/heads/master 367d66cbd -> de40c14ff Better error on missing gcp dependencies. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/454bbaac Tree:

[GitHub] beam pull request #2236: Filling up TBDs in setup.py

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/2236 Filling up TBDs in setup.py R: @davorbonaci You can merge this pull request into a Git repository by running: $ git pull https://github.com/aaltay/beam pkginfo Alternatively you can review

[jira] [Created] (BEAM-1706) Ban Guava as a transitive dependency

Aviem Zur created BEAM-1706: --- Summary: Ban Guava as a transitive dependency Key: BEAM-1706 URL: https://issues.apache.org/jira/browse/BEAM-1706 Project: Beam Issue Type: Improvement

[GitHub] beam pull request #2235: Initial version of Flink Streaming Splittable DoFn ...

GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/2235 Initial version of Flink Streaming Splittable DoFn support There are still two tests in error: ``` Tests in error: SplittableDoFnTest.testLateData:334 » UnsupportedOperation The

[GitHub] beam-site pull request #176: Update quickstart-java.md

GitHub user robertwb opened a pull request: https://github.com/apache/beam-site/pull/176 Update quickstart-java.md I had to make this change for a clean build to work with the 0.6.0 source release. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Closed] (BEAM-1674) Flink user state GC depends on order of timer firing

[ https://issues.apache.org/jira/browse/BEAM-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1674. -- Resolution: Fixed > Flink user state GC depends on order of timer firing >

[GitHub] beam pull request #2234: [BEAM-1704] Added Create.TimestampedValues.withType

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2234 [BEAM-1704] Added Create.TimestampedValues.withType 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-1704) Create.TimestampedValues should take a TypeDescriptor as an alternative to explicitly specifying the Coder

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

[jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922793#comment-15922793 ] Kenneth Knowles commented on BEAM-1612: --- I believe this meets the requirements. It is fine for a

[jira] [Comment Edited] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15905798#comment-15905798 ] Kenneth Knowles edited comment on BEAM-1612 at 3/13/17 7:24 PM: I just

[jira] [Created] (BEAM-1704) Create.TimestampedValues should take a TypeDescriptor as an alternative to explicitly specifying the Coder

Aviem Zur created BEAM-1704: --- Summary: Create.TimestampedValues should take a TypeDescriptor as an alternative to explicitly specifying the Coder Key: BEAM-1704 URL: https://issues.apache.org/jira/browse/BEAM-1704

[jira] [Assigned] (BEAM-1704) Create.TimestampedValues should take a TypeDescriptor as an alternative to explicitly specifying the Coder

[ https://issues.apache.org/jira/browse/BEAM-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1704: --- Assignee: Aviem Zur (was: Davor Bonaci) > Create.TimestampedValues should take a TypeDescriptor as

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

[ https://issues.apache.org/jira/browse/BEAM-720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922696#comment-15922696 ] Kenneth Knowles commented on BEAM-720: -- Yea sorry about that - I didn't notice the JIRA when I just

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

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

[GitHub] beam pull request #2232: [BEAM-720] Run WindowedWordCount on Flink Runner In...

Github user jasonkuster closed the pull request at: https://github.com/apache/beam/pull/2232 --- 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-720) Run WindowedWordCount Integration Test in Flink

[ https://issues.apache.org/jira/browse/BEAM-720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922691#comment-15922691 ] Aljoscha Krettek commented on BEAM-720: --- Open PR about this: https://github.com/apache/beam/pull/2188

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2894

See -- Started by GitHub push by asfgit [EnvInject] - Loading node environment variables. Building remotely on beam2 (beam) in workspace

[jira] [Commented] (BEAM-1594) JOB_STATE_DRAINED should be terminal for waitUntilFinish()

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

[GitHub] beam pull request #2146: [BEAM-1594] Supports DRAINING and DRAINED states

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2146 --- 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: Support DRAINING and DRAINED in the DataflowRunner

Repository: beam Updated Branches: refs/heads/master 7447147e0 -> 367d66cbd Support DRAINING and DRAINED in the DataflowRunner Dataflow's DRAINING is treated as RUNNING, and DRAINED as DONE. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

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

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

[GitHub] beam pull request #2233: Better error on missing gcp dependencies.

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/2233 Better error on missing gcp dependencies. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] beam pull request #2232: [BEAM-720] Run WindowedWordCount on Flink Runner

GitHub user jasonkuster opened a pull request: https://github.com/apache/beam/pull/2232 [BEAM-720] Run WindowedWordCount on Flink Runner Signed-off-by: Jason Kuster Be sure to do all of the following to help us incorporate your contribution

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

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

[jira] [Assigned] (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 ] Jason Kuster reassigned BEAM-720: - Assignee: Jason Kuster (was: Aljoscha Krettek) > Run WindowedWordCount Integration Test in Flink

[jira] [Resolved] (BEAM-1516) null value is not supported in Map with AvroCoder

[ https://issues.apache.org/jira/browse/BEAM-1516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin resolved BEAM-1516. -- Resolution: Not A Bug Fix Version/s: Not applicable > null value is not supported in Map with

[jira] [Resolved] (BEAM-1671) Support bypassing `validate` flag when using tfrecordio

[ https://issues.apache.org/jira/browse/BEAM-1671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-1671. --- Resolution: Fixed Fix Version/s: First stable release > Support bypassing `validate` flag when

[jira] [Commented] (BEAM-1671) Support bypassing `validate` flag when using tfrecordio

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

[GitHub] beam pull request #2208: [BEAM-1671] Add `validate` argument to tfrecordio.R...

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

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

[1/2] beam git commit: Add `validate` argument to tfrecordio.ReadFromTFRecord

Repository: beam Updated Branches: refs/heads/master 781e4172c -> 7447147e0 Add `validate` argument to tfrecordio.ReadFromTFRecord Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b616505d Tree:

[jira] [Resolved] (BEAM-1551) Allow PAssert#that to take a message

[ https://issues.apache.org/jira/browse/BEAM-1551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-1551. --- Resolution: Fixed Fix Version/s: 0.6.0 > Allow PAssert#that to take a message >

[jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner

[ https://issues.apache.org/jira/browse/BEAM-1542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15907748#comment-15907748 ] Guy Molinari commented on BEAM-1542: Here is the isolated error: [INFO]

[jira] [Updated] (BEAM-1702) Add support for local execution to BigtableIO using the google cloud emulator

[ https://issues.apache.org/jira/browse/BEAM-1702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-1702: --- Summary: Add support for local execution to BigtableIO using the google cloud emulator (was: Add

[jira] [Updated] (BEAM-923) Add support for local execution to DatastoreIO using the google cloud emulator

[ https://issues.apache.org/jira/browse/BEAM-923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-923: -- Summary: Add support for local execution to DatastoreIO using the google cloud emulator (was: Add option

[jira] [Updated] (BEAM-1703) Add support for local execution to PubsubIO using the google cloud emulator

[ https://issues.apache.org/jira/browse/BEAM-1703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-1703: --- Summary: Add support for local execution to PubsubIO using the google cloud emulator (was: Add option

[jira] [Updated] (BEAM-923) Add option to DatastoreIO to support local execution with the google cloud emulator

[ https://issues.apache.org/jira/browse/BEAM-923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-923: -- Summary: Add option to DatastoreIO to support local execution with the google cloud emulator (was: Add

[jira] [Created] (BEAM-1702) Add option to BigtableIO to support local execution with the google cloud emulator

Ismaël Mejía created BEAM-1702: -- Summary: Add option to BigtableIO to support local execution with the google cloud emulator Key: BEAM-1702 URL: https://issues.apache.org/jira/browse/BEAM-1702 Project:

[jira] [Created] (BEAM-1703) Add option to PubsubIO to support local execution with the google cloud emulator

Ismaël Mejía created BEAM-1703: -- Summary: Add option to PubsubIO to support local execution with the google cloud emulator Key: BEAM-1703 URL: https://issues.apache.org/jira/browse/BEAM-1703 Project:

[jira] [Commented] (BEAM-923) Add localhost option for DatastoreIO

[ https://issues.apache.org/jira/browse/BEAM-923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15907609#comment-15907609 ] Ismaël Mejía commented on BEAM-923: --- There is an error of assignment with the builder of the IO, when

[GitHub] beam pull request #2231: [BEAM-923] Add localhost option for DatastoreIO (fi...

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/2231 [BEAM-923] Add localhost option for DatastoreIO (fix assignment issue) Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure

[jira] [Commented] (BEAM-923) Add localhost option for DatastoreIO

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

[jira] [Commented] (BEAM-1640) data file missing when submit a job on Flink

[ https://issues.apache.org/jira/browse/BEAM-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15907568#comment-15907568 ] Aljoscha Krettek commented on BEAM-1640: I have a suspicion that FLINK-6031 could be the reason.

[jira] [Updated] (BEAM-1682) Enable all GCP unit tests in Python-SDK

[ https://issues.apache.org/jira/browse/BEAM-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss updated BEAM-1682: - Fix Version/s: (was: 0.6.0) > Enable all GCP unit tests in Python-SDK >

[jira] [Comment Edited] (BEAM-425) Create Elasticsearch IO

[ https://issues.apache.org/jira/browse/BEAM-425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899528#comment-15899528 ] Etienne Chauchot edited comment on BEAM-425 at 3/13/17 9:47 AM: sure, it's

[jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15907069#comment-15907069 ] Aljoscha Krettek commented on BEAM-1612: I think what we could do is keep state/state updates in