[jira] [Commented] (BEAM-2853) Move the nexmark documentation to the website

[ https://issues.apache.org/jira/browse/BEAM-2853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243539#comment-16243539 ] Etienne Chauchot commented on BEAM-2853: sure > Move the nexmark documentation to

Build failed in Jenkins: beam_PostCommit_Python_Verify #3502

See -- [...truncated 934.14 KB...] copying apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py -> apache-beam-2.3.0.dev0/apache_beam/runners/dat

[GitHub] beam pull request #4097: [BEAM-2853] remove Nexmark README.md now that the d...

GitHub user echauchot opened a pull request: https://github.com/apache/beam/pull/4097 [BEAM-2853] remove Nexmark README.md now that the doc is in the website Follow this checklist to help us incorporate your contribution quickly and easily: - [X] Make sure there is a [JIRA

[jira] [Commented] (BEAM-2853) Move the nexmark documentation to the website

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

svn commit: r23007 - /dev/beam/2.2.0/

Author: reuvenlax Date: Wed Nov 8 10:25:42 2017 New Revision: 23007 Log: update source distribution Modified: dev/beam/2.2.0/apache-beam-2.2.0-python.zip dev/beam/2.2.0/apache-beam-2.2.0-python.zip.asc dev/beam/2.2.0/apache-beam-2.2.0-python.zip.md5 dev/beam/2.2.0/apache-beam-2.2

[jira] [Commented] (BEAM-2853) Move the nexmark documentation to the website

[ https://issues.apache.org/jira/browse/BEAM-2853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243668#comment-16243668 ] Etienne Chauchot commented on BEAM-2853: done > Move the nexmark documentation to

[jira] [Created] (BEAM-3157) BeamSql transform should support other PCollection types

Ismaël Mejía created BEAM-3157: -- Summary: BeamSql transform should support other PCollection types Key: BEAM-3157 URL: https://issues.apache.org/jira/browse/BEAM-3157 Project: Beam Issue Type: I

Build failed in Jenkins: beam_PerformanceTests_Python #536

See Changes: [xumingmingv] [BEAM-2203] Implement 'timestamp - interval' -- Started by timer [EnvInject] - Loading node environment variables. Building remotely

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Apex #2755

See

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

This closes #4097 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9c545428 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9c545428 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9c545428 Branch: refs/heads/maste

[GitHub] beam pull request #4097: [BEAM-2853] remove Nexmark README.md now that the d...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4097 ---

[1/2] beam git commit: [BEAM-2853] remove Nexmark README.md now that the doc is in the website

Repository: beam Updated Branches: refs/heads/master e0166ceb6 -> 9c5454287 [BEAM-2853] remove Nexmark README.md now that the doc is in the website Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f78f4559 Tree: http://git-wi

[jira] [Commented] (BEAM-2853) Move the nexmark documentation to the website

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

[GitHub] beam pull request #4098: [BEAM-3118] Fix thread leaks in ElasticsearchIOTest...

GitHub user echauchot opened a pull request: https://github.com/apache/beam/pull/4098 [BEAM-3118] Fix thread leaks in ElasticsearchIOTest.testWriteWith* when using DoFnTester Follow this checklist to help us incorporate your contribution quickly and easily: - [X] Make sur

[jira] [Commented] (BEAM-3118) Fix thread leaks in ElasticsearchIO 5 write tests

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #3503

See Changes: [echauchot] [BEAM-2853] remove Nexmark README.md now that the doc is in the website -- [...truncated 934.62 KB...] copying apache_beam/runners/

[jira] [Created] (BEAM-3158) DoFnTester should call close() in catch bloc and then re-throw exception

Etienne Chauchot created BEAM-3158: -- Summary: DoFnTester should call close() in catch bloc and then re-throw exception Key: BEAM-3158 URL: https://issues.apache.org/jira/browse/BEAM-3158 Project: Bea

[jira] [Comment Edited] (BEAM-3158) DoFnTester should call close() in catch bloc and then re-throw exception

[ https://issues.apache.org/jira/browse/BEAM-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244173#comment-16244173 ] Etienne Chauchot edited comment on BEAM-3158 at 11/8/17 3:39 PM:

[jira] [Commented] (BEAM-3158) DoFnTester should call close() in catch bloc and then re-throw exception

[ https://issues.apache.org/jira/browse/BEAM-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244173#comment-16244173 ] Etienne Chauchot commented on BEAM-3158: @jkff WDYT? > DoFnTester should call clos

[jira] [Updated] (BEAM-3158) DoFnTester should call close() in catch bloc and then re-throw exception to allow using @Rule ExpectedException

[ https://issues.apache.org/jira/browse/BEAM-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated BEAM-3158: --- Summary: DoFnTester should call close() in catch bloc and then re-throw exception to allow usin

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Apex #2756

See

[jira] [Updated] (BEAM-3158) DoFnTester should call close() in catch bloc and then re-throw exception

[ https://issues.apache.org/jira/browse/BEAM-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated BEAM-3158: --- Description: In {{CLONE_ONCE}} and {{DO_NOT_CLONE}} cloning behaviors, it is required to expli

[jira] [Updated] (BEAM-3158) DoFnTester should call close() in catch bloc and then re-throw exception to allow using @Rule ExpectedException

[ https://issues.apache.org/jira/browse/BEAM-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated BEAM-3158: --- Description: In {{CLONE_ONCE}} and {{DO_NOT_CLONE}} cloning behaviors, it is required to expli

Build failed in Jenkins: beam_PostCommit_Python_Verify #3504

See -- [...truncated 931.67 KB...] copying apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py -> apache-beam-2.3.0.dev0/apache_beam/runners/

[4/4] beam git commit: This closes #3979

This closes #3979 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0af97209 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0af97209 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0af97209 Branch: refs/heads/maste

[2/4] beam git commit: Added vcf file io source and modified _TextSource to optionally handle headers

http://git-wip-us.apache.org/repos/asf/beam/blob/f22da33c/sdks/python/apache_beam/testing/data/vcf/valid-4.1-large.vcf -- diff --git a/sdks/python/apache_beam/testing/data/vcf/valid-4.1-large.vcf b/sdks/python/apache_beam/testing/

[3/4] beam git commit: Added vcf file io source and modified _TextSource to optionally handle headers

Added vcf file io source and modified _TextSource to optionally handle headers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f22da33c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f22da33c Diff: http://git-wip-us.apac

[1/4] beam git commit: Added vcf file io source and modified _TextSource to optionally handle headers

Repository: beam Updated Branches: refs/heads/master 9c5454287 -> 0af972095 http://git-wip-us.apache.org/repos/asf/beam/blob/f22da33c/sdks/python/apache_beam/testing/data/vcf/valid-4.2.vcf -- diff --git a/sdks/python/apache_bea

[GitHub] beam pull request #3979: [BEAM-2774] Add I/O source to read VCF files

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3979 ---

[1/2] beam git commit: Ensure Kafka sink serializers are set.

Repository: beam Updated Branches: refs/heads/master 0af972095 -> ae45bbd63 Ensure Kafka sink serializers are set. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b413a966 Tree: http://git-wip-us.apache.org/repos/asf/beam/tr

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

This closes #4034 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ae45bbd6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ae45bbd6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ae45bbd6 Branch: refs/heads/maste

[GitHub] beam pull request #4034: [BEAM-2257] Ensure Kafka sink serializers are set.

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4034 ---

[jira] [Commented] (BEAM-2257) KafkaIO write without key requires a producer fn

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

[jira] [Commented] (BEAM-2774) Add I/O source for VCF files (python)

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

[jira] [Commented] (BEAM-2203) Arithmetic operators: support DATETIME & DATETIME_INTERVAL

[ https://issues.apache.org/jira/browse/BEAM-2203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244320#comment-16244320 ] Anton Kedin commented on BEAM-2203: --- To summarize, implemented operations so far: * TIMES

[jira] [Updated] (BEAM-2257) KafkaIO write without key requires a producer fn

[ https://issues.apache.org/jira/browse/BEAM-2257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raghu Angadi updated BEAM-2257: --- Fix Version/s: 2.3.0 > KafkaIO write without key requires a producer fn > -

[jira] [Commented] (BEAM-2257) KafkaIO write without key requires a producer fn

[ https://issues.apache.org/jira/browse/BEAM-2257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244375#comment-16244375 ] Raghu Angadi commented on BEAM-2257: Thanks [~nerdynick] for the fix. [~jbonofre] pleas

[1/4] beam git commit: [BEAM-2528] create table

Repository: beam Updated Branches: refs/heads/master ae45bbd63 -> 598774738 http://git-wip-us.apache.org/repos/asf/beam/blob/208fc38a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/text/BeamTextCSVTableTest.java --

[3/4] beam git commit: [BEAM-2528] create table

[BEAM-2528] create table Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/208fc38a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/208fc38a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/208fc38a Branch: refs/head

[4/4] beam git commit: This closes #4041

This closes #4041 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59877473 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/59877473 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/59877473 Branch: refs/heads/maste

[2/4] beam git commit: [BEAM-2528] create table

http://git-wip-us.apache.org/repos/asf/beam/blob/208fc38a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/Column.java -- diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extens

[GitHub] beam pull request #4041: [BEAM-2528] BeamSQL DDL :: CreateTable

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4041 ---

[jira] [Commented] (BEAM-2528) BeamSql: support create table

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

[jira] [Created] (BEAM-3159) DoFnTester should be deprecated in favor of TestPipeline

Ben Chambers created BEAM-3159: -- Summary: DoFnTester should be deprecated in favor of TestPipeline Key: BEAM-3159 URL: https://issues.apache.org/jira/browse/BEAM-3159 Project: Beam Issue Type: B

Build failed in Jenkins: beam_PostCommit_Python_Verify #3505

See Changes: [chamikara] Added vcf file io source and modified _TextSource to optionally handle -- [...truncated 928.31 KB...] copying apache_beam/runners/ru

[jira] [Commented] (BEAM-3159) DoFnTester should be deprecated in favor of TestPipeline

[ https://issues.apache.org/jira/browse/BEAM-3159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244421#comment-16244421 ] Kenneth Knowles commented on BEAM-3159: --- Absolutely agree. It is pretty broken and ha

Build failed in Jenkins: beam_PerformanceTests_Python #537

See Changes: [echauchot] [BEAM-2853] remove Nexmark README.md now that the doc is in the website [chamikara] Added vcf file io source and modified _TextSource to optionally handle [chamikara] Ensur

[jira] [Created] (BEAM-3160) Type based coder inference incorrectly assumes that a coder for one type is equivalent to every other coder for that type.

Luke Cwik created BEAM-3160: --- Summary: Type based coder inference incorrectly assumes that a coder for one type is equivalent to every other coder for that type. Key: BEAM-3160 URL: https://issues.apache.org/jira/browse

[GitHub] beam pull request #4099: [BEAM-3040] Disable flaky subprocess variant of ULR...

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/4099 [BEAM-3040] Disable flaky subprocess variant of ULR test. Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https:

[jira] [Commented] (BEAM-3040) Python precommit timed out after 150 minutes

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #3506

See Changes: [chamikara] Ensure Kafka sink serializers are set. [mingmxu] [BEAM-2528] create table -- [...truncated 931.71 KB...] copying apache_beam/runners

[GitHub] beam pull request #4100: Dataflow: Add option to upload heap dumps to GCS

GitHub user bjchambers opened a pull request: https://github.com/apache/beam/pull/4100 Dataflow: Add option to upload heap dumps to GCS This flag needs to go in before backend runner code that reads it. It will have no effect until that code is deployed. Follow this chec

[2/2] beam git commit: Closes #4099

Closes #4099 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/29399fde Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/29399fde Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/29399fde Branch: refs/heads/master Com

[1/2] beam git commit: [BEAM-3040] Disable flaky subprocess variant of ULR test.

Repository: beam Updated Branches: refs/heads/master 598774738 -> 29399fde8 [BEAM-3040] Disable flaky subprocess variant of ULR test. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/30740a53 Tree: http://git-wip-us.apache.or

[GitHub] beam pull request #4099: [BEAM-3040] Disable flaky subprocess variant of ULR...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4099 ---

[jira] [Updated] (BEAM-3160) Type based coder inference incorrectly assumes that a coder for one type is equivalent to every other coder for that type.

[ https://issues.apache.org/jira/browse/BEAM-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-3160: Description: We should prevent coder inference from assuming that two coders for the same type are interchan

[jira] [Commented] (BEAM-3040) Python precommit timed out after 150 minutes

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

[jira] [Created] (BEAM-3161) Cannot output with timestamp XXXX

Xu Mingmin created BEAM-3161: Summary: Cannot output with timestamp Key: BEAM-3161 URL: https://issues.apache.org/jira/browse/BEAM-3161 Project: Beam Issue Type: Bug Components: ds

[GitHub] beam pull request #4101: [BEAM-3161] Cannot output with timestamp XXXX

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/4101 [BEAM-3161] Cannot output with timestamp R: @xumingming CC: @takidau You can merge this pull request into a Git repository by running: $ git pull https://github.com/XuMingmin/beam B

[jira] [Commented] (BEAM-3161) Cannot output with timestamp XXXX

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

[jira] [Created] (BEAM-3162) Add IBM Streams Runner to compatability matrix

Paul created BEAM-3162: -- Summary: Add IBM Streams Runner to compatability matrix Key: BEAM-3162 URL: https://issues.apache.org/jira/browse/BEAM-3162 Project: Beam Issue Type: Task Components:

[jira] [Commented] (BEAM-3147) Nexmark in SQL

[ https://issues.apache.org/jira/browse/BEAM-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244791#comment-16244791 ] Anton Kedin commented on BEAM-3147: --- Ah, the other related jiras are under 'extensions' c

[jira] [Assigned] (BEAM-3084) Support for window analytic functions

[ https://issues.apache.org/jira/browse/BEAM-3084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin reassigned BEAM-3084: Assignee: (was: Xu Mingmin) > Support for window analytic functions > --

[jira] [Commented] (BEAM-3162) Add IBM Streams Runner to compatability matrix

[ https://issues.apache.org/jira/browse/BEAM-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244796#comment-16244796 ] Paul Gerver commented on BEAM-3162: --- I will request Jira access to the Beam dev list to t

Build failed in Jenkins: beam_PostCommit_Python_Verify #3507

See Changes: [robertwb] [BEAM-3040] Disable flaky subprocess variant of ULR test. -- [...truncated 933.06 KB...] copying apache_beam/runners/runner.py -> apa

[jira] [Assigned] (BEAM-3162) Add IBM Streams Runner to compatability matrix

[ https://issues.apache.org/jira/browse/BEAM-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-3162: --- Assignee: Paul Gerver (was: Reuven Lax) > Add IBM Streams Runner to compatability matrix > --

[jira] [Assigned] (BEAM-3162) Add IBM Streams Runner to compatability matrix

[ https://issues.apache.org/jira/browse/BEAM-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-3162: --- Assignee: Paul Gerver (was: Paul Gerver) > Add IBM Streams Runner to compatability matrix > -

Build failed in Jenkins: beam_PostCommit_Python_Verify #3508

See -- [...truncated 930.53 KB...] copying apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py -> apache-beam-2.3.0.dev0/apache_beam/runners/

[jira] [Commented] (BEAM-137) Add implicit conf/pipeline-default.conf options file

[ https://issues.apache.org/jira/browse/BEAM-137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244950#comment-16244950 ] Nicholas Verbeck commented on BEAM-137: --- So I'm looking at adding this support to make

[jira] [Commented] (BEAM-137) Add implicit conf/pipeline-default.conf options file

[ https://issues.apache.org/jira/browse/BEAM-137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244954#comment-16244954 ] Nicholas Verbeck commented on BEAM-137: --- As a follow on. Any idea on how we can expand

[jira] [Commented] (BEAM-3110) The transform Read(UnboundedKafkaSource) is currently not supported

[ https://issues.apache.org/jira/browse/BEAM-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16244960#comment-16244960 ] Xu Mingmin commented on BEAM-3110: -- seems the bug is not there in latest master branch, wi

Build failed in Jenkins: beam_PerformanceTests_Python #538

See Changes: [robertwb] [BEAM-3040] Disable flaky subprocess variant of ULR test. -- Started by timer [EnvInject] - Loading node environment variables. Building

[GitHub] beam pull request #4102: Set save_main_session to True for csv module

GitHub user davidcavazos opened a pull request: https://github.com/apache/beam/pull/4102 Set save_main_session to True for csv module Parsing the game events requires the `csv` module, so we also needed to set `save_main_session` to True for this to work in Dataflow. R: @aa

[GitHub] beam pull request #4103: Adds logging at INFO for all creation, deletion and...

GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/4103 Adds logging at INFO for all creation, deletion and copying of files in WriteFiles This will help with debugging issues such as https://stackoverflow.com/questions/47113773/dataflow-2-1-0-streaming-app

[GitHub] beam pull request #4104: Remove obsolete dependence of FnApiRunner on MapTas...

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/4104 Remove obsolete dependence of FnApiRunner on MapTaskExecutorRunner. Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA iss

[2/3] beam git commit: Fork Control Clients into java-fn-execution

Fork Control Clients into java-fn-execution Deprecate versions in runners-core. Runner-side portability APIs should not have a dependency edge to an SDK, and use of the java-fn-execution package ensures that. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apa

[1/3] beam git commit: Fork Data Service Libraries to java-fn-execution

Repository: beam Updated Branches: refs/heads/master 29399fde8 -> 727253ee3 Fork Data Service Libraries to java-fn-execution Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/70311595 Tree: http://git-wip-us.apache.org/repos/a

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

This closes #4086 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/727253ee Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/727253ee Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/727253ee Branch: refs/heads/maste

[GitHub] beam pull request #4086: [BEAM-2899] Copy runners.core.fn to java-fn-executi...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4086 ---

[jira] [Commented] (BEAM-2899) Universal Local Runner

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

[GitHub] beam pull request #4105: [BEAM-2899] Fork FnDataService from runners-core

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/4105 [BEAM-2899] Fork FnDataService from runners-core Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https://issues.ap

[jira] [Commented] (BEAM-3158) DoFnTester should call close() in catch bloc and then re-throw exception to allow using @Rule ExpectedException

[ https://issues.apache.org/jira/browse/BEAM-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245032#comment-16245032 ] Eugene Kirpichov commented on BEAM-3158: Sorry I'm not following: what exactly goes

[jira] [Commented] (BEAM-2899) Universal Local Runner

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

[GitHub] beam pull request #4106: Update urns.py

GitHub user tvalentyn opened a pull request: https://github.com/apache/beam/pull/4106 Update urns.py Fix typo in GLOBAL_WINDOW_CODER urn constant. Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA

[GitHub] beam pull request #3845: mr-runner: use SerializablePipelineOptions to serde...

Github user huafengw closed the pull request at: https://github.com/apache/beam/pull/3845 ---

svn commit: r23019 - in /dev/beam/2.2.0: apache-beam-2.2.0-python.zip apache-beam-2.2.0-python.zip.asc apache-beam-2.2.0-python.zip.md5 apache-beam-2.2.0-python.zip.sha1

Author: reuvenlax Date: Thu Nov 9 01:52:23 2017 New Revision: 23019 Log: Fix python distribution Modified: dev/beam/2.2.0/apache-beam-2.2.0-python.zip dev/beam/2.2.0/apache-beam-2.2.0-python.zip.asc dev/beam/2.2.0/apache-beam-2.2.0-python.zip.md5 dev/beam/2.2.0/apache-beam-2.2.0-

[jira] [Created] (BEAM-3163) We should run and monitor PostCommit test suites for release branches.

Valentyn Tymofieiev created BEAM-3163: - Summary: We should run and monitor PostCommit test suites for release branches. Key: BEAM-3163 URL: https://issues.apache.org/jira/browse/BEAM-3163 Project:

[jira] [Commented] (BEAM-3163) We should run and monitor PostCommit test suites for release branches.

[ https://issues.apache.org/jira/browse/BEAM-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245111#comment-16245111 ] Valentyn Tymofieiev commented on BEAM-3163: --- Related: https://issues.apache.org/j

Build failed in Jenkins: beam_PostCommit_Python_Verify #3509

See Changes: [tgroh] Fork Control Clients into java-fn-execution [tgroh] Fork Data Service Libraries to java-fn-execution -- [...truncated 935.74 KB...] copy

[GitHub] beam pull request #4107: Merge branch 'master' into jstorm-runner at commit ...

GitHub user peihe opened a pull request: https://github.com/apache/beam/pull/4107 Merge branch 'master' into jstorm-runner at commit 727253e Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https://

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #4313

See

Build failed in Jenkins: beam_PostCommit_Python_Verify #3510

See -- [...truncated 934.28 KB...] copying apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py -> apache-beam-2.3.0.dev0/apache_beam/runners/

[2/2] beam git commit: This closes #4103: Adds logging at INFO for all creation, deletion and copying of files in WriteFiles

This closes #4103: Adds logging at INFO for all creation, deletion and copying of files in WriteFiles Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/867d8168 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/867d8168 Diff

[1/2] beam git commit: Adds logging at INFO for all creation, deletion and copying of files in WriteFiles

Repository: beam Updated Branches: refs/heads/master 727253ee3 -> 867d81684 Adds logging at INFO for all creation, deletion and copying of files in WriteFiles Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/feab6043 Tree: h

[GitHub] beam pull request #4103: Adds logging at INFO for all creation, deletion and...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4103 ---

[jira] [Commented] (BEAM-3162) Add IBM Streams Runner to compatability matrix

[ https://issues.apache.org/jira/browse/BEAM-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16245244#comment-16245244 ] ASF GitHub Bot commented on BEAM-3162: -- pgerv12 opened a new pull request #347: [BEAM-

[jira] [Created] (BEAM-3164) Capture stderr logs during gen proto

holdenk created BEAM-3164: - Summary: Capture stderr logs during gen proto Key: BEAM-3164 URL: https://issues.apache.org/jira/browse/BEAM-3164 Project: Beam Issue Type: Bug Components: build

Build failed in Jenkins: beam_PerformanceTests_Python #539

See Changes: [tgroh] Fork Control Clients into java-fn-execution [tgroh] Fork Data Service Libraries to java-fn-execution [ekirpichov] Adds logging at INFO for all creation, deletion and copying of

Build failed in Jenkins: beam_PostCommit_Python_Verify #3511

See Changes: [ekirpichov] Adds logging at INFO for all creation, deletion and copying of files in -- [...truncated 933.13 KB...] copying apache_beam/runners

[1/2] beam git commit: change `withAllowedTimestampSkew`

Repository: beam Updated Branches: refs/heads/master 867d81684 -> 4451d5566 change `withAllowedTimestampSkew` Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4a5741f2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4a

  1   2   >