[jira] [Closed] (BEAM-2454) Remove unused BeamPipelineCreator class

[ https://issues.apache.org/jira/browse/BEAM-2454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tyler Akidau closed BEAM-2454. -- Resolution: Fixed Fix Version/s: Not applicable > Remove unused BeamPipelineCreator class >

[jira] [Commented] (BEAM-2454) Remove unused BeamPipelineCreator class

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

[1/2] beam git commit: Remove unused BeamPipelineCreator class

Repository: beam Updated Branches: refs/heads/DSL_SQL 9bcae5326 -> abe0f1a0a Remove unused BeamPipelineCreator class Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/51f54925 Tree:

[GitHub] beam pull request #3376: [BEAM-2454] Remove unused BeamPipelineCreator class

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3376 --- 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: [BEAM-2454] This closes #3376

[BEAM-2454] This closes #3376 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/abe0f1a0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/abe0f1a0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/abe0f1a0 Branch:

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3372

See

[jira] [Commented] (BEAM-2440) DSL SQL: Reduce visibility to simplify backwards compatibility

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

[GitHub] beam pull request #3364: [BEAM-2440] BeamSql: reduce visibility

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3364 --- 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: [BEAM-2440] This closes #3364

[BEAM-2440] This closes #3364 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9bcae532 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9bcae532 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9bcae532 Branch:

[1/2] beam git commit: [BEAM-2440] BeamSql: reduce visibility

Repository: beam Updated Branches: refs/heads/DSL_SQL df5859d44 -> 9bcae5326 [BEAM-2440] BeamSql: reduce visibility Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fc5906e1 Tree:

[jira] [Commented] (BEAM-2442) DSL SQL: Public classes/methods should not expose/use calcite types

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

[GitHub] beam pull request #3357: [BEAM-2442] BeamSql api surface test

Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3357 --- 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] [Issue Comment Deleted] (BEAM-940) OnTimerInvokers: key the cache with a (Class, id) tuple or OnTimerMethod

