Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2716

See

[jira] [Commented] (BEAM-2205) AttributeError when running datastore wordcount

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

[GitHub] beam pull request #2946: [BEAM-2205] Fixing typo in datastore_wordcount.py

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

[1/2] beam git commit: Fixing typo in datastore_wordcount.py

Repository: beam Updated Branches: refs/heads/master 1a4ca9acd -> 2b470eaa3 Fixing typo in datastore_wordcount.py Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/938cb2f4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tre

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

This closes #2946 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2b470eaa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2b470eaa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2b470eaa Branch: refs/heads/maste

Jenkins build is unstable: beam_PostCommit_Java_MavenInstall #3698

See

[jira] [Created] (BEAM-2207) BeamSqlInputRefExpression in BeamSQLFnExecutor.buildExpression error

Fei Feng created BEAM-2207: -- Summary: BeamSqlInputRefExpression in BeamSQLFnExecutor.buildExpression error Key: BEAM-2207 URL: https://issues.apache.org/jira/browse/BEAM-2207 Project: Beam Issue Ty

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #1982

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3070

See

Jenkins build is unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3069

See

[jira] [Commented] (BEAM-831) ParDo Chaining

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

[jira] [Commented] (BEAM-831) ParDo Chaining

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

[GitHub] beam pull request #2216: [BEAM-831] ParDo Chaining of Apex Runner

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

[GitHub] beam pull request #2927: [BEAM-831] ParDo Chaining in Apex Runner

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

[1/3] beam git commit: [BEAM-831] ParDo Fusion of Apex Runner

Repository: beam Updated Branches: refs/heads/master 53dd0a529 -> 1a4ca9acd [BEAM-831] ParDo Fusion of Apex Runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/55a7cd4f Tree: http://git-wip-us.apache.org/repos/asf/beam/tr

[3/3] beam git commit: This closes #2927: ParDo Chaining in Apex Runner

This closes #2927: ParDo Chaining in Apex Runner [BEAM-831] Fix chaining, add test. closes #2216 [BEAM-831] ParDo Fusion of Apex Runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1a4ca9ac Tree: http://git-wip-us.apache

[2/3] beam git commit: [BEAM-831] Fix chaining, add test. closes #2216

[BEAM-831] Fix chaining, add test. closes #2216 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b64c8ce7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b64c8ce7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b64c

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

