Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » JDK 1.7 (latest),beam #59

See Changes: [ccy] Remove support for NativeSinks from the Python DirectRunner [lcwik] Make BytesCoder to be a known type [robertwb] Add coder info to

[GitHub] beam pull request #3324: Avoid flakiness in data channel for empty streams.

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/3324 Avoid flakiness in data channel for empty streams. As empty stream is used as end-of-stream marker, don't ever send it as the data itself. Be sure to do all of the following to help us

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #107

See Changes: [ccy] Remove support for NativeSinks from the Python DirectRunner [lcwik] Make BytesCoder to be a known type [robertwb] Add coder info to pubsub io

Build failed in Jenkins: beam_PostCommit_Python_Verify #2439

See Changes: [robertwb] Add coder info to pubsub io -- [...truncated 503.34 KB...] DEPRECATION: pip install --download has been deprecated and will be

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

See Changes: [ccy] Remove support for NativeSinks from the Python DirectRunner [lcwik] Make BytesCoder to be a known type [robertwb] Add

[GitHub] beam pull request #3325: Use inner module for non-public coders.

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/3325 Use inner module for non-public coders. 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-2410) Remove TransportClient from ElasticSearchIO to decouple IO and ES versions

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

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

See Changes: [ccy] Remove support for NativeSinks from the Python DirectRunner [lcwik] Make BytesCoder to be a known type [robertwb] Add

[GitHub] beam pull request #3326: Beam-2383 Round function

GitHub user app-tarush opened a pull request: https://github.com/apache/beam/pull/3326 Beam-2383 Round function 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-2412) Update HBaseIO to use HBase client 1.2.6

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

[GitHub] beam pull request #3327: [BEAM-2412] Update HBaseIO to use HBase client 1.2....

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/3327 [BEAM-2412] Update HBaseIO to use HBase client 1.2.6 Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

[jira] [Updated] (BEAM-2357) Add HCatalogIO (Hive)

