[jira] [Commented] (BEAM-930) Findbugs doesn't pass in MongoDB

[ https://issues.apache.org/jira/browse/BEAM-930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663802#comment-15663802 ] Jean-Baptiste Onofré commented on BEAM-930: --- Thanks for the report [~dhalp...@google.com]. I just

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #832

See

Jenkins build became unstable: beam_PostCommit_RunnableOnService_SparkLocal #140

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1813

See

[jira] [Commented] (BEAM-891) Flake in Spark metrics library?

[ https://issues.apache.org/jira/browse/BEAM-891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663281#comment-15663281 ] Stas Levin commented on BEAM-891: - Sounds good. Btw, why can't we just set

[jira] [Commented] (BEAM-891) Flake in Spark metrics library?

[ https://issues.apache.org/jira/browse/BEAM-891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663349#comment-15663349 ] Amit Sela commented on BEAM-891: Because most tests are batch.. > Flake in Spark metrics library? >

[jira] [Comment Edited] (BEAM-891) Flake in Spark metrics library?

[ https://issues.apache.org/jira/browse/BEAM-891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663281#comment-15663281 ] Stas Levin edited comment on BEAM-891 at 11/14/16 9:29 AM: --- Sounds good. Btw, why

[1/3] incubator-beam-site git commit: [BEAM-505] Fill in the documentation/runners/direct portion of the website

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 6ab73c79a -> a82a0f3bb [BEAM-505] Fill in the documentation/runners/direct portion of the website Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit:

[GitHub] incubator-beam-site pull request #76: [BEAM-505] Fill in the documentation/r...

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

[jira] [Commented] (BEAM-505) Fill in the documentation/runners/direct portion of the website

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

[GitHub] incubator-beam pull request #1043: Datastore Connector prototype using googl...

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

[jira] [Created] (BEAM-977) Fill in Python SDK page

Hadar Hod created BEAM-977: -- Summary: Fill in Python SDK page Key: BEAM-977 URL: https://issues.apache.org/jira/browse/BEAM-977 Project: Beam Issue Type: Task Components: website

[jira] [Closed] (BEAM-954) FileBasedSink: remove unused code of TemporaryFileRetention

[ https://issues.apache.org/jira/browse/BEAM-954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pei He closed BEAM-954. --- Resolution: Fixed Fix Version/s: 0.4.0-incubating > FileBasedSink: remove unused code of TemporaryFileRetention

[2/3] incubator-beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/d8cdb81a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/d8cdb81a Diff:

[GitHub] incubator-beam-site pull request #83: Landing page

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

[GitHub] incubator-beam-site pull request #85: Structure

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

[GitHub] incubator-beam-site pull request #85: Structure

GitHub user hadarhg opened a pull request: https://github.com/apache/incubator-beam-site/pull/85 Structure - [x] Adds a new page for the Python SDK - [x] Adds a link to the new Python SDK page from the 'Using the Docs' page - [x] Renames 'releases' page to 'downloads',

[1/2] incubator-beam-site git commit: Add Jenkins job definitions for existing projects using Jenkins DSL

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 3ec3a49ef -> 8ba89346d Add Jenkins job definitions for existing projects using Jenkins DSL Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit:

[GitHub] incubator-beam-site pull request #80: Add Jenkins job definitions for existi...

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

[2/2] incubator-beam-site git commit: This closes #80

This closes #80 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/8ba89346 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/8ba89346 Diff:

[jira] [Created] (BEAM-978) Support bulk get file sizes in GcsUtil

Pei He created BEAM-978: --- Summary: Support bulk get file sizes in GcsUtil Key: BEAM-978 URL: https://issues.apache.org/jira/browse/BEAM-978 Project: Beam Issue Type: New Feature Components:

[2/3] incubator-beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/159ff482 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/159ff482 Diff:

[3/3] incubator-beam-site git commit: This closes #76

This closes #76 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/a82a0f3b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/a82a0f3b Diff:

[GitHub] incubator-beam-site pull request #84: Use jekyll site.release_latest variabl...

GitHub user melap opened a pull request: https://github.com/apache/incubator-beam-site/pull/84 Use jekyll site.release_latest variable in direct runner sample pom.xml You can merge this pull request into a Git repository by running: $ git pull

[GitHub] incubator-beam-site pull request #84: Use jekyll site.release_latest variabl...

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

[2/3] incubator-beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/832d2abe Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/832d2abe Diff:

[1/3] incubator-beam-site git commit: [BEAM-508] Fill in the documentation/runners/dataflow portion of the website

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site a82a0f3bb -> d5b722e70 [BEAM-508] Fill in the documentation/runners/dataflow portion of the website Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit:

[GitHub] incubator-beam-site pull request #77: [BEAM-508] Fill in the documentation/r...

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

[jira] [Commented] (BEAM-508) Fill in the documentation/runners/dataflow portion of the website

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

[jira] [Commented] (BEAM-978) Support bulk get file sizes in GcsUtil

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

[GitHub] incubator-beam pull request #1359: [BEAM-978] Support bulk get file size in ...

GitHub user peihe opened a pull request: https://github.com/apache/incubator-beam/pull/1359 [BEAM-978] Support bulk get file size in GcsUtil. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[2/2] incubator-beam git commit: This closes #1341

This closes #1341 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0117a283 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0117a283 Diff:

[1/2] incubator-beam git commit: Simplify FileOperations interface

Repository: incubator-beam Updated Branches: refs/heads/master ee55f6e39 -> 0117a2834 Simplify FileOperations interface Refactor removeDirectoryAndFiles() into FileBasedSink. FileIOChannelFactory.match() returns the empty list on an absent parent directory instead of throwing. Project:

[GitHub] incubator-beam pull request #1341: Simplify FileOperations interface by refa...

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

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_SparkLocal #143

See

[2/2] incubator-beam-site git commit: This closes #84

This closes #84 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/3ec3a49e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/3ec3a49e Diff:

[1/2] incubator-beam-site git commit: Use jekyll site.release_latest variable in direct runner sample pom.xml

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site d5b722e70 -> 3ec3a49ef Use jekyll site.release_latest variable in direct runner sample pom.xml Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit:

[3/3] incubator-beam-site git commit: This closes #77

This closes #77 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/d5b722e7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/d5b722e7 Diff:

[3/4] incubator-beam-site git commit: Regenerate html after #85

Regenerate html after #85 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/9f62b6e5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/9f62b6e5 Diff:

[2/4] incubator-beam-site git commit: Rename /get-started/releases to get-started/downloads. Delete old get-started/downloads page.

Rename /get-started/releases to get-started/downloads. Delete old get-started/downloads page. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/fe3b3810 Tree:

[4/4] incubator-beam-site git commit: This closes #85

This closes #85 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/3b93d1b5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/3b93d1b5 Diff:

[1/4] incubator-beam-site git commit: Add Python SDK page and add it to /documentation/index.md

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 160a5d330 -> 3b93d1b56 Add Python SDK page and add it to /documentation/index.md Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit:

[jira] [Resolved] (BEAM-856) IO test should use a free port for embedded resource instance

[ https://issues.apache.org/jira/browse/BEAM-856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-856. --- Resolution: Fixed Fix Version/s: 0.4.0-incubating All existing IO now use free

[jira] [Commented] (BEAM-918) Let users set STORAGE_LEVEL via SparkPipelineOptions.

[ https://issues.apache.org/jira/browse/BEAM-918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664251#comment-15664251 ] Jean-Baptiste Onofré commented on BEAM-918: --- Waiting for merge of

[GitHub] incubator-beam pull request #1356: [BEAM-930] Fix findbugs and re-enable Mav...

GitHub user jbonofre opened a pull request: https://github.com/apache/incubator-beam/pull/1356 [BEAM-930] Fix findbugs and re-enable Maven plugin in MongoDbIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make

[GitHub] incubator-beam pull request #1357: [BEAM-927] Fix findbugs and re-enable Mav...

GitHub user jbonofre opened a pull request: https://github.com/apache/incubator-beam/pull/1357 [BEAM-927] Fix findbugs and re-enable Maven plugin in JmsIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make sure

[jira] [Commented] (BEAM-927) Findbugs doesn't pass in JMS

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

[jira] [Commented] (BEAM-856) IO test should use a free port for embedded resource instance

[ https://issues.apache.org/jira/browse/BEAM-856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664286#comment-15664286 ] Sergio Fernández commented on BEAM-856: --- Cool! Thanks [~jbonofre]. > IO test should use a free port

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

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

[GitHub] incubator-beam-site pull request #86: Adjust main page header to look like v...

Github user francesperry closed the pull request at: https://github.com/apache/incubator-beam-site/pull/86 --- 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

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

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

[GitHub] incubator-beam pull request #1360: [BEAM-498] Rename DoFn.ExtraContextFactor...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1360 [BEAM-498] Rename DoFn.ExtraContextFactory to DoFn.Arguments Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make

[GitHub] incubator-beam-site pull request #86: Adjust main page header to look like v...

GitHub user francesperry opened a pull request: https://github.com/apache/incubator-beam-site/pull/86 Adjust main page header to look like v2's, only with pulldowns Starting the process of merging in the new v2/ landing page by porting the header to the new style. Still

[1/2] incubator-beam git commit: Treat ProcessContext and Context like other DoFn parameters

Repository: incubator-beam Updated Branches: refs/heads/master 0117a2834 -> 13ad8f68a Treat ProcessContext and Context like other DoFn parameters Before this change, ProcessContext and Context were special-cased, while other parameters were treated generically. After this change, all

[2/2] incubator-beam git commit: This closes #1355

This closes #1355 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13ad8f68 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/13ad8f68 Diff:

[GitHub] incubator-beam pull request #1355: [BEAM-498] Treat ProcessContext and Conte...

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

[jira] [Created] (BEAM-975) Issue with MongoDBIO

Reza Nouri created BEAM-975: --- Summary: Issue with MongoDBIO Key: BEAM-975 URL: https://issues.apache.org/jira/browse/BEAM-975 Project: Beam Issue Type: Bug Reporter: Reza Nouri It

[jira] [Updated] (BEAM-975) Issue with MongoDBIO

[ https://issues.apache.org/jira/browse/BEAM-975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza Nouri updated BEAM-975: Description: It appears that there is an issue with MongoDBIO. I am using Apache Beam in a REST service that

[1/3] incubator-beam-site git commit: "before" instead of "behind" for "early" elements

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 2bd194414 -> 6ab73c79a "before" instead of "behind" for "early" elements Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit:

[jira] [Commented] (BEAM-641) Need to test the generated archetypes projects

[ https://issues.apache.org/jira/browse/BEAM-641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15664581#comment-15664581 ] Davor Bonaci commented on BEAM-641: --- We should double-check this -- I believe this is already bound

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_FlinkLocal #833

See

[GitHub] incubator-beam-site pull request #82: "before" instead of "behind" for "earl...

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

[3/3] incubator-beam-site git commit: This closes #82

This closes #82 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/6ab73c79 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/6ab73c79 Diff:

[2/3] incubator-beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/de57d1ae Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/de57d1ae Diff:

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1814

See

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_SparkLocal #141

See

[jira] [Commented] (BEAM-965) Source Transformations Don't Set Correct Output Type in Flink Streaming Runner

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

[jira] [Closed] (BEAM-965) Source Transformations Don't Set Correct Output Type in Flink Streaming Runner

[ https://issues.apache.org/jira/browse/BEAM-965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-965. - Resolution: Fixed > Source Transformations Don't Set Correct Output Type in Flink Streaming Runner

[jira] [Created] (BEAM-976) Update examples README.md to fix instructions to run pipelines

Vikas Kedigehalli created BEAM-976: -- Summary: Update examples README.md to fix instructions to run pipelines Key: BEAM-976 URL: https://issues.apache.org/jira/browse/BEAM-976 Project: Beam

[jira] [Updated] (BEAM-210) Allow control of empty ON_TIME panes analogous to final panes

[ https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-210: - Assignee: Thomas Groh (was: Kenneth Knowles) > Allow control of empty ON_TIME panes analogous to

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_FlinkLocal #834

See

[jira] [Updated] (BEAM-975) Issue with MongoDBIO

[ https://issues.apache.org/jira/browse/BEAM-975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reza Nouri updated BEAM-975: Description: It appears that there is an issue with MongoDBIO. I am using Apache Beam in a REST service that

[GitHub] incubator-beam-site pull request #83: Landing page

GitHub user hadarhg opened a pull request: https://github.com/apache/incubator-beam-site/pull/83 Landing page - [x] Update the prose on the landing page - [ ] Copy Blog & Twitter sections from /src/index.md - [ ] Update content in the slider News section (perhaps with Blog &

[1/2] incubator-beam git commit: [BEAM-965] Set Correct Output Type on Sources in Flink Stream Runner

Repository: incubator-beam Updated Branches: refs/heads/master 8bfa08519 -> ee55f6e39 [BEAM-965] Set Correct Output Type on Sources in Flink Stream Runner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: This closes #1352

This closes #1352 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ee55f6e3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ee55f6e3 Diff:

[GitHub] incubator-beam pull request #1352: [BEAM-965] Set Correct Output Type on Sou...

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

[jira] [Updated] (BEAM-39) Audit trigger implementations to ensure they prefetch appropriately

[ https://issues.apache.org/jira/browse/BEAM-39?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-39: Assignee: Sam Whittle (was: Kenneth Knowles) > Audit trigger implementations to ensure they prefetch

Jenkins build became unstable: beam_PostCommit_RunnableOnService_SparkLocal #142

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify #1815

See

[GitHub] incubator-beam pull request #1358: [BEAM-974] Add PubSub attributes support ...

GitHub user reuvenlax opened a pull request: https://github.com/apache/incubator-beam/pull/1358 [BEAM-974] Add PubSub attributes support to PubsubIO. Introduces a new PubsubMessage class, that allows separate management of payload and attributes from PubSub. Allows the user to

[jira] [Commented] (BEAM-974) Adds attributes support to PubsubIO

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

[2/2] incubator-beam git commit: Closes #1220

Closes #1220 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/560fe79f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/560fe79f Diff:

[1/2] incubator-beam git commit: [BEAM-852] Add validation to file based sources during create time

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 15e78b28a -> 560fe79f8 [BEAM-852] Add validation to file based sources during create time Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: