[GitHub] flink pull request #4550: [FLINK-7461] Remove Backwards compatibility with <...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4550#discussion_r133663689 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateUtil.java --- @@ -49,27 +49,8 @@ public static long

[GitHub] flink pull request #4550: [FLINK-7461] Remove Backwards compatibility with <...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/4550#discussion_r133663458 --- Diff:

[jira] [Commented] (FLINK-7461) Remove Backwards compatibility for Flink 1.1 from Flink 1.4

[ https://issues.apache.org/jira/browse/FLINK-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130140#comment-16130140 ] ASF GitHub Bot commented on FLINK-7461: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-7444) Make external calls non-blocking

[ https://issues.apache.org/jira/browse/FLINK-7444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130133#comment-16130133 ] Till Rohrmann commented on FLINK-7444: -- I agree that the {{FatalErrorHandler}} should be executed

[GitHub] flink pull request #4557: [hotifx][streaming] Simplify state of TwoPhaseComm...

GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4557 [hotifx][streaming] Simplify state of TwoPhaseCommitSinkFunction This simplify state of `TwoPhaseCommitSinkFunction`, by dropping unnecessary complication. This change is already covered

[jira] [Commented] (FLINK-7461) Remove Backwards compatibility for Flink 1.1 from Flink 1.4

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

[GitHub] flink issue #4550: [FLINK-7461] Remove Backwards compatibility with <= Flink...

Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/4550 @StefanRRichter I am ok either with you removing it in this PR or with creating a separate PR, that e.g. I could work on. Just wanted to make sure we will not miss it. --- If your project is set

[GitHub] flink issue #4527: [FLINK-7409] [web] Make WebRuntimeMonitor reactive

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4527 Done @greghogan. --- 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

[jira] [Commented] (FLINK-7409) WebRuntimeMonitor blocks serving threads

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

[jira] [Commented] (FLINK-7423) Always reuse an instance to get elements from the inputFormat

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

[jira] [Commented] (FLINK-7461) Remove Backwards compatibility for Flink 1.1 from Flink 1.4

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

[GitHub] flink issue #4525: [FLINK-7423] Always reuse an instance to get elements fro...

Github user XuPingyong commented on the issue: https://github.com/apache/flink/pull/4525 Thanks @greghogan , `MergeIterator` is really a special case that it would be better to pass the returned object to `MutableObjectIterator#next` again. --- If your project is set up for it, you

[GitHub] flink issue #4550: [FLINK-7461] Remove Backwards compatibility with <= Flink...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4550 @dawidwys It is of course possible that I missed some dead code between. I can also just remove the parts you suggested for this PR. --- If your project is set up for it, you can reply to

[jira] [Comment Edited] (FLINK-3089) State API Should Support Data Expiration (State TTL)

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130083#comment-16130083 ] Stefan Richter edited comment on FLINK-3089 at 8/17/17 8:20 AM:

[jira] [Comment Edited] (FLINK-3089) State API Should Support Data Expiration (State TTL)

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130083#comment-16130083 ] Stefan Richter edited comment on FLINK-3089 at 8/17/17 8:20 AM:

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration (State TTL)

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130083#comment-16130083 ] Stefan Richter commented on FLINK-3089: --- [~sihuazhou] one thing that we would also need to discuss

[jira] [Updated] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-7465: --- Description: In this JIRA. use BloomFilter to implement counting functions. BloomFilter Algorithm

[jira] [Updated] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-7465: --- Description: In this JIRA. use BloomFilter to implement counting functions. BloomFilter Algorithm

[jira] [Updated] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-7465: --- Description: In this JIRA. use BloomFilter to implement counting functions. BloomFilter Algorithm

[jira] [Updated] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-7465: --- Attachment: bloomfilter.png > Add build-in BloomFilterCount on TableAPI >

[jira] [Created] (FLINK-7465) Add build-in BloomFilterCount on TableAPI

sunjincheng created FLINK-7465: -- Summary: Add build-in BloomFilterCount on TableAPI Key: FLINK-7465 URL: https://issues.apache.org/jira/browse/FLINK-7465 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-6465) support FIRST_VALUE on Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6465: --- Issue Type: Sub-task (was: New Feature) Parent: FLINK-7464 > support FIRST_VALUE on Table

[jira] [Created] (FLINK-7464) Add useful build-in Aggregate function into TabalAPI

sunjincheng created FLINK-7464: -- Summary: Add useful build-in Aggregate function into TabalAPI Key: FLINK-7464 URL: https://issues.apache.org/jira/browse/FLINK-7464 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7123) Support timesOrMore in CEP

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

[GitHub] flink issue #4523: [FLINK-7123] [cep] Support timesOrMore in CEP

Github user dianfu commented on the issue: https://github.com/apache/flink/pull/4523 @kl0u That's OK. Thanks a lot. :) --- 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

[jira] [Commented] (FLINK-7123) Support timesOrMore in CEP

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

[GitHub] flink issue #4523: [FLINK-7123] [cep] Support timesOrMore in CEP

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4523 @dianfu I will have a look tomorrow! Thanks for the work btw ;) --- 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

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16130020#comment-16130020 ] Evgeny Kincharov commented on FLINK-3133: - [~gaborhermann], [~aljoscha] thanks for Interest this.

[jira] [Comment Edited] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129080#comment-16129080 ] Xingcan Cui edited comment on FLINK-6233 at 8/17/17 6:05 AM: - Hi [~fhueske], I

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration (State TTL)

[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129974#comment-16129974 ] Sihua Zhou commented on FLINK-3089: --- [~ymost],all we have done it to modify the

<    1   2