[ https://issues.apache.org/jira/browse/BEAM-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-2357: --- Summary: Add HCatalogIO (Hive) (was: Create HCatalogIO (Hive)) > Add HCatalogIO (Hive) >

[jira] [Updated] (BEAM-1942) Add Watermark Metrics in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated BEAM-1942: --- Summary: Add Watermark Metrics in Flink Runner (was: Add Source Watermark Metrics in Flink Runner) >

[jira] [Updated] (BEAM-1945) Add Watermark Metrics in Apex runner

[ https://issues.apache.org/jira/browse/BEAM-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated BEAM-1945: --- Summary: Add Watermark Metrics in Apex runner (was: Add Source Watermark Metrics in Apex runner) >

[jira] [Updated] (BEAM-1941) Add Watermark Metrics in Runners

[ https://issues.apache.org/jira/browse/BEAM-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated BEAM-1941: --- Summary: Add Watermark Metrics in Runners (was: Add Source Watermark Metrics in Runners) > Add

[jira] [Updated] (BEAM-1943) Add Watermark Metrics in Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-1943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated BEAM-1943: --- Summary: Add Watermark Metrics in Dataflow runner (was: Add Source Watermark Metrics in Dataflow

[jira] [Updated] (BEAM-1944) Add Watermark Metrics in Spark runner

[ https://issues.apache.org/jira/browse/BEAM-1944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated BEAM-1944: --- Summary: Add Watermark Metrics in Spark runner (was: Add Source Watermark Metrics in Spark runner) >

Build failed in Jenkins: beam_PostCommit_Python_Verify #2440

See -- [...truncated 502.14 KB...] File was already downloaded /tmp/dataflow-requirements-cache/funcsigs-1.0.2.tar.gz Collecting pbr>=0.11 (from mock->-r

[jira] [Resolved] (BEAM-2326) Verbose INFO logging with stateful DoFns and Dataflow

[ https://issues.apache.org/jira/browse/BEAM-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-2326. --- Resolution: Fixed Fix Version/s: 2.0.0 > Verbose INFO logging with stateful DoFns and

[1/2] beam git commit: [BEAM-2410] Remove TransportClient from ElasticSearchIO to decouple IO and ES server versions

Repository: beam Updated Branches: refs/heads/master e980ae921 -> 1c6861f22 [BEAM-2410] Remove TransportClient from ElasticSearchIO to decouple IO and ES server versions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[jira] [Resolved] (BEAM-2410) Remove TransportClient from ElasticSearchIO to decouple IO and ES versions

[ https://issues.apache.org/jira/browse/BEAM-2410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-2410. Resolution: Fixed Fix Version/s: 2.1.0 > Remove TransportClient from

[2/2] beam git commit: [BEAM-2410] This closes #3328

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

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #110

See Changes: [klk] Add Runner API oriented PTransformMatchers for DirectRunner overrides [klk] DirectRunner override matchers using Runner API [robertwb] Use inner module for non-public

Build failed in Jenkins: beam_PostCommit_Python_Verify #2450

See -- [...truncated 503.14 KB...] Collecting pbr>=0.11 (from mock->-r postcommit_requirements.txt (line 2)) File was already downloaded

[jira] [Commented] (BEAM-2326) Verbose INFO logging with stateful DoFns and Dataflow

[ https://issues.apache.org/jira/browse/BEAM-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16043784#comment-16043784 ] Kenneth Knowles commented on BEAM-2326: --- This was fixed right when it was reported, so should be g2g

[GitHub] beam pull request #3328: [BEAM-2410] Remove TransportClient from ElasticSear...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3328 --- 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-2410) Remove TransportClient from ElasticSearchIO to decouple IO and ES versions

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

[GitHub] beam pull request #3335: Tests for reading windowed side input from resumed ...

GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/3335 Tests for reading windowed side input from resumed SDF call R: @tgroh You can merge this pull request into a Git repository by running: $ git pull https://github.com/jkff/incubator-beam

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » JDK 1.7 (latest),beam #62

See Changes: [klk] Add Runner API oriented PTransformMatchers for DirectRunner overrides [klk] DirectRunner override matchers using Runner API [robertwb]

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

See Changes: [klk] Add Runner API oriented PTransformMatchers for DirectRunner overrides [klk] DirectRunner override matchers using Runner

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » JDK 1.7 (latest),beam #60

See -- [...truncated 1.25 MB...] 2017-06-08\T\12:27:51.552 [INFO] Downloading:

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

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

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #108

See -- [...truncated 2.55 MB...] 2017-06-08T12:35:55.553 [INFO] Downloading:

[1/2] beam git commit: upgrade to version 2.1.0-SNAPSHOT

Repository: beam Updated Branches: refs/heads/DSL_SQL 4c5b7584a -> 5c1f2cbc6 upgrade to version 2.1.0-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/03a913a9 Tree:

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

See -- [...truncated 895.14 KB...] 2017-06-08\T\12:11:45.809 [INFO] Excluding

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

See -- [...truncated 1.26 MB...] 2017-06-08\T\12:31:15.687 [INFO] Downloading:

Build failed in Jenkins: beam_PostCommit_Python_Verify #2442

See Changes: [tgroh] Expand all PValues to component PCollections always -- [...truncated 502.93 KB...] Successfully downloaded pyhamcrest mock setuptools

[2/3] beam git commit: Add Runner API oriented PTransformMatchers for DirectRunner overrides

Add Runner API oriented PTransformMatchers for DirectRunner overrides Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ca7b9c28 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ca7b9c28 Diff:

[1/3] beam git commit: DirectRunner override matchers using Runner API

Repository: beam Updated Branches: refs/heads/master b53e6f0dc -> 4aef93854 DirectRunner override matchers using Runner API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d8d90878 Tree:

[3/3] beam git commit: This closes #3239: [BEAM-2371] Port DirectRunner override matchers to language-agnostic construction APIs

This closes #3239: [BEAM-2371] Port DirectRunner override matchers to language-agnostic construction APIs DirectRunner override matchers using Runner API Add Runner API oriented PTransformMatchers for DirectRunner overrides Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

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

[GitHub] beam pull request #3239: [BEAM-2371] Port DirectRunner override matchers to ...

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

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

See Changes: [tgroh] Expand all PValues to component PCollections always [lcwik] Avoid flakiness in data channel for empty streams. [altay]

[GitHub] beam pull request #3329: Visit a Transform Hierarchy in Topological Order

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/3329 Visit a Transform Hierarchy in Topological Order This reverts commit 6ad6433ec0c02aec8656e9e3b27f6e0f974f8ece. Be sure to do all of the following to help us incorporate your contribution

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #109

See Changes: [tgroh] Expand all PValues to component PCollections always [lcwik] Avoid flakiness in data channel for empty streams. [altay] Refine Python DirectRunner watermark

[jira] [Commented] (BEAM-2282) logic in function accept in BeamSqlExpression

[ https://issues.apache.org/jira/browse/BEAM-2282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16043254#comment-16043254 ] Tarush Grover commented on BEAM-2282: - [~mingmxu] currently accept function in BeamSqlExpression is not

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

See Changes: [tgroh] Expand all PValues to component PCollections always [lcwik] Avoid flakiness in data channel for empty streams. [altay]

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » JDK 1.7 (latest),beam #61

See Changes: [tgroh] Expand all PValues to component PCollections always [lcwik] Avoid flakiness in data channel for empty streams. [altay] Refine Python

Build failed in Jenkins: beam_PostCommit_Python_Verify #2444

See Changes: [altay] Refine Python DirectRunner watermark advancement behavior -- [...truncated 502.49 KB...] Collecting pbr>=0.11 (from mock->-r

Build failed in Jenkins: beam_PostCommit_Python_Verify #2441

See -- [...truncated 502.58 KB...] Collecting pbr>=0.11 (from mock->-r postcommit_requirements.txt (line 2)) File was already downloaded

[3/3] beam git commit: Expand all PValues to component PCollections always

Expand all PValues to component PCollections always Update the implementation of WriteView The PCollectionView is constructed within the composite override, but WriteView just produces a primitive PCollection which has no consumers. Track the ViewWriter within the Direct Runner, and utilize that

[2/3] beam git commit: Expand all PValues to component PCollections always

http://git-wip-us.apache.org/repos/asf/beam/blob/ccf73448/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/StreamingViewOverrides.java -- diff --git

[1/3] beam git commit: This closes #3303

Repository: beam Updated Branches: refs/heads/master 86e1fab69 -> e066a9d6d This closes #3303 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e066a9d6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e066a9d6 Diff:

[GitHub] beam pull request #3303: [BEAM-2364] Expand all PValues to component PCollec...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3303 --- 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-2364) PCollectionView should not be a PValue, it should expand to its underlying PCollection

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

[1/2] beam git commit: Avoid flakiness in data channel for empty streams.

Repository: beam Updated Branches: refs/heads/master e066a9d6d -> d81ed2172 Avoid flakiness in data channel for empty streams. As empty stream is used as end-of-stream marker, don't ever send it as the data itself. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[GitHub] beam pull request #3324: Avoid flakiness in data channel for empty streams.

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3324 --- 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/2] beam git commit: Avoid flakiness in data channel for empty streams.

Avoid flakiness in data channel for empty streams. This closes #3324 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d81ed217 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d81ed217 Diff:

[jira] [Commented] (BEAM-2404) BigQueryIO reading stalls if no data is returned by query

[ https://issues.apache.org/jira/browse/BEAM-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16043133#comment-16043133 ] Stephen Sisk commented on BEAM-2404: I wonder if we're not correctly sending the cleanup signal since

Build failed in Jenkins: beam_PostCommit_Python_Verify #2443

See Changes: [lcwik] Avoid flakiness in data channel for empty streams. -- [...truncated 501.99 KB...] Collecting pbr>=0.11 (from mock->-r

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

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

[GitHub] beam pull request #3322: Refine Python DirectRunner watermark advancement be...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3322 --- 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] [Closed] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephen Sisk closed BEAM-2418. -- > Datastore IO does not work out of the box > - > >

[GitHub] beam pull request #3302: [BEAM-991] Raise entities limit per RPC to 9MB.

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3302 --- 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-991) DatastoreIO Write should flush early for large batches

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

[1/2] beam git commit: Raise entity limit per RPC to 9MB.

Repository: beam Updated Branches: refs/heads/master fdfc70eec -> b53e6f0dc Raise entity limit per RPC to 9MB. This is closer to the API limit, while still leaving room for overhead. Brings the Java SDK into line with the Python SDK. Switch the unit test to use the size of each entity, which

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

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

[jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

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

[jira] [Commented] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

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

Jenkins build is unstable: beam_PostCommit_Java_MavenInstall #4060

See

Build failed in Jenkins: beam_PostCommit_Python_Verify #2446

See Changes: [klk] Add Runner API oriented PTransformMatchers for DirectRunner overrides [klk] DirectRunner override matchers using Runner API --

Build failed in Jenkins: beam_PostCommit_Python_Verify #2445

See Changes: [altay] Raise entity limit per RPC to 9MB. -- [...truncated 503.79 KB...] Collecting pbr>=0.11 (from mock->-r postcommit_requirements.txt (line

[jira] [Created] (BEAM-2424) CAST operator supporting numeric types

Tarush Grover created BEAM-2424: --- Summary: CAST operator supporting numeric types Key: BEAM-2424 URL: https://issues.apache.org/jira/browse/BEAM-2424 Project: Beam Issue Type: Sub-task

[GitHub] beam pull request #3330: [BEAM-2371] Port DirectRunner overrides to SDK-agno...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/3330 [BEAM-2371] Port DirectRunner overrides to SDK-agnostic APIs Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR

[GitHub] beam pull request #3330: [BEAM-2371] Port DirectRunner overrides to SDK-agno...

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #2447

See Changes: [robertwb] Use inner module for non-public coders. -- [...truncated 502.99 KB...] test_read_from_text_metrics

[GitHub] beam pull request #3330: [BEAM-2371] Port DirectRunner overrides to SDK-agno...

GitHub user kennknowles reopened a pull request: https://github.com/apache/beam/pull/3330 [BEAM-2371] Port DirectRunner overrides to SDK-agnostic APIs 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-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

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

[GitHub] beam pull request #3332: Use beam.Map rather than beam.ParDo for PubSub enco...

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/3332 Use beam.Map rather than beam.ParDo for PubSub encoding. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] beam pull request #3333: [BEAM-1630] Adds ability to dynamically replace PTr...

GitHub user chamikaramj opened a pull request: https://github.com/apache/beam/pull/ [BEAM-1630] Adds ability to dynamically replace PTransforms during runtime. Adds two new interfaces, PTransformMatcher and PTransformOverride. Currently only supports replacements where

[jira] [Commented] (BEAM-1630) Add Splittable DoFn to Python SDK

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

[jira] [Created] (BEAM-2426) Remove imports from runner/init

Ahmet Altay created BEAM-2426: - Summary: Remove imports from runner/init Key: BEAM-2426 URL: https://issues.apache.org/jira/browse/BEAM-2426 Project: Beam Issue Type: Bug Components:

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #4061

See

[1/2] beam git commit: Slight debuggability improvements in BigtableIO

Repository: beam Updated Branches: refs/heads/master 911bfbdef -> bc2f97c77 Slight debuggability improvements in BigtableIO - ByteKeyRangeTracker.splitAtPosition logs the "insane" case first. - BigtableIO logs the split position at INFO Project:

[GitHub] beam pull request #3331: Slight debuggability improvements in BigtableIO

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3331 --- 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/2] beam git commit: This closes #3315

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

[GitHub] beam pull request #3315: Move Runner API protos to portability/runners/api

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3315 --- 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 Runner API protos to portability/runners/api

Repository: beam Updated Branches: refs/heads/master bc2f97c77 -> e980ae921 Move Runner API protos to portability/runners/api This fixes a circular import issue between transforms/ and runners/ Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[jira] [Created] (BEAM-2428) Enforce all inputs and outputs are properly declared in Transform Hierarchy

Thomas Groh created BEAM-2428: - Summary: Enforce all inputs and outputs are properly declared in Transform Hierarchy Key: BEAM-2428 URL: https://issues.apache.org/jira/browse/BEAM-2428 Project: Beam

Build failed in Jenkins: beam_PostCommit_Python_Verify #2448

See Changes: [kirpichov] Implements HCatalogIO -- [...truncated 502.46 KB...] File was already downloaded

[GitHub] beam pull request #3220: [BEAM-2357]HiveIO implementation using native API -...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3220 --- 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/2] beam git commit: Use inner module for non-public coders.

Use inner module for non-public coders. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36aea2d2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36aea2d2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36aea2d2

[GitHub] beam pull request #3325: Use inner module for non-public coders.

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

Repository: beam Updated Branches: refs/heads/master 4aef93854 -> 7c5a70edb Closes #3325 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7c5a70ed Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7c5a70ed Diff:

[1/2] beam git commit: Implements HCatalogIO

Repository: beam Updated Branches: refs/heads/master 7c5a70edb -> 911bfbdef Implements HCatalogIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/349898c4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/349898c4

[2/2] beam git commit: This closes #3220: Implements HCatalogIO

This closes #3220: Implements HCatalogIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/911bfbde Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/911bfbde Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/911bfbde

[jira] [Closed] (BEAM-2357) Add HCatalogIO (Hive)

[ https://issues.apache.org/jira/browse/BEAM-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-2357. -- Resolution: Fixed Fix Version/s: 2.1.0 > Add HCatalogIO (Hive) > - >

[jira] [Created] (BEAM-2425) Package does not exit when building beam-sdks-java-javadoc in JDK1.7

Mark Liu created BEAM-2425: -- Summary: Package does not exit when building beam-sdks-java-javadoc in JDK1.7 Key: BEAM-2425 URL: https://issues.apache.org/jira/browse/BEAM-2425 Project: Beam Issue

[jira] [Resolved] (BEAM-685) TextIO path pattern error on Windows OS

[ https://issues.apache.org/jira/browse/BEAM-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-685. Resolution: Duplicate Assignee: Luke Cwik Fix Version/s: Not applicable Since Java TextIO is

[jira] [Commented] (BEAM-2333) Rehydrate Pipeline from Runner API proto

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

  1   2   >