[jira] [Commented] (BEAM-2018) refine expression of Calcite method/function

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

[GitHub] beam pull request #2656: [BEAM-2018] refine expression of Calcite method/fun...

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/2656 [BEAM-2018] refine expression of Calcite method/function In this PR, `BeamSQLFnExecutor` is introduced to replace `BeamSQLSpELExecutor`, as the executor of `SqlOperator` expressions.

[jira] [Resolved] (BEAM-2044) Downgrade HBaseIO to use the stable HBase client version (1.2.x)

[ https://issues.apache.org/jira/browse/BEAM-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-2044. Resolution: Fixed > Downgrade HBaseIO to use the stable HBase client version (1.2.x)

[jira] [Commented] (BEAM-2044) Downgrade HBaseIO to use the stable HBase client version (1.2.x)

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

[GitHub] beam pull request #2648: [BEAM-2044] Downgrade HBaseIO to use the stable HBa...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/2648 --- 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-2044] Downgrade HBaseIO to use the stable HBase client version (1.2.x)

Repository: beam Updated Branches: refs/heads/master be696fc20 -> 1dce98f07 [BEAM-2044] Downgrade HBaseIO to use the stable HBase client version (1.2.x) Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f5c0121d Tree:

[2/2] beam git commit: [BEAM-2044] This closes #2648

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

[jira] [Commented] (BEAM-1940) Add Capabilities info to "Built-in I/O Transforms" page

[ https://issues.apache.org/jira/browse/BEAM-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980269#comment-15980269 ] Aviem Zur commented on BEAM-1940: - This may be a bit much for the table in

[jira] [Comment Edited] (BEAM-1940) Add Capabilities info to "Built-in I/O Transforms" page

[ https://issues.apache.org/jira/browse/BEAM-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980269#comment-15980269 ] Aviem Zur edited comment on BEAM-1940 at 4/23/17 5:13 AM: -- This may be a bit much

[jira] [Comment Edited] (BEAM-2027) get error sometimes while running the same code using beam0.6

[ https://issues.apache.org/jira/browse/BEAM-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980259#comment-15980259 ] Aviem Zur edited comment on BEAM-2027 at 4/23/17 4:26 AM: -- No problem, you're

[jira] [Resolved] (BEAM-2027) get error sometimes while running the same code using beam0.6

[ https://issues.apache.org/jira/browse/BEAM-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur resolved BEAM-2027. - Resolution: Not A Bug Fix Version/s: Not applicable No problem! > get error sometimes while

[jira] [Commented] (BEAM-2027) get error sometimes while running the same code using beam0.6

[ https://issues.apache.org/jira/browse/BEAM-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15980245#comment-15980245 ] liyuntian commented on BEAM-2027: - my application's jar is a fat jar, I submit spark job on yarn-cluster

[GitHub] beam pull request #2655: Rename openWindows => windowsThatAreOpen

GitHub user wtanaka opened a pull request: https://github.com/apache/beam/pull/2655 Rename openWindows => windowsThatAreOpen to make its name have parallel structure with windowsThatShouldFire You can merge this pull request into a Git repository by running: $ git pull

[jira] [Assigned] (BEAM-2010) expose programming interface

[ https://issues.apache.org/jira/browse/BEAM-2010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin reassigned BEAM-2010: Assignee: (was: Xu Mingmin) > expose programming interface > > >

[jira] [Assigned] (BEAM-2008) aggregation functions support

[ https://issues.apache.org/jira/browse/BEAM-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Mingmin reassigned BEAM-2008: Assignee: (was: Xu Mingmin) > aggregation functions support > - > >

[jira] [Assigned] (BEAM-2055) Merge AfterWatermarkEarlyAndLate and FromEndOfWindow

[ https://issues.apache.org/jira/browse/BEAM-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wesley Tanaka reassigned BEAM-2055: --- Assignee: (was: Davor Bonaci) > Merge AfterWatermarkEarlyAndLate and FromEndOfWindow >

[jira] [Assigned] (BEAM-2055) Merge AfterWatermarkEarlyAndLate and FromEndOfWindow

[ https://issues.apache.org/jira/browse/BEAM-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wesley Tanaka reassigned BEAM-2055: --- Assignee: Davor Bonaci (was: Wesley Tanaka) > Merge AfterWatermarkEarlyAndLate and

[GitHub] beam pull request #2654: IntelliJ gives "ambiguous method call" error

GitHub user wtanaka opened a pull request: https://github.com/apache/beam/pull/2654 IntelliJ gives "ambiguous method call" error Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] beam pull request #2653: Add comments to Trigger.java

GitHub user wtanaka opened a pull request: https://github.com/apache/beam/pull/2653 Add comments to Trigger.java You can merge this pull request into a Git repository by running: $ git pull https://github.com/wtanaka/beam comments Alternatively you can review and apply these

[GitHub] beam pull request #2652: Remove unused private fields

GitHub user wtanaka opened a pull request: https://github.com/apache/beam/pull/2652 Remove unused private fields You can merge this pull request into a Git repository by running: $ git pull https://github.com/wtanaka/beam dev Alternatively you can review and apply these

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #2912

See

[jira] [Created] (BEAM-2055) Merge AfterWatermarkEarlyAndLate and FromEndOfWindow

Wesley Tanaka created BEAM-2055: --- Summary: Merge AfterWatermarkEarlyAndLate and FromEndOfWindow Key: BEAM-2055 URL: https://issues.apache.org/jira/browse/BEAM-2055 Project: Beam Issue Type:

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #1752

See

Jenkins build is still unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #2911

See

[jira] [Closed] (BEAM-1428) KinesisIO should comply with PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-1428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov closed BEAM-1428. -- Resolution: Fixed Fix Version/s: First stable release > KinesisIO should comply with

[jira] [Commented] (BEAM-1428) KinesisIO should comply with PTransform style guide

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

[GitHub] beam pull request #2620: [BEAM-1428] KinesisIO should comply with PTransform...

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

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

[1/2] beam git commit: [BEAM-1428] KinesisIO should comply with PTransform style guide

Repository: beam Updated Branches: refs/heads/master 4a8e5d5f9 -> be696fc20 [BEAM-1428] KinesisIO should comply with PTransform style guide Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f420e62a Tree:

[jira] [Commented] (BEAM-2054) Upgrade dataflow.version to v1b3-rev196-1.22.0

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

[GitHub] beam pull request #2651: [BEAM-2054] Update pom.xml: upgrade dataflow.versio...

GitHub user drieber opened a pull request: https://github.com/apache/beam/pull/2651 [BEAM-2054] Update pom.xml: upgrade dataflow.version to v1b3-rev196-1.22.0 Upgrade dataflow.version to v1b3-rev196-1.22.0 Be sure to do all of the following to help us incorporate your

[jira] [Created] (BEAM-2054) Upgrade dataflow.version to v1b3-rev196-1.22.0

David Rieber created BEAM-2054: -- Summary: Upgrade dataflow.version to v1b3-rev196-1.22.0 Key: BEAM-2054 URL: https://issues.apache.org/jira/browse/BEAM-2054 Project: Beam Issue Type: New

[GitHub] beam pull request #2650: Remove unnecessary semicolons

GitHub user wtanaka opened a pull request: https://github.com/apache/beam/pull/2650 Remove unnecessary semicolons 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] [Updated] (BEAM-1672) Accumulable MetricsContainers.

[ https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1672: Description: Make {{MetricsContainer}} accumulable. This can reduce duplication between runners and make

[jira] [Commented] (BEAM-1672) Accumulable MetricsContainers.

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

[GitHub] beam pull request #2649: [BEAM-1672] Accumulable MetricsContainers.

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2649 [BEAM-1672] Accumulable MetricsContainers. 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] [Updated] (BEAM-1672) Accumulable MetricsContainers.

[ https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1672: Description: Make {{MetricsContainer}} accumulable. This can reduce duplication between runners and make

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #2910

See

[jira] [Updated] (BEAM-1672) Reduce duplication in runners metrics implementations

[ https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1672: Description: Refactor metrics implementations to reduce duplication. For example: Making

[jira] [Updated] (BEAM-1672) Reduce duplication in runners metrics implementations

[ https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1672: Description: Refactor metrics implementations to reduce duplication. For example: Making

[jira] [Updated] (BEAM-1672) Reduce duplication in runners metrics implementations

[ https://issues.apache.org/jira/browse/BEAM-1672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-1672: Summary: Reduce duplication in runners metrics implementations (was: Extract interface MetricData) >

[jira] [Commented] (BEAM-2044) Downgrade HBaseIO to use the stable HBase client version (1.2.x)

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

[jira] [Updated] (BEAM-2044) Downgrade HBaseIO to use the stable HBase client version (1.2.x)

[ https://issues.apache.org/jira/browse/BEAM-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-2044: --- Description: We must follow the stable version of the client dependency for HBaseIO. (was: An

[jira] [Updated] (BEAM-2044) Downgrade HBaseIO to use the stable HBase client version (1.2.x)

[ https://issues.apache.org/jira/browse/BEAM-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-2044: --- Summary: Downgrade HBaseIO to use the stable HBase client version (1.2.x) (was: Upgrade HBaseIO to

[jira] [Comment Edited] (BEAM-2027) get error sometimes while running the same code using beam0.6

[ https://issues.apache.org/jira/browse/BEAM-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979797#comment-15979797 ] Aviem Zur edited comment on BEAM-2027 at 4/22/17 7:22 AM: -- {{local class

[jira] [Comment Edited] (BEAM-2027) get error sometimes while running the same code using beam0.6

[ https://issues.apache.org/jira/browse/BEAM-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979797#comment-15979797 ] Aviem Zur edited comment on BEAM-2027 at 4/22/17 7:21 AM: -- {{local class

[2/3] beam git commit: [BEAM-1899] Add JStormRunnerRegistrar and empty implementations of PipelineRunner, RunnerResult, PipelineOptions.

[BEAM-1899] Add JStormRunnerRegistrar and empty implementations of PipelineRunner, RunnerResult, PipelineOptions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/15ebaf0f Tree:

[1/3] beam git commit: [BEAM-1899] Start jstorm runner moduel in feature branch.

Repository: beam Updated Branches: refs/heads/jstorm-runner a8edbb81f -> f6a89b0fc [BEAM-1899] Start jstorm runner moduel in feature branch. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9d4de1b2 Tree:

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

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

[jira] [Commented] (BEAM-2027) get error sometimes while running the same code using beam0.6

[ https://issues.apache.org/jira/browse/BEAM-2027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979797#comment-15979797 ] Aviem Zur commented on BEAM-2027: - {{local class incompatible}} happens when trying to deserialize a Java