[jira] [Commented] (BEAM-1806) a new option `asLeftOuterJoin` for CoGroupByKey

[ https://issues.apache.org/jira/browse/BEAM-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942642#comment-15942642 ] Aviem Zur commented on BEAM-1806: - Have you taken a look at

[jira] [Commented] (BEAM-1805) a new option `asInnerJoin` for CoGroupByKey

[ https://issues.apache.org/jira/browse/BEAM-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942640#comment-15942640 ] Aviem Zur commented on BEAM-1805: - Have you taken a look at

[jira] [Resolved] (BEAM-1810) Spark runner combineGlobally uses Kryo serialization

[ https://issues.apache.org/jira/browse/BEAM-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-1810. - Resolution: Fixed Fix Version/s: First stable release > Spark runner combineGlobally uses Kryo

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2651

See

[jira] [Commented] (BEAM-1810) Spark runner combineGlobally uses Kryo serialization

[ https://issues.apache.org/jira/browse/BEAM-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942618#comment-15942618 ] Ismaël Mejía commented on BEAM-1810: I updated after the PR was merged, and I want to confirm this fix

[jira] [Closed] (BEAM-1802) Spark Runner does not shutdown correctly when executing multiple pipelines in sequence

[ https://issues.apache.org/jira/browse/BEAM-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed BEAM-1802. -- > Spark Runner does not shutdown correctly when executing multiple pipelines in > sequence >

[jira] [Commented] (BEAM-1802) Spark Runner does not shutdown correctly when executing multiple pipelines in sequence

[ https://issues.apache.org/jira/browse/BEAM-1802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942617#comment-15942617 ] Ismaël Mejía commented on BEAM-1802: Works perfectly with the merged PR, thanks. > Spark Runner does

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3042

See

Build failed in Jenkins: beam_PostCommit_Python_Verify #1631

See Changes: [iemejia] Fix Regex#AllMatches javadoc [iemejia] Fix Regex#FindAll javadoc -- [...truncated 411.33 KB...] File was already downloaded

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1630

See

[3/3] beam git commit: This closes #2329

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

[1/3] beam git commit: Fix Regex#AllMatches javadoc

Repository: beam Updated Branches: refs/heads/master c9e55a436 -> 026aec856 Fix Regex#AllMatches javadoc Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b49bae3a Tree:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2650

See

[GitHub] beam pull request #2332: BEAM-1760 Potential null dereference in HDFSFileSin...

GitHub user tedyu opened a pull request: https://github.com/apache/beam/pull/2332 BEAM-1760 Potential null dereference in HDFSFileSink#doFinalize Check whether s.getPath().getParent() is null. If it is null, break out of the loop. You can merge this pull request into a Git

[jira] [Commented] (BEAM-1760) Potential null dereference in HDFSFileSink#doFinalize

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

Build failed in Jenkins: beam_PerformanceTests_Dataflow #234

See -- [...truncated 263.43 KB...] * [new ref] refs/pull/928/head -> origin/pr/928/head * [new ref] refs/pull/929/head -> origin/pr/929/head * [new ref]

Build failed in Jenkins: beam_PostCommit_Python_Verify #1629

See -- [...truncated 404.85 KB...] Collecting packaging>=16.8 (from setuptools->pyhamcrest->-r postcommit_requirements.txt (line 1)) File was already downloaded

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2649

See

[jira] [Commented] (BEAM-1772) Support merging WindowFn other than IntervalWindow on Flink Runner

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

[GitHub] beam pull request #2331: [BEAM-1772] Support merging WindowFn other than Int...

GitHub user JingsongLi opened a pull request: https://github.com/apache/beam/pull/2331 [BEAM-1772] Support merging WindowFn other than IntervalWindow on Flink Runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ]

[jira] [Commented] (BEAM-1772) Support merging WindowFn other than IntervalWindow on Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15942408#comment-15942408 ] Jingsong Lee commented on BEAM-1772: Consider the performance, I retained the combining with sorted

[jira] [Created] (BEAM-1813) --setup_file needs fuller-path

Mike Lambert created BEAM-1813: -- Summary: --setup_file needs fuller-path Key: BEAM-1813 URL: https://issues.apache.org/jira/browse/BEAM-1813 Project: Beam Issue Type: Bug Components:

Build failed in Jenkins: beam_PerformanceTests_Dataflow #233

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

[jira] [Closed] (BEAM-1788) Using google-cloud-datastore in Beam requires re-authentication

[ https://issues.apache.org/jira/browse/BEAM-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Lambert closed BEAM-1788. -- Resolution: Won't Fix Fix Version/s: Not applicable Okay, seems that the official answers were

[jira] [Commented] (BEAM-1573) KafkaIO does not allow using Kafka serializers and deserializers

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

[GitHub] beam pull request #2330: [BEAM-1573] Use Kafka serializers instead of coders...

GitHub user peay opened a pull request: https://github.com/apache/beam/pull/2330 [BEAM-1573] Use Kafka serializers instead of coders in KafkaIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2648

See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #232

See Changes: [aviemzur] [BEAM-1810] Replace usage of RDD#isEmpty on non-serialized RDDs -- [...truncated 231.31 KB...] ! 77fee20...7435b56

[jira] [Created] (BEAM-1812) Allow configuring checkpoints in Flink Runner PipelineOptions

Aljoscha Krettek created BEAM-1812: -- Summary: Allow configuring checkpoints in Flink Runner PipelineOptions Key: BEAM-1812 URL: https://issues.apache.org/jira/browse/BEAM-1812 Project: Beam

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2647

See

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #3038

See

[jira] [Commented] (BEAM-1810) Spark runner combineGlobally uses Kryo serialization

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

[GitHub] beam pull request #2328: [BEAM-1810] Replace usage of RDD#isEmpty on non-ser...

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

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

[1/2] beam git commit: [BEAM-1810] Replace usage of RDD#isEmpty on non-serialized RDDs

Repository: beam Updated Branches: refs/heads/master 348d33588 -> c9e55a436 [BEAM-1810] Replace usage of RDD#isEmpty on non-serialized RDDs Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b32f0482 Tree:

[jira] [Updated] (BEAM-1811) Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps

[ https://issues.apache.org/jira/browse/BEAM-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wesley Tanaka updated BEAM-1811: Description: It seems like these APIs are predominantly duplicative of each other and, that it's

[jira] [Created] (BEAM-1811) Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps

Wesley Tanaka created BEAM-1811: --- Summary: Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps Key: BEAM-1811 URL:

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2646

See

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #3037

See

Build failed in Jenkins: beam_PerformanceTests_Dataflow #231

See -- [...truncated 214.77 KB...] x [deleted] (none) -> origin/pr/99/merge x [deleted] (none) -> origin/pr/990/head x [deleted] (none)