[jira] [Updated] (FLINK-5283) InputStream should be closed in RocksDBKeyedStateBackend#restoreOldSavepointKeyedState

2016-12-30 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5283: -- Description: {code} HashMap namedStates = InstantiationUtil.deserializeObject(restoreState.iterator(

[jira] [Comment Edited] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3

2016-12-30 Thread Martin Grotzke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787987#comment-15787987 ] Martin Grotzke edited comment on FLINK-3154 at 12/30/16 4:55 PM: ---

[jira] [Comment Edited] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3

2016-12-30 Thread Martin Grotzke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787987#comment-15787987 ] Martin Grotzke edited comment on FLINK-3154 at 12/30/16 4:54 PM: ---

[jira] [Commented] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3

2016-12-30 Thread Martin Grotzke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787987#comment-15787987 ] Martin Grotzke commented on FLINK-3154: --- Sounds good? Why not upgrade to kryo 4, wit

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

2016-12-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787847#comment-15787847 ] Stephan Ewen commented on FLINK-4920: - Assigned the issue to you. > Add a Scala Funct

[jira] [Commented] (FLINK-4758) Remove IOReadableWritable from classes where not needed

2016-12-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787846#comment-15787846 ] Stephan Ewen commented on FLINK-4758: - The classes should remove the interface where p

[jira] [Updated] (FLINK-4920) Add a Scala Function Gauge

2016-12-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4920: Assignee: Pattarawat Chormai > Add a Scala Function Gauge > -- > >

[jira] [Commented] (FLINK-4410) Report more information about operator checkpoints

2016-12-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787839#comment-15787839 ] ASF GitHub Bot commented on FLINK-4410: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3042: [FLINK-4410] Expose more fine grained checkpoint statisti...

2016-12-30 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3042 Okay, super. The 'time to triggering' is then `end_to_end_time - sync_time - async_time`? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3

2016-12-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787834#comment-15787834 ] Stephan Ewen commented on FLINK-3154: - This is good news, thanks! Since Flink has its

[jira] [Updated] (FLINK-5345) IOManager failed to properly clean up temp file directory

2016-12-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5345: Fix Version/s: 1.3.0 1.2.0 > IOManager failed to properly clean up temp file dire

[jira] [Commented] (FLINK-5345) IOManager failed to properly clean up temp file directory

2016-12-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787827#comment-15787827 ] Stephan Ewen commented on FLINK-5345: - I think Robert was referring to 1.1.4 RC3. The

[jira] [Updated] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2016-12-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5389: - Affects Version/s: 1.2.0 > Fails #testAnswerFailureWhenSavepointReadFails > --

[jira] [Updated] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2016-12-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5402: - Environment: macOS > Fails AkkaRpcServiceTest#testTerminationFuture >

[jira] [Updated] (FLINK-5401) Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics

2016-12-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5401: - Environment: macOS > Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics > ---

[jira] [Created] (FLINK-5402) Fails AkkaRpcServiceTest#testTerminationFuture

2016-12-30 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5402: Summary: Fails AkkaRpcServiceTest#testTerminationFuture Key: FLINK-5402 URL: https://issues.apache.org/jira/browse/FLINK-5402 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5401) Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics

2016-12-30 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5401: Summary: Fails ConnectionUtilsTest#testReturnLocalHostAddressUsingHeuristics Key: FLINK-5401 URL: https://issues.apache.org/jira/browse/FLINK-5401 Project: Flink

[jira] [Updated] (FLINK-5400) Add accessor to folding states in RuntimeContext

2016-12-30 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5400: - Assignee: Xiaogang Shi > Add accessor to folding states in RuntimeContext > --

[jira] [Commented] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

2016-12-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15787269#comment-15787269 ] ASF GitHub Bot commented on FLINK-5303: --- Github user chermenin commented on the issu

[GitHub] flink issue #2976: [FLINK-5303] [table] Support for SQL GROUPING SETS clause...

2016-12-30 Thread chermenin
Github user chermenin commented on the issue: https://github.com/apache/flink/pull/2976 I cleaned up my code and I will write tests for the plan at this weekend. --- 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 pro