[jira] [Updated] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition

2017-04-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6162: -- Affects Version/s: 1.3.0 > Fix bug in ByteArrayOutputStreamWithPos#setPosition >

[jira] [Closed] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition

2017-04-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6162. - Resolution: Fixed Fixed in af34e5bd0bc8bf93c78b8bf37033ee660e7913be > Fix bug in

[jira] [Updated] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition

2017-04-07 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-6162: -- Fix Version/s: 1.3.0 > Fix bug in ByteArrayOutputStreamWithPos#setPosition >

[GitHub] flink pull request #3595: [FLINK-6162]Fix bug in ByteArrayOutputStreamWithPo...

2017-04-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3595 --- 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] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961580#comment-15961580 ] ASF GitHub Bot commented on FLINK-6162: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961495#comment-15961495 ] Fabian Hueske commented on FLINK-6233: -- I think we only need to update previously emitted results,

[jira] [Created] (FLINK-6281) Create TableSink for JDBC

2017-04-07 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6281: - Summary: Create TableSink for JDBC Key: FLINK-6281 URL: https://issues.apache.org/jira/browse/FLINK-6281 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961480#comment-15961480 ] ASF GitHub Bot commented on FLINK-5256: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3673: [FLINK-5256] Extend DataSetSingleRowJoin to support Left ...

2017-04-07 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3673 Thanks for working on this @DmytroShkvyra. I'll be on vacation next week but will review your PR when I am back. Thanks, Fabian --- If your project is set up for it, you can reply to this

[jira] [Closed] (FLINK-5622) Support tumbling window on batch tables in the SQL API

2017-04-07 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai closed FLINK-5622. - Resolution: Duplicate > Support tumbling window on batch tables in the SQL API >

[jira] [Commented] (FLINK-5622) Support tumbling window on batch tables in the SQL API

2017-04-07 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961476#comment-15961476 ] Haohui Mai commented on FLINK-5622: --- I think so. Thanks for the reminder. I'll close this jira. >

[jira] [Commented] (FLINK-5859) support partition pruning on Table API & SQL

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961472#comment-15961472 ] Fabian Hueske commented on FLINK-5859: -- Hi [~godfreyhe], FilterableTableSource has been merged to

[jira] [Commented] (FLINK-5622) Support tumbling window on batch tables in the SQL API

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961469#comment-15961469 ] Fabian Hueske commented on FLINK-5622: -- Hi [~wheat9], I think this is a duplicate of FLINK-6261 and

[jira] [Closed] (FLINK-3851) Add interface to register external catalogs in the TableEnvironment

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3851. Resolution: Duplicate Duplicate of FLINK-5570 > Add interface to register external catalogs in the

[jira] [Updated] (FLINK-6204) Update all OVER window ProcessFunction implementations to use the SortedQueueState

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6204: - Issue Type: Improvement (was: Bug) > Update all OVER window ProcessFunction implementations to

[jira] [Assigned] (FLINK-6225) Support Row Stream for CassandraSink

2017-04-07 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-6225: - Assignee: Haohui Mai > Support Row Stream for CassandraSink >

[jira] [Closed] (FLINK-6279) the digest of VolcanoRuleMatch matched different table sources with same field names may be same

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6279. Resolution: Fixed Fix Version/s: 1.3.0 Fixed with 697cc96106846547ff856aa5e478fee037ffde1a

[jira] [Commented] (FLINK-6279) the digest of VolcanoRuleMatch matched different table sources with same field names may be same

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961452#comment-15961452 ] ASF GitHub Bot commented on FLINK-6279: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3699: [FLINK-6279] [table] fix bug: the digest of Volcan...

