Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4671

See

[jira] [Commented] (BEAM-2802) TextIO should allow specifying a custom delimiter

[ https://issues.apache.org/jira/browse/BEAM-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144944#comment-16144944 ] Etienne Chauchot commented on BEAM-2802: I agree the {{\002\n}} example seems odd.

[jira] [Commented] (BEAM-2457) Error: "Unable to find registrar for hdfs" - need to prevent/improve error message

[ https://issues.apache.org/jira/browse/BEAM-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145017#comment-16145017 ] Aljoscha Krettek commented on BEAM-2457: The error in 2.2.0-SNAPSHOT occurs because

[jira] [Commented] (BEAM-2802) TextIO should allow specifying a custom delimiter

[ https://issues.apache.org/jira/browse/BEAM-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145054#comment-16145054 ] Ryan Skraba commented on BEAM-2802: --- Hello! Just to chime in -- I'm part of the team tha

[GitHub] beam pull request #3779: [BEAM-2802] Support multi-byte custom separator in ...

GitHub user echauchot opened a pull request: https://github.com/apache/beam/pull/3779 [BEAM-2802] Support multi-byte custom separator in TextIO Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https

[jira] [Commented] (BEAM-2802) TextIO should allow specifying a custom delimiter

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

[GitHub] beam pull request #3780: KafkaIO readme

GitHub user joeyfezster opened a pull request: https://github.com/apache/beam/pull/3780 KafkaIO readme Following Beam's [Documentation page](https://beam.apache.org/documentation/io/built-in/), (which you get to from headder -> doccumentaton -> pipeline i/o -> built in i/o transfor

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2942

See

[jira] [Commented] (BEAM-2669) Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached

[ https://issues.apache.org/jira/browse/BEAM-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145266#comment-16145266 ] Kobi Salant commented on BEAM-2669: --- PR https://github.com/apache/beam/pull/3749 contain

[jira] [Updated] (BEAM-2669) Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached

[ https://issues.apache.org/jira/browse/BEAM-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-2669: Description: Today, when we detect re-use of a dataset in a pipeline in Spark runner we eagerly cache it to

[jira] [Updated] (BEAM-2669) Kryo serialization exception when DStreams containing non-Kryo-serializable data are cached

[ https://issues.apache.org/jira/browse/BEAM-2669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-2669: Fix Version/s: 2.2.0 > Kryo serialization exception when DStreams containing non-Kryo-serializable > data ar

[jira] [Commented] (BEAM-2768) Fix bigquery.WriteTables generating non-unique job identifiers

[ https://issues.apache.org/jira/browse/BEAM-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145351#comment-16145351 ] Matti Remes commented on BEAM-2768: --- Sorry for a slow response. The only error I can see

[jira] [Commented] (BEAM-2761) Write to empty BigQuery partition fails with "No schema specified on job or table." despite having provided schema

[ https://issues.apache.org/jira/browse/BEAM-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145431#comment-16145431 ] Lars Bakke Krogvig commented on BEAM-2761: -- I have the same issue in 2.1.0. Is the

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2943

See

[jira] [Commented] (BEAM-2768) Fix bigquery.WriteTables generating non-unique job identifiers

[ https://issues.apache.org/jira/browse/BEAM-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16145446#comment-16145446 ] Reuven Lax commented on BEAM-2768: -- Which runner are you using? I can't see anything wrong

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

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

[1/2] beam git commit: Add README.md to KafkaIO

Repository: beam Updated Branches: refs/heads/master e33cc24a5 -> f816ad879 Add README.md to KafkaIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf1b0a5e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf1b0a5e Di

[GitHub] beam pull request #3780: KafkaIO readme

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

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #2944

See

Jenkins build is unstable: beam_PostCommit_Java_MavenInstall #4673

See

[jira] [Created] (BEAM-2820) SDKs should measure time spent for active element

Vikas Kedigehalli created BEAM-2820: --- Summary: SDKs should measure time spent for active element Key: BEAM-2820 URL: https://issues.apache.org/jira/browse/BEAM-2820 Project: Beam Issue Type

[jira] [Assigned] (BEAM-2820) SDKs should measure time spent for active element

[ https://issues.apache.org/jira/browse/BEAM-2820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vikas Kedigehalli reassigned BEAM-2820: --- Assignee: Vikas Kedigehalli (was: Ahmet Altay) > SDKs should measure time spent for a

[GitHub] beam pull request #3781: [BEAM-2820] Measure time spent for active transitio...

GitHub user vikkyrk opened a pull request: https://github.com/apache/beam/pull/3781 [BEAM-2820] Measure time spent for active transition in python StateSampler Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JI

[jira] [Commented] (BEAM-2820) SDKs should measure time spent for active element

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

[jira] [Commented] (BEAM-301) Add a Beam SQL DSL

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

[GitHub] beam pull request #3782: [BEAM-301] merge branch DSL_SQL to master

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/3782 [BEAM-301] merge branch DSL_SQL to master Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https://issues.apache

[GitHub] beam pull request #3783: [BEAM-1347] Create value state, combining state, an...

GitHub user lukecwik opened a pull request: https://github.com/apache/beam/pull/3783 [BEAM-1347] Create value state, combining state, and bag state views over the BagUserState. Follow this checklist to help us incorporate your contribution quickly and easily: - [x] Make s

[jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api

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

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #4674

See -- [...truncated 1.06 MB...] 2017-08-29T18:30:41.322 [INFO] Downloading: https://repo.maven.apache.org/maven2/com/github/ben-manes/caffeine/caffeine/2.2.6/caffeine-

[1/2] beam git commit: Remove the circular dependency between pipeline & runner

Repository: beam Updated Branches: refs/heads/master f816ad879 -> 1c26b7488 Remove the circular dependency between pipeline & runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/12362b94 Tree: http://git-wip-us.apache.org

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

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

[GitHub] beam pull request #3770: Remove the circular dependency between pipeline & r...

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

[jira] [Created] (BEAM-2821) isort and autopep8 the current Python code base

holdenk created BEAM-2821: - Summary: isort and autopep8 the current Python code base Key: BEAM-2821 URL: https://issues.apache.org/jira/browse/BEAM-2821 Project: Beam Issue Type: Sub-task C

[jira] [Created] (BEAM-2822) Add support for progress reporting in fn API

Vikas Kedigehalli created BEAM-2822: --- Summary: Add support for progress reporting in fn API Key: BEAM-2822 URL: https://issues.apache.org/jira/browse/BEAM-2822 Project: Beam Issue Type: New

[GitHub] beam pull request #3784: [BEAM-2822] Enable progress request handling in pyt...

GitHub user vikkyrk opened a pull request: https://github.com/apache/beam/pull/3784 [BEAM-2822] Enable progress request handling in python SDK harness Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue

[jira] [Commented] (BEAM-2822) Add support for progress reporting in fn API

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

[jira] [Assigned] (BEAM-2784) Fix issues from automated conversion to allow Python 2 functionality

[ https://issues.apache.org/jira/browse/BEAM-2784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay reassigned BEAM-2784: - Assignee: Holden Karau (was: Ahmet Altay) > Fix issues from automated conversion to allow Python

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

This closes #3568 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/417ff43c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/417ff43c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/417ff43c Branch: refs/heads/DSL_S

[GitHub] beam pull request #3568: [BEAM-2612] Variance builtin aggregation functions

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

[1/2] beam git commit: var_pop and var_samp

Repository: beam Updated Branches: refs/heads/DSL_SQL c6f1f9fd2 -> 417ff43c0 var_pop and var_samp two builtin aggregation functions fix checkstyle address comments change type of sum in class VarAgg to BigDecimal move isSamp field to Var rename VarPop -> Var to make more generic move logic

[jira] [Commented] (BEAM-2612) support variance builtin aggregation function

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

[beam-site] branch mergebot updated (7a775c1 -> 2542036)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git. from 7a775c1 This closes #296 add 5bd80e6 Prepare repository for deployment. add f8e5099 Add cont

[beam-site] 02/02: This closes #301

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 254203610418512d163b887da970d71faca1fded Merge: bf98022 09ea01e Author: Mergebot AuthorDate: Tue Aug 29 21:1

[beam-site] branch asf-site updated (bf98022 -> a22be01)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git. from bf98022 This closes #306: Add content for new post, missed by automatic deployment add 09ea01e Ad

[2/2] beam git commit: This closes #3663: [BEAM-2390] Add support for TimePartitioning in BigQueryIO

This closes #3663: [BEAM-2390] Add support for TimePartitioning in BigQueryIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6280d497 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6280d497 Diff: http://git-wip-us.apach

[1/2] beam git commit: Add support for TimePartitioning in BigQueryIO.write().

Repository: beam Updated Branches: refs/heads/master 1c26b7488 -> 6280d497b Add support for TimePartitioning in BigQueryIO.write(). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b0e03a33 Tree: http://git-wip-us.apache.org/

[GitHub] beam pull request #3663: [BEAM-2390] Add support for TimePartitioning in Big...

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

[jira] [Assigned] (BEAM-2390) allow user to use .setTimePartitioning in BigQueryIO.write

[ https://issues.apache.org/jira/browse/BEAM-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov reassigned BEAM-2390: -- Assignee: Reuven Lax (was: Eric Johston) > allow user to use .setTimePartitioning in Bi

[jira] [Commented] (BEAM-2390) allow user to use .setTimePartitioning in BigQueryIO.write

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

[jira] [Closed] (BEAM-2390) allow user to use .setTimePartitioning in BigQueryIO.write

[ https://issues.apache.org/jira/browse/BEAM-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-2390. -- Resolution: Fixed This has been submitted. Release note: this is NOT update-compatible for Dataf

[jira] [Resolved] (BEAM-2612) support variance builtin aggregation function

[ https://issues.apache.org/jira/browse/BEAM-2612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang resolved BEAM-2612. - Resolution: Resolved Fix Version/s: 2.2.0 > support variance builtin aggregation function >

[GitHub] beam pull request #3785: [WIP][BREAM-2821] Run isort and autopep8 in prepara...

GitHub user holdenk opened a pull request: https://github.com/apache/beam/pull/3785 [WIP][BREAM-2821] Run isort and autopep8 in preparation for futurize. In preparation for running futurize (py2/3 support) run isort on the imports and autopep8 ( W391,W293,W291,E306,E305,E304,E303).

[beam-site] branch asf-site updated: [rebase] add MingminXu to team.md

This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git The following commit(s) were added to refs/heads/asf-site by this push: new ca230ad [rebase] add MingminXu to team.md

[GitHub] beam pull request #3786: Preparing statesampler to work with structured name...

GitHub user pabloem opened a pull request: https://github.com/apache/beam/pull/3786 Preparing statesampler to work with structured names You can merge this pull request into a Git repository by running: $ git pull https://github.com/pabloem/incubator-beam ssampler-structured

[beam-site] branch asf-site updated: Add James Xu(xumingming) as committer

This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git The following commit(s) were added to refs/heads/asf-site by this push: new f641188 Add James Xu(xumingming) as commi

[GitHub] beam pull request #3787: Incorporate partial writeout fix

GitHub user mariapython opened a pull request: https://github.com/apache/beam/pull/3787 Incorporate partial writeout fix Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https://issues.apache.org/ji

[beam-site] 03/03: This closes #288

This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 75dee9f1529e7e33ae063193c8f265a3fffc22be Merge: 7545abc 5391f94 Author: Ahmet Altay AuthorDate: Tue Aug 29 15:28:30

[beam-site] 02/03: Regenerate website

This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 5391f949872bf3c6305725458c329ecdb96b1b40 Author: Ahmet Altay AuthorDate: Tue Aug 29 15:28:29 2017 -0700 Regener

[beam-site] branch asf-site updated (7545abc -> 75dee9f)

This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git. from 7545abc This closes #281 new 9d06670 Add Reuven Lax to committers list. new 5391f94 Regenerate websi

[beam-site] 01/03: Add Reuven Lax to committers list.

This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 9d0667055a79cdf05e111d1c74076a34f687bfad Author: reuvenlax AuthorDate: Thu Aug 10 18:22:51 2017 -0700 Add Reuve

[jira] [Created] (BEAM-2823) Beam Windows MavenInstall tests failing

Reuven Lax created BEAM-2823: Summary: Beam Windows MavenInstall tests failing Key: BEAM-2823 URL: https://issues.apache.org/jira/browse/BEAM-2823 Project: Beam Issue Type: Bug Componen

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #4676

See

[2/2] beam git commit: This closes #3732: Removes unnecessary calls to ValueProvider.isAccessible

This closes #3732: Removes unnecessary calls to ValueProvider.isAccessible Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c1a75747 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c1a75747 Diff: http://git-wip-us.apache.o

[1/2] beam git commit: Removes unnecessary calls to ValueProvider.isAccessible

Repository: beam Updated Branches: refs/heads/master 6280d497b -> c1a757476 Removes unnecessary calls to ValueProvider.isAccessible Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/97810b4b Tree: http://git-wip-us.apache.org/

[GitHub] beam pull request #3732: Removes unnecessary calls to ValueProvider.isAccess...

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

[1/2] beam git commit: BEAM-2581: KinesisClientProvider interface needs to be public

Repository: beam Updated Branches: refs/heads/master c1a757476 -> d64f2cce8 BEAM-2581: KinesisClientProvider interface needs to be public Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/43fafcd1 Tree: http://git-wip-us.apach

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

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

[jira] [Commented] (BEAM-2581) KinesisClientProvider interface needs to be public

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

[GitHub] beam pull request #3540: BEAM-2581: KinesisClientProvider interface needs to...

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

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4678

See

Build failed in Jenkins: beam_PostCommit_Python_Verify #3026

See Changes: [chamikara] BEAM-2581: KinesisClientProvider interface needs to be public -- [...truncated 647.38 KB...] File "

[jira] [Commented] (BEAM-2823) Beam Windows MavenInstall tests failing

[ https://issues.apache.org/jira/browse/BEAM-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146457#comment-16146457 ] Luke Cwik commented on BEAM-2823: - This is really an issue with the maven protoc plugin: h

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4679

See

[GitHub] beam pull request #3788: [BEAM-1347] Implement a BeamFnStateClient which com...

GitHub user lukecwik opened a pull request: https://github.com/apache/beam/pull/3788 [BEAM-1347] Implement a BeamFnStateClient which communicates over gRPC. Follow this checklist to help us incorporate your contribution quickly and easily: - [x] Make sure there is a [JIRA

[jira] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api

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

[GitHub] beam pull request #3789: [JStorm-runner] Bug fix

GitHub user bastiliu opened a pull request: https://github.com/apache/beam/pull/3789 [JStorm-runner] Bug fix Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https://issues.apache.org/jira/projects/

[jira] [Closed] (BEAM-2757) Link to Jenkins view is dead

[ https://issues.apache.org/jira/browse/BEAM-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-2757. Resolution: Fixed Assignee: Pei He (was: Jason Kuster) Fix Version/s: Not applicable I think this is

[jira] [Commented] (BEAM-1763) TestPipeline should ensure that all assertions succeeded

[ https://issues.apache.org/jira/browse/BEAM-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146547#comment-16146547 ] Pei He commented on BEAM-1763: -- Do we require runners to quiesce when bounded data was process

Jenkins build is back to normal : beam_PostCommit_Python_Verify #3027

See

[jira] [Commented] (BEAM-1763) TestPipeline should ensure that all assertions succeeded

[ https://issues.apache.org/jira/browse/BEAM-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16146568#comment-16146568 ] Aviem Zur commented on BEAM-1763: - Currently, {{TestPipeline}} does the validation using th

[GitHub] beam pull request #3564: Update Dataflow container to 20170714

Github user kennknowles closed the pull request at: https://github.com/apache/beam/pull/3564 --- 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] [Created] (BEAM-2824) Support PipelineResult in JStormRunner

Pei He created BEAM-2824: Summary: Support PipelineResult in JStormRunner Key: BEAM-2824 URL: https://issues.apache.org/jira/browse/BEAM-2824 Project: Beam Issue Type: New Feature Component

[GitHub] beam pull request #3790: [BEAM-2632] Use Junit Paramaterized test suits in T...

GitHub user huafengw opened a pull request: https://github.com/apache/beam/pull/3790 [BEAM-2632] Use Junit Paramaterized test suits in TextIOReadTest Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue]

[jira] [Commented] (BEAM-2632) TextIOReadTest create pipelines with non-unique application names

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

[1/3] beam git commit: jstorm-runner: Fix the bug that max waiting time is missing on local mode

Repository: beam Updated Branches: refs/heads/jstorm-runner e00e0e841 -> 914889925 jstorm-runner: Fix the bug that max waiting time is missing on local mode Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/557d7036 Tree: http

[2/3] beam git commit: jstorm-runner: Fix incorrect updating of counter metrics

jstorm-runner: Fix incorrect updating of counter metrics Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c9526869 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c9526869 Diff: http://git-wip-us.apache.org/repos/asf/beam/

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

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