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

[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5345: Assignee: Anton Solovev > IOManager failed to properly clean up temp file directory > -

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

[ https://issues.apache.org/jira/browse/FLINK-5345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15785037#comment-15785037 ] Anton Solovev commented on FLINK-5345: -- 1.1.3 RC3 ? I only see 1.1.3 RC2 on github br

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15785078#comment-15785078 ] Anton Solovev commented on FLINK-3849: -- Yes, one rule for pushing them together. But,

[jira] [Closed] (FLINK-5398) Exclude generated files in module flink-batch-connectors in license checking

[ https://issues.apache.org/jira/browse/FLINK-5398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5398. Resolution: Invalid We recently merged the {{flink-batch-connectors}} and {{flink-streaming-connect

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

[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15785348#comment-15785348 ] Martin Grotzke commented on FLINK-3154: --- As stated in Kryo's changelog, in 3.x the s

[GitHub] flink pull request #3052: Swap the pattern matching order

GitHub user Fokko opened a pull request: https://github.com/apache/flink/pull/3052 Swap the pattern matching order Swap the pattern matching order, because `EuclideanDistanceMetric extends SquaredEuclideanDistanceMetric extends DistanceMetric`, otherwise the EuclideanDistance canno

[GitHub] flink issue #3039: [FLINK-5280] Update TableSource to support nested data

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/3039 Hi @fhueske, @wuchong I've updated my PR according to your reviews. --- 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

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

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

[jira] [Commented] (FLINK-5360) Fix arguments names in WindowedStream

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

[GitHub] flink issue #3022: [FLINK-5360] Fix argument names in WindowedStream

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/3022 Hi @xhumanoid I've updated my PR according to your review. --- 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

[GitHub] flink issue #2885: [FLINK-1707] Affinity propagation

Github user joseprupi commented on the issue: https://github.com/apache/flink/pull/2885 That's the graph for the new commit. https://docs.google.com/drawings/d/1ixKiCFXXjCT6UMLHroGCbR1LbQpoXhgwBam3b2RrUhA/edit?usp=sharing The convergence criteria is that all messages

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

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

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

Xiaogang Shi created FLINK-5400: --- Summary: Add accessor to folding states in RuntimeContext Key: FLINK-5400 URL: https://issues.apache.org/jira/browse/FLINK-5400 Project: Flink Issue Type: Bug

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

[ https://issues.apache.org/jira/browse/FLINK-5400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi updated FLINK-5400: Description: Now {{RuntimeContext}} does not provide the accessors to folding states. Therefore user

[jira] [Updated] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown()

[ https://issues.apache.org/jira/browse/FLINK-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5391: -- Description: {code} private void checkNotShutdown() { checkState(!shutdown, "high availability services ar

[GitHub] flink pull request #3053: [FLINK-5400] Add accessor to folding states in Run...

GitHub user shixiaogang opened a pull request: https://github.com/apache/flink/pull/3053 [FLINK-5400] Add accessor to folding states in RuntimeContext - Add accessors in RuntimeContext and KeyedStateStore - Fix errors in the comments for reducing states in RuntimeContext and Key

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

[ https://issues.apache.org/jira/browse/FLINK-5400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786778#comment-15786778 ] ASF GitHub Bot commented on FLINK-5400: --- GitHub user shixiaogang opened a pull reque

[jira] [Commented] (FLINK-5398) Exclude generated files in module flink-batch-connectors in license checking

[ https://issues.apache.org/jira/browse/FLINK-5398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15786803#comment-15786803 ] Xiaogang Shi commented on FLINK-5398: - [~fhueske] Thanks for your explanation. It help