[jira] [Commented] (BEAM-2405) Create a BigQuery sink for streaming using PTransform

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

[GitHub] beam pull request #3306: [BEAM-2405] Override to sink interface in batch dat...

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

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

[1/2] beam git commit: [BEAM-2405] Override to sink interface in the batch dataflow BQ

Repository: beam Updated Branches: refs/heads/master b6347d02c -> 3cc4ff6d7 [BEAM-2405] Override to sink interface in the batch dataflow BQ Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e641997a Tree:

[jira] [Commented] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16040093#comment-16040093 ] Colin Bookman commented on BEAM-2418: - [~lcwik], I the ProtobufCoderProviderRegistar is included in the

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #4038

See Changes: [bchambers] Increase visibility of some Metrics methods -- [...truncated 271.54 KB...] 2017-06-07T03:10:32.749 [INFO] Downloaded:

[GitHub] beam pull request #3307: Increase visibility of some Metrics methods

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3307 --- 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 #3307: Increase visibility of some Metrics methods

This closes #3307: Increase visibility of some Metrics methods Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b6347d02 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b6347d02 Diff:

[1/2] beam git commit: Increase visibility of some Metrics methods

Repository: beam Updated Branches: refs/heads/master 1d2000d8c -> b6347d02c Increase visibility of some Metrics methods Also revise the Javadoc on MetricsContainers. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/39674ca8

[jira] [Commented] (BEAM-2375) upgrade beam-version to 2.0.0