[ https://issues.apache.org/jira/browse/BEAM-940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Innocent updated BEAM-940: -- Comment: was deleted (was: I could not find any map (reference to the key) or anything matching

[jira] [Commented] (BEAM-940) OnTimerInvokers: key the cache with a (Class, id) tuple or OnTimerMethod

[ https://issues.apache.org/jira/browse/BEAM-940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051270#comment-16051270 ] Innocent commented on BEAM-940: --- I could not find any map (reference to the key) or anything matching

[jira] [Commented] (BEAM-940) OnTimerInvokers: key the cache with a (Class, id) tuple or OnTimerMethod

[ https://issues.apache.org/jira/browse/BEAM-940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051271#comment-16051271 ] Innocent commented on BEAM-940: --- I could not find any map (reference to the key) or anything matching

[jira] [Commented] (BEAM-2454) Remove unused BeamPipelineCreator class

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

[GitHub] beam pull request #3376: [BEAM-2454] Remove unused BeamPipelineCreator class

GitHub user takidau opened a pull request: https://github.com/apache/beam/pull/3376 [BEAM-2454] Remove unused BeamPipelineCreator class The BeamPipelineCreator class appears to be unused (presumably the functionality there moved at some point into BeamQueryPlanner). Assuming there

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4118

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3371

See

[jira] [Created] (BEAM-2454) Remove unused BeamPipelineCreator class

Tyler Akidau created BEAM-2454: -- Summary: Remove unused BeamPipelineCreator class Key: BEAM-2454 URL: https://issues.apache.org/jira/browse/BEAM-2454 Project: Beam Issue Type: Task

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2378

See

[1/2] beam git commit: [BEAM-2442] BeamSql surface api test.

Repository: beam Updated Branches: refs/heads/DSL_SQL 2e9253401 -> df5859d44 [BEAM-2442] BeamSql surface api test. The surface api of BeamSql includes the following: - BeamSql - BeamSqlCli - BeamSqlEnv - All the classes in package org.apache.beam.dsls.sql.schema Calcite related methods are

[2/2] beam git commit: [BEAM-2442] This closes #3357

[BEAM-2442] This closes #3357 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/df5859d4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/df5859d4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/df5859d4 Branch:

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

See Changes: [lcwik] [BEAM-1348] Mark Runner API like types declared within Fn API as [klk] Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #138

See Changes: [lcwik] [BEAM-1348] Mark Runner API like types declared within Fn API as [klk] Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo override

[GitHub] beam pull request #3352: [BEAM-2371] Fix getAdditionalInputs, etc, for Direc...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3352 --- 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-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers

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

[2/2] beam git commit: This closes #3352: Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo override

This closes #3352: Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo override Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c528fb2f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c528fb2f Diff:

[1/2] beam git commit: Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo override

Repository: beam Updated Branches: refs/heads/master 346a77fa8 -> c528fb2f7 Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo override Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/81a72192 Tree:

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

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

[GitHub] beam pull request #3375: [BEAM-1347] Break apart ProcessBundleHandler to use...

GitHub user lukecwik opened a pull request: https://github.com/apache/beam/pull/3375 [BEAM-1347] Break apart ProcessBundleHandler to use service locator pattern based upon URNs. This cleans up ProcessBundleHandler and allows for separate improvements of the various PTransform

[GitHub] beam pull request #3374: Programmatically create Beam view.

GitHub user jasonkuster opened a pull request: https://github.com/apache/beam/pull/3374 Programmatically create Beam view. Signed-off-by: Jason Kuster Be sure to do all of the following to help us incorporate your contribution quickly and

[jira] [Updated] (BEAM-2287) UDAF support

[ https://issues.apache.org/jira/browse/BEAM-2287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-2287: - Description: Create an aggregation wrapper, to accept UDAF functions, with {{AggregateFunctionImpl}};

[jira] [Updated] (BEAM-2287) UDAF support

[ https://issues.apache.org/jira/browse/BEAM-2287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin updated BEAM-2287: - Summary: UDAF support (was: abstract aggregation holder for UDAF support) > UDAF support > >

[GitHub] beam pull request #3373: Populate PBegin input when decoding from Runner API

GitHub user charlesccychen opened a pull request: https://github.com/apache/beam/pull/3373 Populate PBegin input when decoding from Runner API 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-2451) writeProtos() should allow a user to specify message attributes

[ https://issues.apache.org/jira/browse/BEAM-2451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16051167#comment-16051167 ] Keith Berkoben commented on BEAM-2451: -- After some digging into the code, it seems that the timestamp

[jira] [Created] (BEAM-2453) The DirectRunner should exercise all parts of a CombineFn

Thomas Groh created BEAM-2453: - Summary: The DirectRunner should exercise all parts of a CombineFn Key: BEAM-2453 URL: https://issues.apache.org/jira/browse/BEAM-2453 Project: Beam Issue Type:

[jira] [Commented] (BEAM-2446) restrict scope of BeamSqlEnv in dsl query

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

[GitHub] beam pull request #3372: [BEAM-2446] restrict scope of BeamSqlEnv in dsl que...

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/3372 [BEAM-2446] restrict scope of BeamSqlEnv in dsl query R: @xumingming @takidau You can merge this pull request into a Git repository by running: $ git pull https://github.com/XuMingmin/beam

[jira] [Commented] (BEAM-2452) Update filter/project/aggregation tests with BeamSql

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

[GitHub] beam pull request #3371: [BEAM-2452] Update filter/project/aggregation tests...

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/3371 [BEAM-2452] Update filter/project/aggregation tests with BeamSql R: @xumingming @takidau You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (BEAM-2452) Update filter/project/aggregation tests with BeamSql

Xu Mingmin created BEAM-2452: Summary: Update filter/project/aggregation tests with BeamSql Key: BEAM-2452 URL: https://issues.apache.org/jira/browse/BEAM-2452 Project: Beam Issue Type: Test

[GitHub] beam pull request #3370: Introduce pending bundles and RootBundleProvider in...

GitHub user charlesccychen opened a pull request: https://github.com/apache/beam/pull/3370 Introduce pending bundles and RootBundleProvider in DirectRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[jira] [Commented] (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:comment-tabpanel=16051082#comment-16051082 ] ASF GitHub Bot commented on BEAM-2444: -- Github user asfgit closed the pull request at:

[2/2] beam git commit: [BEAM-2444] This closes #3365

[BEAM-2444] This closes #3365 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2e925340 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2e925340 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2e925340 Branch:

[GitHub] beam pull request #3365: [BEAM-2444] BeamSql: use java standard exception

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3365 --- 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-2444] BeamSql: use java standard exception

Repository: beam Updated Branches: refs/heads/DSL_SQL 07fda7c2d -> 2e9253401 [BEAM-2444] BeamSql: use java standard exception Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/83e6c204 Tree:

[jira] [Created] (BEAM-2451) writeProtos() should allow a user to specify message attributes

Keith Berkoben created BEAM-2451: Summary: writeProtos() should allow a user to specify message attributes Key: BEAM-2451 URL: https://issues.apache.org/jira/browse/BEAM-2451 Project: Beam

[GitHub] beam pull request #3369: Use the appropriate context in CombineTest Coder

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/3369 Use the appropriate context in CombineTest Coder Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[jira] [Resolved] (BEAM-1585) Ability to add new file systems to beamFS in the python sdk

[ https://issues.apache.org/jira/browse/BEAM-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sourabh Bajaj resolved BEAM-1585. - Resolution: Fixed With the BeamPlugin system we can add additional filesystems and other plugins

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3370

See

[jira] [Assigned] (BEAM-766) Trigger AST should use @AutoValue

[ https://issues.apache.org/jira/browse/BEAM-766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Innocent reassigned BEAM-766: - Assignee: Innocent > Trigger AST should use @AutoValue > - > >

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4115

See

[jira] [Assigned] (BEAM-940) OnTimerInvokers: key the cache with a (Class, id) tuple or OnTimerMethod

[ https://issues.apache.org/jira/browse/BEAM-940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Innocent reassigned BEAM-940: - Assignee: Innocent > OnTimerInvokers: key the cache with a (Class, id) tuple or OnTimerMethod >

[jira] [Commented] (BEAM-765) TriggerStateMachine does not need to be separate from OnceTriggerStateMachine

[ https://issues.apache.org/jira/browse/BEAM-765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16050941#comment-16050941 ] Innocent commented on BEAM-765: --- Created a pull request for this. > TriggerStateMachine does not need to be

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3369

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #137

See Changes: [ccy] Migrate DirectRunner evaluators to use Beam state API -- [...truncated 2.64 MB...] 2017-06-15T18:34:41.387 [INFO] Downloaded:

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

See Changes: [ccy] Migrate DirectRunner evaluators to use Beam state API -- [...truncated 1.58 MB...] [javadoc]

[jira] [Commented] (BEAM-1348) Model the Fn Api

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

[GitHub] beam pull request #3366: [BEAM-1348] Mark Runner API like types declared wit...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3366 --- 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-1348] Mark Runner API like types declared within Fn API as deprecated.

Repository: beam Updated Branches: refs/heads/master 6fc70b35f -> 346a77fa8 [BEAM-1348] Mark Runner API like types declared within Fn API as deprecated. Add additional documentation. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit:

[2/2] beam git commit: [BEAM-1348] Mark Runner API like types declared within Fn API as deprecated.

[BEAM-1348] Mark Runner API like types declared within Fn API as deprecated. This closes #3366 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/346a77fa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/346a77fa Diff:

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

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

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

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

[1/2] beam git commit: Migrate DirectRunner evaluators to use Beam state API

Repository: beam Updated Branches: refs/heads/master 42c88f415 -> 6fc70b35f Migrate DirectRunner evaluators to use Beam state API Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/be09a162 Tree:

[GitHub] beam pull request #3362: [BEAM-1265] Migrate DirectRunner evaluators to use ...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3362 --- 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-1612) Support real Bundle in Flink runner

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

[GitHub] beam pull request #3368: [BEAM-1612] Support real Bundle in Flink runner

GitHub user JingsongLi opened a pull request: https://github.com/apache/beam/pull/3368 [BEAM-1612] Support real Bundle in Flink runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3368

See

[jira] [Commented] (BEAM-1282) DoFnTester should allow output() calls in start/finishBundle

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

[GitHub] beam pull request #3367: [BEAM-1282] Support @FinishBundle output in DoFnTes...

GitHub user rfevang opened a pull request: https://github.com/apache/beam/pull/3367 [BEAM-1282] Support @FinishBundle output in DoFnTester Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #136

See -- [...truncated 2.64 MB...] 2017-06-15T12:42:25.636 [INFO] Downloaded: https://repo.maven.apache.org/maven2/org/sonatype/gossip/gossip/1.8/gossip-1.8.pom

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

See -- [...truncated 1.51 MB...] 2017-06-15\T\12:32:38.926 [INFO] Downloaded:

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4112

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #3367

See

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

See Changes: [robertwb] [BEAM-1585] Add beam plugins as pipeline options -- [...truncated 1.57 MB...] [javadoc]

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #135

See Changes: [robertwb] [BEAM-1585] Add beam plugins as pipeline options -- [...truncated 2.64 MB...] 2017-06-15T10:14:38.938 [INFO] Downloaded: