[GitHub] incubator-beam pull request #458: Rename DoFnTester#processBatch to processB...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/458 --- 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 #467: [BEAM-243] Add peekOutputValuesInWindow to...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/467 --- 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/3] incubator-beam git commit: Use TimestampedValue in DoFnTester

Repository: incubator-beam Updated Branches: refs/heads/master 774944014 -> 2b269559f Use TimestampedValue in DoFnTester This removes the duplicate OutputElementWithTimestamp data structure. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #462: Use TimestampedValue in DoFnTester

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

[3/3] incubator-beam git commit: This closes #467

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

[2/3] incubator-beam git commit: Add DoFnTester#peekOutputValuesInWindow

Add DoFnTester#peekOutputValuesInWindow This permits DoFns that interact with windowing to test the windowed, rather than overall output. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c627fa84 Tree:

[GitHub] incubator-beam pull request #467: Add peekOutputValuesInWindow to DoFnTester

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/467 Add peekOutputValuesInWindow to DoFnTester Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

svn commit: r14006 - in /release/incubator/beam: ./ 0.1.0-incubating/

Author: davor Date: Wed Jun 15 00:09:45 2016 New Revision: 14006 Log: Apache Beam, release 0.1.0-incubating. Added: release/incubator/beam/0.1.0-incubating/apache-beam-0.1.0-incubating-source-release.zip (with props)

[GitHub] incubator-beam pull request #465: Fix type error in Eclipse

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/465 Fix type error in Eclipse 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 like:

