[1/2] beam git commit: Test runner to stop on EOT watermark, or timeout.

Repository: beam Updated Branches: refs/heads/master 7954896a5 -> efc701ed6 Test runner to stop on EOT watermark, or timeout. Remove timeout since it is already a pipeline option. Advance to infinity at the end of pipelines. Add EOT watermark and expected assertions test options. SparkPipel

[jira] [Commented] (BEAM-1674) Flink user state GC depends on order of timer firing

[ https://issues.apache.org/jira/browse/BEAM-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903196#comment-15903196 ] Aljoscha Krettek commented on BEAM-1674: [~lzljs3620320] Do you maybe have an idea

[jira] [Updated] (BEAM-1674) Flink user state GC depends on order of timer firing

[ https://issues.apache.org/jira/browse/BEAM-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-1674: --- Summary: Flink user state GC depends on order of timer firing (was: User state GC depends on o

[jira] [Commented] (BEAM-1674) User state GC depends on order of timer firing

[ https://issues.apache.org/jira/browse/BEAM-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903183#comment-15903183 ] Aljoscha Krettek commented on BEAM-1674: [~kenn] I'm afraid we can't simply use tim

[jira] [Created] (BEAM-1674) User state GC depends on order of timer firing

Aljoscha Krettek created BEAM-1674: -- Summary: User state GC depends on order of timer firing Key: BEAM-1674 URL: https://issues.apache.org/jira/browse/BEAM-1674 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-68) Support for limiting parallelism of a step

[ https://issues.apache.org/jira/browse/BEAM-68?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903135#comment-15903135 ] Eugene Kirpichov commented on BEAM-68: -- I think this needs a discussion on the Beam dev@

[jira] [Commented] (BEAM-1660) withCoder() error in JdbcIO JavaDoc example

[ https://issues.apache.org/jira/browse/BEAM-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903124#comment-15903124 ] Eugene Kirpichov commented on BEAM-1660: Agreed about the coder issue: we should ta

Jenkins build is back to normal : beam_PostCommit_Java_RunnableOnService_Dataflow #2506

See

[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&focusedCommentId=15903038#comment-15903038 ] Aljoscha Krettek commented on BEAM-1640: Which Flink version are you using? > data

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #2854

See

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

[ https://issues.apache.org/jira/browse/BEAM-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-1673: -- Assignee: Jean-Baptiste Onofré (was: Daniel Halperin) > PubSubIO can't write at

Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #1870

See

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

See -- [...truncated 475.00 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.279 sec - in org.ap

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

See -- [...truncated 474.59 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.338 sec - in org.ap

Build failed in Jenkins: beam_PostCommit_Java_Version_Test » JDK 1.7 (latest),beam #9

See -- [...truncated 474.07 KB...] Tests run: 14, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.293 sec - in org.apache.beam.sdk.

[jira] [Assigned] (BEAM-866) Support set/delete of timer by ID in Spark runner

[ https://issues.apache.org/jira/browse/BEAM-866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-866: -- Assignee: Aviem Zur (was: Amit Sela) > Support set/delete of timer by ID in Spark runner > -

[jira] [Assigned] (BEAM-1115) Support for new Timer API in Spark runner

[ https://issues.apache.org/jira/browse/BEAM-1115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur reassigned BEAM-1115: --- Assignee: Aviem Zur > Support for new Timer API in Spark runner >

Jenkins build is back to normal : beam_PostCommit_Python_Verify #1461

See

Jenkins build is unstable: beam_PostCommit_Java_RunnableOnService_Flink #1869

See

[GitHub] beam pull request #2210: [BEAM-1674] Add unicode type to the typeDict attrib...

GitHub user yuya-tajima opened a pull request: https://github.com/apache/beam/pull/2210 [BEAM-1674] Add unicode type to the typeDict attribute in Python SDK When I executed Biq Query exection on the Google Cloud Dataflow, the following error occurred. ``` UnicodeEncode

[jira] [Commented] (BEAM-1641) Support synchronized processing time in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15902802#comment-15902802 ] Aljoscha Krettek commented on BEAM-1641: Wow, that's a tough one. I think we might

[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&focusedCommentId=15902747#comment-15902747 ] ASF GitHub Bot commented on BEAM-1673: -- GitHub user bchen-talend opened a pull request

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

GitHub user bchen-talend opened a pull request: https://github.com/apache/beam/pull/2209 [BEAM-1673] Fix PubSubIO write attribute issue Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is format

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

Bin Chen created BEAM-1673: -- Summary: PubSubIO can't write attributes Key: BEAM-1673 URL: https://issues.apache.org/jira/browse/BEAM-1673 Project: Beam Issue Type: Bug Components: sdk-java

[GitHub] beam-site pull request #174: Finding a typo in a code block

GitHub user sungjunyoung opened a pull request: https://github.com/apache/beam-site/pull/174 Finding a typo in a code block I found a typo in the Markdown code block. The ``` should be gone. You can merge this pull request into a Git repository by running: $ git pull https://gi

<    1   2   3