[jira] [Comment Edited] (FLINK-8255) Key expressions on named row types do not work

2018-04-29 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16458179#comment-16458179 ] Sergey Nuyanzin edited comment on FLINK-8255 at 4/29/18 8:41 PM: ---

[jira] [Commented] (FLINK-8255) Key expressions on named row types do not work

2018-04-29 Thread Sergey Nuyanzin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16458179#comment-16458179 ] Sergey Nuyanzin commented on FLINK-8255: A little bit research shows that it is so

[jira] [Commented] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS

2018-04-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16458123#comment-16458123 ] ASF GitHub Bot commented on FLINK-9125: --- Github user GJL commented on a diff in the

[jira] [Commented] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS

2018-04-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16458122#comment-16458122 ] ASF GitHub Bot commented on FLINK-9125: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #5933: [FLINK-9125] MiniClusterResource should set CoreOp...

2018-04-29 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5933#discussion_r184892245 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -137,6 +142,7 @@ public int getWebUI

[GitHub] flink pull request #5933: [FLINK-9125] MiniClusterResource should set CoreOp...

2018-04-29 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5933#discussion_r184892264 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterResource.java --- @@ -149,6 +155,7 @@ public void before(

[jira] [Created] (FLINK-9273) Class cast exception

2018-04-29 Thread Bob Lau (JIRA)
Bob Lau created FLINK-9273: -- Summary: Class cast exception Key: FLINK-9273 URL: https://issues.apache.org/jira/browse/FLINK-9273 Project: Flink Issue Type: Bug Components: DataStream API,

[jira] [Commented] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

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

[GitHub] flink issue #5934: [FLINK-9269][state] fix concurrency problem when performi...

2018-04-29 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5934 Hi @StefanRRichter , I think I feel lost again... when I writing the comments for the serializer about why we don't duplicate it, I found a loophole there. In theory, even tough the serializer is j