2017-04-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3699 --- 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

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110481685 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -0,0 +1,167 @@ +/* +

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110476516 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110483259 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SortAggFunction.scala --- @@ -0,0 +1,166 @@ +/*

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110479361 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -0,0 +1,167 @@ +/* +

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110480378 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala --- @@ -0,0 +1,139

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110477811 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -0,0 +1,167 @@ +/* +

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110478103 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -0,0 +1,167 @@ +/* +

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110476920 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SortAggFunction.scala --- @@ -0,0 +1,166 @@ +/*

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110482967 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala --- @@ -0,0 +1,139

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110477127 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamSortRule.scala --- @@ -0,0 +1,67 @@ +/*

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110480674 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala --- @@ -0,0 +1,139

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110479650 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110481364 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala --- @@ -0,0 +1,139

[jira] [Commented] (FLINK-6162) Fix bug in ByteArrayOutputStreamWithPos#setPosition

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961379#comment-15961379 ] ASF GitHub Bot commented on FLINK-6162: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3595: [FLINK-6162]Fix bug in ByteArrayOutputStreamWithPos#setPo...

2017-04-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3595 @wenlong88 thanks for the contribution (and the ping)! Merging ... --- 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

[jira] [Commented] (FLINK-6279) the digest of VolcanoRuleMatch matched different table sources with same field names may be same

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961333#comment-15961333 ] ASF GitHub Bot commented on FLINK-6279: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3699: [FLINK-6279] [table] fix bug: the digest of VolcanoRuleMa...

2017-04-07 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3699 Hi @godfreyhe, thanks for the fix! Will merge this PR. --- 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

[jira] [Commented] (FLINK-6280) Allow logging with Java flags

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961174#comment-15961174 ] ASF GitHub Bot commented on FLINK-6280: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #3701: [FLINK-6280] [scripts] Allow logging with Java fla...

2017-04-07 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3701 [FLINK-6280] [scripts] Allow logging with Java flags Evaluate user-defined Java options immediately before starting services and rotate all log files. You can merge this pull request into a Git

[jira] [Created] (FLINK-6280) Allow logging with Java flags

2017-04-07 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6280: - Summary: Allow logging with Java flags Key: FLINK-6280 URL: https://issues.apache.org/jira/browse/FLINK-6280 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-6104) Resource leak in ListViaRangeSpeedMiniBenchmark

2017-04-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6104: -- Description: {code} final WriteOptions write_options = new WriteOptions() .setSync(false)

[jira] [Commented] (FLINK-4540) Detached job execution may prevent cluster shutdown

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961070#comment-15961070 ] ASF GitHub Bot commented on FLINK-4540: --- Github user MayerRoman closed the pull request at:

[GitHub] flink pull request #3287: [FLINK-4540][yarn] Delayed cluster startup until t...

2017-04-07 Thread MayerRoman
Github user MayerRoman closed the pull request at: https://github.com/apache/flink/pull/3287 --- 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] (FLINK-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark

2017-04-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961024#comment-15961024 ] Ted Yu commented on FLINK-6210: --- I agree all resources should be closed. > RocksDB instance should be

[jira] [Updated] (FLINK-6091) Implement and turn on the retraction for aggregates

2017-04-07 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-6091: --- Description: Implement functions for generating and consuming retract messages for different

[jira] [Updated] (FLINK-6091) Implement and turn on the retraction for aggregates

2017-04-07 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-6091: --- Summary: Implement and turn on the retraction for aggregates (was: Implement and turn on the

[jira] [Updated] (FLINK-6112) Support Calcite 1.12's new numerical functions

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6112: - Summary: Support Calcite 1.12's new numerical functions (was: Support new numerical functions

[jira] [Closed] (FLINK-5829) Bump Calcite version to 1.12 once available

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5829. Resolution: Done Fix Version/s: 1.3.0 > Bump Calcite version to 1.12 once available >

[jira] [Closed] (FLINK-5545) Remove FlinkAggregateExpandDistinctAggregatesRule when upgrading to Calcite 1.12

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5545. Resolution: Fixed Fix Version/s: 1.3.0 Fixed with 0038da41553908a427dd20be75838cccb48c6bcf

[jira] [Updated] (FLINK-6112) Support new numerical functions when calcite release 1.12

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6112: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-5829) > Support new

[GitHub] flink pull request #3695: [FLINK-5545] [table] Remove FlinkAggregateExpandDi...

2017-04-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3695 --- 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] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960888#comment-15960888 ] ASF GitHub Bot commented on FLINK-6012: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

2017-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6012. Resolution: Implemented Fix Version/s: 1.3.0 Implemented with

[GitHub] flink pull request #3693: [FLINK-6012] [table] Support WindowStart / WindowE...

2017-04-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3693 --- 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] (FLINK-5545) Remove FlinkAggregateExpandDistinctAggregatesRule when upgrading to Calcite 1.12

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960889#comment-15960889 ] ASF GitHub Bot commented on FLINK-5545: --- Github user asfgit closed the pull request at:

[GitHub] flink issue #3700: Backbone implementation for supporting sort. Implementati...

2017-04-07 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3700 I just realized that the commit does not have the proper name/number --- 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

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r110396436 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -0,0 +1,167 @@ +/* +

[GitHub] flink issue #3700: Backbone implementation for supporting sort. Implementati...

2017-04-07 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3700 @fhueske @shijinkui @hongyuhong @stefanobortoli @sunjincheng121 @twalthr I have created a first implementation for supporting logical sort. As per the discussion on the JIRA issue the

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

2017-04-07 Thread rtudoran
GitHub user rtudoran opened a pull request: https://github.com/apache/flink/pull/3700 Backbone implementation for supporting sort. Implementation includes util functions, sort aggregations (without retraction), rule and sort cases identification Thanks for contributing

[jira] [Commented] (FLINK-6279) the digest of VolcanoRuleMatch matched different table sources with same field names may be same

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960809#comment-15960809 ] ASF GitHub Bot commented on FLINK-6279: --- GitHub user godfreyhe opened a pull request:

[GitHub] flink pull request #3699: [FLINK-6279] [table] fix bug: the digest of Volcan...

2017-04-07 Thread godfreyhe
GitHub user godfreyhe opened a pull request: https://github.com/apache/flink/pull/3699 [FLINK-6279] [table] fix bug: the digest of VolcanoRuleMatch matched … toString of TableSourceScan should contain table name and result of explainSource to distinguish the difference of table

[jira] [Created] (FLINK-6279) the digest of VolcanoRuleMatch matched different table sources with same field names may be same

2017-04-07 Thread godfrey he (JIRA)
godfrey he created FLINK-6279: - Summary: the digest of VolcanoRuleMatch matched different table sources with same field names may be same Key: FLINK-6279 URL: https://issues.apache.org/jira/browse/FLINK-6279

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960760#comment-15960760 ] ASF GitHub Bot commented on FLINK-2184: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-6208) Implement skip till next match strategy

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960759#comment-15960759 ] ASF GitHub Bot commented on FLINK-6208: --- GitHub user dawidwys opened a pull request:

[GitHub] flink issue #3110: [FLINK-2184] Cannot get last element with maxBy/minBy.

2017-04-07 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3110 Thanks @gallenvara, the changes look good to me but we would also need a few tests. @aljoscha, what do you think about this change? Should we add it to be consistent with the Java API or do

[GitHub] flink pull request #3698: [FLINK-6208] Implement skip till next match strate...

2017-04-07 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3698 [FLINK-6208] Implement skip till next match strategy Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110379778 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -382,7 +381,10 @@ object

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960724#comment-15960724 ] ASF GitHub Bot commented on FLINK-6196: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960728#comment-15960728 ] ASF GitHub Bot commented on FLINK-6196: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960723#comment-15960723 ] ASF GitHub Bot commented on FLINK-6196: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110381407 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/DeferredTypeFlinkTableFunction.scala --- @@ -40,6 +43,10 @@ class

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960722#comment-15960722 ] ASF GitHub Bot commented on FLINK-6196: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960725#comment-15960725 ] ASF GitHub Bot commented on FLINK-6196: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110379996 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/DeferredTypeFlinkTableFunction.scala --- @@ -40,6 +43,10 @@ class

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110381497 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/UserDefinedTableFunctions.scala --- @@ -232,7 +244,8 @@ class

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960726#comment-15960726 ] ASF GitHub Bot commented on FLINK-6196: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960727#comment-15960727 ] ASF GitHub Bot commented on FLINK-6196: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110378068 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -382,7 +381,10 @@ object

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110379666 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala --- @@ -135,8 +135,11 @@ abstract class

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r110377050 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala --- @@ -135,8 +135,11 @@ abstract class

[GitHub] flink issue #3632: [FLINK-6176] [scripts] Add JARs to CLASSPATH deterministi...

2017-04-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3632 Updated for YARN @StephanEwen @EronWright --- 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

[jira] [Commented] (FLINK-6176) Add JARs to CLASSPATH deterministically

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960705#comment-15960705 ] ASF GitHub Bot commented on FLINK-6176: --- Github user greghogan commented on the issue:

[jira] [Commented] (FLINK-5545) Remove FlinkAggregateExpandDistinctAggregatesRule when upgrading to Calcite 1.12

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960670#comment-15960670 ] ASF GitHub Bot commented on FLINK-5545: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3695: [FLINK-5545] [table] Remove FlinkAggregateExpandDistinctA...

2017-04-07 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3695 merging --- 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

[jira] [Commented] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960634#comment-15960634 ] ASF GitHub Bot commented on FLINK-6012: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960632#comment-15960632 ] ASF GitHub Bot commented on FLINK-6012: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960633#comment-15960633 ] ASF GitHub Bot commented on FLINK-6012: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960636#comment-15960636 ] ASF GitHub Bot commented on FLINK-6012: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960637#comment-15960637 ] ASF GitHub Bot commented on FLINK-6012: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-6012) Support WindowStart / WindowEnd functions in streaming SQL

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960635#comment-15960635 ] ASF GitHub Bot commented on FLINK-6012: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3693: [FLINK-6012] [table] Support WindowStart / WindowE...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3693#discussion_r110361333 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala --- @@ -0,0 +1,117 @@ +/*

[GitHub] flink pull request #3693: [FLINK-6012] [table] Support WindowStart / WindowE...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3693#discussion_r110362631 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala --- @@ -0,0 +1,117 @@ +/*

[GitHub] flink pull request #3693: [FLINK-6012] [table] Support WindowStart / WindowE...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3693#discussion_r110362433 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala --- @@ -0,0 +1,117 @@ +/*

[GitHub] flink pull request #3693: [FLINK-6012] [table] Support WindowStart / WindowE...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3693#discussion_r110361425 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala --- @@ -0,0 +1,117 @@ +/*

[GitHub] flink pull request #3693: [FLINK-6012] [table] Support WindowStart / WindowE...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3693#discussion_r110360562 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala --- @@ -0,0 +1,117 @@ +/*

[GitHub] flink pull request #3693: [FLINK-6012] [table] Support WindowStart / WindowE...

2017-04-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3693#discussion_r110361292 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala --- @@ -0,0 +1,117 @@ +/*

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960614#comment-15960614 ] ASF GitHub Bot commented on FLINK-6257: --- GitHub user sunjincheng121 opened a pull request:

[GitHub] flink pull request #3697: [FLINK-6257][table]Optimize test cases

2017-04-07 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/3697 [FLINK-6257][table]Optimize test cases Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your

[jira] [Commented] (FLINK-6090) Add RetractionRule at the stage of decoration

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960585#comment-15960585 ] ASF GitHub Bot commented on FLINK-6090: --- GitHub user hequn8128 opened a pull request:

[GitHub] flink pull request #3696: [FLINK-6090] [table] Add RetractionRule at the sta...

2017-04-07 Thread hequn8128
GitHub user hequn8128 opened a pull request: https://github.com/apache/flink/pull/3696 [FLINK-6090] [table] Add RetractionRule at the stage of decoration Add RetractionRules at the stage of decoration. These rules can derive NeedRetraction property and accumulating mode. There are

[jira] [Commented] (FLINK-6240) codeGen dataStream aggregates that use AggregateAggFunction

2017-04-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15960578#comment-15960578 ] ASF GitHub Bot commented on FLINK-6240: --- Github user fhueske commented on a diff in the pull

  1   2   >