[GitHub] beam-site pull request #177: [BEAM-1652] Code style instructions in contribu...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam-site/pull/177 [BEAM-1652] Code style instructions in contribution guide You can merge this pull request into a Git repository by running: $ git pull https://github.com/aviemzur/beam-site code-style-inst

[jira] [Commented] (BEAM-1652) Add code style xml to the website

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

[jira] [Comment Edited] (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&focusedCommentId=15923650#comment-15923650 ] Stas Levin edited comment on BEAM-1712 at 3/14/17 6:20 AM: --- [A re

[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&focusedCommentId=15923650#comment-15923650 ] Stas Levin commented on BEAM-1712: -- [A related discussion|https://lists.apache.org/thread

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Flink #1919

See

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

See Changes: [robertwb] Auto-generated runner api proto bindings. [robertwb] Runner API context helper classes. [robertwb] Runner API encoding of

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest),beam #18

See Changes: [robertwb] Auto-generated runner api proto bindings. [robertwb] Runner API context helper classes. [robertwb] Runner API encoding of WindowFns. [

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

See Changes: [robertwb] Auto-generated runner api proto bindings. [robertwb] Runner API context helper classes. [robertwb] Runner API encoding of

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

See Changes: [robertwb] Auto-generated runner api proto bindings. [robertwb] Runner API context helper classes. [robertwb] Runner API encoding of WindowFns. [

[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 repository

[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&focusedCommentId=15923602#comment-15923602 ] Kenneth Knowles commented on BEAM-1712: --- Since TestPipeline is coupled with automatic

[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&focusedCommentId=15923595#comment-15923595 ] Raghu Angadi commented on BEAM-1573: Thanks [~peay]. Please go ahead a send github PR,

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 enabled

[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&focusedCommentId=15923351#comment-15923351 ] Eugene Kirpichov commented on BEAM-1712: As an intermediate step to unifying everyt

[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&focusedCommentId=15923347#comment-15923347 ] Kenneth Knowles commented on BEAM-1712: --- I don't think it will yield correct behavior

[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&focusedCommentId=15923329#comment-15923329 ] Eugene Kirpichov commented on BEAM-1712: OK, seems like that is in fact what happen

[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&focusedCommentId=15923326#comment-15923326 ] Eugene Kirpichov commented on BEAM-1712: An optimistic interpretation is probably t

[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&focusedCommentId=15923321#comment-15923321 ] Eugene Kirpichov commented on BEAM-1712: https://github.com/apache/beam/blob/master

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 PipelineStateM

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

See -- [...truncated 482.52 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.302 sec - in org.apache.beam.sdk

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. [robe

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

GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/2240 TestFlinkRunner calls waitUntilFinish() R: @tgroh Will file JIRA now. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jkff/incubator-beam f

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 org.ap

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 org.a

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) @ beam-sdk

[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 C

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 PipelineStateM

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 Issu

[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&focusedCommentId=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 TableRow.

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] Tes

[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&focusedCommentId=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 ti

[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&focusedCommentId=15923050#comment-15923050 ] Thomas Groh commented on BEAM-1653: --- This is caused by a second call to finalizeCheckpoin

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

[GitHub] beam pull request #2195: [BEAM-1651] Add code style xml to the project repos...

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

[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: refs/heads/maste

[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: http://git-w

[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: refs/h

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2895

See

[1/2] beam git commit: Filling up TBDs in setup.py

Repository: beam Updated Branches: refs/heads/master de40c14ff -> ebd2ee01e Filling up TBDs in setup.py Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b3cb505d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b3cb505d

[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 enabl

[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: refs/heads/maste

[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. In

[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 Typ

[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 enabl

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

This closes #2233 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/de40c14f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/de40c14f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/de40c14f Branch: refs/heads/maste

[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: http://git-wip-us.apache.org/repos/asf/beam

[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 and

[jira] [Created] (BEAM-1707) Add warning when no template_location is specified in the presence of RuntimeValueProvider objects

María GH created BEAM-1707: -- Summary: Add warning when no template_location is specified in the presence of RuntimeValueProvider objects Key: BEAM-1707 URL: https://issues.apache.org/jira/browse/BEAM-1707 Pr

[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 Compo

[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 transf

[jira] [Created] (BEAM-1705) add method in Pipeline to visualize the DAG

Xu Mingmin created BEAM-1705: Summary: add method in Pipeline to visualize the DAG Key: BEAM-1705 URL: https://issues.apache.org/jira/browse/BEAM-1705 Project: Beam Issue Type: New Feature

[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 ht

[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 forma

[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&focusedCommentId=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&focusedCommentId=15922793#comment-15922793 ] Kenneth Knowles commented on BEAM-1612: --- I believe this meets the requirements. It is

[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&focusedCommentId=15905798#comment-15905798 ] Kenneth Knowles edited comment on BEAM-1612 at 3/13/17 7:24 PM: -

[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 an

[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&focusedCommentId=15922696#comment-15922696 ] Kenneth Knowles commented on BEAM-720: -- Yea sorry about that - I didn't notice the JIRA

[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&focusedCommentId=15922694#comment-15922694 ] ASF GitHub Bot commented on BEAM-720: - Github user jasonkuster closed the pull request a

[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&focusedCommentId=15922691#comment-15922691 ] Aljoscha Krettek commented on BEAM-720: --- Open PR about this: https://github.com/apache

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&focusedCommentId=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 enabl

[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: http://git-wip-us.apache.org/repos/

[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: refs/heads/maste

[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 like:

[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 quickly and easily:

[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&focusedCommentId=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 Avro

[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 u

[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&focusedCommentId=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 enabl

[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: refs/heads/maste

[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: http://git-wip-us.apache.org/r

[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&focusedCommentId=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 optio

[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 lo

[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: B

  1   2   >