[jira] [Assigned] (BEAM-2467) KinesisIO watermark based on approximateArrivalTimestamp

[ https://issues.apache.org/jira/browse/BEAM-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2467: -- Assignee: Paweł Kaczmarczyk > KinesisIO watermark based on approximateArrivalTimestamp >

[GitHub] beam pull request #3408: None should be a valid return element

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3408 --- 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: None should be a valid return element

Repository: beam Updated Branches: refs/heads/master 7b4f5eeaa -> a40d11c8e None should be a valid return element Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5a95d620 Tree:

[2/2] beam git commit: Closes #3408

Closes #3408 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a40d11c8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a40d11c8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a40d11c8 Branch: refs/heads/master

[jira] [Created] (BEAM-2487) Give a option to ignore the timer that is larger than END_OF_GLOBAL_WINDOW

Jingsong Lee created BEAM-2487: -- Summary: Give a option to ignore the timer that is larger than END_OF_GLOBAL_WINDOW Key: BEAM-2487 URL: https://issues.apache.org/jira/browse/BEAM-2487 Project: Beam

[jira] [Commented] (BEAM-2486) Should throws some useful messages when statefulParDo use non-KV input

[ https://issues.apache.org/jira/browse/BEAM-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056877#comment-16056877 ] Jingsong Lee commented on BEAM-2486: [~kenn] Can we do some validates before runner? > Should throws

[jira] [Created] (BEAM-2486) Should throws some useful messages when statefulParDo use non-KV input

Jingsong Lee created BEAM-2486: -- Summary: Should throws some useful messages when statefulParDo use non-KV input Key: BEAM-2486 URL: https://issues.apache.org/jira/browse/BEAM-2486 Project: Beam

[jira] [Resolved] (BEAM-2247) support date/time functions

[ https://issues.apache.org/jira/browse/BEAM-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Xu resolved BEAM-2247. Resolution: Fixed Fix Version/s: Not applicable > support date/time functions >

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #4165

See

[jira] [Commented] (BEAM-1620) Add streaming Dataflow ValidatesRunner coverage

[ https://issues.apache.org/jira/browse/BEAM-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056835#comment-16056835 ] Kenneth Knowles commented on BEAM-1620: --- I think we might already have a category for tests that use

[jira] [Comment Edited] (BEAM-1620) Add streaming Dataflow ValidatesRunner coverage

[ https://issues.apache.org/jira/browse/BEAM-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056835#comment-16056835 ] Kenneth Knowles edited comment on BEAM-1620 at 6/21/17 2:01 AM: For

[jira] [Commented] (BEAM-1438) The default behavior for the Write transform doesn't work well with the Dataflow streaming runner

[ https://issues.apache.org/jira/browse/BEAM-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056813#comment-16056813 ] Reuven Lax commented on BEAM-1438: -- I believe so > The default behavior for the Write transform

[jira] [Created] (BEAM-2485) Reject stateful ParDo / DoFn in merging windows at construction time in Dataflow runner

Kenneth Knowles created BEAM-2485: - Summary: Reject stateful ParDo / DoFn in merging windows at construction time in Dataflow runner Key: BEAM-2485 URL: https://issues.apache.org/jira/browse/BEAM-2485

[jira] [Commented] (BEAM-1438) The default behavior for the Write transform doesn't work well with the Dataflow streaming runner

[ https://issues.apache.org/jira/browse/BEAM-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056800#comment-16056800 ] Kenneth Knowles commented on BEAM-1438: --- [~reuvenlax] does the recent merge finish this one off? >

[jira] [Commented] (BEAM-1438) The default behavior for the Write transform doesn't work well with the Dataflow streaming runner

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

[2/2] beam git commit: This closes #1952: BEAM-1438 Auto shard streaming sinks

This closes #1952: BEAM-1438 Auto shard streaming sinks Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7b4f5eea Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7b4f5eea Diff:

[GitHub] beam pull request #1952: BEAM-1438 Auto shard streaming sinks

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/1952 --- 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-1438 Auto shard streaming sinks

Repository: beam Updated Branches: refs/heads/master 223dbb449 -> 7b4f5eeaa BEAM-1438 Auto shard streaming sinks If a Write operation in streaming requests runner-determined sharding, make the Dataflow runner default to maxNumWorkers * 2 shards. Project:

[jira] [Commented] (BEAM-2460) Make python maven variables available elsewhere

[ https://issues.apache.org/jira/browse/BEAM-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056727#comment-16056727 ] Ahmet Altay commented on BEAM-2460: --- Sounds good to me, thank you for the detailed explanation. > Make

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #4164

See -- [...truncated 1.05 MB...] 2017-06-21T00:36:39.720 [INFO] Downloaded: https://repo.maven.apache.org/maven2/de/jflex/jflex/1.6.0/jflex-1.6.0.jar (1025 KB at

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #158

See Changes: [github] Remove notifications from JDK versions test. [lcwik] Increases backoff in GcsUtil [chamikara] Fix dataflow runner test to call pipeline.run instead of runner.run

[GitHub] beam pull request #3409: Allow production of unprocessed bundles, introduce ...

GitHub user charlesccychen opened a pull request: https://github.com/apache/beam/pull/3409 Allow production of unprocessed bundles, introduce TestStream evaluator in DirectRunner This change depends on #3405. You can merge this pull request into a Git repository by running: $

[jira] [Commented] (BEAM-2460) Make python maven variables available elsewhere

[ https://issues.apache.org/jira/browse/BEAM-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056682#comment-16056682 ] Stephen Sisk commented on BEAM-2460: You are correct, that does mean that a project that wants to use

[jira] [Closed] (BEAM-1377) Support Splittable DoFn in Dataflow streaming runner

[ https://issues.apache.org/jira/browse/BEAM-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1377. -- Resolution: Fixed Fix Version/s: 2.1.0 > Support Splittable DoFn in Dataflow streaming

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

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

[GitHub] beam pull request #3404: Add a cloud-pubsub dependency to the list of gcp ex...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3404 --- 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: Add a cloud-pubsub dependency to the list of gcp extra packages

Repository: beam Updated Branches: refs/heads/master fd40d4b29 -> 223dbb449 Add a cloud-pubsub dependency to the list of gcp extra packages Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ef19024d Tree:

[GitHub] beam pull request #3408: None should be a valid return element

GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/3408 None should be a valid return element 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-1377) Support Splittable DoFn in Dataflow streaming runner

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

[GitHub] beam pull request #1898: [BEAM-1377] Splittable DoFn in Dataflow streaming r...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/1898 --- 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 #1898: [BEAM-1377] Splittable DoFn in Dataflow streaming runner

This closes #1898: [BEAM-1377] Splittable DoFn in Dataflow streaming runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fd40d4b2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fd40d4b2 Diff:

[1/3] beam git commit: [BEAM-1377] Splittable DoFn in Dataflow streaming runner

Repository: beam Updated Branches: refs/heads/master 698b89e2b -> fd40d4b29 [BEAM-1377] Splittable DoFn in Dataflow streaming runner Transform expansion and translation for the involved primitive transforms. Of course, the current PR will only work after the respective Dataflow worker and

[2/3] beam git commit: Bump Dataflow worker to 20170619

Bump Dataflow worker to 20170619 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4f6032c9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4f6032c9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4f6032c9 Branch:

[jira] [Commented] (BEAM-1620) Add streaming Dataflow ValidatesRunner coverage

[ https://issues.apache.org/jira/browse/BEAM-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056663#comment-16056663 ] Eugene Kirpichov commented on BEAM-1620: Note: there are tests like SplittableDoFnTest that, in

[jira] [Updated] (BEAM-2483) SplittableDoFnTest should not explicitly setStreaming(true)

[ https://issues.apache.org/jira/browse/BEAM-2483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-2483: --- Description: https://github.com/apache/beam/pull/1898 adds Splittable DoFn to Dataflow

[GitHub] beam pull request #3407: Return a valid Coder for any subtype of Mutation on...

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/3407 Return a valid Coder for any subtype of Mutation on HBaseCoderProvide… …rRegistrar Be sure to do all of the following to help us incorporate your contribution quickly and easily:

[jira] [Commented] (BEAM-2482) CodedValueMutationDetector should use the coders structural value

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

[GitHub] beam pull request #3406: [BEAM-2482] CodedValueMutationDetector should use t...

GitHub user evindj reopened a pull request: https://github.com/apache/beam/pull/3406 [BEAM-2482] CodedValueMutationDetector should use the coders structural value Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ]

[jira] [Commented] (BEAM-2482) CodedValueMutationDetector should use the coders structural value

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

[GitHub] beam pull request #3406: [BEAM-2482] CodedValueMutationDetector should use t...

Github user evindj closed the pull request at: https://github.com/apache/beam/pull/3406 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (BEAM-2482) CodedValueMutationDetector should use the coders structural value

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

[GitHub] beam pull request #3406: [BEAM-2482] CodedValueMutationDetector should use t...

GitHub user evindj opened a pull request: https://github.com/apache/beam/pull/3406 [BEAM-2482] CodedValueMutationDetector should use the coders structural value Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[jira] [Commented] (BEAM-2460) Make python maven variables available elsewhere

[ https://issues.apache.org/jira/browse/BEAM-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056615#comment-16056615 ] Ahmet Altay commented on BEAM-2460: --- I am not a Maven expert and feel free to ignore this. How does

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #3407

See

[jira] [Commented] (BEAM-2460) Make python maven variables available elsewhere

[ https://issues.apache.org/jira/browse/BEAM-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056609#comment-16056609 ] Stephen Sisk commented on BEAM-2460: I wish that would help but it doesn't. The fundamental problem is

[GitHub] beam pull request #3405: Use state / timer API for DirectRunner timer firing...

GitHub user charlesccychen opened a pull request: https://github.com/apache/beam/pull/3405 Use state / timer API for DirectRunner timer firings Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[jira] [Commented] (BEAM-2460) Make python maven variables available elsewhere

[ https://issues.apache.org/jira/browse/BEAM-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056558#comment-16056558 ] Stephen Sisk commented on BEAM-2460: With a bit more investigation, I've landed on the following

[jira] [Commented] (BEAM-2302) WriteFiles with runner-determined sharding and large numbers of windows causes OOM errors

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

[GitHub] beam pull request #3161: [BEAM-2302] Add spilling code to WriteFiles.

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3161 --- 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 #3161: [BEAM-2302] Add spilling code to WriteFiles.

This closes #3161: [BEAM-2302] Add spilling code to WriteFiles. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/698b89e2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/698b89e2 Diff:

[1/2] beam git commit: Add spilling code to WriteFiles.

Repository: beam Updated Branches: refs/heads/master 10e47646d -> 698b89e2b Add spilling code to WriteFiles. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/69b01a61 Tree:

[jira] [Commented] (BEAM-1542) Need Source/Sink for Spanner

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

[GitHub] beam pull request #3404: Add a cloud-pubsub dependency to the list of gcp ex...

GitHub user aaltay opened a pull request: https://github.com/apache/beam/pull/3404 Add a cloud-pubsub dependency to the list of gcp extra packages R: @charlesccychen cc: @tvalentyn You can merge this pull request into a Git repository by running: $ git pull

[GitHub] beam pull request #3358: [BEAM-1542] Support ValueProviders in SpannerIO

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3358 --- 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 #3358: [BEAM-1542] Support ValueProviders in SpannerIO

This closes #3358: [BEAM-1542] Support ValueProviders in SpannerIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/10e47646 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/10e47646 Diff:

[1/2] beam git commit: Support ValueProviders in SpannerIO.Write

Repository: beam Updated Branches: refs/heads/master 608a9c459 -> 10e47646d Support ValueProviders in SpannerIO.Write Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/42a2de91 Tree:

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4156

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3406

See

[GitHub] beam pull request #3275: Flink runner: refactor the translator into two phas...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3275 --- 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/3] beam git commit: FlinkRunner: remove the unused ReflectiveOneToOneOverrideFactory.

FlinkRunner: remove the unused ReflectiveOneToOneOverrideFactory. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f69e3b53 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f69e3b53 Diff:

[1/3] beam git commit: Flink runner: refactor the translator into two phases: rewriting and translating.

Repository: beam Updated Branches: refs/heads/master e4ef23e16 -> 608a9c459 Flink runner: refactor the translator into two phases: rewriting and translating. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/52794096 Tree:

[jira] [Created] (BEAM-2484) Add streaming examples for Python

David Cavazos created BEAM-2484: --- Summary: Add streaming examples for Python Key: BEAM-2484 URL: https://issues.apache.org/jira/browse/BEAM-2484 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-2483) SplittableDoFnTest should not explicitly setStreaming(true)

Eugene Kirpichov created BEAM-2483: -- Summary: SplittableDoFnTest should not explicitly setStreaming(true) Key: BEAM-2483 URL: https://issues.apache.org/jira/browse/BEAM-2483 Project: Beam

Jenkins build is back to normal : beam_PostCommit_Python_Verify #2535

See

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4155

See

[jira] [Commented] (BEAM-115) Beam Runner API

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

[GitHub] beam pull request #3361: [BEAM-115] Port fn_api_runner to be able to use run...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3361 --- 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: Port fn_api_runner to be able to use runner protos.

Repository: beam Updated Branches: refs/heads/master f51fdd960 -> e4ef23e16 Port fn_api_runner to be able to use runner protos. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/08ec0d4d Tree:

[2/2] beam git commit: Closes #3361

Closes #3361 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e4ef23e1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e4ef23e1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e4ef23e1 Branch: refs/heads/master

[GitHub] beam pull request #3393: Fix Dataflow runner test to call pipeline.run inste...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3393 --- 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 dataflow runner test to call pipeline.run instead of runner.run

Repository: beam Updated Branches: refs/heads/master 59598d8f4 -> f51fdd960 Fix dataflow runner test to call pipeline.run instead of runner.run Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a0523b2d Tree:

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

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

[jira] [Resolved] (BEAM-2443) BeamSqlRecordType should migrate to using a builder pattern via AutoValue/AutoBuilder

[ https://issues.apache.org/jira/browse/BEAM-2443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2443. - Resolution: Fixed Fix Version/s: Not applicable > BeamSqlRecordType should migrate to using a

[jira] [Resolved] (BEAM-2444) DSL SQL: Use standard java exceptions instead of custom ones

[ https://issues.apache.org/jira/browse/BEAM-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik resolved BEAM-2444. - Resolution: Fixed Fix Version/s: Not applicable > DSL SQL: Use standard java exceptions instead of

[jira] [Commented] (BEAM-2460) Make python maven variables available elsewhere

[ https://issues.apache.org/jira/browse/BEAM-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056401#comment-16056401 ] Stephen Sisk commented on BEAM-2460: I realized that #2 above implies that I'd have to add a variable

[jira] [Commented] (BEAM-2460) Make python maven variables available elsewhere

[ https://issues.apache.org/jira/browse/BEAM-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056396#comment-16056396 ] Stephen Sisk commented on BEAM-2460: okay, this is more complex than I had hoped.See

Build failed in Jenkins: beam_PostCommit_Python_Verify #2534

See Changes: [github] Remove notifications from JDK versions test. -- [...truncated 1.12 MB...] "type": "STRING", "value":

[GitHub] beam pull request #3381: Increases backoff in GcsUtil

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

Increases backoff in GcsUtil This closes #3381 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59598d8f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/59598d8f Diff:

[1/2] beam git commit: Increases backoff in GcsUtil

Repository: beam Updated Branches: refs/heads/master 0eb4004a8 -> 59598d8f4 Increases backoff in GcsUtil Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b7ff103f Tree:

[jira] [Commented] (BEAM-2458) Move HashingFn from test -> main to make it more accessible

[ https://issues.apache.org/jira/browse/BEAM-2458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056361#comment-16056361 ] Stephen Sisk commented on BEAM-2458: [~tgroh] pointed out that as part of this, we'd be making

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3405

See

[GitHub] beam pull request #3403: Remove notifications from JDK versions test.

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3403 --- 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: Remove notifications from JDK versions test.

Repository: beam Updated Branches: refs/heads/master c1a2226c9 -> 0eb4004a8 Remove notifications from JDK versions test. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5e12e9d7 Tree:

[2/2] beam git commit: This closes #3403: Remove notifications from JDK versions test.

This closes #3403: Remove notifications from JDK versions test. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0eb4004a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0eb4004a Diff:

Jenkins build is back to normal : beam_PostCommit_Java_MavenInstall #4154

See

[GitHub] beam pull request #3403: Remove notifications from JDK versions test.

GitHub user jasonkuster opened a pull request: https://github.com/apache/beam/pull/3403 Remove notifications from JDK versions test. 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-2395) BigtableIO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-2395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056286#comment-16056286 ] Solomon Duskis commented on BEAM-2395: -- The python cloud bigtable client is missing some key features

[jira] [Commented] (BEAM-2192) support DISTINCT select

[ https://issues.apache.org/jira/browse/BEAM-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056275#comment-16056275 ] Xu Mingmin commented on BEAM-2192: -- added a test for {{distinct}}, please have a check

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #157

See Changes: [lcwik] Retries http code 0 (usually network error) -- [...truncated 2.65 MB...] 2017-06-20T18:33:56.275 [INFO] Downloaded:

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

[ https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056223#comment-16056223 ] Kenneth Knowles commented on BEAM-210: -- I think this is what you want when you are disabling empty on

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

[ https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056223#comment-16056223 ] Kenneth Knowles edited comment on BEAM-210 at 6/20/17 6:19 PM: ---

[jira] [Closed] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested

[ https://issues.apache.org/jira/browse/BEAM-32?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles closed BEAM-32. --- Resolution: Won't Fix Assignee: Kenneth Knowles Fix Version/s: Not applicable > Consider

[jira] [Commented] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested

[ https://issues.apache.org/jira/browse/BEAM-32?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056221#comment-16056221 ] Kenneth Knowles commented on BEAM-32: - Even though anyone affected by this probably has an erroneous

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

[ https://issues.apache.org/jira/browse/BEAM-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-210: Assignee: Pei He > Allow control of empty ON_TIME panes analogous to final panes >

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

See Changes: [lcwik] Retries http code 0 (usually network error) -- [...truncated 854.61 KB...]

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

See Changes: [lcwik] Retries http code 0 (usually network error) -- [...truncated 854.58 KB...]

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

See Changes: [lcwik] Retries http code 0 (usually network error) -- [...truncated 851.74 KB...]

[jira] [Commented] (BEAM-9) Storm Runner

[ https://issues.apache.org/jira/browse/BEAM-9?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056175#comment-16056175 ] Pei He commented on BEAM-9: --- Hi Xiao LI, The jstorm runner is in my github repo, and we are working on merging it to

[jira] [Assigned] (BEAM-2445) DSL SQL to use service locator pattern to automatically register UDFs

[ https://issues.apache.org/jira/browse/BEAM-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin reassigned BEAM-2445: Assignee: (was: Xu Mingmin) > DSL SQL to use service locator pattern to automatically register

  1   2   >