[ https://issues.apache.org/jira/browse/BEAM-2375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16040056#comment-16040056 ] Kenneth Knowles commented on BEAM-2375: --- I think during development, you don't need to use versions

[jira] [Assigned] (BEAM-1476) Support MapState in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1476: - Assignee: Pei He (was: Jingsong Lee) > Support MapState in Flink runner >

[jira] [Resolved] (BEAM-1476) Support MapState in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles resolved BEAM-1476. --- Resolution: Fixed Fix Version/s: 2.1.0 > Support MapState in Flink runner >

[jira] [Assigned] (BEAM-1476) Support MapState in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-1476: - Assignee: Jingsong Lee (was: Pei He) > Support MapState in Flink runner >

[jira] [Commented] (BEAM-1476) Support MapState in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16040044#comment-16040044 ] Jingsong Lee commented on BEAM-1476: solved in https://github.com/apache/beam/pull/3289 > Support

[jira] [Assigned] (BEAM-1476) Support MapState in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned BEAM-1476: -- Assignee: Pei He (was: Jingsong Lee) > Support MapState in Flink runner >

[jira] [Commented] (BEAM-2416) Add AkkaIO

[ https://issues.apache.org/jira/browse/BEAM-2416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039955#comment-16039955 ] Manu Zhang commented on BEAM-2416: -- [~jbonofre], do you mean an akka-stream connector ? Could you give

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4037

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #102

See Changes: [altay] Do not fail when gen_protos cannot be imported [klk] Fix RawPTransform translation [klk] Improve Splittable ParDo translation [altay] Migrate Python tests to not

Jenkins build is back to normal : beam_PostCommit_Python_Verify #2424

See

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » JDK 1.7 (latest),beam #53

See Changes: [altay] Do not fail when gen_protos cannot be imported [klk] Fix RawPTransform translation [klk] Improve Splittable ParDo translation

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

See Changes: [altay] Do not fail when gen_protos cannot be imported [klk] Fix RawPTransform translation [klk] Improve Splittable ParDo

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

See Changes: [altay] Do not fail when gen_protos cannot be imported [klk] Fix RawPTransform translation [klk] Improve Splittable ParDo

[GitHub] beam pull request #3300: Fix the staging directory path in copying from GCS

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

[1/2] beam git commit: Fix the staging directory path in copying from GCS

Repository: beam Updated Branches: refs/heads/master 6fed1779d -> 1d2000d8c Fix the staging directory path in copying from GCS Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/171a9930 Tree:

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

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #2423

See -- Started by GitHub push by asfgit [EnvInject] - Loading node environment variables. Building remotely on beam3 (beam) in workspace

[jira] [Updated] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin Bookman updated BEAM-2418: Yep. It's a flat jar file of a compressed binary. > Datastore IO does not work out of the box >

[1/2] beam git commit: Fix imports in sdk_worker.

Repository: beam Updated Branches: refs/heads/master be26dd301 -> 6fed1779d Fix imports in sdk_worker. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/efe8e1f4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/efe8e1f4

[GitHub] beam pull request #3308: Fix imports in sdk_worker.

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

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

[jira] [Commented] (BEAM-2414) Add TwitterIO

[ https://issues.apache.org/jira/browse/BEAM-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039843#comment-16039843 ] Davor Bonaci commented on BEAM-2414: May or may not be relevant -- there's elsewhere work on the Apache

[jira] [Commented] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039838#comment-16039838 ] Luke Cwik commented on BEAM-2418: - [~bookman_google] Does build/libs/*.jar contain a jar representing

[jira] [Assigned] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2418: -- Assignee: Vikas Kedigehalli (was: Davor Bonaci) > Datastore IO does not work out of the box >

[jira] [Commented] (BEAM-2394) Postcommit_Java_JDK_Version_Test is broken since SpannerWriteIT failed

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

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

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

[GitHub] beam pull request #3298: [BEAM-2394] Support concurrent execution of Spanner...

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

[1/2] beam git commit: Generate a random table name. Assume Spanner database exists.

Repository: beam Updated Branches: refs/heads/master 6853d8ef6 -> be26dd301 Generate a random table name. Assume Spanner database exists. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3a9c00ac Tree:

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4032

See

[GitHub] beam pull request #3308: Fix imports in sdk_worker.

GitHub user robertwb opened a pull request: https://github.com/apache/beam/pull/3308 Fix imports in sdk_worker. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[GitHub] beam pull request #3307: Increase visibility of some Metrics methods

GitHub user bjchambers opened a pull request: https://github.com/apache/beam/pull/3307 Increase visibility of some Metrics methods Also revise the Javadoc on MetricsContainers. Be sure to do all of the following to help us incorporate your contribution quickly and

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4031

See

[jira] [Commented] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039733#comment-16039733 ] Colin Bookman commented on BEAM-2418: - Same issue. Tried with the following arguments. java -jar

[jira] [Commented] (BEAM-2405) Create a BigQuery sink for streaming using PTransform

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

[GitHub] beam pull request #3306: [BEAM-2405] Override to sink interface in batch dat...

GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/3306 [BEAM-2405] Override to sink interface in batch dataflow Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4029

See

[GitHub] beam pull request #3304: Whitelist find for tox environments

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

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

[1/2] beam git commit: Whitelist find for tox environments

Repository: beam Updated Branches: refs/heads/master fdfd77510 -> 6853d8ef6 Whitelist find for tox environments Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dcfb31ff Tree:

[jira] [Commented] (BEAM-2405) Create a BigQuery sink for streaming using PTransform

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

[GitHub] beam pull request #3288: [BEAM-2405] Write to BQ using the streaming API

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

[1/2] beam git commit: [BEAM-2405] Write to BQ using the streaming API

Repository: beam Updated Branches: refs/heads/master fa3922b57 -> fdfd77510 [BEAM-2405] Write to BQ using the streaming API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1498684d Tree:

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

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

[jira] [Commented] (BEAM-1265) Add streaming support to Python DirectRunner

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

[GitHub] beam pull request #3305: [BEAM-1265] soft-enable the use of streaming flag

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

[1/2] beam git commit: soft-enable the use of streaming flag

Repository: beam Updated Branches: refs/heads/master e3139a38f -> fa3922b57 soft-enable the use of streaming flag Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/51139509 Tree:

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

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

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

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

[jira] [Commented] (BEAM-1265) Add streaming support to Python DirectRunner

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

[GitHub] beam pull request #3305: [BEAM-1265] soft-enable the use of streaming flag

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/3305 [BEAM-1265] soft-enable the use of streaming flag R: @tvalentyn You can merge this pull request into a Git repository by running: $ git pull https://github.com/aaltay/beam stflag Alternatively

[GitHub] beam pull request #3282: [BEAM-3271] Improve Splittable ParDo translation

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

[3/3] beam git commit: This closes #3282: [BEAM-3271] Improve Splittable ParDo translation

This closes #3282: [BEAM-3271] Improve Splittable ParDo translation Improve Splittable ParDo translation Fix RawPTransform translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/513c952f Tree:

[1/3] beam git commit: Fix RawPTransform translation

Repository: beam Updated Branches: refs/heads/master 7c608c32a -> 513c952fa Fix RawPTransform translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/840492d9 Tree:

[jira] [Created] (BEAM-2419) Refactor dependency.py as the types are inconsistently passed in the filecopy code

Sourabh Bajaj created BEAM-2419: --- Summary: Refactor dependency.py as the types are inconsistently passed in the filecopy code Key: BEAM-2419 URL: https://issues.apache.org/jira/browse/BEAM-2419

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

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

[GitHub] beam pull request #3279: Do not fail when gen_protos cannot be imported

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

[1/2] beam git commit: Do not fail when gen_protos cannot be imported

Repository: beam Updated Branches: refs/heads/master a05455088 -> 7c608c32a Do not fail when gen_protos cannot be imported Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ae3dc5f3 Tree:

[jira] [Commented] (BEAM-2415) Add FacebookIO

[ https://issues.apache.org/jira/browse/BEAM-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039492#comment-16039492 ] Jean-Baptiste Onofré commented on BEAM-2415: I started an IO leveraging {{org.facebook4j}}

[jira] [Commented] (BEAM-2414) Add TwitterIO

[ https://issues.apache.org/jira/browse/BEAM-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039487#comment-16039487 ] Jean-Baptiste Onofré commented on BEAM-2414: I started a IO using {{org.twitter4j}} that can

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4027

See

[jira] [Commented] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039467#comment-16039467 ] Vikas Kedigehalli commented on BEAM-2418: - [~bookman_google] could you try running it without

[GitHub] beam pull request #3304: Whitelist find for tox environments

GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/3304 Whitelist find for tox environments Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[jira] [Commented] (BEAM-2414) Add TwitterIO

[ https://issues.apache.org/jira/browse/BEAM-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039463#comment-16039463 ] Eugene Kirpichov commented on BEAM-2414: Please clarify what you mean by this. > Add TwitterIO >

[jira] [Commented] (BEAM-2415) Add FacebookIO

[ https://issues.apache.org/jira/browse/BEAM-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039460#comment-16039460 ] Eugene Kirpichov commented on BEAM-2415: Please clarify what you mean by this? > Add FacebookIO >

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #101

See Changes: [jbonofre] [BEAM-2276] Cleanups on the windowed DefaultFilenamePolicy [aljoscha.krettek] [BEAM-1498] Use Flink-native side outputs [aljoscha.krettek] Remove the FnOutputT

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

See Changes: [jbonofre] [BEAM-2276] Cleanups on the windowed DefaultFilenamePolicy [aljoscha.krettek] [BEAM-1498] Use Flink-native side

[jira] [Commented] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039392#comment-16039392 ] Colin Bookman commented on BEAM-2418: - If it helps I'm trying to build this as a template. Here's my

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

See Changes: [jbonofre] [BEAM-2276] Cleanups on the windowed DefaultFilenamePolicy [aljoscha.krettek] [BEAM-1498] Use Flink-native side

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #3051

See

[jira] [Commented] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039324#comment-16039324 ] Vikas Kedigehalli commented on BEAM-2418: - Looks like we do include

[jira] [Commented] (BEAM-2364) PCollectionView should not be a PValue, it should expand to its underlying PCollection

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

[GitHub] beam pull request #3303: [BEAM-2364] Expand all PValues to component PCollec...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/3303 [BEAM-2364] Expand all PValues to component PCollections always Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[jira] [Updated] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2418: -- Fix Version/s: 2.1.0 > Datastore IO does not work out of the box >

[jira] [Updated] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2418: -- Priority: Blocker (was: Major) > Datastore IO does not work out of the box >

[jira] [Commented] (BEAM-2418) Datastore IO does not work out of the box

[ https://issues.apache.org/jira/browse/BEAM-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039282#comment-16039282 ] Colin Bookman commented on BEAM-2418: - Tried adding `compile group: 'org.apache.beam', name:

[jira] [Updated] (BEAM-1679) create gRPC IO

[ https://issues.apache.org/jira/browse/BEAM-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephen Sisk updated BEAM-1679: --- Component/s: (was: sdk-java-core) sdk-java-extensions > create gRPC IO >

[jira] [Created] (BEAM-2418) Datastore IO does not work out of the box

Stephen Sisk created BEAM-2418: -- Summary: Datastore IO does not work out of the box Key: BEAM-2418 URL: https://issues.apache.org/jira/browse/BEAM-2418 Project: Beam Issue Type: Bug

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Flink #3050

See

[GitHub] beam pull request #3289: Flink runner: support MapState in FlinkStateInterna...

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

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

[1/2] beam git commit: Flink runner: support MapState in FlinkStateInternals.

Repository: beam Updated Branches: refs/heads/master aebd3a4c5 -> a05455088 Flink runner: support MapState in FlinkStateInternals. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dbab052c Tree:

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4025

See

[jira] [Commented] (BEAM-1679) create gRPC IO

[ https://issues.apache.org/jira/browse/BEAM-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16039006#comment-16039006 ] Jean-Baptiste Onofré commented on BEAM-1679: BEAM-2088 > create gRPC IO > -- > >

[jira] [Assigned] (BEAM-2414) Add TwitterIO

[ https://issues.apache.org/jira/browse/BEAM-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-2414: -- Assignee: Jean-Baptiste Onofré (was: Davor Bonaci) > Add TwitterIO >

[jira] [Updated] (BEAM-2415) Add FacebookIO

[ https://issues.apache.org/jira/browse/BEAM-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-2415: --- Summary: Add FacebookIO (was: Add facebookIO) > Add FacebookIO > -- > >

[jira] [Assigned] (BEAM-2415) Add facebookIO

[ https://issues.apache.org/jira/browse/BEAM-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré reassigned BEAM-2415: -- Assignee: Jean-Baptiste Onofré > Add facebookIO > -- > >

[jira] [Closed] (BEAM-2331) SQRT Function

[ https://issues.apache.org/jira/browse/BEAM-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tarush Grover closed BEAM-2331. --- Resolution: Fixed Fix Version/s: 2.0.0 > SQRT Function > - > > Key:

[jira] [Commented] (BEAM-2330) MOD Function

[ https://issues.apache.org/jira/browse/BEAM-2330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16038957#comment-16038957 ] Tarush Grover commented on BEAM-2330: - This is already being implemented in arithmetic functions. >

[jira] [Resolved] (BEAM-2330) MOD Function

[ https://issues.apache.org/jira/browse/BEAM-2330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tarush Grover resolved BEAM-2330. - Resolution: Fixed Fix Version/s: 2.0.0 > MOD Function > > >

[jira] [Closed] (BEAM-2329) ABS Function

[ https://issues.apache.org/jira/browse/BEAM-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tarush Grover closed BEAM-2329. --- Resolution: Fixed Fix Version/s: 2.0.0 > ABS Function > > > Key:

[jira] [Closed] (BEAM-1498) Use Flink-native side outputs

[ https://issues.apache.org/jira/browse/BEAM-1498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-1498. -- Resolution: Fixed Fix Version/s: 2.1.0 > Use Flink-native side outputs >

  1   2   >