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

[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&focusedCommentId=17406527#comment-17406527 ] Yun Tang commented on FLINK-23721: -- [~lmagics] could you share the code example to repr

[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] [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: F

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

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

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

[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] [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: 297795fa9d3977

[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&focusedCommentId=17408575#comment-17408575 ] Yun Tang commented on FLINK-23983: -- I could reproduced it locally by running RocksDBSta

[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] [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-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] [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&focusedCommentId=17409484#comment-17409484 ] Yun Tang commented on FLINK-24148: -- Bloom filter takes effects in production environmen

[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&focusedCommentId=17409585#comment-17409585 ] Yun Tang commented on FLINK-23822: -- Verify the state TTL in python API via docs. Found

[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-24149) Make checkpoint relocatable

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

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

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

[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&focusedCommentId=17410352#comment-17410352 ] Yun Tang commented on FLINK-23886: -- [~pnowojski] I think FLINK-19741 is not like the pr

[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] [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: 7bf42400d99a5d

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

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

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

[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&focusedCommentId=17411661#comment-17411661 ] Yun Tang commented on FLINK-24148: -- merged in master: 371f247a45adac24f7fbd4e92782cc4dc

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

[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: 602a177f639154

[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&focusedCommentId=17411765#comment-17411765 ] Yun Tang commented on FLINK-23949: -- [~dwysakowicz] Thanks for your reminder, I am takin

[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&focusedCommentId=17411773#comment-17411773 ] Yun Tang commented on FLINK-23949: -- [~dwysakowicz] Since interfaces of snapshot strateg

[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&focusedCommentId=17411740#comment-17411740 ] Yun Tang edited comment on FLINK-23949 at 9/8/21, 8:24 AM: --- me

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

[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] [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] [Updated] (FLINK-11634) Translate "State Backends" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-11634: - Fix Version/s: 1.13.3 1.14.0 > Translate "State Backends" page into Chinese > ---

[jira] [Resolved] (FLINK-11634) Translate "State Backends" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-11634. -- Resolution: Fixed Merged master: bc5890ecfd388e842306aa7717198227f5768cb4 release-1.13: 8725a17d1cc50c

[jira] [Assigned] (FLINK-23699) The code comment's reference is wrong for the function isUsingFixedMemoryPerSlot

[ https://issues.apache.org/jira/browse/FLINK-23699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23699: Assignee: Mans Singh > The code comment's reference is wrong for the function > isUsingFixedMemo

[jira] [Commented] (FLINK-23699) The code comment's reference is wrong for the function isUsingFixedMemoryPerSlot

[ https://issues.apache.org/jira/browse/FLINK-23699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397972#comment-17397972 ] Yun Tang commented on FLINK-23699: -- [~mans2singh] Already assign this ticket to you. >

[jira] [Updated] (FLINK-23699) The code comment's reference is wrong for the function isUsingFixedMemoryPerSlot

[ https://issues.apache.org/jira/browse/FLINK-23699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23699: - Fix Version/s: 1.14.0 > The code comment's reference is wrong for the function > isUsingFixedMemoryPerS

[jira] [Resolved] (FLINK-23699) The code comment's reference is wrong for the function isUsingFixedMemoryPerSlot

[ https://issues.apache.org/jira/browse/FLINK-23699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23699. -- Resolution: Fixed merged in master: 1352705c78a0dd1fa9e97e6703696ee414ab38d8 > The code comment's ref

[jira] [Created] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions

Yun Tang created FLINK-23737: Summary: Ensure publish-to-dockerhub.sh only publish specific flink versions Key: FLINK-23737 URL: https://issues.apache.org/jira/browse/FLINK-23737 Project: Flink

[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&focusedCommentId=17398421#comment-17398421 ] Yun Tang commented on FLINK-14482: -- [~legojoey17] Not yet completely addressed, you cou

[jira] [Created] (FLINK-23756) Release FRocksDB-6.20.3 binaries

Yun Tang created FLINK-23756: Summary: Release FRocksDB-6.20.3 binaries Key: FLINK-23756 URL: https://issues.apache.org/jira/browse/FLINK-23756 Project: Flink Issue Type: Sub-task Comp

[jira] [Assigned] (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 reassigned FLINK-14482: Assignee: Yun Tang (was: Mika Naylor) > Bump up rocksdb version > --- > >

[jira] [Assigned] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-19710: Assignee: Yun Tang > Fix performance regression to rebase FRocksDB with higher version RocksDB >

[jira] [Updated] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-19710: - Parent: FLINK-14482 Issue Type: Sub-task (was: Improvement) > Fix performance regression to reb

[jira] [Commented] (FLINK-13598) frocksdb doesn't have arm release

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398481#comment-17398481 ] Yun Tang commented on FLINK-13598: -- [~WangHui] Since we decide to upgrade base version

[jira] [Assigned] (FLINK-13598) frocksdb doesn't have arm release

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-13598: Assignee: Mika Naylor > frocksdb doesn't have arm release > -- >

[jira] [Updated] (FLINK-13598) frocksdb doesn't have arm release

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13598: - Fix Version/s: 1.14.0 > frocksdb doesn't have arm release > -- > >

[jira] [Updated] (FLINK-13598) frocksdb doesn't have arm release

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13598: - Affects Version/s: (was: 2.0.0) > frocksdb doesn't have arm release > -

[jira] [Resolved] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-19710. -- Resolution: Information Provided As wrote in the [announcement email|https://lists.apache.org/thread.

[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&focusedCommentId=17398421#comment-17398421 ] Yun Tang edited comment on FLINK-14482 at 8/13/21, 8:26 AM:

[jira] [Assigned] (FLINK-23649) Add RocksDB packages to parent-first classloading patterns.

[ https://issues.apache.org/jira/browse/FLINK-23649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23649: Assignee: Yun Tang > Add RocksDB packages to parent-first classloading patterns. > --

[jira] [Created] (FLINK-23789) Remove unnecessary setTotalOrderForSeek for Rocks iterator

Yun Tang created FLINK-23789: Summary: Remove unnecessary setTotalOrderForSeek for Rocks iterator Key: FLINK-23789 URL: https://issues.apache.org/jira/browse/FLINK-23789 Project: Flink Issue Type

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

Yun Tang created FLINK-23791: Summary: Enable RocksDB log again Key: FLINK-23791 URL: https://issues.apache.org/jira/browse/FLINK-23791 Project: Flink Issue Type: Improvement Components

[jira] [Assigned] (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 reassigned FLINK-23791: Assignee: Zakelly Lan > Enable RocksDB log again > > > K

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-15532: - Fix Version/s: 1.14.0 > Enable strict capacity limit for memory usage for RocksDB >

[jira] [Assigned] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-15532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-15532: Assignee: Yun Tang > Enable strict capacity limit for memory usage for RocksDB >

[jira] [Created] (FLINK-23798) Avoid using reflection to get filter when partition filter is enabled

Yun Tang created FLINK-23798: Summary: Avoid using reflection to get filter when partition filter is enabled Key: FLINK-23798 URL: https://issues.apache.org/jira/browse/FLINK-23798 Project: Flink

[jira] [Assigned] (FLINK-23798) Avoid using reflection to get filter when partition filter is enabled

[ https://issues.apache.org/jira/browse/FLINK-23798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23798: Assignee: PengFei Li > Avoid using reflection to get filter when partition filter is enabled > --

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

Yun Tang created FLINK-23800: Summary: Expose newly added RocksDB native metrics Key: FLINK-23800 URL: https://issues.apache.org/jira/browse/FLINK-23800 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-23649) Add RocksDB packages to parent-first classloading patterns.

[ https://issues.apache.org/jira/browse/FLINK-23649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23649. -- Resolution: Fixed Merged in master: d57d9f84d84408547e00f3a715e8f05b4408af11 > Add RocksDB packages t

[jira] [Resolved] (FLINK-23789) Remove unnecessary setTotalOrderForSeek for Rocks iterator

[ https://issues.apache.org/jira/browse/FLINK-23789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23789. -- Resolution: Fixed merged in master: ee74231c385e2c2d6b11cc5d4e5f557f03d0a30f > Remove unnecessary set

[jira] [Assigned] (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 reassigned FLINK-23822: Assignee: Yun Tang > Test config state ttl in Python DataStream API > ---

[jira] [Updated] (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 updated FLINK-23198: - Fix Version/s: 1.14.0 > An old interface method is used in this section of [Passing Options Factory > t

[jira] [Updated] (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 updated FLINK-23198: - Fix Version/s: 1.13.3 > An old interface method is used in this section of [Passing Options Factory > t

[jira] [Resolved] (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 resolved FLINK-23198. -- Resolution: Fixed merged master: 0abc23de1f8ab521bf9ac4a21b6b1bce7da6fadc release-1.13: 097f717b28cfdc

[jira] [Commented] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400819#comment-17400819 ] Yun Tang commented on FLINK-21321: -- [~legojoey17] Thanks for yout reminder, since Flink

[jira] [Updated] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21321: - Fix Version/s: 1.15.0 > Change RocksDB incremental checkpoint re-scaling to use deleteRange > --

[jira] [Comment Edited] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400819#comment-17400819 ] Yun Tang edited comment on FLINK-21321 at 8/18/21, 6:22 AM:

[jira] [Updated] (FLINK-21321) Change RocksDB incremental checkpoint re-scaling to use deleteRange

[ https://issues.apache.org/jira/browse/FLINK-21321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21321: - Priority: Major (was: Minor) > Change RocksDB incremental checkpoint re-scaling to use deleteRange > --

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

[ https://issues.apache.org/jira/browse/FLINK-23044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23044: Assignee: wuguihu > fix typos in docs > - > > Key: FLINK-23044 >

[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=17400852#comment-17400852 ] Yun Tang commented on FLINK-23044: -- [~hapihu] sure, please provide a PR to find typos a

[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

[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&focusedCommentId=17402079#comment-17402079 ] Yun Tang edited comment on FLINK-23841 at 8/20/21, 7:20 AM:

[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&focusedCommentId=17402079#comment-17402079 ] Yun Tang commented on FLINK-23841: -- I think the typo may be obvious, however, from my u

[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&focusedCommentId=17402322#comment-17402322 ] Yun Tang commented on FLINK-23721: -- [~lmagics] Whether enable incremental checkpoints h

[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&focusedCommentId=17403577#comment-17403577 ] Yun Tang commented on FLINK-23886: -- Flink actually synchronizes invocations of onTimer(

[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&focusedCommentId=17404141#comment-17404141 ] Yun Tang commented on FLINK-23949: -- Thanks for creating this ticket and I think this de

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

[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] [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] [Commented] (FLINK-14482) Bump up rocksdb version

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

[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&focusedCommentId=17413132#comment-17413132 ] Yun Tang edited comment on FLINK-14482 at 9/10/21, 11:47 AM: -

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

[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&focusedCommentId=17414676#comment-17414676 ] Yun Tang commented on FLINK-24149: -- [~Feifan Wang] My core idea is that we should avoid

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

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

[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: 164a

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

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

[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&focusedCommentId=17417115#comment-17417115 ] Yun Tang commented on FLINK-23949: -- merged in release-1.12: b84223034a55a16df4d977f5be1

[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&focusedCommentId=17419576#comment-17419576 ] Yun Tang commented on FLINK-23519: -- merged in master( 1.15.0) : e2bda3df78b0a7d16acf81

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

[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&focusedCommentId=17437722#comment-17437722 ] Yun Tang commented on FLINK-21543: -- [~Ming Li], you could refer to RocksDB's documentat

[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&focusedCommentId=17438997#comment-17438997 ] Yun Tang commented on FLINK-18473: -- [~fanrui] I think your proposed idea cannot resolve

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

[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: 547b3befcff50b

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