[jira] [Resolved] (FLINK-24475) Remove no longer used NestedMap* classes

[ https://issues.apache.org/jira/browse/FLINK-24475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24475. -- Resolution: Fixed Merged in master: fc4f255644a64bb556b0dcefb165a9c772164c5b > Remove no longer used

[jira] [Updated] (FLINK-24783) Improve monitoring experience and usability of state backend

[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24783: - Summary: Improve monitoring experience and usability of state backend (was: Improve state backend

[jira] [Updated] (FLINK-24784) Enable state.backend.latency-track.state-name-as-variable by default

[ https://issues.apache.org/jira/browse/FLINK-24784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24784: - Description: This could help improve the usablility of state access latency. > Enable

[jira] [Updated] (FLINK-24786) Introduce RocksDB's statistics related options

[ https://issues.apache.org/jira/browse/FLINK-24786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24786: - Description: Currently, Flink only support RocksDB's native metrics of property related. However, such

[jira] [Created] (FLINK-24788) Report RocksDB statistics as metrics

Yun Tang created FLINK-24788: Summary: Report RocksDB statistics as metrics Key: FLINK-24788 URL: https://issues.apache.org/jira/browse/FLINK-24788 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-24786) Introduce RocksDB's statistis related options

[ https://issues.apache.org/jira/browse/FLINK-24786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24786: - Summary: Introduce RocksDB's statistis related options (was: Introduce metrics of RocksDB's statistis)

[jira] [Created] (FLINK-24787) Add more details of state latency tracking documentation

Yun Tang created FLINK-24787: Summary: Add more details of state latency tracking documentation Key: FLINK-24787 URL: https://issues.apache.org/jira/browse/FLINK-24787 Project: Flink Issue Type:

[jira] [Created] (FLINK-24786) Introduce metrics of RocksDB's statistis

Yun Tang created FLINK-24786: Summary: Introduce metrics of RocksDB's statistis Key: FLINK-24786 URL: https://issues.apache.org/jira/browse/FLINK-24786 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24785) Relocate RocksDB's log under flink log directory by default

Yun Tang created FLINK-24785: Summary: Relocate RocksDB's log under flink log directory by default Key: FLINK-24785 URL: https://issues.apache.org/jira/browse/FLINK-24785 Project: Flink Issue

[jira] [Created] (FLINK-24784) Enable state.backend.latency-track.state-name-as-variable by default

Yun Tang created FLINK-24784: Summary: Enable state.backend.latency-track.state-name-as-variable by default Key: FLINK-24784 URL: https://issues.apache.org/jira/browse/FLINK-24784 Project: Flink

[jira] [Updated] (FLINK-24783) Improve state backend monitoring experience and usability

[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24783: - Component/s: Runtime / Metrics > Improve state backend monitoring experience and usability >

[jira] [Created] (FLINK-24783) Improve state backend monitoring experience and usability

Yun Tang created FLINK-24783: Summary: Improve state backend monitoring experience and usability Key: FLINK-24783 URL: https://issues.apache.org/jira/browse/FLINK-24783 Project: Flink Issue

[jira] [Commented] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439002#comment-17439002 ] Yun Tang commented on FLINK-24046: -- [~Zakelly] Since {{DefaultConfigurableOptionsFactory}} had existed

[jira] [Resolved] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24597. -- Resolution: Fixed Merged master: a907d92673a711612b287d184c00dad7fa42269f release-1.14:

[jira] [Updated] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24597: - Fix Version/s: 1.13.4 1.14.1 1.15.0 > RocksdbStateBackend

[jira] [Closed] (FLINK-18473) Optimize RocksDB disk load balancing strategy

[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-18473. Resolution: Information Provided > Optimize RocksDB disk load balancing strategy >

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438997#comment-17438997 ] Yun Tang commented on FLINK-18473: -- [~fanrui] I think your proposed idea cannot resolve the case of

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437722#comment-17437722 ] Yun Tang commented on FLINK-21543: -- [~Ming Li], you could refer to RocksDB's documentation:

[jira] [Commented] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436635#comment-17436635 ] Yun Tang commented on FLINK-24597: -- [~mayuehappy] Already assigned to you, please go ahead. >

[jira] [Assigned] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24597: Assignee: Yue Ma > RocksdbStateBackend getKeysAndNamespaces would return duplicate data when >

[jira] [Commented] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435847#comment-17435847 ] Yun Tang commented on FLINK-21543: -- Since RocksDB's FIFO compaction would cause data lost quitely, it

[jira] [Closed] (FLINK-21543) when using FIFO compaction, I found sst being deleted on the first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-21543. Resolution: Information Provided > when using FIFO compaction, I found sst being deleted on the first

[jira] [Commented] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435842#comment-17435842 ] Yun Tang commented on FLINK-24597: -- I think this is valid, and current {{RocksStateKeysIterator}},

[jira] [Resolved] (FLINK-24678) Correct the metric name of map state contains latency

[ https://issues.apache.org/jira/browse/FLINK-24678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24678. -- Resolution: Fixed Merged master: b1a409ef1c53a24d717c789eea8c09ddbc94f7f1 release-1.14:

[jira] [Updated] (FLINK-24678) Correct the metric name of map state contains latency

[ https://issues.apache.org/jira/browse/FLINK-24678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24678: - Fix Version/s: 1.15.0 > Correct the metric name of map state contains latency >

[jira] [Assigned] (FLINK-24678) Correct the metric name of map state contains latency

[ https://issues.apache.org/jira/browse/FLINK-24678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24678: Assignee: Jinzhong Li (was: Yun Tang) > Correct the metric name of map state contains latency >

[jira] [Created] (FLINK-24678) Correct the metric name of map state contains latency

Yun Tang created FLINK-24678: Summary: Correct the metric name of map state contains latency Key: FLINK-24678 URL: https://issues.apache.org/jira/browse/FLINK-24678 Project: Flink Issue Type:

[jira] [Created] (FLINK-24667) Channel state writer would fail the task directly if meeting exception previously

Yun Tang created FLINK-24667: Summary: Channel state writer would fail the task directly if meeting exception previously Key: FLINK-24667 URL: https://issues.apache.org/jira/browse/FLINK-24667 Project:

[jira] [Resolved] (FLINK-24546) Acknowledged description miss on Monitoring Checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-24546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24546. -- Fix Version/s: 1.15.0 Resolution: Fixed merged in master:

[jira] [Commented] (FLINK-24546) Acknowledged description miss on Monitoring Checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-24546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430987#comment-17430987 ] Yun Tang commented on FLINK-24546: -- [~Alston Williams], thanks for your enthusiasm! As I wrote in

[jira] [Assigned] (FLINK-24546) Acknowledged description miss on Monitoring Checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-24546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24546: Assignee: camilesing > Acknowledged description miss on Monitoring Checkpointing page >

[jira] [Resolved] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method

[ https://issues.apache.org/jira/browse/FLINK-24432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24432. -- Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed merged in master:

[jira] [Resolved] (FLINK-24460) Rocksdb Iterator Error Handling Improvement

[ https://issues.apache.org/jira/browse/FLINK-24460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24460. -- Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed merged in master:

[jira] [Commented] (FLINK-24460) Rocksdb Iterator Error Handling Improvement

[ https://issues.apache.org/jira/browse/FLINK-24460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426944#comment-17426944 ] Yun Tang commented on FLINK-24460: -- This fix should be useful, [~victorunique] already assigned this

[jira] [Assigned] (FLINK-24460) Rocksdb Iterator Error Handling Improvement

[ https://issues.apache.org/jira/browse/FLINK-24460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24460: Assignee: Victor Xu > Rocksdb Iterator Error Handling Improvement >

[jira] [Resolved] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24148. -- Resolution: Fixed merged in release-1.14: 7882d5e5e7d6c6bd0c12f659b4c92829703a2b29 > Add bloom

[jira] [Resolved] (FLINK-23519) Aggregate State Backend Latency by State Level

[ https://issues.apache.org/jira/browse/FLINK-23519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23519. -- Resolution: Fixed Merged in release-1.14: b5fab64432c9839f956c9c169f617edf1026669f > Aggregate State

[jira] [Commented] (FLINK-23519) Aggregate State Backend Latency by State Level

[ https://issues.apache.org/jira/browse/FLINK-23519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419576#comment-17419576 ] Yun Tang commented on FLINK-23519: -- merged in master( 1.15.0) :

[jira] [Commented] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17417115#comment-17417115 ] Yun Tang commented on FLINK-23949: -- merged in release-1.12: b84223034a55a16df4d977f5be1ff9e6e3d4291a >

[jira] [Updated] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23949: - Component/s: (was: Runtime / State Backends) Runtime / Checkpointing > first

[jira] [Updated] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23949: - Component/s: Runtime / State Backends > first incremental checkpoint after a savepoint will degenerate

[jira] [Updated] (FLINK-23180) Initialize checkpoint location lazily in DataStream Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-23180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23180: - Release Note: (was: merged in master: 164a59ac1bb4dd39e6532478c30234eeafd76cd0) merged in master:

[jira] [Updated] (FLINK-24240) HA JobGraph deserialization problem when migrate 1.12.4 to 1.13.2

[ https://issues.apache.org/jira/browse/FLINK-24240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24240: - Component/s: (was: Runtime / State Backends) Runtime / Coordination > HA JobGraph

[jira] [Updated] (FLINK-23180) Initialize checkpoint location lazily in DataStream Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-23180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23180: - Fix Version/s: 1.15.0 > Initialize checkpoint location lazily in DataStream Batch Jobs >

[jira] [Resolved] (FLINK-23180) Initialize checkpoint location lazily in DataStream Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-23180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23180. -- Release Note: merged in master: 164a59ac1bb4dd39e6532478c30234eeafd76cd0 Resolution: Fixed >

[jira] [Commented] (FLINK-24149) Make checkpoint self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17414676#comment-17414676 ] Yun Tang commented on FLINK-24149: -- [~Feifan Wang] My core idea is that we should avoid any misuse from

[jira] [Updated] (FLINK-14482) Bump up rocksdb version

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-14482: - Attachment: image.png > Bump up rocksdb version > --- > > Key:

[jira] [Comment Edited] (FLINK-14482) Bump up rocksdb version

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413132#comment-17413132 ] Yun Tang edited comment on FLINK-14482 at 9/10/21, 11:47 AM: - According to

[jira] [Commented] (FLINK-14482) Bump up rocksdb version

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413132#comment-17413132 ] Yun Tang commented on FLINK-14482: -- According to the nexmark, state-related queries could have at most

[jira] [Assigned] (FLINK-24210) Window related serailizer should not return 0 as its serialized length

[ https://issues.apache.org/jira/browse/FLINK-24210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24210: Assignee: Jinzhong Li > Window related serailizer should not return 0 as its serialized length >

[jira] [Created] (FLINK-24210) Window related serailizer should not return 0 as its serialized length

Yun Tang created FLINK-24210: Summary: Window related serailizer should not return 0 as its serialized length Key: FLINK-24210 URL: https://issues.apache.org/jira/browse/FLINK-24210 Project: Flink

[jira] [Updated] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23949: - Fix Version/s: (was: 1.12.6) > first incremental checkpoint after a savepoint will degenerate into

[jira] [Comment Edited] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411740#comment-17411740 ] Yun Tang edited comment on FLINK-23949 at 9/8/21, 8:24 AM: --- merged master:

[jira] [Commented] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411773#comment-17411773 ] Yun Tang commented on FLINK-23949: -- [~dwysakowicz] Since interfaces of snapshot strategy has been

[jira] [Commented] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411765#comment-17411765 ] Yun Tang commented on FLINK-23949: -- [~dwysakowicz] Thanks for your reminder, I am taking a look now. >

[jira] [Resolved] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23949. -- Resolution: Fixed merged master: d2007b74d543edb05af203f115459c51378867d3 release-1.14:

[jira] [Updated] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23949: - Fix Version/s: 1.15.0 1.13.3 1.12.6 1.14.0 >

[jira] [Commented] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411661#comment-17411661 ] Yun Tang commented on FLINK-24148: -- merged in master: 371f247a45adac24f7fbd4e92782cc4dc0b31dc3 > Add

[jira] [Updated] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24148: - Fix Version/s: 1.14.1 1.15.0 > Add bloom filter policy option in

[jira] [Commented] (FLINK-24149) Make checkpoint relocatable

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410943#comment-17410943 ] Yun Tang commented on FLINK-24149: -- [~Feifan Wang] That's why I think we should take all cases into

[jira] [Resolved] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23983. -- Resolution: Fixed Merged master: 4f5978fd4f53428b6af85f487f3f2abbf2f590fd release-1.14:

[jira] [Updated] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23983: - Fix Version/s: 1.15.0 > JVM crash when running RocksDBStateBackend tests >

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410352#comment-17410352 ] Yun Tang commented on FLINK-23886: -- [~pnowojski] I think FLINK-19741 is not like the problem we meet. I

[jira] [Commented] (FLINK-24149) Make checkpoint relocatable

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410315#comment-17410315 ] Yun Tang commented on FLINK-24149: -- [~Feifan Wang] The incremental checkpoint might have different path

[jira] [Commented] (FLINK-24149) Make checkpoint relocatable

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410136#comment-17410136 ] Yun Tang commented on FLINK-24149: -- Before further discussion or review, I have several questions: #

[jira] [Resolved] (FLINK-23822) Test config state ttl in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-23822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23822. -- Resolution: Fixed > Test config state ttl in Python DataStream API >

[jira] [Commented] (FLINK-23822) Test config state ttl in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-23822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409585#comment-17409585 ] Yun Tang commented on FLINK-23822: -- Verify the state TTL in python API via docs. Found two problems

[jira] [Commented] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409484#comment-17409484 ] Yun Tang commented on FLINK-24148: -- Bloom filter takes effects in production environment. [~wind_ljy] 

[jira] [Assigned] (FLINK-24148) Add bloom filter policy option in RocksDBConfiguredOptions

[ https://issues.apache.org/jira/browse/FLINK-24148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24148: Assignee: Jiayi Liao > Add bloom filter policy option in RocksDBConfiguredOptions >

[jira] [Updated] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23983: - Component/s: Tests > JVM crash when running RocksDBStateBackend tests >

[jira] [Assigned] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23983: Assignee: Yun Tang > JVM crash when running RocksDBStateBackend tests >

[jira] [Commented] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408575#comment-17408575 ] Yun Tang commented on FLINK-23983: -- I could reproduced it locally by running RocksDBStateBackend tests

[jira] [Resolved] (FLINK-24106) Remove notice that python does not support state TTL

[ https://issues.apache.org/jira/browse/FLINK-24106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24106. -- Resolution: Fixed merged master: aa2dddcf1cf9fb6241c4840f9c907530b76dc02a release-1.14:

[jira] [Assigned] (FLINK-24106) Remove notice that python does not support state TTL

[ https://issues.apache.org/jira/browse/FLINK-24106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24106: Assignee: Yun Tang > Remove notice that python does not support state TTL >

[jira] [Created] (FLINK-24106) Remove notice that python does not support state TTL

Yun Tang created FLINK-24106: Summary: Remove notice that python does not support state TTL Key: FLINK-24106 URL: https://issues.apache.org/jira/browse/FLINK-24106 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24105) state TTL might not take effect for pyflink

[ https://issues.apache.org/jira/browse/FLINK-24105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24105: - Parent: FLINK-23822 Issue Type: Sub-task (was: Bug) > state TTL might not take effect for

[jira] [Created] (FLINK-24105) state TTL might not take effect for pyflink

Yun Tang created FLINK-24105: Summary: state TTL might not take effect for pyflink Key: FLINK-24105 URL: https://issues.apache.org/jira/browse/FLINK-24105 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-23519) Aggregate State Backend Latency by State Level

[ https://issues.apache.org/jira/browse/FLINK-23519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23519: - Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0

[jira] [Created] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

Yun Tang created FLINK-24046: Summary: Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions Key: FLINK-24046 URL: https://issues.apache.org/jira/browse/FLINK-24046 Project:

[jira] [Updated] (FLINK-23791) Enable RocksDB log again

[ https://issues.apache.org/jira/browse/FLINK-23791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23791: - Fix Version/s: (was: 1.14.0) 1.14.1 > Enable RocksDB log again >

[jira] [Commented] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406527#comment-17406527 ] Yun Tang commented on FLINK-23721: -- [~lmagics] could you share the code example to reproduce this on

[jira] [Updated] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23983: - Summary: JVM crash when running RocksDBStateBackend tests (was: JVM crash when running

[jira] [Commented] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405659#comment-17405659 ] Yun Tang commented on FLINK-23721: -- [~lmagics] From the code implementation, what you described is

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405647#comment-17405647 ] Yun Tang commented on FLINK-23886: -- Thanks for Piotr's explaniation, [~qingru zhang] do you have legacy

[jira] [Resolved] (FLINK-23800) Expose newly added RocksDB native metrics

[ https://issues.apache.org/jira/browse/FLINK-23800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23800. -- Resolution: Fixed merged in master bbcdb0b360f16647beb81206715ea54f7010b71e > Expose newly added

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405551#comment-17405551 ] Yun Tang commented on FLINK-23886: -- [~pnowojski] would you please share more information about the

[jira] [Resolved] (FLINK-23992) Update doc version in release-1.13 to 1.13.2

[ https://issues.apache.org/jira/browse/FLINK-23992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23992. -- Resolution: Fixed fixed in release-1.13.2 b5e593453fd57911827aa185e46fcbb8f8495260 > Update doc

[jira] [Assigned] (FLINK-23992) Update doc version in release-1.13 to 1.13.2

[ https://issues.apache.org/jira/browse/FLINK-23992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23992: Assignee: Yun Tang > Update doc version in release-1.13 to 1.13.2 >

[jira] [Created] (FLINK-23992) Update doc version in release-1.13 to 1.13.2

Yun Tang created FLINK-23992: Summary: Update doc version in release-1.13 to 1.13.2 Key: FLINK-23992 URL: https://issues.apache.org/jira/browse/FLINK-23992 Project: Flink Issue Type: Bug

[jira] [Issue Comment Deleted] (FLINK-23983) JVM crash when running RocksDBStateBackendConfigTest

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23983: - Comment: was deleted (was: I checked the dump file hprof

[jira] [Commented] (FLINK-23983) JVM crash when running RocksDBStateBackendConfigTest

[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404897#comment-17404897 ] Yun Tang commented on FLINK-23983: -- I checked the dump file hprof

[jira] [Assigned] (FLINK-23519) Aggregate State Backend Latency by State Level

[ https://issues.apache.org/jira/browse/FLINK-23519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23519: Assignee: Yun Tang > Aggregate State Backend Latency by State Level >

[jira] [Updated] (FLINK-23519) Aggregate State Backend Latency by State Level

[ https://issues.apache.org/jira/browse/FLINK-23519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23519: - Fix Version/s: 1.14.0 > Aggregate State Backend Latency by State Level >

[jira] [Commented] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404141#comment-17404141 ] Yun Tang commented on FLINK-23949: -- Thanks for creating this ticket and I think this deserves a fix, I

[jira] [Assigned] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

[ https://issues.apache.org/jira/browse/FLINK-23949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23949: Assignee: Feifan Wang > first incremental checkpoint after a savepoint will degenerate into a

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403577#comment-17403577 ] Yun Tang commented on FLINK-23886: -- Flink actually synchronizes invocations of onTimer() and

[jira] [Commented] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402322#comment-17402322 ] Yun Tang commented on FLINK-23721: -- [~lmagics] Whether enable incremental checkpoints has no

[jira] [Comment Edited] (FLINK-23841) [doc]Modify incorrect English statements for page 'execution_configuration'

[ https://issues.apache.org/jira/browse/FLINK-23841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402079#comment-17402079 ] Yun Tang edited comment on FLINK-23841 at 8/20/21, 7:20 AM: I think the typo

[jira] [Commented] (FLINK-23841) [doc]Modify incorrect English statements for page 'execution_configuration'

[ https://issues.apache.org/jira/browse/FLINK-23841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402079#comment-17402079 ] Yun Tang commented on FLINK-23841: -- I think the typo may be obvious, however, from my understanding of

[jira] [Created] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType

Yun Tang created FLINK-23869: Summary: Correct javadoc of ExecutionConfig#registerKryoType Key: FLINK-23869 URL: https://issues.apache.org/jira/browse/FLINK-23869 Project: Flink Issue Type: Bug

<    4   5   6   7   8   9   10   11   12   13   >