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

[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] [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] [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=17400819#comment-17400819 ] Yun Tang edited comment on FLINK-21321 at 8/18/21, 6:22 AM: [~legojoey17]

[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=17400819#comment-17400819 ] Yun Tang commented on FLINK-21321: -- [~legojoey17] Thanks for yout reminder, since Flink-1.14 has been

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

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

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

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

[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

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

[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

[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

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

[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

[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] [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] [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=17398481#comment-17398481 ] Yun Tang commented on FLINK-13598: -- [~WangHui] Since we decide to upgrade base version to

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

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

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

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

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

[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=17397972#comment-17397972 ] Yun Tang commented on FLINK-23699: -- [~mans2singh] Already assign this ticket to you. > The code

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

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

[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] [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=17395855#comment-17395855 ] Yun Tang commented on FLINK-22059: -- [~zhoujira86] What's the progress of your PR? > add a new option

[jira] [Updated] (FLINK-23511) Fix the location error in metric page.

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

[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=17392993#comment-17392993 ] Yun Tang commented on FLINK-23346: -- [~klion26] Do you have more investigation results? >

[jira] [Commented] (FLINK-23221) Docker image vulnerability

[ https://issues.apache.org/jira/browse/FLINK-23221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391940#comment-17391940 ] Yun Tang commented on FLINK-23221: -- [~Raszan] I also wonder could this problem be fixed with a newer

[jira] [Updated] (FLINK-23059) Update playgrounds for Flink 1.13

[ https://issues.apache.org/jira/browse/FLINK-23059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23059: - Fix Version/s: (was: 1.13.1) 1.13.3 > Update playgrounds for Flink 1.13 >

[jira] [Updated] (FLINK-22855) Translate the 'Overview of Python API' page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-22855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22855: - Fix Version/s: 1.13.2 1.14.0 > Translate the 'Overview of Python API' page into

[jira] [Updated] (FLINK-21229) Support ssl connection with schema registry format

[ https://issues.apache.org/jira/browse/FLINK-21229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21229: - Fix Version/s: (was: 1.13.3) 1.13.2 > Support ssl connection with schema

[jira] [Updated] (FLINK-23443) LaunchCoordinatorTest fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23443: - Fix Version/s: (was: 1.13.2) 1.13.3 > LaunchCoordinatorTest fails on azure >

[jira] [Updated] (FLINK-23155) Streaming File Sink s3 end-to-end test fail on azure

[ https://issues.apache.org/jira/browse/FLINK-23155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23155: - Fix Version/s: (was: 1.13.2) 1.13.3 > Streaming File Sink s3 end-to-end test

[jira] [Updated] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

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

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

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

[jira] [Updated] (FLINK-22959) Keep the job jar files on JobManager

[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22959: - Fix Version/s: (was: 1.13.2) > Keep the job jar files on JobManager >

[jira] [Updated] (FLINK-22932) RocksDBStateBackendWindowITCase fails with savepoint timeout

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

[jira] [Updated] (FLINK-22799) Missing documentation: State backwards compatibility is not support for Flink SQL

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

[jira] [Updated] (FLINK-22203) KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-22203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22203: - Fix Version/s: 1.13.2 > KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to >

[jira] [Updated] (FLINK-22589) There are quite a few Python classes doesn't appear in the Python docs

[ https://issues.apache.org/jira/browse/FLINK-22589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22589: - Fix Version/s: (was: 1.13.2) 1.13.3 > There are quite a few Python classes

[jira] [Updated] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

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

[jira] [Commented] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17391272#comment-17391272 ] Yun Tang commented on FLINK-22578: -- [~hiscat] I think the navigate menu is on the right side, what the

[jira] [Updated] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22578: - Fix Version/s: (was: 1.13.2) 1.13.3 > deployment configuration page miss content

[jira] [Updated] (FLINK-22527) Give friendly hint when click FlameGraph without rest.flamegraph.enabled

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

[jira] [Updated] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

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

[jira] [Updated] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22480: - Fix Version/s: (was: 1.13.2) 1.13.3 > KafkaChangelogTableITCase hangs on Azure >

[jira] [Updated] (FLINK-22370) ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true

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

[jira] [Updated] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22358: - Fix Version/s: (was: 1.13.2) 1.13.3 > Add missing stability annotation to Split

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

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

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

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

[jira] [Commented] (FLINK-23563) Sometimes ‘Stop’ cannot stop the job

[ https://issues.apache.org/jira/browse/FLINK-23563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17390556#comment-17390556 ] Yun Tang commented on FLINK-23563: -- [~AlexYinHan] I have assigned this ticket to you, and you could

[jira] [Assigned] (FLINK-23563) Sometimes ‘Stop’ cannot stop the job

[ https://issues.apache.org/jira/browse/FLINK-23563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23563: Assignee: Han Yin > Sometimes ‘Stop’ cannot stop the job >

[jira] [Commented] (FLINK-23535) The value of option high-availability.cluster-id in flink-conf.yaml is replaced improperly

[ https://issues.apache.org/jira/browse/FLINK-23535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389757#comment-17389757 ] Yun Tang commented on FLINK-23535: -- [~yulei0824] Could you share what the steps/commands you do to stop

[jira] [Comment Edited] (FLINK-23535) The value of option high-availability.cluster-id in flink-conf.yaml is replaced improperly

[ https://issues.apache.org/jira/browse/FLINK-23535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389306#comment-17389306 ] Yun Tang edited comment on FLINK-23535 at 7/29/21, 8:45 AM: [~yulei0824] If

[jira] [Reopened] (FLINK-23515) I try to specify savepoint dir in my app. However, the startup task reports an error, java.lang.unsupported operationexception: the configuration is unmodifiable; its c

[ https://issues.apache.org/jira/browse/FLINK-23515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reopened FLINK-23515: -- > I try to specify savepoint dir in my app. However, the startup task reports > an error,

[jira] [Commented] (FLINK-23535) The value of option high-availability.cluster-id in flink-conf.yaml is replaced improperly

[ https://issues.apache.org/jira/browse/FLINK-23535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389306#comment-17389306 ] Yun Tang commented on FLINK-23535: -- [~yulei0824] If high-availability.cluster-id is configured

[jira] [Commented] (FLINK-23515) I try to specify savepoint dir in my app. However, the startup task reports an error, java.lang.unsupported operationexception: the configuration is unmodifiable; its

[ https://issues.apache.org/jira/browse/FLINK-23515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388413#comment-17388413 ] Yun Tang commented on FLINK-23515: -- You should link the duplicated ticket in this ticket if you close

[jira] [Commented] (FLINK-23515) I try to specify savepoint dir in my app. However, the startup task reports an error, java.lang.unsupported operationexception: the configuration is unmodifiable; its

[ https://issues.apache.org/jira/browse/FLINK-23515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17387987#comment-17387987 ] Yun Tang commented on FLINK-23515: -- [~soberchi...@gamil.com] This is a bug as it attempts to modify

[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.3) 1.13.2 > Use -Dfast for building e2e tests on AZP >

[jira] [Updated] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

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

[jira] [Updated] (FLINK-22898) HiveParallelismInference limit return wrong parallelism

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

[jira] [Updated] (FLINK-23201) The check on alignmentDurationNanos seems to be too strict

[ https://issues.apache.org/jira/browse/FLINK-23201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23201: - Fix Version/s: (was: 1.13.3) 1.13.2 > The check on alignmentDurationNanos seems

[jira] [Updated] (FLINK-23188) Unsupported function definition: IFNULL. Only user defined functions are supported as inline functions

[ https://issues.apache.org/jira/browse/FLINK-23188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23188: - Fix Version/s: (was: 1.13.3) 1.13.2 > Unsupported function definition: IFNULL.

[jira] [Resolved] (FLINK-21411) The components on which Flink depends may contain vulnerabilities. If yes, fix them.

[ https://issues.apache.org/jira/browse/FLINK-21411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-21411. -- Assignee: Yun Tang Resolution: Fixed > The components on which Flink depends may contain

[jira] [Updated] (FLINK-21411) The components on which Flink depends may contain vulnerabilities. If yes, fix them.

[ https://issues.apache.org/jira/browse/FLINK-21411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21411: - Fix Version/s: 1.14.0 > The components on which Flink depends may contain vulnerabilities. If yes, >

[jira] [Updated] (FLINK-21411) The components on which Flink depends may contain vulnerabilities. If yes, fix them.

[ https://issues.apache.org/jira/browse/FLINK-21411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21411: - Fix Version/s: 1.13.2 1.12.5 1.11.4 > The components on which

[jira] [Resolved] (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 resolved FLINK-23471. -- Resolution: Fixed merged in master fdde1e445ac2a9e4f49e86e55b7d85ef4501ab33 > Try best to ensure all

[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=17385876#comment-17385876 ] Yun Tang commented on FLINK-23440: -- [~yang89520] I have assigned this ticket to you, and you could

[jira] [Assigned] (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:all-tabpanel ] Yun Tang reassigned FLINK-23440: Assignee: yang89520 > The "State. Backend" of "Flink-CONF.YAML" is inconsistent with the >

[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

[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=17385291#comment-17385291 ] Yun Tang commented on FLINK-23440: -- [~yang89520] would you like to take this ticket to modify the

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

[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=17381745#comment-17381745 ] Yun Tang edited comment on FLINK-23367 at 7/16/21, 6:15 AM: This failure is

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

[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=17381745#comment-17381745 ] Yun Tang commented on FLINK-23367: -- This failure is due to not close internal priority queue iterator.

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

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

[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=17381098#comment-17381098 ] Yun Tang commented on FLINK-22528: -- [~alpinegizmo], it seems that I did not fully understand your

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

[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=17380431#comment-17380431 ] Yun Tang commented on FLINK-22722: -- in release-1.13: ef21d506bebee0ac6466d4abe2f844ef7c15cde5 > Add

[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

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