[1/2] incubator-beam git commit: gearpump: switch to stable version

2016-08-26 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/gearpump-runner 091a15a07 -> bf0a2edae gearpump: switch to stable version They have apparently deleted the SNAPSHOT jar and now builds are failing. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Commented] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440339#comment-15440339 ] ASF GitHub Bot commented on BEAM-598: - GitHub user dhalperi reopened a pull request:

[GitHub] incubator-beam pull request #895: [BEAM-598] gearpump: switch to stable vers...

2016-08-26 Thread dhalperi
GitHub user dhalperi reopened a pull request: https://github.com/apache/incubator-beam/pull/895 [BEAM-598] gearpump: switch to stable version They have apparently deleted the SNAPSHOT jar and now builds are failing. You can merge this pull request into a Git repository by running:

[jira] [Commented] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440338#comment-15440338 ] ASF GitHub Bot commented on BEAM-598: - Github user dhalperi closed the pull request at:

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

2016-08-26 Thread dhalperi
Closes #895 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bf0a2eda Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bf0a2eda Diff:

[GitHub] incubator-beam pull request #895: [BEAM-598] gearpump: switch to stable vers...

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

Re: Build failed in Jenkins: beam_PostCommit_RunnableOnService_GearpumpLocal #146

2016-08-26 Thread Dan Halperin
Sorry for the build spam everyone. I filed BEAM-598 about this, and I was able to fixed compilation but then I broken the runnable on service test suite. I think we need Manu's intervention to fix. For now, I've disabled the build. On Fri, Aug 26, 2016 at 5:53 PM, Apache Jenkins Server <

Build failed in Jenkins: beam_PostCommit_RunnableOnService_GearpumpLocal #146

2016-08-26 Thread Apache Jenkins Server
See Changes: [dhalperi] gearpump: switch to stable version -- [...truncated 17829 lines...] PAssertTest.testContainsInAnyOrder:310 » Runtime Failed to construct

[jira] [Created] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

2016-08-26 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-598: Summary: GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted Key: BEAM-598 URL: https://issues.apache.org/jira/browse/BEAM-598 Project:

[GitHub] incubator-beam pull request #895: [BEAM-598] gearpump: switch to stable vers...

2016-08-26 Thread dhalperi
Github user dhalperi closed the pull request at: https://github.com/apache/incubator-beam/pull/895 --- 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-65) SplittableDoFn

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-65?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440438#comment-15440438 ] ASF GitHub Bot commented on BEAM-65: GitHub user jkff opened a pull request:

[GitHub] incubator-beam pull request #896: [BEAM-65] SplittableDoFn prototype.

2016-08-26 Thread jkff
GitHub user jkff opened a pull request: https://github.com/apache/incubator-beam/pull/896 [BEAM-65] SplittableDoFn prototype. Work in progress. Currently only runs in direct runner, and not ready for any use by real users. No tests for most of the code yet (will add

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1033

2016-08-26 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440343#comment-15440343 ] ASF GitHub Bot commented on BEAM-598: - Github user asfgit closed the pull request at:

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_SparkLocal #25

2016-08-26 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-598) GearpumpRunner depends on SNAPSHOT jar that has since been released and deleted

2016-08-26 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440358#comment-15440358 ] Daniel Halperin commented on BEAM-598: -- Hmm. The test suite still failed after I made this change, even

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1034

2016-08-26 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_RunnableOnService_GearpumpLocal #143

2016-08-26 Thread Apache Jenkins Server
See -- [...truncated 7289 lines...] [INFO] Excluding com.google.api-client:google-api-client-jackson2:jar:1.22.0 from the shaded jar. [INFO] Excluding

[jira] [Commented] (BEAM-404) PubsubIO should have a mode that supports maintaining message attributes.

