[jira] [Reopened] (BEAM-855) Remove the need for --streaming option in the spark runner

[ https://issues.apache.org/jira/browse/BEAM-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela reopened BEAM-855: Assignee: (was: Jean-Baptiste Onofré) > Remove the need for --streaming option in the spark runner >

[jira] [Closed] (BEAM-855) Remove the need for --streaming option in the spark runner

[ https://issues.apache.org/jira/browse/BEAM-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-855. -- Resolution: Duplicate Fix Version/s: Not applicable > Remove the need for --streaming option in the spark

[jira] [Updated] (BEAM-855) Remove the need for --streaming option in the spark runner

[ https://issues.apache.org/jira/browse/BEAM-855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-855: --- Fix Version/s: (was: 0.4.0-incubating) > Remove the need for --streaming option in the spark runner >

[jira] [Updated] (BEAM-807) [SparkRunner] Replace OldDoFn with DoFn

[ https://issues.apache.org/jira/browse/BEAM-807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-807: --- Fix Version/s: (was: 0.4.0-incubating) 0.5.0-incubating > [SparkRunner] Replace OldDoFn

[jira] [Updated] (BEAM-757) The SparkRunner should utilize the SDK's DoFnRunner instead of writing it's own.

[ https://issues.apache.org/jira/browse/BEAM-757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-757: --- Fix Version/s: (was: 0.4.0-incubating) 0.5.0-incubating > The SparkRunner should utilize

[jira] [Commented] (BEAM-690) Backoff in the DirectRunner Monitor if no work is Available

[ https://issues.apache.org/jira/browse/BEAM-690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15751670#comment-15751670 ] Stas Levin commented on BEAM-690: - Hi, I'm trying to look into it, correct me if I'm wrong, but won't

[jira] [Assigned] (BEAM-647) Fault-tolerant sideInputs via Broadcast variables

[ https://issues.apache.org/jira/browse/BEAM-647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kobi Salant reassigned BEAM-647: Assignee: Kobi Salant (was: Amit Sela) > Fault-tolerant sideInputs via Broadcast variables >

[jira] [Created] (BEAM-1163) Add signature keys to the release guide vote template

Ismaël Mejía created BEAM-1163: -- Summary: Add signature keys to the release guide vote template Key: BEAM-1163 URL: https://issues.apache.org/jira/browse/BEAM-1163 Project: Beam Issue Type:

[jira] [Created] (BEAM-1162) Create RedisIO

Ismaël Mejía created BEAM-1162: -- Summary: Create RedisIO Key: BEAM-1162 URL: https://issues.apache.org/jira/browse/BEAM-1162 Project: Beam Issue Type: Improvement Components:

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #1

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on beam1 (beam) in workspace

[GitHub] incubator-beam pull request #1624: [BEAM-647] Fault-tolerant sideInputs via ...

GitHub user kobisalant opened a pull request: https://github.com/apache/incubator-beam/pull/1624 [BEAM-647] Fault-tolerant sideInputs via Broadcast variables Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[GitHub] incubator-beam pull request #1620: [BEAM-1154] Get side input from proper wi...

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

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

[jira] [Commented] (BEAM-1023) Add test coverage for BigQueryIO.Write in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-1023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752424#comment-15752424 ] Daniel Halperin commented on BEAM-1023: --- This was implemented by PR #1400, which was accidentally

Build failed in Jenkins: beam_PostCommit_Java_RunnableOnService_Apex #2

See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on beam3 (beam) in workspace

[jira] [Commented] (BEAM-1022) TableNamespace should not use Java object equality when comparing windows

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

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

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

[GitHub] incubator-beam pull request #1629: Set Dataflow worker version to 0.4.0-incu...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1629 --- 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: Set Dataflow worker version to 0.4.0-incubating

Repository: incubator-beam Updated Branches: refs/heads/release-0.4.0-incubating 7e234aa79 -> 5dcffe066 Set Dataflow worker version to 0.4.0-incubating Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #1631: Change counter name in TestDataflowRunner

GitHub user joshualitt opened a pull request: https://github.com/apache/incubator-beam/pull/1631 Change counter name in TestDataflowRunner This small change updates the name of the windmill watermark counter in TestDataflowRunner You can merge this pull request into a Git

[1/2] incubator-beam git commit: [BEAM-1022] Add testing coverage for BigQuery streaming writes

Repository: incubator-beam Updated Branches: refs/heads/master 3c4b6930e -> 3e1a62815 [BEAM-1022] Add testing coverage for BigQuery streaming writes Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #1400: [BEAM-1022] Add test coverage for BigQuer...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1400 --- 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] [Created] (BEAM-1164) Allow a DoFn to opt in to mutating it's input

Frances Perry created BEAM-1164: --- Summary: Allow a DoFn to opt in to mutating it's input Key: BEAM-1164 URL: https://issues.apache.org/jira/browse/BEAM-1164 Project: Beam Issue Type: Bug

[jira] [Resolved] (BEAM-1023) Add test coverage for BigQueryIO.Write in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-1023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1023. --- Resolution: Fixed Fix Version/s: 0.5.0-incubating > Add test coverage for

[jira] [Commented] (BEAM-647) Fault-tolerant sideInputs via Broadcast variables

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

[GitHub] incubator-beam pull request #1625: Don't incorrectly log error in MetricsEnv...

GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/1625 Don't incorrectly log error in MetricsEnvironment 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 #1629: Set Dataflow worker version to 0.4.0-incu...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1629 Set Dataflow worker version to 0.4.0-incubating Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[1/2] incubator-beam git commit: [BEAM-1154] Get side input from proper window in ReduceFn

Repository: incubator-beam Updated Branches: refs/heads/release-0.4.0-incubating c09fbd43b -> 3ca8d2bfc [BEAM-1154] Get side input from proper window in ReduceFn Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

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

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

[GitHub] incubator-beam pull request #1626: Fix typo in mvn command args in Apex post...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1626 Fix typo in mvn command args in Apex postcommit Jenkins job Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure

[GitHub] incubator-beam pull request #1627: [BEAM-1160] Add option to disable failure...

GitHub user swegner opened a pull request: https://github.com/apache/incubator-beam/pull/1627 [BEAM-1160] Add option to disable failures if filePattern resolves to empty Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [

[GitHub] incubator-beam pull request #1628: Bump 0.4.0 incubating worker

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1628 Bump 0.4.0 incubating worker 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

[GitHub] incubator-beam pull request #1628: Bump 0.4.0 incubating worker

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

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

[1/2] incubator-beam git commit: Don't incorrectly log error in MetricsEnvironment

Repository: incubator-beam Updated Branches: refs/heads/release-0.4.0-incubating 5dcffe066 -> c09fbd43b Don't incorrectly log error in MetricsEnvironment Using getCurrentContainer() logs an error if metrics are not supported. This is because it acts as the common point of access for user code

[GitHub] incubator-beam pull request #1630: Cherry pick #1620 to release-0.4.0-incuba...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1630 Cherry pick #1620 to release-0.4.0-incubating Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title

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

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

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Apex #4

See

[jira] [Commented] (BEAM-1160) Disabling Read transform validation cause empty file patterns to unexpected succeed

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

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

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

[1/2] incubator-beam git commit: Fix mvn command args in Apex postcommit Jenkins job

Repository: incubator-beam Updated Branches: refs/heads/master 4323247a3 -> b38c9e9eb Fix mvn command args in Apex postcommit Jenkins job Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8c00f63c Tree:

[GitHub] incubator-beam pull request #1626: Fix typo in mvn command args in Apex post...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1626 --- 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-1154) ReduceFnRunner fetches side input from the wrong window

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

[GitHub] incubator-beam pull request #1630: Cherry pick #1620 to release-0.4.0-incuba...

Github user kennknowles closed the pull request at: https://github.com/apache/incubator-beam/pull/1630 --- 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] [Created] (BEAM-1165) Unexpected file created when checking dependencies on clean repo

Ismaël Mejía created BEAM-1165: -- Summary: Unexpected file created when checking dependencies on clean repo Key: BEAM-1165 URL: https://issues.apache.org/jira/browse/BEAM-1165 Project: Beam

[jira] [Updated] (BEAM-1166) Source.getDefaultOutputCoder() documentation should mention CannotProvideCoderException

[ https://issues.apache.org/jira/browse/BEAM-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-1166: -- Component/s: sdk-java-core beam-model > Source.getDefaultOutputCoder()

[GitHub] incubator-beam pull request #1625: Don't incorrectly log error in MetricsEnv...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1625 --- 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 #1637: [BEAM-1153] GcsUtil: use non-batch API fo...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/1637 [BEAM-1153] GcsUtil: use non-batch API for single file size requests. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[jira] [Updated] (BEAM-1084) Update apitools to version 0.5.6

[ https://issues.apache.org/jira/browse/BEAM-1084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sourabh Bajaj updated BEAM-1084: Description: There are some fixes to JsonValue that should be included in beam

[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=15752949#comment-15752949 ] ASF GitHub Bot commented on BEAM-498: - GitHub user jkff opened a pull request:

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

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

[1/2] incubator-beam git commit: Update the BQ export flat from Json to Avro

Repository: incubator-beam Updated Branches: refs/heads/python-sdk e383c7715 -> d3c887480 Update the BQ export flat from Json to Avro Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0a558c71 Tree:

incubator-beam git commit: [maven-release-plugin] prepare release v0.4.0-incubating-RC3

Repository: incubator-beam Updated Branches: refs/heads/release-0.4.0-incubating bce0a0d50 -> 3d67e7a1f [maven-release-plugin] prepare release v0.4.0-incubating-RC3 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Tags: refs/tags/v0.4.0-incubating-RC3 [created] 112e38e4a

[1/2] incubator-beam git commit: Update Apitools to version 0.5.6

Repository: incubator-beam Updated Branches: refs/heads/python-sdk e26527873 -> 3b4fd5c7d Update Apitools to version 0.5.6 This brings in the fix to https://github.com/google/apitools/pull/136 needed for the BigQuery reader. Project:

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

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

[GitHub] incubator-beam pull request #1638: Make a RunnableOnService test for Metrics

GitHub user bjchambers opened a pull request: https://github.com/apache/incubator-beam/pull/1638 Make a RunnableOnService test for Metrics Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [*] Make sure the PR title is

[GitHub] incubator-beam pull request #1635: Remove deprecated methods of InMemoryTime...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1635 Remove deprecated methods of InMemoryTimerInternals Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR

[jira] [Commented] (BEAM-1153) GcsUtil needs to set timeout and retry explicitly in BatchRequest.

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

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

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

[1/2] incubator-beam git commit: [BEAM-1153] GcsUtil: use non-batch API for single file size requests.

Repository: incubator-beam Updated Branches: refs/heads/release-0.4.0-incubating f753422a3 -> bce0a0d50 [BEAM-1153] GcsUtil: use non-batch API for single file size requests. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Commented] (BEAM-1153) GcsUtil needs to set timeout and retry explicitly in BatchRequest.

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

[GitHub] incubator-beam pull request #1637: [BEAM-1153] GcsUtil: use non-batch API fo...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1637 --- 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] [Resolved] (BEAM-1153) GcsUtil needs to set timeout and retry explicitly in BatchRequest.

[ https://issues.apache.org/jira/browse/BEAM-1153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-1153. Resolution: Fixed Fix Version/s: 0.4.0-incubating > GcsUtil needs to set timeout and retry

incubator-beam git commit: [maven-release-plugin] rollback changes from release preparation of v0.4.0-incubating-RC3

Repository: incubator-beam Updated Branches: refs/heads/release-0.4.0-incubating 3d67e7a1f -> 93045e9c1 [maven-release-plugin] rollback changes from release preparation of v0.4.0-incubating-RC3 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Resolved] (BEAM-1104) WordCount: Metrics error in the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Chambers resolved BEAM-1104. Resolution: Fixed Fix Version/s: 0.4.0-incubating > WordCount: Metrics error in the

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2116

See

[GitHub] incubator-beam pull request #1617: [BEAM-964] json avro flag migration

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1617 --- 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-964) Investing exporting BQ as Avro instead of Json for dataflow runner

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

[1/2] incubator-beam git commit: Rename PTransform.apply() to PTransform.expand()

Repository: incubator-beam Updated Branches: refs/heads/python-sdk d3c887480 -> e26527873 Rename PTransform.apply() to PTransform.expand() See https://issues.apache.org/jira/browse/BEAM-1125 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

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

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

[jira] [Commented] (BEAM-1084) Update apitools to version 0.5.6

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

[GitHub] incubator-beam pull request #1501: [BEAM-1084] Update Apitools to version 0....

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

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2115

See -- [...truncated 5829 lines...] Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.384 sec - in org.apache.beam.sdk.transforms.LatestTest Running

[GitHub] incubator-beam pull request #1636: [BEAM-498] Moves OldDoFn to runners-core

GitHub user jkff opened a pull request: https://github.com/apache/incubator-beam/pull/1636 [BEAM-498] Moves OldDoFn to runners-core This will of course need the usual Dataflow worker surgery. R: @kennknowles You can merge this pull request into a Git repository by

[jira] [Commented] (BEAM-1104) WordCount: Metrics error in the DirectRunner

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

[GitHub] incubator-beam pull request #1615: [BEAM-1104] Don't incorrectly log error i...

Github user bjchambers closed the pull request at: https://github.com/apache/incubator-beam/pull/1615 --- 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-site pull request #111: [BEAM-1163] Add signature keys to the...

GitHub user iemejia opened a pull request: https://github.com/apache/incubator-beam-site/pull/111 [BEAM-1163] Add signature keys to the vote template (release guide) You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (BEAM-1163) Add signature keys to the release guide vote template

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

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Apex #5

See

[jira] [Created] (BEAM-1166) Source.getDefaultOutputCoder() documentation should mention CannotProvideCoderException

Stephen Sisk created BEAM-1166: -- Summary: Source.getDefaultOutputCoder() documentation should mention CannotProvideCoderException Key: BEAM-1166 URL: https://issues.apache.org/jira/browse/BEAM-1166

[jira] [Commented] (BEAM-1125) Rename PTransform.apply to PTransform.expand

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

[jira] [Resolved] (BEAM-1120) Prepare Dataflow runner for 0.4.0 release

[ https://issues.apache.org/jira/browse/BEAM-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-1120. --- Resolution: Fixed Fix Version/s: Not applicable > Prepare Dataflow runner for 0.4.0

[GitHub] incubator-beam pull request #1634: [BEAM-1125] Rename PTransform.apply() to ...

GitHub user aaltay opened a pull request: https://github.com/apache/incubator-beam/pull/1634 [BEAM-1125] Rename PTransform.apply() to PTransform.expand() Rename apply function to expand to match the recent change in the Java SDK. You can merge this pull request into a Git

incubator-beam git commit: [maven-release-plugin] rollback changes from release preparation of v0.4.0-incubating-RC2

Repository: incubator-beam Updated Branches: refs/heads/release-0.4.0-incubating a29affd05 -> f753422a3 [maven-release-plugin] rollback changes from release preparation of v0.4.0-incubating-RC2 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[10/10] incubator-beam git commit: This closes #1565

This closes #1565 Renames ParDo.getNewFn to getFn Moves DoFnAdapters to runners-core Removes unused code from NoOpOldDoFn Removes ArgumentProvider.windowingInternals Removes code for wrapping DoFn as an OldDoFn Removes OldDoFn from ParDo Pushes uses of OldDoFn deeper inside Flink

[03/10] incubator-beam git commit: Remove ParDo.of(OldDoFn) from Apex runner

Remove ParDo.of(OldDoFn) from Apex runner The only such usage was of AssignWindowsDoFn. Now, instead, it is instantiated directly using a new translator for Window.Bound. This change also separates the overloads of ApexParDoOperator for old and new DoFn, to make the OldDoFn overload easier to

[05/10] incubator-beam git commit: Removes OldDoFn from ParDo

Removes OldDoFn from ParDo Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e9e53c5d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e9e53c5d Diff:

[09/10] incubator-beam git commit: Renames ParDo.getNewFn to getFn

Renames ParDo.getNewFn to getFn Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6b502fc1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6b502fc1 Diff:

[07/10] incubator-beam git commit: Removes ArgumentProvider.windowingInternals

Removes ArgumentProvider.windowingInternals Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f3e8a038 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f3e8a038 Diff:

[06/10] incubator-beam git commit: Removes unused code from NoOpOldDoFn

Removes unused code from NoOpOldDoFn Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ca1dd7a3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ca1dd7a3 Diff:

[04/10] incubator-beam git commit: Removes code for wrapping DoFn as an OldDoFn

Removes code for wrapping DoFn as an OldDoFn Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a22de150 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a22de150 Diff:

[01/10] incubator-beam git commit: Converts all easy OldDoFns to DoFn

Repository: incubator-beam Updated Branches: refs/heads/master 3e1a62815 -> 5a3ace4a7 Converts all easy OldDoFns to DoFn Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f5f329ee Tree:

[02/10] incubator-beam git commit: Pushes uses of OldDoFn deeper inside Flink runner

Pushes uses of OldDoFn deeper inside Flink runner In particular, various DoFnOperator's now take a regular DoFn rather than an OldDoFn, and convert it to an OldDoFn internally. This allows to remove uses of ParDo.getFn() returning OldDoFn. The only case where the OldDoFn inside a DoFnOperator

[08/10] incubator-beam git commit: Moves DoFnAdapters to runners-core

Moves DoFnAdapters to runners-core Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/33ed3238 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/33ed3238 Diff:

[GitHub] incubator-beam pull request #1565: [BEAM-498] Practically removes OldDoFn fr...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1565 --- 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-498) Make DoFnWithContext the new DoFn

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

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2111

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

[jira] [Commented] (BEAM-1023) Add test coverage for BigQueryIO.Write in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-1023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752428#comment-15752428 ] Daniel Halperin commented on BEAM-1023: --- https://github.com/apache/incubator-beam/pull/1400 > Add

[incubator-beam] Git Push Summary

Repository: incubator-beam Updated Tags: refs/tags/v0.4.0-incubating-RC2 [created] 76246ac4f

  1   2   >