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

[ https://issues.apache.org/jira/browse/FLINK-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6362: --- Assignee: mingleizhang > Unprotected access to registeredStates in > SharedStateRegistry#get

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

[ https://issues.apache.org/jira/browse/FLINK-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16053074#comment-16053074 ] mingleizhang commented on FLINK-6362: - Exactly. But the newest code seems fix the issu

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052877#comment-16052877 ] ASF GitHub Bot commented on FLINK-6783: --- Github user tedyu commented on a diff in th

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r122570865 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java --- @@ -161,6 +164,77 @@ public static LambdaExecutable check

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

[ https://issues.apache.org/jira/browse/FLINK-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052817#comment-16052817 ] Ted Yu commented on FLINK-6362: --- registeredStates is modified inside registerReference(). Wi

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

[ https://issues.apache.org/jira/browse/FLINK-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6359: -- Description: In this thread on mailing list: http://search-hadoop.com/m/Flink/VkLeQPmRa31hd5cw Gyula Fóra menti

[jira] [Updated] (FLINK-6422) Unreachable code in FileInputFormat#createInputSplits

[ https://issues.apache.org/jira/browse/FLINK-6422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6422: -- Description: Here is related code: {code} if (minNumSplits < 1) { throw new IllegalArgumentException("

[jira] [Updated] (FLINK-6389) Upgrade hbase dependency to 1.3.1

[ https://issues.apache.org/jira/browse/FLINK-6389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6389: -- Description: hbase 1.3.1 has been released. It fixes compatibility issue in 1.3.0 release, among other bug fixes

[jira] [Updated] (FLINK-6838) RescalingITCase fails in master branch

[ https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6838: -- Description: {code} Tests in error: RescalingITCase.testSavepointRescalingInKeyedState[1] » JobExecution Job

[jira] [Updated] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6493: -- Description: {code} && ((partitionStateSerializer == null && ((Snapshot) obj).getPartitionStateSerializ

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052793#comment-16052793 ] ASF GitHub Bot commented on FLINK-6783: --- Github user dawidwys closed the pull reques

[GitHub] flink pull request #4089: [FLINK-6783] Removed lamba indices for abstract cl...

Github user dawidwys closed the pull request at: https://github.com/apache/flink/pull/4089 --- 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 if the feature is en

[jira] [Commented] (FLINK-6933) Refactor NFACompiler to reduce code duplication

[ https://issues.apache.org/jira/browse/FLINK-6933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16052768#comment-16052768 ] ASF GitHub Bot commented on FLINK-6933: --- Github user dawidwys commented on a diff in

[jira] [Commented] (FLINK-6904) Support for quantifier range to CEP's pattern API

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

[GitHub] flink pull request #4132: [FLINK-6933] [cep] Refactor NFACompiler to reduce ...

Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/4132#discussion_r122564524 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -348,7 +348,7 @@ long getWindowTime() {

[GitHub] flink issue #4121: [FLINK-6904] [cep] Support for quantifier range to CEP's ...

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4121 Hi @dianfu, sorry for late reply. I was on short vacations. The updated PR looks good! I agree though with @kl0u that changes from #4132 should be covered by this PR. --- If your project is set u