2016-08-26 Thread rnh (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438894#comment-15438894 ] rnh commented on BEAM-404: -- Seconding the request for message attribute access on read and also being able to set

[1/2] incubator-beam git commit: Added support for reporting aggregator values to Spark sinks

2016-08-26 Thread amitsela
Repository: incubator-beam Updated Branches: refs/heads/master 204678323 -> f346c877a Added support for reporting aggregator values to Spark sinks Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/226dea2f

[jira] [Commented] (BEAM-579) Integrate NamedAggregators into Spark's sink system

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15438757#comment-15438757 ] ASF GitHub Bot commented on BEAM-579: - Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request #867: [BEAM-579] Added Graphite and Csv Spark si...

2016-08-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/867 --- 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 git commit: [BEAM-579] Integrate NamedAggregators into Spark sink system This closes #867

2016-08-26 Thread amitsela
[BEAM-579] Integrate NamedAggregators into Spark sink system This closes #867 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f346c877 Tree:

[jira] [Created] (BEAM-593) Support cancel() and waitUntilFinish() in FlinkRunnerResult

2016-08-26 Thread Pei He (JIRA)
Pei He created BEAM-593: --- Summary: Support cancel() and waitUntilFinish() in FlinkRunnerResult Key: BEAM-593 URL: https://issues.apache.org/jira/browse/BEAM-593 Project: Beam Issue Type: New Feature

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439523#comment-15439523 ] ASF GitHub Bot commented on BEAM-589: - GitHub user gauravgopi123 reopened a pull request:

[GitHub] incubator-beam pull request #889: [BEAM-589] Fixing IO.Read transformation

2016-08-26 Thread gauravgopi123
GitHub user gauravgopi123 reopened a pull request: https://github.com/apache/incubator-beam/pull/889 [BEAM-589] Fixing IO.Read transformation Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

[jira] [Updated] (BEAM-592) StackOverflowError Failed example/java/WordCount When Using SparkRunner

2016-08-26 Thread Mark Liu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Liu updated BEAM-592: -- Description: WordCount(example/java/WordCount) failed running with sparkRunner in following command: {code} mvn

[jira] [Created] (BEAM-596) Support cancel() and waitUntilFinish() in DirectRunner

2016-08-26 Thread Pei He (JIRA)
Pei He created BEAM-596: --- Summary: Support cancel() and waitUntilFinish() in DirectRunner Key: BEAM-596 URL: https://issues.apache.org/jira/browse/BEAM-596 Project: Beam Issue Type: New Feature

[GitHub] incubator-beam pull request #889: [BEAM-589] Fixing IO.Read transformation

2016-08-26 Thread gauravgopi123
Github user gauravgopi123 closed the pull request at: https://github.com/apache/incubator-beam/pull/889 --- 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-594) Support cancel() and waitUntilFinish() in FlinkRunnerResult

2016-08-26 Thread Pei He (JIRA)
Pei He created BEAM-594: --- Summary: Support cancel() and waitUntilFinish() in FlinkRunnerResult Key: BEAM-594 URL: https://issues.apache.org/jira/browse/BEAM-594 Project: Beam Issue Type: New Feature

[jira] [Created] (BEAM-595) Support cancel() and waitUntilFinish() in Spark EvaluationContext

2016-08-26 Thread Pei He (JIRA)
Pei He created BEAM-595: --- Summary: Support cancel() and waitUntilFinish() in Spark EvaluationContext Key: BEAM-595 URL: https://issues.apache.org/jira/browse/BEAM-595 Project: Beam Issue Type: New

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439546#comment-15439546 ] ASF GitHub Bot commented on BEAM-589: - Github user gauravgopi123 closed the pull request at:

[GitHub] incubator-beam pull request #889: [BEAM-589] Fixing IO.Read transformation

2016-08-26 Thread gauravgopi123
Github user gauravgopi123 closed the pull request at: https://github.com/apache/incubator-beam/pull/889 --- 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 git commit: travis.yml: disable updating snapshots

2016-08-26 Thread dhalperi
travis.yml: disable updating snapshots Will still update releases with the --update-snapshots version (I know, bad name) Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ba16e946 Tree:

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

2016-08-26 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/master f346c877a -> de249e614 Closes #875 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/de249e61 Tree:

[GitHub] incubator-beam pull request #875: travis.yml: disable updating snapshots

2016-08-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/875 --- 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 pull request #889: [BEAM-589] Fixing IO.Read transformation

2016-08-26 Thread gauravgopi123
GitHub user gauravgopi123 reopened a pull request: https://github.com/apache/incubator-beam/pull/889 [BEAM-589] Fixing IO.Read transformation Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

[GitHub] incubator-beam pull request #889: [BEAM-589] Fixing IO.Read transformation

2016-08-26 Thread gauravgopi123
Github user gauravgopi123 closed the pull request at: https://github.com/apache/incubator-beam/pull/889 --- 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-566) Implement proposal process

2016-08-26 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439431#comment-15439431 ] Kenneth Knowles commented on BEAM-566: -- In the website redesign, we lost the link to misc technical

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439383#comment-15439383 ] ASF GitHub Bot commented on BEAM-589: - Github user gauravgopi123 closed the pull request at:

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439384#comment-15439384 ] ASF GitHub Bot commented on BEAM-589: - GitHub user gauravgopi123 reopened a pull request:

[jira] [Commented] (BEAM-582) Allow usage of the new GCP service account JSON key

2016-08-26 Thread Alex Van Boxel (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439230#comment-15439230 ] Alex Van Boxel commented on BEAM-582: - I've added tests and some error messages as well. Travis fails

[GitHub] incubator-beam pull request #891: [BEAM-572] Remove Spark Reference in WordC...

2016-08-26 Thread markflyhigh
GitHub user markflyhigh opened a pull request: https://github.com/apache/incubator-beam/pull/891 [BEAM-572] Remove Spark Reference in WordCount Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title

[jira] [Commented] (BEAM-572) Remove Spark references in WordCount

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439839#comment-15439839 ] ASF GitHub Bot commented on BEAM-572: - GitHub user markflyhigh opened a pull request:

[jira] [Commented] (BEAM-592) StackOverflowError Failed example/java/WordCount When Using SparkRunner

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439893#comment-15439893 ] ASF GitHub Bot commented on BEAM-592: - GitHub user markflyhigh opened a pull request:

[jira] [Commented] (BEAM-592) StackOverflowError Failed example/java/WordCount When Using SparkRunner

2016-08-26 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439753#comment-15439753 ] Amit Sela commented on BEAM-592: Add this exclusion to spark-core dependency in examples-java:

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439817#comment-15439817 ] ASF GitHub Bot commented on BEAM-589: - GitHub user gauravgopi123 reopened a pull request:

[jira] [Updated] (BEAM-597) Provide type information from Coders

2016-08-26 Thread Kenneth Knowles (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-597: - Component/s: (was: sdk-java-extensions) sdk-java-core > Provide type

[jira] [Commented] (BEAM-592) StackOverflowError Failed example/java/WordCount When Using SparkRunner

2016-08-26 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439743#comment-15439743 ] Luke Cwik commented on BEAM-592: Unless runners shade all their dependencies it will be near impossible to

[jira] [Commented] (BEAM-592) StackOverflowError Failed example/java/WordCount When Using SparkRunner

2016-08-26 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439755#comment-15439755 ] Amit Sela commented on BEAM-592: Sorry for the messy write-up - via mobile ;-) > StackOverflowError Failed

[GitHub] incubator-beam pull request #889: [BEAM-589] Fixing IO.Read transformation

2016-08-26 Thread gauravgopi123
GitHub user gauravgopi123 reopened a pull request: https://github.com/apache/incubator-beam/pull/889 [BEAM-589] Fixing IO.Read transformation Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

[jira] [Created] (BEAM-597) Provide type information from Coders

2016-08-26 Thread Jeremie Lenfant-Engelmann (JIRA)
Jeremie Lenfant-Engelmann created BEAM-597: -- Summary: Provide type information from Coders Key: BEAM-597 URL: https://issues.apache.org/jira/browse/BEAM-597 Project: Beam Issue

[jira] [Commented] (BEAM-592) StackOverflowError Failed example/java/WordCount When Using SparkRunner

2016-08-26 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439745#comment-15439745 ] Amit Sela commented on BEAM-592: [~aviemzur] you tackled this just a couple of days ago, right ? >

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

2016-08-26 Thread dhalperi
Closes #868 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9abd0bc8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9abd0bc8 Diff:

[1/2] incubator-beam git commit: Query latest timestamp

2016-08-26 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/master de249e614 -> 9abd0bc8a Query latest timestamp Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d9d0f8d2 Tree:

[GitHub] incubator-beam pull request #868: [BEAM-473]: DatastoreIO statistics query f...

2016-08-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/868 --- 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-473) DatastoreIO querying latest timestamp statistics doesn't work with namespace

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440006#comment-15440006 ] ASF GitHub Bot commented on BEAM-473: - Github user asfgit closed the pull request at:

[jira] [Updated] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-589: --- Assignee: Luke Cwik > Making IO.Read transformations to extend PTransform >

[GitHub] incubator-beam pull request #889: [BEAM-589] Fixing IO.Read transformation

2016-08-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/889 --- 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-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440105#comment-15440105 ] ASF GitHub Bot commented on BEAM-589: - Github user asfgit closed the pull request at:

[jira] [Commented] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440110#comment-15440110 ] Luke Cwik commented on BEAM-589: I added you to the contributors list on the project so you will be able to

[jira] [Resolved] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-589. Resolution: Fixed Fix Version/s: 0.3.0-incubating > Making IO.Read transformations to extend

[jira] [Updated] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-589: --- Priority: Minor (was: Major) > Making IO.Read transformations to extend PTransform >

[jira] [Updated] (BEAM-589) Making IO.Read transformations to extend PTransform<PBegin, PCollection>

2016-08-26 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-589: --- Assignee: gaurav gupta (was: Luke Cwik) > Making IO.Read transformations to extend PTransform

[GitHub] incubator-beam pull request #894: Rename TIMESTAMP_MIN/MAX to POSITIVE/NEGAT...

2016-08-26 Thread tgroh
GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/894 Rename TIMESTAMP_MIN/MAX to POSITIVE/NEGATIVE_INFINITY Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[jira] [Commented] (BEAM-461) Create custom Kinesis source

2016-08-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15440150#comment-15440150 ] ASF GitHub Bot commented on BEAM-461: - Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request #893: Update Dataflow Container Version

2016-08-26 Thread tgroh
GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/893 Update Dataflow Container Version 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:

[2/2] incubator-beam git commit: [BEAM-589] Fixing IO.Read transformation

2016-08-26 Thread lcwik
[BEAM-589] Fixing IO.Read transformation This closes #889 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/95ab4380 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/95ab4380 Diff:

[4/5] incubator-beam git commit: kinesis: a connector for Amazon Kinesis

2016-08-26 Thread dhalperi
kinesis: a connector for Amazon Kinesis Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bed22de6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bed22de6 Diff:

[GitHub] incubator-beam pull request #687: [BEAM-461] Create custom Kinesis source

2016-08-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/687 --- 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/5] incubator-beam git commit: kinesis: a connector for Amazon Kinesis

2016-08-26 Thread dhalperi
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/bed22de6/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java -- diff --git

[2/5] incubator-beam git commit: Organize imports in Kinesis

2016-08-26 Thread dhalperi
Organize imports in Kinesis Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bed50565 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bed50565 Diff:

[1/5] incubator-beam git commit: Fix javadoc in Kinesis

2016-08-26 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/master 95ab43809 -> a17a99f58 Fix javadoc in Kinesis Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a5005fbe Tree:

[5/5] incubator-beam git commit: Closes #687

2016-08-26 Thread dhalperi
Closes #687 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a17a99f5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a17a99f5 Diff:

Build failed in Jenkins: beam_PostCommit_RunnableOnService_GearpumpLocal #145

2016-08-26 Thread Apache Jenkins Server
See -- [...truncated 8144 lines...] [INFO] Excluding com.google.api-client:google-api-client-jackson2:jar:1.22.0 from the shaded jar. [INFO] Excluding

[GitHub] incubator-beam pull request #895: gearpump: switch to stable version

2016-08-26 Thread dhalperi
GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/895 gearpump: switch to stable version They have apparently deleted the SNAPSHOT jar and now builds are failing. You can merge this pull request into a Git repository by running: $ git

[GitHub] incubator-beam pull request #890: Updates SourceTestBase concurrent splittin...

2016-08-26 Thread chamikaramj
GitHub user chamikaramj opened a pull request: https://github.com/apache/incubator-beam/pull/890 Updates SourceTestBase concurrent splitting test to share thread pool Updates SourceTestBase concurrent splitting test to share thread pool across runs. Without this, runs

incubator-beam git commit: Modified BigtableIO to use DoFn setup/tearDown methods instead of startBundle/finishBundle

2016-08-26 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/master bfd810f41 -> e871f1731 Modified BigtableIO to use DoFn setup/tearDown methods instead of startBundle/finishBundle Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #834: BigtableIO StreamingWrite Setup and Teardo...

2016-08-26 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/834 --- 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-559) DoFnTester should handle Setup / TearDown

2016-08-26 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-559: - Assignee: Thomas Groh (was: Daniel Halperin) > DoFnTester should handle Setup / TearDown >

[jira] [Closed] (BEAM-255) Understand and improve performance of Write/FileBasedSink

2016-08-26 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin closed BEAM-255. Resolution: Fixed Fix Version/s: Not applicable > Understand and improve performance of

[1/2] incubator-beam git commit: [BEAM-294] Rename dataflow references to beam

2016-08-26 Thread jbonofre
Repository: incubator-beam Updated Branches: refs/heads/master b21c35d1a -> 204678323 [BEAM-294] Rename dataflow references to beam Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e233e5f6 Tree:

[2/2] incubator-beam git commit: [BEAM-294] This closes #884

2016-08-26 Thread jbonofre
[BEAM-294] This closes #884 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/20467832 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/20467832 Diff:

[jira] [Resolved] (BEAM-294) Change properties named dataflow.* to beam.*

2016-08-26 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-294. --- Resolution: Fixed > Change properties named dataflow.* to beam.* >