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

2017-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980310#comment-15980310 ] 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-22 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/3001 @tzulitai Thanks for your reviewing and nice comments. I have already addressed them. =) --- If your project is set up for it, you can reply to this email and have your reply appear on

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

2017-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980122#comment-15980122 ] ASF GitHub Bot commented on FLINK-6091: --- Github user hequn8128 commented on a diff i

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

2017-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980123#comment-15980123 ] ASF GitHub Bot commented on FLINK-6091: --- Github user hequn8128 commented on a diff i

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

2017-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980126#comment-15980126 ] ASF GitHub Bot commented on FLINK-6091: --- Github user hequn8128 commented on a diff i

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

2017-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980128#comment-15980128 ] ASF GitHub Bot commented on FLINK-6091: --- Github user hequn8128 commented on a diff i

[GitHub] flink pull request #3733: [FLINK-6091] [table] Implement and turn on retract...

2017-04-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/3733#discussion_r112817965 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupWindowAggregate.scala --- @@ -107,6 +107,

[GitHub] flink pull request #3733: [FLINK-6091] [table] Implement and turn on retract...

2017-04-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/3733#discussion_r112817995 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala --- @@ -84,16 +109,38 @@ class

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

2017-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980125#comment-15980125 ] ASF GitHub Bot commented on FLINK-6091: --- Github user hequn8128 commented on a diff i

[GitHub] flink pull request #3733: [FLINK-6091] [table] Implement and turn on retract...

2017-04-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/3733#discussion_r112817910 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/RetractionITCase.scala --- @@ -0,0 +1,310 @@ +/* + *

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

2017-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980127#comment-15980127 ] ASF GitHub Bot commented on FLINK-6091: --- Github user hequn8128 commented on a diff i

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

2017-04-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980124#comment-15980124 ] ASF GitHub Bot commented on FLINK-6091: --- Github user hequn8128 commented on a diff i

[GitHub] flink pull request #3733: [FLINK-6091] [table] Implement and turn on retract...

2017-04-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/3733#discussion_r112817968 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala --- @@ -129,11 +131,17 @@

[GitHub] flink pull request #3733: [FLINK-6091] [table] Implement and turn on retract...

2017-04-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/3733#discussion_r112818000 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala --- @@ -84,16 +109,38 @@ class

[GitHub] flink pull request #3733: [FLINK-6091] [table] Implement and turn on retract...

2017-04-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/3733#discussion_r112817984 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala --- @@ -68,12 +70,35 @@ class

[GitHub] flink pull request #3733: [FLINK-6091] [table] Implement and turn on retract...

2017-04-22 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/3733#discussion_r112818005 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/RetractionITCase.scala --- @@ -0,0 +1,310 @@ +/* + *

[jira] [Created] (FLINK-6362) Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount

2017-04-22 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6362: - Summary: Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount Key: FLINK-6362 URL: https://issues.apache.org/jira/browse/FLINK-6362 Project: Flink

[jira] [Created] (FLINK-6361) Finalize the AggregateFunction interface and refactoring built-in aggregates

2017-04-22 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6361: Summary: Finalize the AggregateFunction interface and refactoring built-in aggregates Key: FLINK-6361 URL: https://issues.apache.org/jira/browse/FLINK-6361 Project: F

[jira] [Created] (FLINK-6360) Failed to create assembly for Scala 2.11 due to tools/change-scala-version.sh not changing flink-gelly-examples_2.10

2017-04-22 Thread Jacek Laskowski (JIRA)
Jacek Laskowski created FLINK-6360: -- Summary: Failed to create assembly for Scala 2.11 due to tools/change-scala-version.sh not changing flink-gelly-examples_2.10 Key: FLINK-6360 URL: https://issues.apache.org/ji

[jira] [Commented] (FLINK-1743) Add multinomial logistic regression to machine learning library

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

[GitHub] flink issue #3428: [FLINK-1743] Add multinomial logistic regression to machi...

2017-04-22 Thread mtunique
Github user mtunique commented on the issue: https://github.com/apache/flink/pull/3428 @thvasilo After #3756 is merged, I will change 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 have

[jira] [Commented] (FLINK-2013) Create generalized linear model framework

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

[GitHub] flink issue #3756: [FLINK-2013] Create generalized linear model framework

2017-04-22 Thread mtunique
Github user mtunique commented on the issue: https://github.com/apache/flink/pull/3756 Split from #3428. --- 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

[jira] [Created] (FLINK-6359) Utilize Hierarchical Timing Wheels for performant timer

2017-04-22 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6359: - Summary: Utilize Hierarchical Timing Wheels for performant timer Key: FLINK-6359 URL: https://issues.apache.org/jira/browse/FLINK-6359 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-2013) Create generalized linear model framework

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

[GitHub] flink pull request #3756: [FLINK-2013] Create generalized linear model frame...

2017-04-22 Thread mtunique
GitHub user mtunique opened a pull request: https://github.com/apache/flink/pull/3756 [FLINK-2013] Create generalized linear model framework Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If yo

[GitHub] flink issue #3524: [FLINK-6014][checkpoint] Allow the registration of state ...

2017-04-22 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3524 Merged. @shixiaogang can you please close 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 have

[jira] [Commented] (FLINK-6014) Allow the registration of state objects in checkpoints

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

[jira] [Created] (FLINK-6358) Write job details for Gelly examples

2017-04-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6358: - Summary: Write job details for Gelly examples Key: FLINK-6358 URL: https://issues.apache.org/jira/browse/FLINK-6358 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6357) Parametertool get unrequested parameters

2017-04-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6357: - Summary: Parametertool get unrequested parameters Key: FLINK-6357 URL: https://issues.apache.org/jira/browse/FLINK-6357 Project: Flink Issue Type: Improvement

[GitHub] flink issue #3524: [FLINK-6014][checkpoint] Allow the registration of state ...

2017-04-22 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3524 Merging this. --- 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,

[jira] [Commented] (FLINK-6014) Allow the registration of state objects in checkpoints

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

[jira] [Commented] (FLINK-6319) Add timeout when shutting SystemProcessingTimeService down

2017-04-22 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979854#comment-15979854 ] mingleizhang commented on FLINK-6319: - +1 I have to say, the method of {code}shutdownN

[jira] [Resolved] (FLINK-5813) code generation for user-defined aggregate functions

2017-04-22 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang resolved FLINK-5813. -- Resolution: Fixed All required issues are solved. > code generation for user-defined aggregate