[jira] [Commented] (FLINK-1466) Add InputFormat to read HCatalog tables

2017-04-01 Thread Prabhu Kasinathan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952560#comment-15952560 ] Prabhu Kasinathan commented on FLINK-1466: -- Hi [~fhueske], Can you please post s

[jira] [Commented] (FLINK-4676) Merge flink-batch-connectors and flink-streaming-connectors modules

2017-04-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952558#comment-15952558 ] ASF GitHub Bot commented on FLINK-4676: --- Github user prabhu1984 commented on the iss

[GitHub] flink issue #2897: [FLINK-4676] [connectors] Merge batch and streaming conne...

2017-04-01 Thread prabhu1984
Github user prabhu1984 commented on the issue: https://github.com/apache/flink/pull/2897 Hi @fhueske, Can you please post some simple example on how to read a Hive table on flink through flink-hcatalog connector? Thanks Prabhu --- If your project is set u

[jira] [Commented] (FLINK-6239) Sharing of State Across Operators

2017-04-01 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952466#comment-15952466 ] Elias Levy commented on FLINK-6239: --- If sharing state across operators is not feasible,

[jira] [Created] (FLINK-6243) Continuous Joins: True Sliding Window Joins

2017-04-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-6243: - Summary: Continuous Joins: True Sliding Window Joins Key: FLINK-6243 URL: https://issues.apache.org/jira/browse/FLINK-6243 Project: Flink Issue Type: New Feature

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

2017-04-01 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3001 Thanks a lot for your work on this. I'll try to review this early next week :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2017-04-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952366#comment-15952366 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2017-04-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952344#comment-15952344 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tony810430 commented on the iss

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

2017-04-01 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/3001 Hi @tzulitai, I have finished implementing union state with `CheckpointedFunction` and `CheckpointedRestoring`. I also added some tests for handling the union state and migration path

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration

2017-04-01 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952328#comment-15952328 ] Elias Levy commented on FLINK-3089: --- I gather that {{TimelyFlatMapFunction}} has been su

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

2017-04-01 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-6090: --- Summary: Add RetractionRule at the stage of decoration (was: Implement optimizer for retraction and t

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

2017-04-01 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-6090: --- Description: Implement optimizer for retraction: 1.Add RetractionRule at the stage of decoration,whi

[jira] [Commented] (FLINK-5564) User Defined Aggregates

2017-04-01 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952127#comment-15952127 ] Shaoxuan Wang commented on FLINK-5564: -- [~fhueske], implementing the entire codeGen i

[jira] [Created] (FLINK-6242) codeGen DataSet Goupingwindow Aggregates

2017-04-01 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6242: Summary: codeGen DataSet Goupingwindow Aggregates Key: FLINK-6242 URL: https://issues.apache.org/jira/browse/FLINK-6242 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction

2017-04-01 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6241: Summary: codeGen dataStream aggregates that use ProcessFunction Key: FLINK-6241 URL: https://issues.apache.org/jira/browse/FLINK-6241 Project: Flink Issue Ty

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

2017-04-01 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6240: Summary: codeGen dataStream aggregates that use AggregateAggFunction Key: FLINK-6240 URL: https://issues.apache.org/jira/browse/FLINK-6240 Project: Flink Is

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

2017-04-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952121#comment-15952121 ] ASF GitHub Bot commented on FLINK-6196: --- Github user KurtYoung commented on the issu

[GitHub] flink issue #3623: [FLINK-6196] [table] Support dynamic schema in Table Func...

2017-04-01 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3623 Looks good to me, @twalthr @fhueske can you also take a look? --- 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 no

[jira] [Commented] (FLINK-6218) Not able to access the rows in table after converting dataset to table after using registerdataset

2017-04-01 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952115#comment-15952115 ] Kurt Young commented on FLINK-6218: --- What's the type of DataSet when you trying to regis

[jira] [Created] (FLINK-6239) Sharing of State Across Operators

2017-04-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-6239: - Summary: Sharing of State Across Operators Key: FLINK-6239 URL: https://issues.apache.org/jira/browse/FLINK-6239 Project: Flink Issue Type: Improvement C

[jira] [Updated] (FLINK-6238) support OVER on batch SQL

2017-04-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6238: -- Description: The syntax of the {{OVER}} clause is: {code} OVER ( [PARTITION BY clause]

[jira] [Updated] (FLINK-6238) support OVER on batch SQL

2017-04-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6238: -- Description: The syntax of the {{OVER}} clause is: {code} OVER ( [PARTITION BY clause]

[jira] [Updated] (FLINK-6238) support OVER on batch SQL

2017-04-01 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-6238: -- Description: The syntax of the {{OVER}} clause is: {code} OVER ( [PARTITION BY clause]

[jira] [Commented] (FLINK-5989) Protobuf in akka needs to be shaded

2017-04-01 Thread Wenlong Lyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952094#comment-15952094 ] Wenlong Lyu commented on FLINK-5989: hi, [~rmetzger], have you ever try add a module l

[jira] [Created] (FLINK-6238) support OVER on batch SQL

2017-04-01 Thread godfrey he (JIRA)
godfrey he created FLINK-6238: - Summary: support OVER on batch SQL Key: FLINK-6238 URL: https://issues.apache.org/jira/browse/FLINK-6238 Project: Flink Issue Type: New Feature Component

[jira] [Comment Edited] (FLINK-5989) Protobuf in akka needs to be shaded

2017-04-01 Thread Wenlong Lyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952094#comment-15952094 ] Wenlong Lyu edited comment on FLINK-5989 at 4/1/17 7:10 AM: hi