Jenkins build is still unstable: beam_PostCommit_MavenVerify #1473

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1473

See

[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=15553995#comment-15553995 ] Frances Perry commented on BEAM-570: Assigning to Konstantinos to follow up after #1053 is in. >

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

[ https://issues.apache.org/jira/browse/BEAM-570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Frances Perry updated BEAM-570: --- Assignee: Konstantinos Katsiapis > Update AvroSource to support more compression types >

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

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

[GitHub] incubator-beam pull request #1049: [BEAM-498] Add DoFnInvoker for OldDoFn, f...

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

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

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

[1/2] incubator-beam git commit: Add DoFnInvoker for OldDoFn, for migration ease

Repository: incubator-beam Updated Branches: refs/heads/master 9b71f1636 -> 03b89c065 Add DoFnInvoker for OldDoFn, for migration ease This allows any runner to use DoFnInvokers.invokerFor(Object) to be agnostic as to whether they are running a DoFn or OldDoFn. Thus, the migration of the

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1472

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1472

See

[GitHub] incubator-beam pull request #1007: Add support for bz2 compression in python

GitHub user tim1357 reopened a pull request: https://github.com/apache/incubator-beam/pull/1007 Add support for bz2 compression in python This is my first contribution to any open source project ever, so I have no idea if I'm doing this right. You can merge this pull request into

[GitHub] incubator-beam pull request #1007: Add support for bz2 compression in python

Github user tim1357 closed the pull request at: https://github.com/apache/incubator-beam/pull/1007 --- 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 #1062: [BEAM-721] Fixing tox for python

Github user pabloem closed the pull request at: https://github.com/apache/incubator-beam/pull/1062 --- 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-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=15553512#comment-15553512 ] ASF GitHub Bot commented on BEAM-25: GitHub user kennknowles opened a pull request:

[GitHub] incubator-beam pull request #1064: [BEAM-25] Add StateSpec as a curried way ...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1064 [BEAM-25] Add StateSpec as a curried way to build a StateTag Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make

Jenkins build became unstable: beam_PostCommit_MavenVerify #1471

See

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

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify #1470

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1470

See

[jira] [Commented] (BEAM-310) Exercise splitIntoBundles/generateInitialSplits in the Direct Runner

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

[GitHub] incubator-beam pull request #1063: [BEAM-310] Perform initial splitting in t...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/1063 [BEAM-310] Perform initial splitting in the DirectRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[GitHub] incubator-beam pull request #1039: Forward port Dataflow PR-431, PR-454, PR-...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1039 --- 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/4] incubator-beam git commit: Forward port Dataflow PR-454 to Beam

Repository: incubator-beam Updated Branches: refs/heads/master ecbc64117 -> 9b71f1636 Forward port Dataflow PR-454 to Beam Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0ac0caf2 Tree:

[3/4] incubator-beam git commit: Forward port Dataflow PR-453 to Beam

Forward port Dataflow PR-453 to Beam Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f33e869 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9f33e869 Diff:

[2/4] incubator-beam git commit: Forward port Dataflow PR-431 to Beam

Forward port Dataflow PR-431 to Beam Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cca861ba Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cca861ba Diff:

[3/4] incubator-beam git commit: Remove KeyedResourcePool

Remove KeyedResourcePool This interface is no longer used. Instead, the runner ensures that bundles will be provided containing the appropriate input to the TestStreamEvaluatorFactory. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #1051: [BEAM-310] Add RootTransformEvaluatorFact...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1051 --- 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/4] incubator-beam git commit: Add RootTransformEvaluatorFactory

Repository: incubator-beam Updated Branches: refs/heads/master 0ddba6d8d -> ecbc64117 http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7306e16b/runners/direct-java/src/test/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactoryTest.java

[2/4] incubator-beam git commit: Add RootTransformEvaluatorFactory

Add RootTransformEvaluatorFactory Use for Root Transforms. These transforms generate their own initial inputs, which the Evaluator is responsible for providing back to them to generate elements from the root PCollections. Update ExecutorServiceParallelExecutor to schedule roots based on the

[4/4] incubator-beam git commit: [BEAM-310] Add RootTransformEvaluatorFactory

[BEAM-310] Add RootTransformEvaluatorFactory This closes #1051 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ecbc6411 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ecbc6411 Diff:

[jira] [Commented] (BEAM-726) Standardize naming of PipelineResult objects

[ https://issues.apache.org/jira/browse/BEAM-726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15553379#comment-15553379 ] Kenneth Knowles commented on BEAM-726: -- I've toyed with the idea that that API on this thing is the

[jira] [Commented] (BEAM-726) Standardize naming of PipelineResult objects

[ https://issues.apache.org/jira/browse/BEAM-726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15553367#comment-15553367 ] Ben Chambers commented on BEAM-726: --- Great point. We could consider also choosing a different suffix.

[jira] [Commented] (BEAM-726) Standardize naming of PipelineResult objects

[ https://issues.apache.org/jira/browse/BEAM-726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15553364#comment-15553364 ] Luke Cwik commented on BEAM-726: Is PipelineResult the appropriate suffix? If I support a non-blocking mode

[jira] [Created] (BEAM-726) Standardize naming of PipelineResult objects

Ben Chambers created BEAM-726: - Summary: Standardize naming of PipelineResult objects Key: BEAM-726 URL: https://issues.apache.org/jira/browse/BEAM-726 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-59) IOChannelFactory rethinking/redesign

[ https://issues.apache.org/jira/browse/BEAM-59?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15553163#comment-15553163 ] Amit Sela commented on BEAM-59: --- We've discussed over the dev list about data locality, and it seems that it

[jira] [Commented] (BEAM-721) Travis CI fails to run Python tox tests on Mac

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

[GitHub] incubator-beam pull request #1062: [BEAM-721] Fixing tox for python

GitHub user pabloem opened a pull request: https://github.com/apache/incubator-beam/pull/1062 [BEAM-721] Fixing tox for python Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ x ] Make sure the PR title is formatted

[jira] [Updated] (BEAM-725) Remove legacy credentials flags related to GCP and adopt application default credentials as only supported default flow

[ https://issues.apache.org/jira/browse/BEAM-725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-725: --- Description: Drop the following GcpOptions and use ADC

[jira] [Created] (BEAM-725) Remove legacy credentials flags related to GCP and adopt application default credentials as only supported default flow

Luke Cwik created BEAM-725: -- Summary: Remove legacy credentials flags related to GCP and adopt application default credentials as only supported default flow Key: BEAM-725 URL:

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

Closes #1058 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6b061456 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6b061456 Diff:

[1/2] incubator-beam git commit: Fixes a bug in avroio_test.py on Windows.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 99a33ecdb -> 6b0614564 Fixes a bug in avroio_test.py on Windows. We open a binary file without 'b' mode. Without this file can get corrupted in Windows and the test becomes flaky. Project:

[jira] [Commented] (BEAM-724) NullPointerException in Snapshot State

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

[GitHub] incubator-beam pull request #1061: BEAM-724 - Null pointer fix

GitHub user sumitchawla opened a pull request: https://github.com/apache/incubator-beam/pull/1061 BEAM-724 - Null pointer fix This seems like a timing Issue. Its reproducible in case where Kafka topic does not exist yet. The UDF operator run is not called yet, but other thread

[jira] [Created] (BEAM-724) NullPointerException in Snapshot State

Sumit Chawla created BEAM-724: - Summary: NullPointerException in Snapshot State Key: BEAM-724 URL: https://issues.apache.org/jira/browse/BEAM-724 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-723) Provide a runner-internal ExecutorService for maintenance tasks

Thomas Groh created BEAM-723: Summary: Provide a runner-internal ExecutorService for maintenance tasks Key: BEAM-723 URL: https://issues.apache.org/jira/browse/BEAM-723 Project: Beam Issue

Jenkins build became unstable: beam_PostCommit_MavenVerify #1469

See

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

See

[jira] [Commented] (BEAM-717) Migrate KafkaIO to use AutoValue to reduce boilerplate

[ https://issues.apache.org/jira/browse/BEAM-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15552714#comment-15552714 ] Eugene Kirpichov commented on BEAM-717: --- https://github.com/apache/incubator-beam/pull/1048 > Migrate

[jira] [Assigned] (BEAM-717) Migrate KafkaIO to use AutoValue to reduce boilerplate

[ https://issues.apache.org/jira/browse/BEAM-717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov reassigned BEAM-717: - Assignee: Eugene Kirpichov (was: James Malone) > Migrate KafkaIO to use AutoValue to

[GitHub] incubator-beam pull request #1047: Little fixes to LatestFnTest

Github user kennknowles closed the pull request at: https://github.com/apache/incubator-beam/pull/1047 --- 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 #1059: Fix Streaming Integration Test Failure in...

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

Repository: incubator-beam Updated Branches: refs/heads/master f554398bc -> 0ddba6d8d Fix Precommit Integration Test Failure Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f5aa6eb7 Tree:

[2/2] incubator-beam git commit: Fix Streaming Integration Test Failure in Precommit

Fix Streaming Integration Test Failure in Precommit This closes #1059 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0ddba6d8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0ddba6d8 Diff:

[1/3] incubator-beam git commit: De-pluralize error message expectation in LatestFnTests

Repository: incubator-beam Updated Branches: refs/heads/master 8130bc36f -> f554398bc De-pluralize error message expectation in LatestFnTests Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/60a8aef7

[3/3] incubator-beam git commit: Forbid files ending in Tests.java as they should end in Test.java

Forbid files ending in Tests.java as they should end in Test.java Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f554398b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f554398b Diff:

[2/3] incubator-beam git commit: Move LatestFnTests to LatestFnTest

Move LatestFnTests to LatestFnTest Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/52e43ac7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/52e43ac7 Diff:

[jira] [Commented] (BEAM-59) IOChannelFactory rethinking/redesign

[ https://issues.apache.org/jira/browse/BEAM-59?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15552316#comment-15552316 ] Jean-Baptiste Onofré commented on BEAM-59: -- It makes sense. In order to be able to provide a better

[jira] [Commented] (BEAM-59) IOChannelFactory rethinking/redesign

[ https://issues.apache.org/jira/browse/BEAM-59?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15552303#comment-15552303 ] Daniel Halperin commented on BEAM-59: - I think there are two separable tasks. 1. Completely rethink the

[GitHub] incubator-beam pull request #1060: checkstyle: improve Javadoc checking

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/1060 checkstyle: improve Javadoc checking * Enable `JavadocParagraph`, which gives a consistent style in how we format paragraphs. This caught a LOT of missing tags and other issues.

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1279

See

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1278

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1465

See

[jira] [Commented] (BEAM-59) IOChannelFactory rethinking/redesign

[ https://issues.apache.org/jira/browse/BEAM-59?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15551806#comment-15551806 ] Jean-Baptiste Onofré commented on BEAM-59: -- Hi guys, HDFS (and other filesystems like S3, ...) is a

[jira] [Updated] (BEAM-585) Support other message than TextMessage in JmsIO

[ https://issues.apache.org/jira/browse/BEAM-585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-585: -- Summary: Support other message than TextMessage in JmsIO (was: Support other message

[jira] [Resolved] (BEAM-698) Use AutoValue and deal with Document instead of String in MongoDbIO

[ https://issues.apache.org/jira/browse/BEAM-698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-698. --- Resolution: Fixed > Use AutoValue and deal with Document instead of String in MongoDbIO

[GitHub] incubator-beam pull request #1054: [BEAM-698] Use AutoValue in MongoDB GridF...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1054 --- 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-698) Use AutoValue and deal with Document instead of String in MongoDbIO

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

[2/2] incubator-beam git commit: [BEAM-698] This closes #1054

[BEAM-698] This closes #1054 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8130bc36 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8130bc36 Diff:

[jira] [Commented] (BEAM-716) Migrate JmsIO to use AutoValue to reduce boilerplate

[ https://issues.apache.org/jira/browse/BEAM-716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15551146#comment-15551146 ] Jean-Baptiste Onofré commented on BEAM-716: --- I already created this Jira related to that:

[jira] [Assigned] (BEAM-716) Migrate JmsIO to use AutoValue to reduce boilerplate

[ https://issues.apache.org/jira/browse/BEAM-716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-716: - Assignee: Jean-Baptiste Onofré (was: James Malone) > Migrate JmsIO to use

Jenkins build became unstable: beam_PostCommit_MavenVerify #1464

See

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

See

[jira] [Commented] (BEAM-378) Integrate Python SDK in the Maven build

[ https://issues.apache.org/jira/browse/BEAM-378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15551032#comment-15551032 ] Sergio Fernández commented on BEAM-378: --- I guess the status of this issue is not aligned what happened