[jira] [Updated] (BEAM-1684) Add unit tests for iobase.py

[ https://issues.apache.org/jira/browse/BEAM-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss updated BEAM-1684: - Description: Python-SDK's {{apache_beam/runners/dataflow/native_io/iobase.py}} does not have associated

[jira] [Assigned] (BEAM-1684) Add unit tests for iobase.py

[ https://issues.apache.org/jira/browse/BEAM-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tibor Kiss reassigned BEAM-1684: Assignee: Rahul Sabbineni (was: Tibor Kiss) > Add unit tests for iobase.py >

Build failed in Jenkins: beam_PostCommit_Python_Verify #1685

See Changes: [dhalperi] Fix PubSubIO write attribute issue [hepei.hp] [BEAM-1838] GlobalWindow: add equals() and hashCode(). -- [...truncated 657.12 KB...]

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #3104

See

[jira] [Closed] (BEAM-1838) GlobalWindow equals() and hashCode() doesn't work with other serialization frameworks

[ https://issues.apache.org/jira/browse/BEAM-1838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-1838. - Resolution: Fixed Fix Version/s: First stable release > GlobalWindow equals() and

Build failed in Jenkins: beam_PostCommit_Python_Verify #1684

See -- [...truncated 643.90 KB...] test_undeclared_side_outputs (apache_beam.transforms.ptransform_test.PTransformTest) ... ok

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Spark #1450

See

[GitHub] beam pull request #2371: [BEAM-1838] GlobalWindow: add equals() and hashCode...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2371 --- 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-1838) GlobalWindow equals() and hashCode() doesn't work with other serialization frameworks

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

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

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

[1/2] beam git commit: [BEAM-1838] GlobalWindow: add equals() and hashCode().

Repository: beam Updated Branches: refs/heads/master 1e2ad65f8 -> 935ecd4e0 [BEAM-1838] GlobalWindow: add equals() and hashCode(). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ea9f5b1b Tree:

[jira] [Commented] (BEAM-1673) PubSubIO can't write attributes

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

[GitHub] beam pull request #2209: [BEAM-1673] Fix PubSubIO write attribute issue

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2209 --- 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: Fix PubSubIO write attribute issue

Repository: beam Updated Branches: refs/heads/master b1c287bd5 -> 1e2ad65f8 Fix PubSubIO write attribute issue Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ad9df5b5 Tree:

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

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #1683

See Changes: [dhalperi] Fixed: small documentation issue in HDFS IO -- [...truncated 669.47 KB...] test_par_do_with_multiple_outputs_and_using_yield

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3102

See

Build failed in Jenkins: beam_PostCommit_Python_Verify #1682

See Changes: [altay] Increase the memory threshold for the direct runner test [altay] [BEAM-1441] Fix size check for windows and improve error message [dhalperi] Reopen BigQuery utils after #2271

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #3101

See

[GitHub] beam pull request #2389: Add TestStream to Python SDK

GitHub user charlesccychen opened a pull request: https://github.com/apache/beam/pull/2389 Add TestStream to Python SDK The TestStream will be used for verifying streaming runner semantics. You can merge this pull request into a Git repository by running: $ git pull

[GitHub] beam pull request #2388: Change side inputs to be references rather than ful...

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/2388 Change side inputs to be references rather than full PValues. This is more consistent with the Runner API's structure. Be sure to do all of the following to help us incorporate your

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Spark #1449

See -- [...truncated 220.72 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted]

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3103

See -- [...truncated 216.04 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted]

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #1448

See

[jira] [Commented] (BEAM-1579) Runners should verify that PT overrides converged

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

[GitHub] beam pull request #2346: Fixed: small documentation issue in HDFS IO

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

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

[GitHub] beam pull request #2387: [BEAM-1579] Add a Dataflow-specific primitive for c...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2387 [BEAM-1579] Add a Dataflow-specific primitive for creating a view Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[1/2] beam git commit: Fixed: small documentation issue in HDFS IO

Repository: beam Updated Branches: refs/heads/master 7057d1e22 -> b1c287bd5 Fixed: small documentation issue in HDFS IO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aa420678 Tree:

[jira] [Commented] (BEAM-1836) Reopen BigQuery utils after #2271

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

[GitHub] beam pull request #2366: [BEAM-1836] Reopen BigQuery utils after #2271

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

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

[1/2] beam git commit: Reopen BigQuery utils after #2271

Repository: beam Updated Branches: refs/heads/master 3b4e0fb16 -> 7057d1e22 Reopen BigQuery utils after #2271 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/077ee5ef Tree:

[GitHub] beam pull request #2386: Improve PTransformMatcher ToStrings

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2386 Improve PTransformMatcher ToStrings 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] [Created] (BEAM-1845) ERROR: Error fetching remote repo 'origin'

Ahmet Altay created BEAM-1845: - Summary: ERROR: Error fetching remote repo 'origin' Key: BEAM-1845 URL: https://issues.apache.org/jira/browse/BEAM-1845 Project: Beam Issue Type: Bug

Build failed in Jenkins: beam_PostCommit_Python_Verify #1681

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

[jira] [Commented] (BEAM-1441) Add an IOChannelFactory interface to Python SDK

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

[GitHub] beam pull request #2382: [BEAM-1441] Fix size check for windows and improve ...

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

See -- [...truncated 219.17 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted] (none)

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

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

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3100

See -- [...truncated 219.29 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted]

[1/2] beam git commit: [BEAM-1441] Fix size check for windows and improve error message

Repository: beam Updated Branches: refs/heads/master 07d9bd5f8 -> 3b4e0fb16 [BEAM-1441] Fix size check for windows and improve error message Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6ceae061 Tree:

[jira] [Commented] (BEAM-1844) test_memory_usage fails in post commit

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

[GitHub] beam pull request #2384: [BEAM-1844] Increase the memory threshold for the d...

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

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

[1/2] beam git commit: Increase the memory threshold for the direct runner test

Repository: beam Updated Branches: refs/heads/master d4de13718 -> 07d9bd5f8 Increase the memory threshold for the direct runner test Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/065a545a Tree:

[jira] [Resolved] (BEAM-1640) data file missing when submit a job on Flink

[ https://issues.apache.org/jira/browse/BEAM-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin resolved BEAM-1640. -- Resolution: Not A Problem Fix Version/s: Not applicable Not related with Beam, issue cause by

[jira] [Commented] (BEAM-1640) data file missing when submit a job on Flink

[ https://issues.apache.org/jira/browse/BEAM-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950102#comment-15950102 ] Xu Mingmin commented on BEAM-1640: -- Figure out that it's an issue of System.properties conflict, in Flink

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3099

See -- [...truncated 1.98 MB...] File " line

[GitHub] beam pull request #2385: Add request number of splits to display data in Dat...

GitHub user vikkyrk opened a pull request: https://github.com/apache/beam/pull/2385 Add request number of splits to display data in DatastoreIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1447

See

Build failed in Jenkins: beam_PerformanceTests_JDBC #56

See Changes: [kirpichov] Fix NPE in Kafka value writer. [kirpichov] Improves logging in FileBasedSource splitting [altay] [BEAM-1795] Upgrade google-cloud-bigquery to 0.23.0

[jira] [Commented] (BEAM-1844) test_memory_usage fails in post commit

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

[GitHub] beam pull request #2384: [BEAM-1844] Increase the memory threshold for the d...

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/2384 [BEAM-1844] Increase the memory threshold for the direct runner test It seems like overtime the memory usage increased, this is to prevent test failures. You can merge this pull request into a Git

Build failed in Jenkins: beam_PerformanceTests_Dataflow #250

See Changes: [kirpichov] Fix NPE in Kafka value writer. [kirpichov] Improves logging in FileBasedSource splitting [altay] [BEAM-1795] Upgrade google-cloud-bigquery to 0.23.0

[jira] [Created] (BEAM-1843) 'PDone' object has no attribute 'to_runner_api'

Ahmet Altay created BEAM-1843: - Summary: 'PDone' object has no attribute 'to_runner_api' Key: BEAM-1843 URL: https://issues.apache.org/jira/browse/BEAM-1843 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-1843) 'PDone' object has no attribute 'to_runner_api'

[ https://issues.apache.org/jira/browse/BEAM-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950085#comment-15950085 ] Ahmet Altay commented on BEAM-1843: --- Two more instances:

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #3098

See

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Flink #2126

See

[jira] [Comment Edited] (BEAM-1823) TimedOutException in postcommit

[ https://issues.apache.org/jira/browse/BEAM-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950076#comment-15950076 ] Ahmet Altay edited comment on BEAM-1823 at 3/30/17 11:50 PM: - Thank you Mark.

[jira] [Created] (BEAM-1844) test_memory_usage fails in post commit

Ahmet Altay created BEAM-1844: - Summary: test_memory_usage fails in post commit Key: BEAM-1844 URL: https://issues.apache.org/jira/browse/BEAM-1844 Project: Beam Issue Type: Bug

[GitHub] beam-site pull request #197: Transfer content from Create Your Pipeline to P...

GitHub user hadarhg opened a pull request: https://github.com/apache/beam-site/pull/197 Transfer content from Create Your Pipeline to Programming Guide. Transfer content from Create Your Pipeline to Programming Guide. Delete Create Your Pipeline and remove from top menu. You

[jira] [Commented] (BEAM-1823) TimedOutException in postcommit

[ https://issues.apache.org/jira/browse/BEAM-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950083#comment-15950083 ] Mark Liu commented on BEAM-1823: If pipeline failed, I think the full console log will be printed. But

Build failed in Jenkins: beam_PostCommit_Python_Verify #1679

See Changes: [altay] [BEAM-1795] Upgrade google-cloud-bigquery to 0.23.0 -- [...truncated 657.63 KB...] test_undeclared_side_outputs

[jira] [Commented] (BEAM-1823) TimedOutException in postcommit

[ https://issues.apache.org/jira/browse/BEAM-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950078#comment-15950078 ] Ahmet Altay commented on BEAM-1823: --- Before BEAM-1728 is there a way to find out the job ids from the

[jira] [Commented] (BEAM-1823) TimedOutException in postcommit

[ https://issues.apache.org/jira/browse/BEAM-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950076#comment-15950076 ] Ahmet Altay commented on BEAM-1823: --- Thank you Mark. I think 10 minutes timeout makes sense. BEAM-1728

[jira] [Closed] (BEAM-1795) Upgrade google-cloud-bigquery to 0.23.0

[ https://issues.apache.org/jira/browse/BEAM-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay closed BEAM-1795. - Resolution: Fixed Fix Version/s: First stable release > Upgrade google-cloud-bigquery to 0.23.0 >

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Dataflow #2694

See

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1446

See

[GitHub] beam pull request #2383: Add ValueProvider class for FileBasedSource I/O Tra...

GitHub user mariapython opened a pull request: https://github.com/apache/beam/pull/2383 Add ValueProvider class for FileBasedSource I/O Transforms - [x] Add ValueProvider class. - [x] Derive StaticValueProvider and RuntimeValueProvider from ValueProvider. - [x] Derive

[jira] [Commented] (BEAM-1441) Add an IOChannelFactory interface to Python SDK

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

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3096

See Changes: [kirpichov] Improves logging in FileBasedSource splitting -- [...truncated 1.96 MB...] test_transform_no_super_init

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3097

See -- [...truncated 2.02 MB...] test_transform_no_super_init (apache_beam.pipeline_test.PipelineTest) ... ok test_visit_entire_graph

[jira] [Commented] (BEAM-1795) Upgrade google-cloud-bigquery to 0.23.0

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

[GitHub] beam pull request #2378: [BEAM-1795] Upgrade google-cloud-bigquery to 0.23.0

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

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

[jira] [Commented] (BEAM-1579) Runners should verify that PT overrides converged

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

[1/2] beam git commit: [BEAM-1795] Upgrade google-cloud-bigquery to 0.23.0

Repository: beam Updated Branches: refs/heads/master cfd164398 -> d4de13718 [BEAM-1795] Upgrade google-cloud-bigquery to 0.23.0 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/82aba4ba Tree:

[GitHub] beam pull request #2381: [BEAM-1579] Use Batch Replacement in the Apex Runne...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2381 [BEAM-1579] Use Batch Replacement in the Apex Runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Commented] (BEAM-1579) Runners should verify that PT overrides converged

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

[GitHub] beam pull request #2380: [BEAM-1579] Use Batch Replacement in the Flink Runn...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2380 [BEAM-1579] Use Batch Replacement in the Flink Runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Build failed in Jenkins: beam_PostCommit_Python_Verify #1678

See Changes: [kirpichov] Improves logging in FileBasedSource splitting -- [...truncated 647.37 KB...] test_par_do_with_multiple_outputs_and_using_yield

[jira] [Commented] (BEAM-1579) Runners should verify that PT overrides converged

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

[GitHub] beam pull request #2379: [BEAM-1579] Use Batch Replacement API in the Datafl...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2379 [BEAM-1579] Use Batch Replacement API in the Dataflow Runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[jira] [Commented] (BEAM-1795) Upgrade google-cloud-bigquery to 0.23.0

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

[GitHub] beam pull request #2378: [BEAM-1795] Upgrade google-cloud-bigquery to 0.23.0

GitHub user markflyhigh opened a pull request: https://github.com/apache/beam/pull/2378 [BEAM-1795] Upgrade google-cloud-bigquery to 0.23.0 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 #2375: Improves logging in FileBasedSource splitting

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

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #1677

See Changes: [kirpichov] Fix NPE in Kafka value writer. -- [...truncated 589.05 KB...] testGetAttr

[GitHub] beam pull request #2376: Annotate output type for python CoGroupByKey

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

See -- [...truncated 652.36 KB...] test_par_do_with_multiple_outputs_and_using_yield (apache_beam.transforms.ptransform_test.PTransformTest) ... ok

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3095

See Changes: [kirpichov] Fix NPE in Kafka value writer. -- [...truncated 2.01 MB...] File

[jira] [Commented] (BEAM-1269) BigtableIO should make more efficient use of connections

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

[GitHub] beam pull request #2377: BEAM-1269: Update bigtable library dependency and a...

GitHub user mdshalda opened a pull request: https://github.com/apache/beam/pull/2377 BEAM-1269: Update bigtable library dependency and add cached data pools. Hi @dhalperi, Can you review these changes to add the new bigtable library and cached data pools? You can merge

[jira] [Commented] (BEAM-1795) Upgrade google-cloud-bigquery to 0.23.0

[ https://issues.apache.org/jira/browse/BEAM-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15949848#comment-15949848 ] Mark Liu commented on BEAM-1795: +1 to have a guide for dependency update. I found Java dependency tree in

[GitHub] beam pull request #2369: [BEAM-1837] Fix NPE in KafkaIO writer.

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

See -- [...truncated 219.08 KB...] x [deleted] (none) -> origin/pr/942/head x [deleted] (none) -> origin/pr/942/merge x [deleted]

[jira] [Commented] (BEAM-1837) NPE in KafkaIO writer

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

[1/2] beam git commit: Fix NPE in Kafka value writer.

Repository: beam Updated Branches: refs/heads/master ffd87553f -> 66f249933 Fix NPE in Kafka value writer. KafkaIO.writer()...values() does not require user to set key coder since the key always null. Validation passes, but it results in an NPE at runtime when the writer is tries to

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

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

  1   2   3   >