[jira] [Commented] (FLINK-5590) Create a proper internal state hierarchy

[ https://issues.apache.org/jira/browse/FLINK-5590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833260#comment-15833260 ] Xiaogang Shi commented on FLINK-5590: - [~StephanEwen], do you have any ideas of the solution? I think

[jira] [Assigned] (FLINK-5544) Implement Internal Timer Service in RocksDB

[ https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi reassigned FLINK-5544: --- Assignee: Xiaogang Shi > Implement Internal Timer Service in RocksDB >

[jira] [Comment Edited] (FLINK-4683) Add SlideRow row-windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833214#comment-15833214 ] sunjincheng edited comment on FLINK-4683 at 1/22/17 1:12 AM: - Hi,[~fhueske] I

[jira] [Commented] (FLINK-4683) Add SlideRow row-windows for batch tables

[ https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833214#comment-15833214 ] sunjincheng commented on FLINK-4683: Hi,[~fhueske] I picking up this issue of the reason, sliding-row

[jira] [Comment Edited] (FLINK-5525) Streaming Version of a Linear Regression model

[ https://issues.apache.org/jira/browse/FLINK-5525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833070#comment-15833070 ] Stavros Kontopoulos edited comment on FLINK-5525 at 1/21/17 5:38 PM: -

[jira] [Comment Edited] (FLINK-5525) Streaming Version of a Linear Regression model

[ https://issues.apache.org/jira/browse/FLINK-5525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833070#comment-15833070 ] Stavros Kontopoulos edited comment on FLINK-5525 at 1/21/17 5:38 PM: -

[jira] [Comment Edited] (FLINK-5525) Streaming Version of a Linear Regression model

[ https://issues.apache.org/jira/browse/FLINK-5525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833070#comment-15833070 ] Stavros Kontopoulos edited comment on FLINK-5525 at 1/21/17 5:37 PM: -

[jira] [Commented] (FLINK-5525) Streaming Version of a Linear Regression model

[ https://issues.apache.org/jira/browse/FLINK-5525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833070#comment-15833070 ] Stavros Kontopoulos commented on FLINK-5525: [~mtunqiue] Sure I agree there other algorithms

[jira] [Created] (FLINK-5602) Migration with RocksDB job led to NPE for next checkpoint

Ufuk Celebi created FLINK-5602: -- Summary: Migration with RocksDB job led to NPE for next checkpoint Key: FLINK-5602 URL: https://issues.apache.org/jira/browse/FLINK-5602 Project: Flink Issue

[jira] [Created] (FLINK-5601) Window operator does not checkpoint watermarks

Ufuk Celebi created FLINK-5601: -- Summary: Window operator does not checkpoint watermarks Key: FLINK-5601 URL: https://issues.apache.org/jira/browse/FLINK-5601 Project: Flink Issue Type:

[jira] [Created] (FLINK-5600) Improve error message when triggering savepoint without specified directory

Ufuk Celebi created FLINK-5600: -- Summary: Improve error message when triggering savepoint without specified directory Key: FLINK-5600 URL: https://issues.apache.org/jira/browse/FLINK-5600 Project: Flink

[jira] [Created] (FLINK-5599) State interface docs often refer to keyed state only

Ufuk Celebi created FLINK-5599: -- Summary: State interface docs often refer to keyed state only Key: FLINK-5599 URL: https://issues.apache.org/jira/browse/FLINK-5599 Project: Flink Issue Type:

[GitHub] flink issue #3149: FLINK-2168 Add HBaseTableSource

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3149 Hi @fhueske , Regarding to the field type serialization, I think maybe we can provide default deserialization for basic types (int,long,String...) if users do use the `Bytes.toBytes(...)`

[jira] [Commented] (FLINK-5584) Support Sliding-count row-window on streaming sql

[ https://issues.apache.org/jira/browse/FLINK-5584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833018#comment-15833018 ] ASF GitHub Bot commented on FLINK-5584: --- Github user wuchong commented on the issue:

[GitHub] flink issue #3175: [FLINK-5584]support sliding-count row-window on streaming...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3175 Hi @hongyuhong , don't worry about that. Very welcome to contribute to Flink. And please feel free to contact us if you have any question! --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833003#comment-15833003 ] Jark Wu commented on FLINK-5592: Hi [~tonycox], I think it maybe a problem in your code. The first level