[jira] [Resolved] (BEAM-1950) Access to static field shouldn't be protected by lock on non-static MicrobatchSource.this

[ https://issues.apache.org/jira/browse/BEAM-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-1950. - Resolution: Fixed Fix Version/s: First stable release > Access to static field shouldn't be

[jira] [Updated] (BEAM-1950) Access to static field shouldn't be protected by lock on non-static MicrobatchSource.this

[ https://issues.apache.org/jira/browse/BEAM-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1950: Fix Version/s: (was: First stable release) > Access to static field shouldn't be protected by lock on

[GitHub] beam pull request #2514: [BEAM-1950] Add missing 'static' keyword to Microba...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2514 --- 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-1950) Access to static field shouldn't be protected by lock on non-static MicrobatchSource.this

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

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

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

[1/2] beam git commit: [BEAM-1950] Add missing 'static' keyword to MicrobatchSource#initReaderCache

Repository: beam Updated Branches: refs/heads/master dc672f420 -> 21a2b96a1 [BEAM-1950] Add missing 'static' keyword to MicrobatchSource#initReaderCache Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdabd41a Tree:

[jira] [Commented] (BEAM-1672) Extract interface MetricData

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

[GitHub] beam pull request #2522: [BEAM-1672] Extract interface MetricData

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2522 [BEAM-1672] Extract interface MetricData 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-301) Add a Beam SQL DSL

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

[GitHub] beam pull request #2479: [BEAM-301] Add a Beam SQL DSL

Github user XuMingmin closed the pull request at: https://github.com/apache/beam/pull/2479 --- 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] [Created] (BEAM-1959) Standard IO Metrics in Python SDK

Aviem Zur created BEAM-1959: --- Summary: Standard IO Metrics in Python SDK Key: BEAM-1959 URL: https://issues.apache.org/jira/browse/BEAM-1959 Project: Beam Issue Type: Sub-task

[jira] [Created] (BEAM-1958) Standard IO Metrics in Java SDK

Aviem Zur created BEAM-1958: --- Summary: Standard IO Metrics in Java SDK Key: BEAM-1958 URL: https://issues.apache.org/jira/browse/BEAM-1958 Project: Beam Issue Type: Sub-task Components:

[jira] [Created] (BEAM-1957) Missing DoFn annotations documentation

Aviem Zur created BEAM-1957: --- Summary: Missing DoFn annotations documentation Key: BEAM-1957 URL: https://issues.apache.org/jira/browse/BEAM-1957 Project: Beam Issue Type: Improvement

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1838

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #2821

See

[jira] [Commented] (BEAM-972) Add basic level of unit testing to gearpump runner

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

[GitHub] beam pull request #2521: [BEAM-972] Add more unit test to Gearpump runner

GitHub user huafengw opened a pull request: https://github.com/apache/beam/pull/2521 [BEAM-972] Add more unit test to Gearpump runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #2820

See

[jira] [Commented] (BEAM-1789) window can't not use in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15966945#comment-15966945 ] tianyou commented on BEAM-1789: --- [~amitsela] Yes I can't find anything ERROR or WARNING message in Spark UI

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

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

[GitHub] beam pull request #2520: [BEAM-1166] Update docs for getDefaultOutputCoder

GitHub user ssisk opened a pull request: https://github.com/apache/beam/pull/2520 [BEAM-1166] Update docs for getDefaultOutputCoder 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

Build failed in Jenkins: beam_PerformanceTests_JDBC #107

See Changes: [jbonofre] [BEAM-1882] Update postgres k8 scripts & add scripts for running local [kirpichov] Removes MapElements.MissingOutputTypeDescriptor [kirpichov] Removes

[jira] [Resolved] (BEAM-1807) IO ITs: shared language neutral directory for kubernetes resources

[ https://issues.apache.org/jira/browse/BEAM-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephen Sisk resolved BEAM-1807. Resolution: Fixed Fix Version/s: First stable release Moved this today, jenkins still seems

[jira] [Closed] (BEAM-1912) Move HashingFn into io/common so it can be used by other tests

[ https://issues.apache.org/jira/browse/BEAM-1912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephen Sisk closed BEAM-1912. -- > Move HashingFn into io/common so it can be used by other tests >

[jira] [Closed] (BEAM-1852) dead links on beam website

[ https://issues.apache.org/jira/browse/BEAM-1852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephen Sisk closed BEAM-1852. -- > dead links on beam website > -- > > Key: BEAM-1852 >

[jira] [Closed] (BEAM-1896) Add list of In Progress IOs to the Pipeline I/O section of the website

[ https://issues.apache.org/jira/browse/BEAM-1896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephen Sisk closed BEAM-1896. -- > Add list of In Progress IOs to the Pipeline I/O section of the website >

[jira] [Commented] (BEAM-1956) Flatten operation should respect input type hints.

[ https://issues.apache.org/jira/browse/BEAM-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15966906#comment-15966906 ] Vikas Kedigehalli commented on BEAM-1956: - cc [~lcwik] [~robertwb] [~dhalp...@google.com] >

[jira] [Created] (BEAM-1956) Flatten operation should respect input type hints.

Vikas Kedigehalli created BEAM-1956: --- Summary: Flatten operation should respect input type hints. Key: BEAM-1956 URL: https://issues.apache.org/jira/browse/BEAM-1956 Project: Beam Issue

Build failed in Jenkins: beam_PostCommit_Python_Verify #1837

See Changes: [dhalperi] Move Triggers from sdk-core to runners-core-construction -- [...truncated 725.83 KB...] File

[jira] [Commented] (BEAM-1925) Make DoFn invocation logic of Python SDK more extensible

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

[GitHub] beam pull request #2519: [BEAM-1925] Updates DoFn invocation logic to be mor...

GitHub user chamikaramj opened a pull request: https://github.com/apache/beam/pull/2519 [BEAM-1925] Updates DoFn invocation logic to be more extensible. Adds following abstractions. DoFnSignature: describes the signature of a given DoFn object. DoFnInvoker: defines a

Build failed in Jenkins: beam_PerformanceTests_Dataflow #301

See Changes: [jbonofre] [BEAM-1882] Update postgres k8 scripts & add scripts for running local [kirpichov] Removes MapElements.MissingOutputTypeDescriptor [kirpichov] Removes

[jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api

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

[GitHub] beam pull request #2518: [BEAM-1347] Update protos related to State API for ...

GitHub user lukecwik opened a pull request: https://github.com/apache/beam/pull/2518 [BEAM-1347] Update protos related to State API for prototyping purposes Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure

[GitHub] beam pull request #2517: Test all Known Coders to ensure they Serialize via ...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2517 Test all Known Coders to ensure they Serialize via URN Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1836

See

[GitHub] beam pull request #2513: Move Triggers from sdk-core to runners-core-constru...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2513 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[1/2] beam git commit: Move Triggers from sdk-core to runners-core-construction

Repository: beam Updated Branches: refs/heads/master 8479094c2 -> dc672f420 Move Triggers from sdk-core to runners-core-construction Converting to/from Runner API is not the SDK API surface. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[jira] [Commented] (BEAM-1222) Move GCS specific constants out of fileio

[ https://issues.apache.org/jira/browse/BEAM-1222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15966746#comment-15966746 ] Sourabh Bajaj commented on BEAM-1222: - [~chamikara] this can be resolved now. > Move GCS specific

Build failed in Jenkins: beam_PostCommit_Python_Verify #1835

See Changes: [jbonofre] [BEAM-911] Mark IO APIs as @Experimental [tgroh] Move travis/jenkins folders in a test-infra folder [tgroh] Move jdbc's postgres k8s scripts into shared k8s dir [tgroh]

[jira] [Commented] (BEAM-1222) Move GCS specific constants out of fileio

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

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

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

[GitHub] beam pull request #2483: [BEAM-1222] Chunk size should be FS dependent

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2483 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[1/2] beam git commit: [BEAM-1222] Chunk size should be FS dependent

Repository: beam Updated Branches: refs/heads/master 94c9e3817 -> 8479094c2 [BEAM-1222] Chunk size should be FS dependent Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6f3fd354 Tree:

[jira] [Created] (BEAM-1955) mapOutputs doesn't permit one replacement PValue to be used to represent multiple original PValues

Thomas Groh created BEAM-1955: - Summary: mapOutputs doesn't permit one replacement PValue to be used to represent multiple original PValues Key: BEAM-1955 URL: https://issues.apache.org/jira/browse/BEAM-1955

Jenkins build is unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #2818

See

[jira] [Commented] (BEAM-1644) IO ITs: shared directory for kubernetes resources and PipelineOptions?

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

[5/6] beam git commit: Move travis/jenkins folders in a test-infra folder

http://git-wip-us.apache.org/repos/asf/beam/blob/66b20af9/.test-infra/jenkins/job_beam_PreCommit_Website_Stage.groovy -- diff --git a/.test-infra/jenkins/job_beam_PreCommit_Website_Stage.groovy

[GitHub] beam pull request #2466: [BEAM-1644] Move travis & jenkins into shared test-...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2466 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[2/6] beam git commit: Move jdbc's postgres k8s scripts into shared k8s dir

Move jdbc's postgres k8s scripts into shared k8s dir Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/57588990 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/57588990 Diff:

[4/6] beam git commit: Move HIFIO k8s scripts into shared dir

Move HIFIO k8s scripts into shared dir Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/34b95076 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/34b95076 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/34b95076

[3/6] beam git commit: Move HIFIO k8s scripts into shared dir

http://git-wip-us.apache.org/repos/asf/beam/blob/34b95076/sdks/java/io/hadoop/jdk1.8-tests/src/test/resources/kubernetes/elasticsearch/es_test_data.py -- diff --git

[1/6] beam git commit: This closes #2466

Repository: beam Updated Branches: refs/heads/master 1788cef96 -> 94c9e3817 This closes #2466 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/94c9e381 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/94c9e381 Diff:

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1834

See

[jira] [Created] (BEAM-1954) "test" extra need nose in the requirements list

Marc Boissonneault created BEAM-1954: Summary: "test" extra need nose in the requirements list Key: BEAM-1954 URL: https://issues.apache.org/jira/browse/BEAM-1954 Project: Beam Issue

[2/3] beam git commit: [BEAM-301] Initial skeleton for Beam SQL

[BEAM-301] Initial skeleton for Beam SQL Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7867ce62 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7867ce62 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7867ce62

[1/3] beam git commit: [BEAM-301] Initial skeleton for Beam SQL

Repository: beam Updated Branches: refs/heads/DSL_SQL 3625dbd9e -> f1c2b6540 http://git-wip-us.apache.org/repos/asf/beam/blob/7867ce62/dsls/sql/src/main/java/org/beam/dsls/sql/schema/BaseBeamTable.java -- diff --git

[3/3] beam git commit: [BEAM-301] This closes #2479

[BEAM-301] This closes #2479 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f1c2b654 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f1c2b654 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f1c2b654 Branch:

[jira] [Commented] (BEAM-1928) Populate Runner API Components from the Java SDK

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

[02/50] [abbrv] beam git commit: Improve HadoopInputFormatIO DisplayData and Cassandra tests

Improve HadoopInputFormatIO DisplayData and Cassandra tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c08b7b17 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c08b7b17 Diff:

[23/50] [abbrv] beam git commit: This closes #2498

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

[28/50] [abbrv] beam git commit: [BEAM-1722] Move PubsubIO into the google-cloud-platform module

http://git-wip-us.apache.org/repos/asf/beam/blob/5bcb8c57/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClientTest.java -- diff --git

[49/50] [abbrv] beam git commit: [BEAM-911] This closes #2510

[BEAM-911] This closes #2510 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1788cef9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1788cef9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1788cef9 Branch:

[17/50] [abbrv] beam git commit: This closes #2497

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

[01/50] [abbrv] beam git commit: This closes #2487 [Forced Update!]

Repository: beam Updated Branches: refs/heads/DSL_SQL 870e42dec -> 3625dbd9e (forced update) This closes #2487 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8beea73c Tree:

[42/50] [abbrv] beam git commit: Removes MapElements.MissingOutputTypeDescriptor

Removes MapElements.MissingOutputTypeDescriptor This comes from changing MapElements.via(fn).withOutputType(td) to MapElements.into(td).via(fn) which is also shorter. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3bf6c6b3

[45/50] [abbrv] beam git commit: Revert "Throw specialized exception in value providers"

Revert "Throw specialized exception in value providers" This reverts commit ee92b9642bb6b6e42bb701ab638c55539163bb69. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4854291f Tree:

[05/50] [abbrv] beam git commit: This closes #2491

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

[12/50] [abbrv] beam git commit: Remove Orderdness of Input, Output expansions

http://git-wip-us.apache.org/repos/asf/beam/blob/0e5737fd/runners/direct-java/src/test/java/org/apache/beam/runners/direct/DirectGraphVisitorTest.java -- diff --git

[13/50] [abbrv] beam git commit: Remove Orderdness of Input, Output expansions

Remove Orderdness of Input, Output expansions This brings the PInput and POutput expansion signatures back in line with the Runner API. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0e5737fd Tree:

[34/50] [abbrv] beam git commit: [BEAM-1722] Move PubsubIO into the google-cloud-platform module

[BEAM-1722] Move PubsubIO into the google-cloud-platform module Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5bcb8c57 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5bcb8c57 Diff:

[31/50] [abbrv] beam git commit: [BEAM-1722] Move PubsubIO into the google-cloud-platform module

http://git-wip-us.apache.org/repos/asf/beam/blob/5bcb8c57/sdks/java/core/src/test/java/org/apache/beam/sdk/util/PubsubGrpcClientTest.java -- diff --git

[09/50] [abbrv] beam git commit: Closes #2494

Closes #2494 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a5a5bf94 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a5a5bf94 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a5a5bf94 Branch: refs/heads/DSL_SQL

[32/50] [abbrv] beam git commit: [BEAM-1722] Move PubsubIO into the google-cloud-platform module

http://git-wip-us.apache.org/repos/asf/beam/blob/5bcb8c57/sdks/java/core/src/main/java/org/apache/beam/sdk/util/PubsubGrpcClient.java -- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/PubsubGrpcClient.java

[41/50] [abbrv] beam git commit: [BEAM-1882] This closes #2431

[BEAM-1882] This closes #2431 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f3143540 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f3143540 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f3143540 Branch:

[27/50] [abbrv] beam git commit: This closes #2504

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

[21/50] [abbrv] beam git commit: This closes #2496

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

[20/50] [abbrv] beam git commit: Throw specialized exception in value providers

Throw specialized exception in value providers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ee92b964 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ee92b964 Diff:

[07/50] [abbrv] beam git commit: Fix build breaks caused by overlaps between b615013 and c08b7b1

Fix build breaks caused by overlaps between b615013 and c08b7b1 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/732610d8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/732610d8 Diff:

[29/50] [abbrv] beam git commit: [BEAM-1722] Move PubsubIO into the google-cloud-platform module

http://git-wip-us.apache.org/repos/asf/beam/blob/5bcb8c57/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java -- diff --git

[48/50] [abbrv] beam git commit: [BEAM-911] Mark IO APIs as @Experimental

[BEAM-911] Mark IO APIs as @Experimental Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/024b6e05 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/024b6e05 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/024b6e05

[15/50] [abbrv] beam git commit: This closes #2493

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

[22/50] [abbrv] beam git commit: DataflowRunner: remove dead code

DataflowRunner: remove dead code It is not possible to try to use an unbounded source in batch mode any more, as the runner will automatically enable streaming mode. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f4736729

[40/50] [abbrv] beam git commit: [BEAM-1882] Update postgres k8 scripts & add scripts for running local dev test

[BEAM-1882] Update postgres k8 scripts & add scripts for running local dev test Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4d1feebf Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4d1feebf Diff:

[50/50] [abbrv] beam git commit: Add DSLs module

Add DSLs module Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3625dbd9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3625dbd9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3625dbd9 Branch:

[10/50] [abbrv] beam git commit: This closes #2430

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

[24/50] [abbrv] beam git commit: Clean HFIOWithEmbeddedCassandraTest before Execution

Clean HFIOWithEmbeddedCassandraTest before Execution HIFIO Cassandra tests were failing if run twice in a row without a clean Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/041b636b Tree:

[11/50] [abbrv] beam git commit: Remove Orderdness of Input, Output expansions

http://git-wip-us.apache.org/repos/asf/beam/blob/0e5737fd/sdks/java/core/src/test/java/org/apache/beam/sdk/runners/TransformHierarchyTest.java -- diff --git

[18/50] [abbrv] beam git commit: DataflowRunner: send windowing strategy using Runner API proto

DataflowRunner: send windowing strategy using Runner API proto Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/69f412dc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/69f412dc Diff:

[04/50] [abbrv] beam git commit: Remove Jdk1.8-tests/.toDelete

Remove Jdk1.8-tests/.toDelete Breaks RAT. File not useful. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ee7965c9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ee7965c9 Diff:

[38/50] [abbrv] beam git commit: [BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent tag usage

[BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent tag usage Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b1148442 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b1148442 Diff:

[47/50] [abbrv] beam git commit: This closes #2515

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

[39/50] [abbrv] beam git commit: [BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent name usage

[BEAM-115] Update timer/state fields on ParDoPayload to use a map field for consistent name usage This closes #2511 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/435c3b42 Tree:

[08/50] [abbrv] beam git commit: Ignore more python build artifacts.

Ignore more python build artifacts. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a1683578 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a1683578 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a1683578

[16/50] [abbrv] beam git commit: DataflowRunner misc cleanups

DataflowRunner misc cleanups Bad use of format string, very old debugging assert Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3fb3a0c5 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3fb3a0c5 Diff:

[19/50] [abbrv] beam git commit: This closes #2495

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

[43/50] [abbrv] beam git commit: Removes FlatMapElements.MissingOutputTypeDescriptor

Removes FlatMapElements.MissingOutputTypeDescriptor This comes from changing FlatMapElements.via(fn).withOutputType(td) to FlatMapElements.into(td).via(fn) which is also shorter. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[46/50] [abbrv] beam git commit: Revert "Revert "Revert "Add ValueProvider class for FileBasedSource I/O Transforms"""

Revert "Revert "Revert "Add ValueProvider class for FileBasedSource I/O Transforms""" This reverts commit 28a0ea86721871a97f68b573019e818217266356. Manually resolved Conflicts: sdks/python/apache_beam/io/filebasedsource.py sdks/python/apache_beam/runners/direct/direct_runner.py

[33/50] [abbrv] beam git commit: [BEAM-1722] Move PubsubIO into the google-cloud-platform module

http://git-wip-us.apache.org/repos/asf/beam/blob/5bcb8c57/sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubUnboundedSource.java -- diff --git

[36/50] [abbrv] beam git commit: Use SdkComponents in WindowingStrategy.toProto

Use SdkComponents in WindowingStrategy.toProto Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e0fd0a22 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e0fd0a22 Diff:

  1   2   3   >