[jira] [Updated] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoguohao updated FLINK-11046: -- Description: When i'm using es6 sink to index into es, bulk process with some exception catched, and 

[jira] [Created] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

luoguohao created FLINK-11046: - Summary: ElasticSearch6Connector cause thread blocked when index failed with retry Key: FLINK-11046 URL: https://issues.apache.org/jira/browse/FLINK-11046 Project: Flink

[jira] [Commented] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state

[ https://issues.apache.org/jira/browse/FLINK-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706122#comment-16706122 ] ASF GitHub Bot commented on FLINK-9702: --- klion26 commented on issue #7210: [FLINK-9

[jira] [Updated] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state

[ https://issues.apache.org/jira/browse/FLINK-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9702: -- Labels: pull-request-available (was: ) > Improvement in (de)serialization of keys and values f

[GitHub] klion26 commented on issue #7210: [FLINK-9702][State Backends, Checkpointing] Improvement in (de)serialization of keys and values for RocksDB state

klion26 commented on issue #7210: [FLINK-9702][State Backends, Checkpointing] Improvement in (de)serialization of keys and values for RocksDB state URL: https://github.com/apache/flink/pull/7210#issuecomment-443486915 cc @StefanRRichter

[jira] [Commented] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state

[ https://issues.apache.org/jira/browse/FLINK-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706121#comment-16706121 ] ASF GitHub Bot commented on FLINK-9702: --- klion26 opened a new pull request #7210: [

[GitHub] klion26 opened a new pull request #7210: [FLINK-9702][State Backends, Checkpointing] Improvement in (de)serialization of keys and values for RocksDB state

klion26 opened a new pull request #7210: [FLINK-9702][State Backends, Checkpointing] Improvement in (de)serialization of keys and values for RocksDB state URL: https://github.com/apache/flink/pull/7210 ## What is the purpose of the change When Flink interacts with state in RocksDB,

[jira] [Updated] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

[ https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11045: Description: We should use {{UserCodeClassLoader}} when new a {{RuntimeUDFContext}}. i.e., Change

[jira] [Created] (FLINK-11045) UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor

Hequn Cheng created FLINK-11045: --- Summary: UserCodeClassLoader has not been set correctly for RuntimeUDFContext in CollectionExecutor Key: FLINK-11045 URL: https://issues.apache.org/jira/browse/FLINK-11045

[jira] [Commented] (FLINK-11039) LogicalExchange and HashPartitioner realization

[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706089#comment-16706089 ] Jark Wu commented on FLINK-11039: - Hi [~ambition], could you explain more about why we n

[jira] [Commented] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706058#comment-16706058 ] ASF GitHub Bot commented on FLINK-11010: lamber-ken commented on issue #7180: [F

[GitHub] lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-443472946 Thanks for review @walterdd. Yes, Ok, I'm very glad to. read more about [Calcite SqlFun

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706042#comment-16706042 ] ASF GitHub Bot commented on FLINK-7208: --- walterddr commented on a change in pull re

[GitHub] walterddr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

walterddr commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r238080462 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/func

[jira] [Commented] (FLINK-10457) Support SequenceFile for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16705743#comment-16705743 ] ASF GitHub Bot commented on FLINK-10457: jihyun commented on issue #6774: [FLINK

[GitHub] jihyun commented on issue #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink

jihyun commented on issue #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink URL: https://github.com/apache/flink/pull/6774#issuecomment-443413453 Hi @kl0u Thanks for your review. I've fixed code based your feedback. Please review whether the changes is okay. --

[jira] [Commented] (FLINK-11039) LogicalExchange and HashPartitioner realization

[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16705710#comment-16705710 ] ambition commented on FLINK-11039: -- pull request links [PR7202|https://github.com/apach