[04/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/transforms/window.py -- diff --git a/sdks/python/google/cloud/dataflow/transforms/window.py

[07/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/transforms/ptransform.py -- diff --git a/sdks/python/google/cloud/dataflow/transforms/ptransform.py

[jira] [Commented] (BEAM-341) ReduceFnRunner allows GC time overflow

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

[39/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/internal/pickler.py -- diff --git a/sdks/python/apache_beam/internal/pickler.py b/sdks/python/apache_beam/internal/pickler.py new file

[11/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/io/iobase.py -- diff --git a/sdks/python/google/cloud/dataflow/io/iobase.py b/sdks/python/google/cloud/dataflow/io/iobase.py

[GitHub] incubator-beam pull request #464: [BEAM-341] Fix ReduceFnRunner GC time over...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/464 [BEAM-341] Fix ReduceFnRunner GC time overflow Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title

[47/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/examples/cookbook/bigquery_side_input_test.py -- diff --git a/sdks/python/apache_beam/examples/cookbook/bigquery_side_input_test.py

[32/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/transforms/combiners_test.py -- diff --git a/sdks/python/apache_beam/transforms/combiners_test.py

[25/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/utils/processes_test.py -- diff --git a/sdks/python/apache_beam/utils/processes_test.py b/sdks/python/apache_beam/utils/processes_test.py

[30/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/transforms/ptransform_test.py -- diff --git a/sdks/python/apache_beam/transforms/ptransform_test.py

[49/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

Move all files to apache_beam folder Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b14dfadd Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b14dfadd Diff:

[29/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/transforms/timeutil_test.py -- diff --git a/sdks/python/apache_beam/transforms/timeutil_test.py

[46/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/examples/snippets/snippets.py -- diff --git a/sdks/python/apache_beam/examples/snippets/snippets.py

[42/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/internal/clients/dataflow/dataflow_v1b3_messages.py -- diff --git

[23/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/examples/cookbook/bigquery_schema.py -- diff --git a/sdks/python/google/cloud/dataflow/examples/cookbook/bigquery_schema.py

[36/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/io/fileio.py -- diff --git a/sdks/python/apache_beam/io/fileio.py b/sdks/python/apache_beam/io/fileio.py new file mode 100644 index

[GitHub] incubator-beam pull request #461: Initial Beam Python SDK

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

[34/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/pipeline.py -- diff --git a/sdks/python/apache_beam/pipeline.py b/sdks/python/apache_beam/pipeline.py new file mode 100644 index

[40/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/internal/clients/storage/storage_v1_messages.py -- diff --git a/sdks/python/apache_beam/internal/clients/storage/storage_v1_messages.py

[20/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/clients/bigquery/bigquery_v2_messages.py -- diff --git

[02/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/utils/counters.pxd -- diff --git a/sdks/python/google/cloud/dataflow/utils/counters.pxd

[24/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/coders/stream_test.py -- diff --git a/sdks/python/google/cloud/dataflow/coders/stream_test.py

[45/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/internal/apiclient.py -- diff --git a/sdks/python/apache_beam/internal/apiclient.py b/sdks/python/apache_beam/internal/apiclient.py new

[03/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/typehints/typed_pipeline_test.py -- diff --git a/sdks/python/google/cloud/dataflow/typehints/typed_pipeline_test.py

[26/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/utils/dependency.py -- diff --git a/sdks/python/apache_beam/utils/dependency.py b/sdks/python/apache_beam/utils/dependency.py new file

[08/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/transforms/combiners_test.py -- diff --git a/sdks/python/google/cloud/dataflow/transforms/combiners_test.py

[12/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/io/fileio.py -- diff --git a/sdks/python/google/cloud/dataflow/io/fileio.py b/sdks/python/google/cloud/dataflow/io/fileio.py

[38/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/internal/windmill_pb2.py -- diff --git a/sdks/python/apache_beam/internal/windmill_pb2.py

[28/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/transforms/window_test.py -- diff --git a/sdks/python/apache_beam/transforms/window_test.py

[35/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/io/iobase.py -- diff --git a/sdks/python/apache_beam/io/iobase.py b/sdks/python/apache_beam/io/iobase.py new file mode 100644 index

[44/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/internal/clients/bigquery/bigquery_v2_messages.py -- diff --git

[16/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/clients/storage/storage_v1_messages.py -- diff --git

[41/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/internal/clients/storage/__init__.py -- diff --git a/sdks/python/apache_beam/internal/clients/storage/__init__.py

[48/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/coders/typecoders.py -- diff --git a/sdks/python/apache_beam/coders/typecoders.py b/sdks/python/apache_beam/coders/typecoders.py new file

[21/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/apiclient.py -- diff --git a/sdks/python/google/cloud/dataflow/internal/apiclient.py

[31/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/transforms/ptransform.py -- diff --git a/sdks/python/apache_beam/transforms/ptransform.py

[27/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/typehints/typehints.py -- diff --git a/sdks/python/apache_beam/typehints/typehints.py b/sdks/python/apache_beam/typehints/typehints.py

[09/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/runners/dataflow_runner.py -- diff --git a/sdks/python/google/cloud/dataflow/runners/dataflow_runner.py

[18/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py -- diff --git

[13/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/windmill_service_pb2.py -- diff --git a/sdks/python/google/cloud/dataflow/internal/windmill_service_pb2.py

[22/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/examples/snippets/snippets.py -- diff --git a/sdks/python/google/cloud/dataflow/examples/snippets/snippets.py

[05/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/transforms/timeutil.py -- diff --git a/sdks/python/google/cloud/dataflow/transforms/timeutil.py

[14/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/windmill_pb2.py -- diff --git a/sdks/python/google/cloud/dataflow/internal/windmill_pb2.py

[43/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/apache_beam/internal/clients/dataflow/dataflow_v1b3_client.py -- diff --git

[17/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/clients/storage/__init__.py -- diff --git a/sdks/python/google/cloud/dataflow/internal/clients/storage/__init__.py

[06/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/transforms/ptransform_test.py -- diff --git a/sdks/python/google/cloud/dataflow/transforms/ptransform_test.py

[19/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py -- diff --git

[15/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/internal/pickler.py -- diff --git a/sdks/python/google/cloud/dataflow/internal/pickler.py

[01/50] [abbrv] incubator-beam git commit: Move all files to apache_beam folder

Repository: incubator-beam Updated Branches: refs/heads/python-sdk d53e96a0d -> cd0f50980 http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b14dfadd/sdks/python/google/cloud/dataflow/utils/pipeline_options_validator_test.py

[GitHub] incubator-beam pull request #463: Explicitly set the Runner in TestFlinkPipe...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/463 Explicitly set the Runner in TestFlinkPipelineRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[GitHub] incubator-beam pull request #462: Use TimestampedValue in DoFnTester

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/462 Use TimestampedValue in DoFnTester 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:

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

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

[GitHub] incubator-beam pull request #461: Initial Beam Python SDK

GitHub user silviulica opened a pull request: https://github.com/apache/incubator-beam/pull/461 Initial Beam Python SDK Baby Beam Python SDK joins the Beam family. Code moved from https://github.com/GoogleCloudPlatform/DataflowPythonSDK/ R: @davorbonaci, @francesperry,

[jira] [Created] (BEAM-341) ReduceFnRunner allows GC time overflow

Kenneth Knowles created BEAM-341: Summary: ReduceFnRunner allows GC time overflow Key: BEAM-341 URL: https://issues.apache.org/jira/browse/BEAM-341 Project: Beam Issue Type: Bug

[jira] [Resolved] (BEAM-340) Use Avro coder for KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghu Angadi resolved BEAM-340. --- Resolution: Duplicate > Use Avro coder for KafkaIO > --- > >

[jira] [Created] (BEAM-340) Use Avro coder for KafkaIO

Raghu Angadi created BEAM-340: - Summary: Use Avro coder for KafkaIO Key: BEAM-340 URL: https://issues.apache.org/jira/browse/BEAM-340 Project: Beam Issue Type: Improvement Reporter:

[GitHub] incubator-beam pull request #455: Set trimStackTrace to false for WordCountI...

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

[GitHub] incubator-beam pull request #452: Fix PAssert with empty collections

Github user kennknowles closed the pull request at: https://github.com/apache/incubator-beam/pull/452 --- 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-243) Remove DirectPipelineRunner and keep only the InProcessPipelineRunner

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

[7/8] incubator-beam git commit: Update the Default Pipeline Runner

Update the Default Pipeline Runner Select the InProcessRunner if it is on the classpath, and throw an exception otherwise. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a3ffd510 Tree:

[5/8] incubator-beam git commit: Increase Visibility of Flink Test PipelineOptions

Increase Visibility of Flink Test PipelineOptions This fixes an issue where the package-private nature would cause an exception Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/816a3bf1 Tree:

[8/8] incubator-beam git commit: This closes #446

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

[1/8] incubator-beam git commit: Move GcsUtil TextIO Tests to TextIOTest

Repository: incubator-beam Updated Branches: refs/heads/master c8ad2e7dd -> 774944014 Move GcsUtil TextIO Tests to TextIOTest These tests are not a test of the DataflowRunner, nor any DataflowRunner specific behavior, so they should be part of TextIOTest Project:

[GitHub] incubator-beam pull request #446: [BEAM-243][BEAM-22] Change the Default Pip...

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

[6/8] incubator-beam git commit: Set Runner in DataflowRunner Tests

Set Runner in DataflowRunner Tests Otherwise the Default Runner is used, which may be unavailable. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4d1e68af Tree:

[3/8] incubator-beam git commit: Update Direct Module tests to explicitly set Pipeline

Update Direct Module tests to explicitly set Pipeline Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a8a33b19 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a8a33b19 Diff:

[4/8] incubator-beam git commit: Update Pipeline Execution Style in WindowedWordCountTest

Update Pipeline Execution Style in WindowedWordCountTest This sets the runner a Pipeline creation time rather than sending a (potentially rewritten) pipeline to a new runner instance. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/8] incubator-beam git commit: Use TestPipeline#testingPipelineOptions in IO Tests

Use TestPipeline#testingPipelineOptions in IO Tests Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f73bd73c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f73bd73c Diff:

[jira] [Commented] (BEAM-327) Dataflow runner should have configuration for System.out/err handling

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

[GitHub] incubator-beam pull request #458: Rename DoFnTester#processBatch to processB...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/458 Rename DoFnTester#processBatch to processBundle Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

svn commit: r13998 - /release/incubator/beam/0.1.0-incubating/

Author: davor Date: Tue Jun 14 16:28:12 2016 New Revision: 13998 Log: Add a directory for 0.1.0-incubating version. The real purpose is to test permissions. Added: release/incubator/beam/0.1.0-incubating/

svn commit: r13997 - /dev/incubator/beam/KEYS

Author: davor Date: Tue Jun 14 16:25:07 2016 New Revision: 13997 Log: Add KEYS for Apache Beam, dev portion. Added: dev/incubator/beam/KEYS Added: dev/incubator/beam/KEYS == --- dev/incubator/beam/KEYS (added) +++

[GitHub] incubator-beam pull request #457: Revert GBK-based PAssert

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

Repository: incubator-beam Updated Branches: refs/heads/master f9a9214dd -> c8ad2e7dd Revert GBK-based PAssert This changed neglected the use of counters by the Dataflow runner, which is used to prevent tests for spuriously passing when a PCollection is empty. Obvious fixes for that revealed

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

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

[GitHub] incubator-beam pull request #457: Revert GBK-based PAssert

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/457 Revert GBK-based PAssert 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 like:

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #539

See