[ https://issues.apache.org/jira/browse/BEAM-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1620: -- Summary: Add streaming Dataflow ValidatesRunner coverage (was: Add streaming Dataflow RunnableOn

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

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

[GitHub] beam pull request #2947: [BEAM-1620] Run ValidatesRunner on Dataflow streami...

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2947 [BEAM-1620] Run ValidatesRunner on Dataflow streaming in postcommit Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure th

[jira] [Commented] (BEAM-2205) AttributeError when running datastore wordcount

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

[GitHub] beam pull request #2946: [BEAM-2205] Fixing typo in datastore_wordcount.py

GitHub user pabloem opened a pull request: https://github.com/apache/beam/pull/2946 [BEAM-2205] Fixing typo in datastore_wordcount.py You can merge this pull request into a Git repository by running: $ git pull https://github.com/pabloem/incubator-beam fix-dswc Alternatively

[GitHub] beam pull request #2945: Only cythonize files within apache_beam

GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/2945 Only cythonize files within apache_beam 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 became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1981

See

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Dataflow #3068

See -- [...truncated 1.66 MB...] [WARNING] ByteKeyRangeTracker{range=ByteKeyRange{startKey=[6b6579303030303030303030], endKey=[6b6579303030303030303039]},

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Flink #2713

See

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #3696

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3067

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #3697

See -- [...truncated 460.30 KB...] 2017-05-08T00:07:04.374 [INFO] Running org.apache.beam.sdk.util.common.ReflectHelpersTest 2017-05-08T00:07:04.376 [INFO] Tests run: 1

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Flink #2712

See

[jira] [Commented] (BEAM-1113) Support for new Timer API in Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-1113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000116#comment-16000116 ] ASF GitHub Bot commented on BEAM-1113: -- Github user kennknowles closed the pull reques

[GitHub] beam pull request #2901: [BEAM-1113] Re-enable UsesTimersInParDo tests in Da...

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

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3066

See

[jira] [Commented] (BEAM-2150) Support for recursive wildcards in GcsPath

[ https://issues.apache.org/jira/browse/BEAM-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000114#comment-16000114 ] Daniel Halperin commented on BEAM-2150: --- Funny, my shell does the behavior I'd expect

[GitHub] beam pull request #2944: Cherry pick #2940 onto release-2.0.0

GitHub user kennknowles opened a pull request: https://github.com/apache/beam/pull/2944 Cherry pick #2940 onto release-2.0.0 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-1340) Remove or make private public bits of the SDK that shouldn't be public

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

[2/4] beam git commit: Move TestDataflowRunner into dataflow package

http://git-wip-us.apache.org/repos/asf/beam/blob/b46e7b9b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/testing/TestDataflowRunnerTest.java -- diff --git a/runners/google-cloud-dataflow-java/src

[GitHub] beam pull request #2940: [BEAM-1340] Move TestDataflowRunner into dataflow p...

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

[3/4] beam git commit: Move TestDataflowRunner into dataflow package

Move TestDataflowRunner into dataflow package Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b46e7b9b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b46e7b9b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b46e7b

[1/4] beam git commit: Register the TestDataflowRunner via registrar

Repository: beam Updated Branches: refs/heads/master dabad1ae5 -> 53dd0a529 Register the TestDataflowRunner via registrar Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eb043d06 Tree: http://git-wip-us.apache.org/repos/asf/

[4/4] beam git commit: This closes #2940: Move TestDataflowRunner into dataflow package

This closes #2940: Move TestDataflowRunner into dataflow package Move TestDataflowRunner into dataflow package Register the TestDataflowRunner via registrar Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/53dd0a52 Tree: htt

[jira] [Updated] (BEAM-2205) AttributeError when running datastore wordcount

[ https://issues.apache.org/jira/browse/BEAM-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-2205: Ugh. Sorry about that. I'll fix that tonight. > AttributeError when running datastore wordcount > ---

[jira] [Created] (BEAM-2206) Move pipeline options into separate package from beam/utils

Sourabh Bajaj created BEAM-2206: --- Summary: Move pipeline options into separate package from beam/utils Key: BEAM-2206 URL: https://issues.apache.org/jira/browse/BEAM-2206 Project: Beam Issue T

[jira] [Created] (BEAM-2205) AttributeError when running datastore wordcount

Ahmet Altay created BEAM-2205: - Summary: AttributeError when running datastore wordcount Key: BEAM-2205 URL: https://issues.apache.org/jira/browse/BEAM-2205 Project: Beam Issue Type: Bug

[GitHub] beam pull request #2943: CherryPick #2935 to 2.0 release branch

GitHub user sb2nov opened a pull request: https://github.com/apache/beam/pull/2943 CherryPick #2935 to 2.0 release branch 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 became unstable: beam_PostCommit_Java_MavenInstall #3695

See

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #1979

See

[jira] [Created] (BEAM-2204) fix error in CALCITE-1761

Xu Mingmin created BEAM-2204: Summary: fix error in CALCITE-1761 Key: BEAM-2204 URL: https://issues.apache.org/jira/browse/BEAM-2204 Project: Beam Issue Type: Bug Components: dsl-sql

[jira] [Commented] (BEAM-1612) Support real Bundle in Flink runner

[ https://issues.apache.org/jira/browse/BEAM-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1520#comment-1520 ] Kenneth Knowles commented on BEAM-1612: --- This is probably already obvious and taken i

[jira] [Commented] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1505#comment-1505 ] Jean-Baptiste Onofré commented on BEAM-638: --- A good test is to check (with for ins

[jira] [Commented] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1503#comment-1503 ] Jean-Baptiste Onofré commented on BEAM-638: --- Agree, it's resolved. This is what I

[jira] [Commented] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1502#comment-1502 ] Asmir Avdicevic commented on BEAM-638: -- Thanks for the input, I'll search the issues.

[jira] [Commented] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1500#comment-1500 ] Davor Bonaci commented on BEAM-638: --- I believe this JIRA is fixed, as we have windowed fil

[jira] [Resolved] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-638. --- Resolution: Fixed Fix Version/s: 2.0.0 > Add sink transform to write bounded data per window, pan

[jira] [Commented] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999898#comment-15999898 ] Davor Bonaci commented on BEAM-638: --- [~Arqu], windowing specified at Window.into applies w

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

[ 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() !=

[jira] [Comment Edited] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999835#comment-15999835 ] Asmir Avdicevic edited comment on BEAM-638 at 5/7/17 1:18 PM: --

[jira] [Commented] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999835#comment-15999835 ] Asmir Avdicevic commented on BEAM-638: -- Sure here's the majority of it: {code:title=My

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1978

See

[jira] [Commented] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999799#comment-15999799 ] Jean-Baptiste Onofré commented on BEAM-638: --- Can you share your pipeline ? (especi

[jira] [Commented] (BEAM-638) Add sink transform to write bounded data per window, pane, [and key] even when PCollection is unbounded

[ https://issues.apache.org/jira/browse/BEAM-638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999798#comment-15999798 ] Asmir Avdicevic commented on BEAM-638: -- I've tried it out and doesn't seem to work prop

[jira] [Created] (BEAM-2203) Arithmetic operators: support DATETIME & DATETIME_INTERVAL

James Xu created BEAM-2203: -- Summary: Arithmetic operators: support DATETIME & DATETIME_INTERVAL Key: BEAM-2203 URL: https://issues.apache.org/jira/browse/BEAM-2203 Project: Beam Issue Type: New Fea

[jira] [Assigned] (BEAM-2203) Arithmetic operators: support DATETIME & DATETIME_INTERVAL

[ https://issues.apache.org/jira/browse/BEAM-2203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Xu reassigned BEAM-2203: -- Assignee: (was: Xu Mingmin) > Arithmetic operators: support DATETIME & DATETIME_INTERVAL > -

[jira] [Commented] (BEAM-2079) Support TextIO as SQL source/sink

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

[GitHub] beam pull request #2942: [BEAM-2079] Support TextIO as SQL source/sink

GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/2942 [BEAM-2079] Support TextIO as SQL source/sink Support TextIO as SQL source/sink You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming/beam

[jira] [Resolved] (BEAM-2189) ImportError get_filesystem

[ https://issues.apache.org/jira/browse/BEAM-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-2189. --- Resolution: Fixed Fix Version/s: (was: 2.0.0) Not applicable > ImportErro