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

2017-05-30 Thread tarush grover (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029022#comment-16029022 ] tarush grover commented on BEAM-2329: - Pull request has been created. https://github.

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

2017-05-30 Thread tarush grover (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029151#comment-16029151 ] tarush grover commented on BEAM-2331: - This task is implemented with the ABS function a

[jira] [Commented] (BEAM-16) Make Spark RDDs readable as PCollections

2017-05-30 Thread tarush grover (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-16?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029185#comment-16029185 ] tarush grover commented on BEAM-16: --- [~amitsela] Can I take this task? > Make Spark RDDs r

[jira] [Assigned] (BEAM-2159) CAST operator support

2017-05-30 Thread tarush grover (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarush grover reassigned BEAM-2159: --- Assignee: tarush grover > CAST operator support > - > > Ke

[jira] [Created] (BEAM-2380) Flink Batch Runner does not forward additional outputs to operator

2017-05-30 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created BEAM-2380: -- Summary: Flink Batch Runner does not forward additional outputs to operator Key: BEAM-2380 URL: https://issues.apache.org/jira/browse/BEAM-2380 Project: Beam

[jira] [Commented] (BEAM-2380) Flink Batch Runner does not forward additional outputs to operator

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029188#comment-16029188 ] ASF GitHub Bot commented on BEAM-2380: -- GitHub user aljoscha opened a pull request:

[GitHub] beam pull request #3258: [BEAM-2380] Forward additional outputs to DoFnRunne...

2017-05-30 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/beam/pull/3258 [BEAM-2380] Forward additional outputs to DoFnRunner in Flink Batch R: @iemejia or anyone, really 😃 You can merge this pull request into a Git repository by running: $ git pull https://gith

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2968

2017-05-30 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #72

2017-05-30 Thread Apache Jenkins Server
See -- [...truncated 351.32 KB...] 2017-05-30T12:04:24.973 [INFO] Downloaded: https://repo.maven.apache.org/maven2/io/grpc/grpc-core/1.2.0/grpc-core-1.2.0.pom (3

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2969

2017-05-30 Thread Apache Jenkins Server
See

[jira] [Created] (BEAM-2381) Extend the SparkContextOptions

2017-05-30 Thread JIRA
Jean-Baptiste Onofré created BEAM-2381: -- Summary: Extend the SparkContextOptions Key: BEAM-2381 URL: https://issues.apache.org/jira/browse/BEAM-2381 Project: Beam Issue Type: Improvement

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #2970

2017-05-30 Thread Apache Jenkins Server
See

[jira] [Assigned] (BEAM-2378) extend join-library to support FULL OUTER JOIN

2017-05-30 Thread Davor Bonaci (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2378: -- Assignee: James Xu > extend join-library to support FULL OUTER JOIN > --

[jira] [Commented] (BEAM-2378) extend join-library to support FULL OUTER JOIN

2017-05-30 Thread Davor Bonaci (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029540#comment-16029540 ] Davor Bonaci commented on BEAM-2378: SGTM; please proceed as you see fit. > extend joi

[jira] [Updated] (BEAM-2382) Introduce PubSubService in the PubSubIO

2017-05-30 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-2382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-2382: --- Summary: Introduce PubSubService in the PubSubIO (was: Introduce PubSubService) > Int

[jira] [Created] (BEAM-2382) Introduce PubSubService

2017-05-30 Thread JIRA
Jean-Baptiste Onofré created BEAM-2382: -- Summary: Introduce PubSubService Key: BEAM-2382 URL: https://issues.apache.org/jira/browse/BEAM-2382 Project: Beam Issue Type: Wish Com

[jira] [Created] (BEAM-2383) ROUND math function

2017-05-30 Thread tarush grover (JIRA)
tarush grover created BEAM-2383: --- Summary: ROUND math function Key: BEAM-2383 URL: https://issues.apache.org/jira/browse/BEAM-2383 Project: Beam Issue Type: Sub-task Components: dsl-s

[jira] [Created] (BEAM-2384) TRUNCATE

2017-05-30 Thread tarush grover (JIRA)
tarush grover created BEAM-2384: --- Summary: TRUNCATE Key: BEAM-2384 URL: https://issues.apache.org/jira/browse/BEAM-2384 Project: Beam Issue Type: Sub-task Components: dsl-sql

[jira] [Updated] (BEAM-2384) TRUNCATE math function

2017-05-30 Thread tarush grover (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarush grover updated BEAM-2384: Summary: TRUNCATE math function (was: TRUNCATE) > TRUNCATE math function > -- >

[1/3] beam git commit: [BEAM-2380] Forward additional outputs to DoFnRunner in Flink Batch

2017-05-30 Thread dhalperi
Repository: beam Updated Branches: refs/heads/master 2cb4b03de -> 711faffef [BEAM-2380] Forward additional outputs to DoFnRunner in Flink Batch Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9afe395b Tree: http://git-wip-us

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

2017-05-30 Thread dhalperi
This closes #3258 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/711faffe Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/711faffe Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/711faffe Branch: refs/heads/maste

[GitHub] beam pull request #3258: [BEAM-2380] Forward additional outputs to DoFnRunne...

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

[2/3] beam git commit: Fix flushing of pushed-back data in Flink Runner on +Inf watermark

2017-05-30 Thread dhalperi
Fix flushing of pushed-back data in Flink Runner on +Inf watermark Before, we only flushed all pushed-back data when receiving a +Inf watermark on the side input. It can happen that we receive that watermark before getting any data on the main input. This changes DoFnOperator to also flush when re

[jira] [Commented] (BEAM-2380) Flink Batch Runner does not forward additional outputs to operator

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029604#comment-16029604 ] ASF GitHub Bot commented on BEAM-2380: -- Github user asfgit closed the pull request at:

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

2017-05-30 Thread dhalperi
This closes #3257 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aff406b8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aff406b8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aff406b8 Branch: refs/heads/maste

[1/2] beam git commit: fix javadoc of View

2017-05-30 Thread dhalperi
Repository: beam Updated Branches: refs/heads/master 711faffef -> aff406b89 fix javadoc of View Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dd79d5aa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dd79d5aa Diff: h

[GitHub] beam pull request #3257: fix javadoc of View

2017-05-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3257 --- 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_ValidatesRunner_Flink #2972

2017-05-30 Thread Apache Jenkins Server
See

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #2973

2017-05-30 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3960

2017-05-30 Thread Apache Jenkins Server
See Changes: [aljoscha.krettek] [BEAM-2380] Forward additional outputs to DoFnRunner in Flink Batch [aljoscha.krettek] Fix flushing of pushed-back data in Flink Runner on +Inf watermark -

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3961

2017-05-30 Thread Apache Jenkins Server
See Changes: [dhalperi] fix javadoc of View -- [...truncated 3.07 MB...] 2017-05-30T17:43:25.032 [INFO] Downloading: https://repo.maven.apache.org/maven2

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #73

2017-05-30 Thread Apache Jenkins Server
See Changes: [aljoscha.krettek] [BEAM-2380] Forward additional outputs to DoFnRunner in Flink Batch [aljoscha.krettek] Fix flushing of pushed-back data in Flink Runner on +Inf watermark

[jira] [Created] (BEAM-2385) IO authoring overview - improve steps for beginners

2017-05-30 Thread Stephen Sisk (JIRA)
Stephen Sisk created BEAM-2385: -- Summary: IO authoring overview - improve steps for beginners Key: BEAM-2385 URL: https://issues.apache.org/jira/browse/BEAM-2385 Project: Beam Issue Type: Improv

[jira] [Updated] (BEAM-2131) Need Jenkins tests run outside of Google environments

2017-05-30 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2131: Summary: Need Jenkins tests run outside of Google environments (was: Google application default credentials

[jira] [Updated] (BEAM-2131) Need Jenkins tests run outside of Google environments

2017-05-30 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-2131: Description: Now that TravisCI no longer runs, we no longer have coverage for running tests which execute out

[jira] [Resolved] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2379. - Resolution: Duplicate Fix Version/s: Not applicable > SpannerIO tests are failing >

[jira] [Reopened] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reopened BEAM-2379: - > SpannerIO tests are failing > --- > > Key: BEAM-2379 >

[jira] [Commented] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029903#comment-16029903 ] Luke Cwik commented on BEAM-2379: - Decided to keep this open to fix the SpannerIO test issu

[jira] [Commented] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread Mairbek Khadikov (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029909#comment-16029909 ] Mairbek Khadikov commented on BEAM-2379: Will send a fix PR > SpannerIO tests are

[jira] [Commented] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029918#comment-16029918 ] Jean-Baptiste Onofré commented on BEAM-2379: By the way, it also impacts contri

[jira] [Created] (BEAM-2386) Change regex used for splitting words

2017-05-30 Thread Ahmet Altay (JIRA)
Ahmet Altay created BEAM-2386: - Summary: Change regex used for splitting words Key: BEAM-2386 URL: https://issues.apache.org/jira/browse/BEAM-2386 Project: Beam Issue Type: Bug Componen

[jira] [Commented] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029965#comment-16029965 ] Daniel Halperin commented on BEAM-2379: --- Feel free to rollback if fix is not coming q

[jira] [Created] (BEAM-2387) Add Top Natural and Reversed

2017-05-30 Thread Ahmet Altay (JIRA)
Ahmet Altay created BEAM-2387: - Summary: Add Top Natural and Reversed Key: BEAM-2387 URL: https://issues.apache.org/jira/browse/BEAM-2387 Project: Beam Issue Type: Bug Components: sdk-p

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3962

2017-05-30 Thread Apache Jenkins Server
See -- [...truncated 3.06 MB...] 2017-05-30T19:14:26.312 [INFO] Downloading: https://repo.maven.apache.org/maven2/org/apache/flink/flink-core/1.2.1/flink-core-1.2.1-tes

[GitHub] beam pull request #3259: [BEAM-2379] Avoid reading projectId from environmen...

2017-05-30 Thread mairbek
GitHub user mairbek opened a pull request: https://github.com/apache/beam/pull/3259 [BEAM-2379] Avoid reading projectId from environment variable in tests. SpannerOptions.Builder requires projectId to be not-null. Was green because I had GOOGLE_APPLICATION_CREDENTIALS confi

[jira] [Commented] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16029971#comment-16029971 ] ASF GitHub Bot commented on BEAM-2379: -- GitHub user mairbek opened a pull request:

[jira] [Created] (BEAM-2388) Built-In I/Os page - "discoverability"/"supported with adapters" section

2017-05-30 Thread Stephen Sisk (JIRA)
Stephen Sisk created BEAM-2388: -- Summary: Built-In I/Os page - "discoverability"/"supported with adapters" section Key: BEAM-2388 URL: https://issues.apache.org/jira/browse/BEAM-2388 Project: Beam

[2/2] beam git commit: [BEAM-2379] This closes #3259

2017-05-30 Thread jbonofre
[BEAM-2379] This closes #3259 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2d3e9fe7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2d3e9fe7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2d3e9fe7 Branch: refs

[1/2] beam git commit: [BEAM-2379] Avoid reading projectId from environment variable in tests. SpannerOptions.Builder requires projectId to be not-null.

2017-05-30 Thread jbonofre
Repository: beam Updated Branches: refs/heads/master aff406b89 -> 2d3e9fe75 [BEAM-2379] Avoid reading projectId from environment variable in tests. SpannerOptions.Builder requires projectId to be not-null. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.ap

[GitHub] beam pull request #3259: [BEAM-2379] Avoid reading projectId from environmen...

2017-05-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3259 --- 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] [Commented] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030040#comment-16030040 ] ASF GitHub Bot commented on BEAM-2379: -- Github user asfgit closed the pull request at:

[jira] [Updated] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-2379: --- Component/s: testing > SpannerIO tests are failing > --- > >

[jira] [Updated] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré updated BEAM-2379: --- Fix Version/s: (was: Not applicable) 2.1.0 > SpannerIO tests are

[jira] [Resolved] (BEAM-2379) SpannerIO tests are failing

2017-05-30 Thread JIRA
[ https://issues.apache.org/jira/browse/BEAM-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-2379. Resolution: Fixed > SpannerIO tests are failing > --- > >

[GitHub] beam pull request #3260: [BEAM-1347] Remove the usage of a thread local on a...

2017-05-30 Thread lukecwik
GitHub user lukecwik opened a pull request: https://github.com/apache/beam/pull/3260 [BEAM-1347] Remove the usage of a thread local on a potentially hot path Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2975

2017-05-30 Thread Apache Jenkins Server
See

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

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

[2/2] beam git commit: [BEAM-1347] Remove the usage of a thread local on a potentially hot path

2017-05-30 Thread lcwik
[BEAM-1347] Remove the usage of a thread local on a potentially hot path This closes #3260 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/49067b16 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/49067b16 Diff: http://gi

[1/2] beam git commit: [BEAM-1347] Remove the usage of a thread local on a potentially hot path

2017-05-30 Thread lcwik
Repository: beam Updated Branches: refs/heads/master 2d3e9fe75 -> 49067b164 [BEAM-1347] Remove the usage of a thread local on a potentially hot path Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/60779e2e Tree: http://git-w

[GitHub] beam pull request #3260: [BEAM-1347] Remove the usage of a thread local on a...

2017-05-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3260 --- 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] [Commented] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030144#comment-16030144 ] ASF GitHub Bot commented on BEAM-1347: -- Github user asfgit closed the pull request at:

[GitHub] beam pull request #3261: Rephrases messages on RetryHttpRequestInitializer

2017-05-30 Thread jkff
GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/3261 Rephrases messages on RetryHttpRequestInitializer "will NOT retry" messages are confusing some customers into thinking that an entire high-level operation inside a Beam job, involving this reques

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3963

2017-05-30 Thread Apache Jenkins Server
See Changes: [jbonofre] [BEAM-2379] Avoid reading projectId from environment variable in tests. -- [...truncated 3.07 MB...] 2017-05-30T21:24:31.124 [INF

[GitHub] beam pull request #3262: Clean up pyc files before running tests

2017-05-30 Thread sb2nov
GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/3262 Clean up pyc files before running tests 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:

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #2976

2017-05-30 Thread Apache Jenkins Server
See

[jira] [Created] (BEAM-2389) GcpCoreApiSurfaceTest isn't testing right module

2017-05-30 Thread Daniel Halperin (JIRA)
Daniel Halperin created BEAM-2389: - Summary: GcpCoreApiSurfaceTest isn't testing right module Key: BEAM-2389 URL: https://issues.apache.org/jira/browse/BEAM-2389 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-2373) AvroSource: Premature End of stream Exception on SnappyCompressorInputStream

2017-05-30 Thread Daniel Halperin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-2373: -- Fix Version/s: 2.1.0 > AvroSource: Premature End of stream Exception on SnappyCompressorInputStre

[2/2] beam git commit: This closes #3044: [BEAM-2248] KafkaIO support to use start read time to set start offset

2017-05-30 Thread jkff
This closes #3044: [BEAM-2248] KafkaIO support to use start read time to set start offset Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/94d677dc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/94d677dc Diff: http://git

[1/2] beam git commit: [BEAM-2248] KafkaIO support to use start read time to set start offset

2017-05-30 Thread jkff
Repository: beam Updated Branches: refs/heads/master 49067b164 -> 94d677dc9 [BEAM-2248] KafkaIO support to use start read time to set start offset Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d29e353e Tree: http://git-wip

[GitHub] beam pull request #3044: [BEAM-2248] KafkaIO support to use start read time ...

2017-05-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3044 --- 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] [Commented] (BEAM-2248) KafkaIO support to use start read time to set start offset

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030232#comment-16030232 ] ASF GitHub Bot commented on BEAM-2248: -- Github user asfgit closed the pull request at:

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2977

2017-05-30 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3964

2017-05-30 Thread Apache Jenkins Server
See Changes: [lcwik] [BEAM-1347] Remove the usage of a thread local on a potentially hot path -- [...truncated 3.07 MB...] 2017-05-30T22:31:16.427 [INFO]

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

2017-05-30 Thread Eric Johston (JIRA)
Eric Johston created BEAM-2390: -- Summary: allow user to use .setTimePartitioning in BigQueryIO.write Key: BEAM-2390 URL: https://issues.apache.org/jira/browse/BEAM-2390 Project: Beam Issue Type:

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3965

2017-05-30 Thread Apache Jenkins Server
See Changes: [kirpichov] [BEAM-2248] KafkaIO support to use start read time to set start offset -- [...truncated 3.06 MB...] 2017-05-30T23:05:43.338 [INF

[GitHub] beam pull request #3263: Flink*DoFnFunction: fix check for single-output dof...

2017-05-30 Thread dhalperi
GitHub user dhalperi opened a pull request: https://github.com/apache/beam/pull/3263 Flink*DoFnFunction: fix check for single-output dofns Fixes Findbugs and (presumably) increases efficiency by using the right OutputManager. R: @aljoscha but since this is a PostCommit brea

[jira] [Created] (BEAM-2391) Migrate to gcloud java core for default GCP project id detection

2017-05-30 Thread Luke Cwik (JIRA)
Luke Cwik created BEAM-2391: --- Summary: Migrate to gcloud java core for default GCP project id detection Key: BEAM-2391 URL: https://issues.apache.org/jira/browse/BEAM-2391 Project: Beam Issue Type

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

2017-05-30 Thread altay
This closes #3262 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f9431a39 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f9431a39 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f9431a39 Branch: refs/heads/maste

[1/2] beam git commit: Clean up pyc files before running tests

2017-05-30 Thread altay
Repository: beam Updated Branches: refs/heads/master 94d677dc9 -> f9431a390 Clean up pyc files before running tests Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2ddaaeac Tree: http://git-wip-us.apache.org/repos/asf/beam/t

[GitHub] beam pull request #3262: Clean up pyc files before running tests

2017-05-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3262 --- 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_Flink #2978

2017-05-30 Thread Apache Jenkins Server
See

[jira] [Created] (BEAM-2392) Avoid use of proto builder clone

2017-05-30 Thread Nigel Kilmer (JIRA)
Nigel Kilmer created BEAM-2392: -- Summary: Avoid use of proto builder clone Key: BEAM-2392 URL: https://issues.apache.org/jira/browse/BEAM-2392 Project: Beam Issue Type: Improvement Com

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #74

2017-05-30 Thread Apache Jenkins Server
See Changes: [jbonofre] [BEAM-2379] Avoid reading projectId from environment variable in tests. [lcwik] [BEAM-1347] Remove the usage of a thread local on a potentially hot path [kirpicho

[2/2] beam git commit: [BEAM-1544] Java cross-JDK version tests on Jenkins\n\nThis closes #3184

2017-05-30 Thread lcwik
[BEAM-1544] Java cross-JDK version tests on Jenkins\n\nThis closes #3184 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2fa24d89 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2fa24d89 Diff: http://git-wip-us.apache.org

[1/2] beam git commit: [BEAM-1544] Java cross-JDK version tests on Jenkins

2017-05-30 Thread lcwik
Repository: beam Updated Branches: refs/heads/master f9431a390 -> 2fa24d89c [BEAM-1544] Java cross-JDK version tests on Jenkins Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2f9a38e5 Tree: http://git-wip-us.apache.org/repo

[GitHub] beam pull request #3184: [BEAM-1544] Java cross-JDK version tests on Jenkins

2017-05-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3184 --- 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] [Commented] (BEAM-1544) Move Java cross-JDK tests from Travis to Jenkins

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030439#comment-16030439 ] ASF GitHub Bot commented on BEAM-1544: -- Github user asfgit closed the pull request at:

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3967

2017-05-30 Thread Apache Jenkins Server
See -- [...truncated 3.06 MB...] 2017-05-31T00:55:54.857 [INFO] Downloaded: https://repo.maven.apache.org/maven2/com/twitter/chill_2.10/0.7.4/chill_2.10-0.7.4.jar (217

[GitHub] beam pull request #3264: Fetch only relevant PR

2017-05-30 Thread jasonkuster
GitHub user jasonkuster opened a pull request: https://github.com/apache/beam/pull/3264 Fetch only relevant PR Per https://github.com/jenkinsci/ghprb-plugin/pull/521 we can be much more efficient about how we fetch PRs initially. Be sure to do all of the following to help u

[jira] [Commented] (BEAM-2392) Avoid use of proto builder clone

2017-05-30 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030453#comment-16030453 ] Luke Cwik commented on BEAM-2392: - How did clone not work for you? If it seems like a bug,

[jira] [Assigned] (BEAM-2392) Avoid use of proto builder clone

2017-05-30 Thread Luke Cwik (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik reassigned BEAM-2392: --- Assignee: Nigel Kilmer (was: Daniel Halperin) > Avoid use of proto builder clone > --

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2980

2017-05-30 Thread Apache Jenkins Server
See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3966

2017-05-30 Thread Apache Jenkins Server
See Changes: [altay] Clean up pyc files before running tests -- [...truncated 3.07 MB...] 2017-05-31T01:02:26.354 [INFO] Downloaded: https://repo.maven.a

[GitHub] beam pull request #3265: Property names cleanup

2017-05-30 Thread jkff
GitHub user jkff opened a pull request: https://github.com/apache/beam/pull/3265 Property names cleanup This also updates Dataflow worker to a version that doesn't depend on PropertyNames which are not used in Dataflow runner itself. So, from now on, if a PropertyNames entry is unu

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3968

2017-05-30 Thread Apache Jenkins Server
See Changes: [lcwik] [BEAM-1544] Java cross-JDK version tests on Jenkins -- [...truncated 3.07 MB...] 2017-05-31T01:47:00.862 [INFO] Downloaded: https://

[jira] [Closed] (BEAM-2248) KafkaIO support to use start read time to set start offset

2017-05-30 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed BEAM-2248. -- Resolution: Fixed Fix Version/s: 2.1.0 > KafkaIO support to use start read time to set start offse

[jira] [Updated] (BEAM-1962) Connection should be closed in case start() throws exception

2017-05-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated BEAM-1962: - Description: In JmsIO#start() : {code} try { Connection connection; if (spec.getUsername() !

[GitHub] beam pull request #3266: [BEAM-2390] added time partitioning to BigQueryIO

2017-05-30 Thread ericjohnston1989
GitHub user ericjohnston1989 opened a pull request: https://github.com/apache/beam/pull/3266 [BEAM-2390] added time partitioning to BigQueryIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

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

2017-05-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030497#comment-16030497 ] ASF GitHub Bot commented on BEAM-2390: -- GitHub user ericjohnston1989 opened a pull req

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

2017-05-30 Thread Eric Johston (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030499#comment-16030499 ] Eric Johston commented on BEAM-2390: I've created a pull request with the functionality

  1   2   >