[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447086#comment-16447086 ] Triones Deng commented on FLINK-9231: - [~yuzhih...@gmail.com] i am interested in this issue.  >

[jira] [Assigned] (FLINK-8999) Ensure the job has an operator with operator state.

[ https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-8999: --- Assignee: mingleizhang > Ensure the job has an operator with operator state. >

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

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

[GitHub] flink issue #5887: [FLINK-6719] Add details about fault-tolerance of timers ...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5887 Looks good @bowenli86 ---

[jira] [Commented] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447058#comment-16447058 ] mingleizhang commented on FLINK-9193: - Do we plan to support write to ORC or Parquet format in future

[jira] [Created] (FLINK-9232) Add harness test for AggregationCodeGenerator

Rong Rong created FLINK-9232: Summary: Add harness test for AggregationCodeGenerator Key: FLINK-9232 URL: https://issues.apache.org/jira/browse/FLINK-9232 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8739: - Description: Possible optimizaitons: 1. Decouple distinct map and actual accumulator so that they can

[jira] [Updated] (FLINK-8739) Optimize runtime support for distinct filter

[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-8739: - Summary: Optimize runtime support for distinct filter (was: Optimize runtime support for distinct filter

[GitHub] flink issue #5848: Minor cleanup of Java example code for AsyncFunctions

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5848 Thanks a lot! Merging this in the next merge batch... ---

[jira] [Commented] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16446910#comment-16446910 ] Stephan Ewen commented on FLINK-9193: - I see that we want to get things started easy, but we should

[GitHub] flink issue #5878: [FLINK-9216][Streaming] Fix comparator violation

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5878 Good fix, thanks! Could you add a test for this? That is important to ensure this fix is not accidentally broken again in the future... ---

[jira] [Commented] (FLINK-9216) Fix comparator violation

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

[jira] [Commented] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd

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

[GitHub] flink issue #5882: [FLINK-9223] bufferConsumers should be closed in Spillabl...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5882 Looks good, thanks! Will merge this in the next batch... ---

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5885#discussion_r183214737 --- Diff: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

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

[GitHub] flink issue #5885: [FLINK-8715] Remove usage of StateDescriptor in state han...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5885 +1 to the general approach here Should add some tests (also checking why previous state migration tests did not catch this) ---

[jira] [Created] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

Ted Yu created FLINK-9231: - Summary: Enable SO_REUSEADDR on listen sockets Key: FLINK-9231 URL: https://issues.apache.org/jira/browse/FLINK-9231 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer

[ https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16446852#comment-16446852 ] ASF GitHub Bot commented on FLINK-9194: --- GitHub user yuqi1129 opened a pull request:

[GitHub] flink pull request #5888: [FLINK-9194] [histroyserver] Finished jobs are not...

GitHub user yuqi1129 opened a pull request: https://github.com/apache/flink/pull/5888 [FLINK-9194] [histroyserver] Finished jobs are not archived to Histor… ## What is the purpose of the change This is to solve the problem that history server can only show only one

[jira] [Commented] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

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

[GitHub] flink issue #5886: [FLINK-9230][test] harden WebFrontendITCase#testStopYarn(...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5886 Thanks @sihuazhou for catching this up! ---

[jira] [Updated] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

[ https://issues.apache.org/jira/browse/FLINK-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-9230: -- Priority: Critical (was: Major) > WebFrontendITCase.testStopYarn is unstable >

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16446659#comment-16446659 ] ASF GitHub Bot commented on FLINK-6719: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #5887: [FLINK-6719] Add details about fault-tolerance of ...

GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/5887 [FLINK-6719] Add details about fault-tolerance of timers to ProcessFunction docs ## What is the purpose of the change The fault-tolerance of timers is a frequently asked questions on the

[jira] [Updated] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6719: Fix Version/s: 1.5.1 1.6.0 > Add details about fault-tolerance of timers to

[jira] [Updated] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-6719: Affects Version/s: 1.5.0 > Add details about fault-tolerance of timers to ProcessFunction docs >

[jira] [Assigned] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-6719: --- Assignee: Bowen Li > Add details about fault-tolerance of timers to ProcessFunction docs >