[jira] [Updated] (FLINK-23471) Try best to ensure all operators and state manager handle the checkpoint complete notification

[ https://issues.apache.org/jira/browse/FLINK-23471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23471: - Summary: Try best to ensure all operators and state manager handle the checkpoint complete notification

[jira] [Updated] (FLINK-23471) Try best to ensure all operators and state manager handle the checkpoint notification complete

[ https://issues.apache.org/jira/browse/FLINK-23471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23471: - Summary: Try best to ensure all operators and state manager handle the checkpoint notification complete

[jira] [Created] (FLINK-23471) Try best to ensure all operators and state manager handle the checkpoint notification

Yun Tang created FLINK-23471: Summary: Try best to ensure all operators and state manager handle the checkpoint notification Key: FLINK-23471 URL: https://issues.apache.org/jira/browse/FLINK-23471 Project

[jira] [Commented] (FLINK-23440) The "State. Backend" of "Flink-CONF.YAML" is inconsistent with the documentation

[ https://issues.apache.org/jira/browse/FLINK-23440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17385291#comment-17385291 ] Yun Tang commented on FLINK-23440: -- [~yang89520] would you like to take this ticket to

[jira] [Resolved] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23367. -- Resolution: Fixed Merged in master: c225a8c3757ed96417e721ae013165d51f463ec0 > testKeyGroupedInternal

[jira] [Comment Edited] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381745#comment-17381745 ] Yun Tang edited comment on FLINK-23367 at 7/16/21, 6:15 AM:

[jira] [Assigned] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23367: Assignee: Yun Tang > testKeyGroupedInternalPriorityQueue does not dispose > ChangelogDelegateEmb

[jira] [Commented] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381745#comment-17381745 ] Yun Tang commented on FLINK-23367: -- This failure is due to not close internal priority

[jira] [Updated] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23367: - Fix Version/s: 1.14.0 > testKeyGroupedInternalPriorityQueue does not dispose > ChangelogDelegateEmbedde

[jira] [Updated] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23367: - Priority: Blocker (was: Major) > testKeyGroupedInternalPriorityQueue does not dispose > ChangelogDeleg

[jira] [Commented] (FLINK-22528) Document latency tracking metrics for state accesses

[ https://issues.apache.org/jira/browse/FLINK-22528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381098#comment-17381098 ] Yun Tang commented on FLINK-22528: -- [~alpinegizmo], it seems that I did not fully under

[jira] [Updated] (FLINK-23312) Use -Dfast for building e2e tests on AZP

[ https://issues.apache.org/jira/browse/FLINK-23312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23312: - Fix Version/s: (was: 1.13.2) 1.13.3 > Use -Dfast for building e2e tests on AZP >

[jira] [Updated] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22545: - Fix Version/s: (was: 1.13.3) 1.13.2 > JVM crashes when runing > OperatorEventSen

[jira] [Commented] (FLINK-22722) Add Documentation for Kafka New Source

[ https://issues.apache.org/jira/browse/FLINK-22722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17380431#comment-17380431 ] Yun Tang commented on FLINK-22722: -- in release-1.13: ef21d506bebee0ac6466d4abe2f844ef7c

[jira] [Updated] (FLINK-22722) Add Documentation for Kafka New Source

[ https://issues.apache.org/jira/browse/FLINK-22722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22722: - Fix Version/s: 1.13.2 > Add Documentation for Kafka New Source > --

[jira] [Updated] (FLINK-23223) When flushAlways is enabled the subpartition may lose notification of data availability

[ https://issues.apache.org/jira/browse/FLINK-23223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23223: - Fix Version/s: (was: 1.13.3) 1.13.2 > When flushAlways is enabled the subpartitio

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22443: - Fix Version/s: (was: 1.13.3) 1.13.2 > can not be execute an extreme long sql unde

[jira] [Updated] (FLINK-23306) FlinkRelMdUniqueKeys causes exception when used with new Schema

[ https://issues.apache.org/jira/browse/FLINK-23306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23306: - Fix Version/s: (was: 1.13.3) 1.13.2 > FlinkRelMdUniqueKeys causes exception when

[jira] [Updated] (FLINK-23184) CompileException Assignment conversion not possible from type "int" to type "short"

[ https://issues.apache.org/jira/browse/FLINK-23184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23184: - Fix Version/s: (was: 1.13.3) 1.13.2 > CompileException Assignment conversion not

[jira] [Updated] (FLINK-23182) Connection leak in RMQSource

[ https://issues.apache.org/jira/browse/FLINK-23182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23182: - Fix Version/s: (was: 1.13.3) 1.13.2 > Connection leak in RMQSource > ---

[jira] [Updated] (FLINK-23270) Impove description of Regular Joins section

[ https://issues.apache.org/jira/browse/FLINK-23270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23270: - Fix Version/s: (was: 1.13.3) 1.13.2 > Impove description of Regular Joins section

[jira] [Updated] (FLINK-23248) SinkWriter is not closed when failing

[ https://issues.apache.org/jira/browse/FLINK-23248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23248: - Fix Version/s: (was: 1.13.3) 1.13.2 > SinkWriter is not closed when failing > ---

[jira] [Updated] (FLINK-23260) [DOCS]The link on page docs/libs/gelly/overview is failed and 404 is returned

[ https://issues.apache.org/jira/browse/FLINK-23260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23260: - Fix Version/s: (was: 1.13.3) 1.13.2 > [DOCS]The link on page docs/libs/gelly/over

[jira] [Updated] (FLINK-23259) [DOCS]The 'window' link on page docs/dev/datastream/operators/overview is failed and 404 is returned

[ https://issues.apache.org/jira/browse/FLINK-23259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23259: - Fix Version/s: (was: 1.13.3) 1.13.2 > [DOCS]The 'window' link on page docs/dev/da

[jira] [Updated] (FLINK-23226) Flink Chinese doc learn-flink/etl transformation.svg display issue

[ https://issues.apache.org/jira/browse/FLINK-23226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23226: - Fix Version/s: (was: 1.13.3) 1.13.2 > Flink Chinese doc learn-flink/etl transform

[jira] [Updated] (FLINK-22884) Select view columns fail when store metadata with hive

[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22884: - Fix Version/s: (was: 1.13.3) 1.13.2 > Select view columns fail when store metadat

[jira] [Updated] (FLINK-22528) Document latency tracking metrics for state accesses

[ https://issues.apache.org/jira/browse/FLINK-22528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22528: - Fix Version/s: (was: 1.13.3) 1.13.2 > Document latency tracking metrics for state

[jira] [Updated] (FLINK-23168) Catalog shouldn't merge properties for alter DB operation

[ https://issues.apache.org/jira/browse/FLINK-23168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23168: - Fix Version/s: (was: 1.13.3) 1.13.2 > Catalog shouldn't merge properties for alte

[jira] [Updated] (FLINK-23200) Correct grammatical mistakes in 'Table API' page of 'Table API & SQL'

[ https://issues.apache.org/jira/browse/FLINK-23200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23200: - Fix Version/s: (was: 1.13.3) 1.13.2 > Correct grammatical mistakes in 'Table API'

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22954: - Fix Version/s: (was: 1.13.2) 1.13.3 > Don't support consuming update and delete c

[jira] [Updated] (FLINK-23156) Change the reference of 'docs/dev/table/sql/queries'

[ https://issues.apache.org/jira/browse/FLINK-23156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23156: - Fix Version/s: (was: 1.13.3) 1.13.2 > Change the reference of 'docs/dev/table/sql

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22954: - Fix Version/s: (was: 1.13.3) 1.13.2 > Don't support consuming update and delete c

[jira] [Updated] (FLINK-22462) JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients.

[ https://issues.apache.org/jira/browse/FLINK-22462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22462: - Fix Version/s: (was: 1.13.3) 1.13.2 > JdbcExactlyOnceSinkE2eTest.testInsert faile

[jira] [Updated] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

[ https://issues.apache.org/jira/browse/FLINK-20888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-20888: - Fix Version/s: (was: 1.13.3) 1.13.2 > ContinuousFileReaderOperator should not clo

[jira] [Updated] (FLINK-18182) Upgrade AWS SDK in flink-connector-kinesis to include new region af-south-1

[ https://issues.apache.org/jira/browse/FLINK-18182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-18182: - Fix Version/s: (was: 1.13.3) 1.13.2 > Upgrade AWS SDK in flink-connector-kinesis

[jira] [Updated] (FLINK-22964) Connector-base exposes dependency to flink-core.

[ https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22964: - Fix Version/s: (was: 1.13.3) 1.13.2 > Connector-base exposes dependency to flink-

[jira] [Commented] (FLINK-23352) Collect Sink Operator Factory does not support to configure max bytes per batch

[ https://issues.apache.org/jira/browse/FLINK-23352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378986#comment-17378986 ] Yun Tang commented on FLINK-23352: -- [~TsReaper] Thanks for your reminder, I had correct

[jira] [Updated] (FLINK-23352) Collect Sink Operator Factory does not support to configure max bytes per batch

[ https://issues.apache.org/jira/browse/FLINK-23352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23352: - Description: Current {{CollectSinkOperatorFactory}} only supports max bytes per batch as 2MB. However, t

[jira] [Created] (FLINK-23352) Collect Sink Operator Factory does not support to configure max bytes per batch

Yun Tang created FLINK-23352: Summary: Collect Sink Operator Factory does not support to configure max bytes per batch Key: FLINK-23352 URL: https://issues.apache.org/jira/browse/FLINK-23352 Project: Flin

[jira] [Commented] (FLINK-23346) RocksDBStateBackend may core dump in flink_compactionfilterjni.cc

[ https://issues.apache.org/jira/browse/FLINK-23346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17378878#comment-17378878 ] Yun Tang commented on FLINK-23346: -- [~klion26] Thanks for your debugging. Would you ple

[jira] [Updated] (FLINK-23346) RocksDBStateBackend may core dump in flink_compactionfilterjni.cc

[ https://issues.apache.org/jira/browse/FLINK-23346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23346: - Description: The code in [flink_compactionfilte.cpp  |https://github.com/ververica/frocksdb/blob/49bc897

[jira] [Updated] (FLINK-23346) RocksDBStateBackend may core dump in flink_compactionfilterjni.cc

[ https://issues.apache.org/jira/browse/FLINK-23346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23346: - Description: The code in [flink_compactionfilte.cpp  |https://github.com/ververica/frocksdb/blob/49bc897

[jira] [Commented] (FLINK-23323) HAQueryableStateRocksDBBackendITCase failed due to heap OOM

[ https://issues.apache.org/jira/browse/FLINK-23323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377962#comment-17377962 ] Yun Tang commented on FLINK-23323: -- [~trohrmann] I don't think we have merged something

[jira] [Commented] (FLINK-23268) [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed and 404 is returned

[ https://issues.apache.org/jira/browse/FLINK-23268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376998#comment-17376998 ] Yun Tang commented on FLINK-23268: -- [~hapihu], already assigned this ticket to you. >

[jira] [Assigned] (FLINK-23268) [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed and 404 is returned

[ https://issues.apache.org/jira/browse/FLINK-23268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23268: Assignee: wuguihu > [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed

[jira] [Resolved] (FLINK-21804) Create and wire changelog writer with backend

[ https://issues.apache.org/jira/browse/FLINK-21804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-21804. -- Resolution: Fixed > Create and wire changelog writer with backend > --

[jira] [Commented] (FLINK-21804) Create and wire changelog writer with backend

[ https://issues.apache.org/jira/browse/FLINK-21804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376978#comment-17376978 ] Yun Tang commented on FLINK-21804: -- Merged master: e1ea4d960b191565a191c74e455e324fbb52

[jira] [Commented] (FLINK-23233) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376350#comment-17376350 ] Yun Tang commented on FLINK-23233: -- [~sewen], as the original developer of this feature

[jira] [Commented] (FLINK-22752) Add robust default state configuration to StateFun

[ https://issues.apache.org/jira/browse/FLINK-22752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17375162#comment-17375162 ] Yun Tang commented on FLINK-22752: -- [~sewen], you could refer to [SPINNING_DISK_OPTIMI

[jira] [Commented] (FLINK-22937) rocksdb cause jvm to crash

[ https://issues.apache.org/jira/browse/FLINK-22937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17374774#comment-17374774 ] Yun Tang commented on FLINK-22937: -- [~PiersSoCool] you could configure the ulimit of ta

[jira] [Commented] (FLINK-23198) An old interface method is used in this section of [Passing Options Factory to RocksDB].

[ https://issues.apache.org/jira/browse/FLINK-23198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17374728#comment-17374728 ] Yun Tang commented on FLINK-23198: -- [~yanchenyun], thanks for your update! You could go

[jira] [Updated] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22955: - Fix Version/s: (was: 1.13.2) 1.13.3 > lookup join filter push down result to mism

[jira] [Resolved] (FLINK-22528) Document latency tracking metrics for state accesses

[ https://issues.apache.org/jira/browse/FLINK-22528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-22528. -- Resolution: Fixed > Document latency tracking metrics for state accesses > ---

[jira] [Commented] (FLINK-22528) Document latency tracking metrics for state accesses

[ https://issues.apache.org/jira/browse/FLINK-22528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373295#comment-17373295 ] Yun Tang commented on FLINK-22528: -- Merged master: 9e3b09dd6271d4a8bfd6d7e4e9c24934c20a

[jira] [Updated] (FLINK-22528) Document latency tracking metrics for state accesses

[ https://issues.apache.org/jira/browse/FLINK-22528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22528: - Fix Version/s: 1.13.3 > Document latency tracking metrics for state accesses > -

[jira] [Commented] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373186#comment-17373186 ] Yun Tang commented on FLINK-18464: -- [~guxiangfly], in general, adding a performance tes

[jira] [Assigned] (FLINK-21504) State ownership: notify TMs about checkpoint subsumption

[ https://issues.apache.org/jira/browse/FLINK-21504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-21504: Assignee: Yun Tang > State ownership: notify TMs about checkpoint subsumption > -

[jira] [Assigned] (FLINK-23137) State ownership: disable discarding and ref counting state of ChangelogStateBackendHandle on JM

[ https://issues.apache.org/jira/browse/FLINK-23137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23137: Assignee: Zakelly Lan > State ownership: disable discarding and ref counting state of > Changelo

[jira] [Comment Edited] (FLINK-23198) An old interface method is used in this section of [Passing Options Factory to RocksDB].

[ https://issues.apache.org/jira/browse/FLINK-23198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373160#comment-17373160 ] Yun Tang edited comment on FLINK-23198 at 7/2/21, 3:04 AM: --- [~

[jira] [Commented] (FLINK-23198) An old interface method is used in this section of [Passing Options Factory to RocksDB].

[ https://issues.apache.org/jira/browse/FLINK-23198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373160#comment-17373160 ] Yun Tang commented on FLINK-23198: -- [~yanchenyun] You don't need to create another tick

[jira] [Assigned] (FLINK-23198) An old interface method is used in this section of [Passing Options Factory to RocksDB].

[ https://issues.apache.org/jira/browse/FLINK-23198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23198: Assignee: Carl > An old interface method is used in this section of [Passing Options Factory > t

[jira] [Closed] (FLINK-23211) An old interface method is used in this section of [Passing Options Factory to RocksDB].

[ https://issues.apache.org/jira/browse/FLINK-23211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-23211. Resolution: Duplicate > An old interface method is used in this section of [Passing Options Factory > to

[jira] [Commented] (FLINK-23185) REST API docs refer to removed rescaling endpoints

[ https://issues.apache.org/jira/browse/FLINK-23185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372654#comment-17372654 ] Yun Tang commented on FLINK-23185: -- I think this ticket deserived to be resolved, and w

[jira] [Commented] (FLINK-23198) An old interface method is used in this section of [Passing Options Factory to RocksDB].

[ https://issues.apache.org/jira/browse/FLINK-23198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372646#comment-17372646 ] Yun Tang commented on FLINK-23198: -- [~yanchenyun], I noticed that this documentation er

[jira] [Updated] (FLINK-18182) Upgrade AWS SDK in flink-connector-kinesis to include new region af-south-1

[ https://issues.apache.org/jira/browse/FLINK-18182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-18182: - Fix Version/s: (was: 1.13.2) 1.13.3 > Upgrade AWS SDK in flink-connector-kinesis

[jira] [Updated] (FLINK-22964) Connector-base exposes dependency to flink-core.

[ https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22964: - Fix Version/s: (was: 1.13.2) 1.13.3 > Connector-base exposes dependency to flink-

[jira] [Updated] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

[ https://issues.apache.org/jira/browse/FLINK-20888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-20888: - Fix Version/s: 1.13.3 > ContinuousFileReaderOperator should not close the output on close() > --

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22954: - Fix Version/s: 1.13.3 > Don't support consuming update and delete changes when use table function > tha

[jira] [Updated] (FLINK-23156) Change the reference of 'docs/dev/table/sql/queries'

[ https://issues.apache.org/jira/browse/FLINK-23156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23156: - Fix Version/s: (was: 1.13.2) 1.13.3 > Change the reference of 'docs/dev/table/sql

[jira] [Updated] (FLINK-22462) JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients.

[ https://issues.apache.org/jira/browse/FLINK-22462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22462: - Fix Version/s: (was: 1.13.2) 1.13.3 > JdbcExactlyOnceSinkE2eTest.testInsert faile

[jira] [Closed] (FLINK-18335) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs

[ https://issues.apache.org/jira/browse/FLINK-18335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-18335. Resolution: Fixed > NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs > ---

[jira] [Commented] (FLINK-18335) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs

[ https://issues.apache.org/jira/browse/FLINK-18335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371010#comment-17371010 ] Yun Tang commented on FLINK-18335: -- I think the failed case on March did not include th

[jira] [Assigned] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-22059: Assignee: xiaogang zhou > add a new option is rocksdb statebackend to enable job threads setting

[jira] [Commented] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371001#comment-17371001 ] Yun Tang commented on FLINK-22059: -- [~zhoujira86] Okay, re-assign this ticket to you.

[jira] [Commented] (FLINK-18335) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs

[ https://issues.apache.org/jira/browse/FLINK-18335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370568#comment-17370568 ] Yun Tang commented on FLINK-18335: -- I think we might better go to https://issues.apache

[jira] [Commented] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370567#comment-17370567 ] Yun Tang commented on FLINK-22059: -- [~zhoujira86], will you have time to submit your PR

[jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22059: - Fix Version/s: 1.14.0 > add a new option is rocksdb statebackend to enable job threads setting > ---

[jira] [Updated] (FLINK-22701) "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg

[ https://issues.apache.org/jira/browse/FLINK-22701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22701: - Fix Version/s: (was: 1.13.2) 1.13.3 > "bin/flink savepoint -d :savepointpath" can

[jira] [Updated] (FLINK-23041) Change local alignment timeout back to the global time out

[ https://issues.apache.org/jira/browse/FLINK-23041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23041: - Component/s: Runtime / Checkpointing > Change local alignment timeout back to the global time out >

[jira] [Commented] (FLINK-23044) fix typos in docs

[ https://issues.apache.org/jira/browse/FLINK-23044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369313#comment-17369313 ] Yun Tang commented on FLINK-23044: -- As discussed in https://github.com/apache/flink/pul

[jira] [Commented] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368746#comment-17368746 ] Yun Tang commented on FLINK-18464: -- [~guxiangfly] I think this might be a possible way.

[jira] [Commented] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368724#comment-17368724 ] Yun Tang commented on FLINK-18464: -- [~guxiangfly], namespace is allowed to change, whic

[jira] [Commented] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368703#comment-17368703 ] Yun Tang commented on FLINK-18464: -- I think the root cause is that {{getRuntimeContext(

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368673#comment-17368673 ] Yun Tang commented on FLINK-22890: -- Since this ticket is a blocker for relaseing 1.13.2

[jira] [Commented] (FLINK-23108) KafkaITCase.testCancelingEmptyTopic fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368667#comment-17368667 ] Yun Tang commented on FLINK-23108: -- [~Jack-Lee] Did you plan to fix this, and will your

[jira] [Commented] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366973#comment-17366973 ] Yun Tang commented on FLINK-22974: -- Merged in master: 55eb22bbd6b5fa3aadbf3ca0ec39370a7

[jira] [Resolved] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-22974. -- Resolution: Fixed > No execution checkpointing config desc in flink-conf.yaml > -

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22974: - Fix Version/s: 1.14.0 > No execution checkpointing config desc in flink-conf.yaml > ---

[jira] [Resolved] (FLINK-22678) Hide ChangelogStateBackend From Users

[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-22678. -- Resolution: Fixed > Hide ChangelogStateBackend From Users > -- >

[jira] [Commented] (FLINK-22678) Hide ChangelogStateBackend From Users

[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366956#comment-17366956 ] Yun Tang commented on FLINK-22678: -- Merged in master: 641c31e92fd8ff3702d2ac3510a63b065

[jira] [Updated] (FLINK-23050) Add Chinese version of documentation of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23050: - Fix Version/s: (was: 1.14.0) > Add Chinese version of documentation of unaligned checkpoint > --

[jira] [Resolved] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23012. -- Resolution: Fixed > Add v1.13 docs link in "Pick Docs Version" for master branch > ---

[jira] [Updated] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23012: - Fix Version/s: 1.14.0 > Add v1.13 docs link in "Pick Docs Version" for master branch > -

[jira] [Commented] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366363#comment-17366363 ] Yun Tang commented on FLINK-23012: -- Fixed by a hotfix: 73b3d10613d95a399f60c982f94a740b

[jira] [Assigned] (FLINK-23050) Add Chinese version of documentation of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23050: Assignee: Han Yin > Add Chinese version of documentation of unaligned checkpoint > --

[jira] [Created] (FLINK-23050) Add Chinese version of documentation of unaligned checkpoint

Yun Tang created FLINK-23050: Summary: Add Chinese version of documentation of unaligned checkpoint Key: FLINK-23050 URL: https://issues.apache.org/jira/browse/FLINK-23050 Project: Flink Issue T

[jira] [Updated] (FLINK-23018) State factories should handle extended state descriptors

[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23018: - Fix Version/s: 1.13.2 > State factories should handle extended state descriptors > -

[jira] [Resolved] (FLINK-23018) State factories should handle extended state descriptors

[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23018. -- Resolution: Fixed > State factories should handle extended state descriptors > ---

[jira] [Commented] (FLINK-23018) State factories should handle extended state descriptors

[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366351#comment-17366351 ] Yun Tang commented on FLINK-23018: -- Merged master: 73c103b6b117fe3996eedfb9d04e926f00c7

[jira] [Updated] (FLINK-23018) State factories should handle extended state descriptors

[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23018: - Description: Currently, {{TtlStateFactory}} and other state factories can only handle fixed type of sta

<    6   7   8   9   10   11   12   13   14   15   >