[jira] [Commented] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer

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

[GitHub] flink issue #5889: [FLINK-9188] [kinesis] Generic mechanism to set ClientCon...

Github user tweise commented on the issue: https://github.com/apache/flink/pull/5889 R: @tzulitai ---

[jira] [Commented] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer

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

[GitHub] flink pull request #5889: [FLINK-9188] [kinesis] Generic mechanism to set Cl...

GitHub user tweise opened a pull request: https://github.com/apache/flink/pull/5889 [FLINK-9188] [kinesis] Generic mechanism to set ClientConfiguration properties. ## What is the purpose of the change This pull request enables setting properties on the AWS ClientConfigurati

[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&focusedCommentId=16447110#comment-16447110 ] Hai Zhou commented on FLINK-9231: - hi [~triones], This ticket is assigned to you and you c

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

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-9231: --- Assignee: Triones Deng > Enable SO_REUSEADDR on listen sockets >

[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&focusedCommentId=16447086#comment-16447086 ] Triones Deng commented on FLINK-9231: - [~yuzhih...@gmail.com] i am interested in this

[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&focusedCommentId=16447061#comment-16447061 ] ASF GitHub Bot commented on FLINK-6719: --- Github user zhangminglei commented on the i

[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&focusedCommentId=16447058#comment-16447058 ] mingleizhang commented on FLINK-9193: - Do we plan to support write to ORC or Parquet f

[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 sepa

[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&focusedCommentId=16446910#comment-16446910 ] Stephan Ewen commented on FLINK-9193: - I see that we want to get things started easy,

[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&focusedCommentId=16446907#comment-16446907 ] ASF GitHub Bot commented on FLINK-9216: --- Github user StephanEwen commented on the is

[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&focusedCommentId=16446905#comment-16446905 ] ASF GitHub Bot commented on FLINK-9223: --- Github user StephanEwen commented on the is

[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&focusedCommentId=16446904#comment-16446904 ] ASF GitHub Bot commented on FLINK-8715: --- Github user StephanEwen commented on a diff

[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 --- @@ -1

[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&focusedCommentId=16446901#comment-16446901 ] ASF GitHub Bot commented on FLINK-8715: --- Github user StephanEwen commented on the is

[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 Rep

[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&focusedCommentId=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 c

[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&focusedCommentId=16446805#comment-16446805 ] ASF GitHub Bot commented on FLINK-9230: --- Github user zhangminglei commented on the i

[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 >