[jira] [Commented] (FLINK-18263) Allow external checkpoints to be persisted even when the job is in "Finished" state.

[ https://issues.apache.org/jira/browse/FLINK-18263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133854#comment-17133854 ] Yun Tang commented on FLINK-18263: -- I think this future depends on how we give definiti

[jira] [Commented] (FLINK-18503) bug occurs when `HeapReducingState#add` method handles null

[ https://issues.apache.org/jira/browse/FLINK-18503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155055#comment-17155055 ] Yun Tang commented on FLINK-18503: -- I think this issue is duplicate with FLINK-15424 >

[jira] [Commented] (FLINK-18573) plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has no dir named "services" , but "service"

[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156477#comment-17156477 ] Yun Tang commented on FLINK-18573: -- [~OneCloud] Have you ever checked whether the flink

[jira] [Commented] (FLINK-18573) plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has no dir named "services" , but "service"

[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17156550#comment-17156550 ] Yun Tang commented on FLINK-18573: -- [~OneCloud] Yes, you're right, this is indeed a bug

[jira] [Updated] (FLINK-18573) plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has no dir named "services" , but "service"

[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-18573: - Fix Version/s: 1.11.1 > plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has no dir >

[jira] [Updated] (FLINK-18573) plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has no dir named "services" , but "service"

[ https://issues.apache.org/jira/browse/FLINK-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-18573: - Priority: Blocker (was: Major) > plugins/metrics-influx/flink-metrics-influxdb-1.11.0.jar META-INF has

[jira] [Commented] (FLINK-18554) Memory exceeds taskmanager.memory.process.size when enabling mmap_read for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-18554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157178#comment-17157178 ] Yun Tang commented on FLINK-18554: -- [~kien_truong] From my point of view, it's not easy

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160869#comment-17160869 ] Yun Tang commented on FLINK-18637: -- [~oripwk], will you meet the error when creating sa

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161104#comment-17161104 ] Yun Tang commented on FLINK-18637: -- [~oripwk] What's the max parallelism of your job? I

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161229#comment-17161229 ] Yun Tang commented on FLINK-18637: -- [~oripwk] If you really setMaxParallelism as 512 ex

[jira] [Comment Edited] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161229#comment-17161229 ] Yun Tang edited comment on FLINK-18637 at 7/20/20, 5:03 PM:

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161403#comment-17161403 ] Yun Tang commented on FLINK-18637: -- [~oripwk] Could you please paste the code where you

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161444#comment-17161444 ] Yun Tang commented on FLINK-18637: -- [~oripwk], I think I have found the root cause: the

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161821#comment-17161821 ] Yun Tang commented on FLINK-18637: -- [~oripwk] This is because {{RocksDBSerializedCompos

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161917#comment-17161917 ] Yun Tang commented on FLINK-18637: -- [~oripwk] Resume from previous checkpoint would not

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

[ https://issues.apache.org/jira/browse/FLINK-18335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163183#comment-17163183 ] Yun Tang commented on FLINK-18335: -- [~rmetzger] I cannot produce this locally and I als

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163186#comment-17163186 ] Yun Tang commented on FLINK-18637: -- You could use another field to get the value from v

[jira] [Commented] (FLINK-18712) Flink RocksDB statebackend memory leak issue

[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165194#comment-17165194 ] Yun Tang commented on FLINK-18712: -- [~lio_sy], do you have a simple job to reproduce th

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173320#comment-17173320 ] Yun Tang commented on FLINK-7289: - [~itsharshonly], you could call [DBOptions#setUseDire

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1720#comment-1720 ] Yun Tang commented on FLINK-19481: -- [~baugarten], from my point of view, we could still

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211228#comment-17211228 ] Yun Tang commented on FLINK-19481: -- If so, why we still must need to support native GCS

[jira] [Commented] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211627#comment-17211627 ] Yun Tang commented on FLINK-19553: -- I think this deserves to fix, [~liufangliang] would

[jira] [Commented] (FLINK-19481) Add support for a flink native GCS FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211631#comment-17211631 ] Yun Tang commented on FLINK-19481: -- [~jgrier] Sounds reasonable to me. [~rmetzger] wha

[jira] [Commented] (FLINK-19594) SubTasks start index don't unified and may confuse users

[ https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212823#comment-17212823 ] Yun Tang commented on FLINK-19594: -- This is caused by [job-checkpoints-subtask.compone

[jira] [Assigned] (FLINK-19125) Avoid memory fragmentation when running flink docker image

[ https://issues.apache.org/jira/browse/FLINK-19125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-19125: Assignee: Yun Tang > Avoid memory fragmentation when running flink docker image > ---

[jira] [Assigned] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-19553: Assignee: liufangliang > The format of checkpoint Completion Time and Failure Time should be chan

[jira] [Commented] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212897#comment-17212897 ] Yun Tang commented on FLINK-19553: -- [~liufangliang] Already assign to you, please go ah

[jira] [Updated] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-19553: - Fix Version/s: 1.12.0 > The format of checkpoint Completion Time and Failure Time should be changed > f

[jira] [Commented] (FLINK-19594) SubTasks start index don't unified and may confuse users

[ https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213040#comment-17213040 ] Yun Tang commented on FLINK-19594: -- [~chesnay] As I wrote in previous comment, the inco

[jira] [Commented] (FLINK-19642) RocksDBListStatePerformanceTest.testRocksDbListStateAPIs is instable

[ https://issues.apache.org/jira/browse/FLINK-19642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213908#comment-17213908 ] Yun Tang commented on FLINK-19642: -- [~dian.fu] we have already agree to drop those test

[jira] [Commented] (FLINK-18712) Flink RocksDB statebackend memory leak issue

[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215313#comment-17215313 ] Yun Tang commented on FLINK-18712: -- [~Caesar] Jemalloc could help resolve memory fragme

[jira] [Closed] (FLINK-18373) Drop performance unit tests in RocksDB state backend module

[ https://issues.apache.org/jira/browse/FLINK-18373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-18373. Resolution: Fixed > Drop performance unit tests in RocksDB state backend module >

[jira] [Commented] (FLINK-18373) Drop performance unit tests in RocksDB state backend module

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

[jira] [Commented] (FLINK-19596) Do not recover CompletedCheckpointStore on each failover

[ https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216530#comment-17216530 ] Yun Tang commented on FLINK-19596: -- [~wind_ljy] this issue duplicates with FLINK-6984 a

[jira] [Created] (FLINK-19710) Avoid performance regression introduced by thread-local keyword of FRocksDB

Yun Tang created FLINK-19710: Summary: Avoid performance regression introduced by thread-local keyword of FRocksDB Key: FLINK-19710 URL: https://issues.apache.org/jira/browse/FLINK-19710 Project: Flink

[jira] [Assigned] (FLINK-6984) Do not recover CompletedCheckpointStore on every restore

[ https://issues.apache.org/jira/browse/FLINK-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-6984: --- Assignee: Jiayi Liao (was: Yun Tang) > Do not recover CompletedCheckpointStore on every restore > -

[jira] [Updated] (FLINK-19710) Avoid performance regression introduced by thread-local keyword of FRocksDB

[ https://issues.apache.org/jira/browse/FLINK-19710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-19710: - Component/s: Runtime / State Backends > Avoid performance regression introduced by thread-local keyword

[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=17216572#comment-17216572 ] Yun Tang commented on FLINK-14482: -- Thanks for [~liyu] 's reminder, I have created the

[jira] [Commented] (FLINK-19619) Test failed in Azure For EmulatedPubSubSourceTest

[ https://issues.apache.org/jira/browse/FLINK-19619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216576#comment-17216576 ] Yun Tang commented on FLINK-19619: -- Another instance: https://dev.azure.com/apache-fli

[jira] [Assigned] (FLINK-19594) SubTasks start index don't unified and may confuse users

[ https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-19594: Assignee: Zoltan Ivanfi > SubTasks start index don't unified and may confuse users >

[jira] [Assigned] (FLINK-19594) SubTasks start index don't unified and may confuse users

[ https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-19594: Assignee: zlzhang0122 (was: Zoltan Ivanfi) > SubTasks start index don't unified and may confuse

[jira] [Commented] (FLINK-20298) Replace usage of {{site.baseurl}} in flink documentation

[ https://issues.apache.org/jira/browse/FLINK-20298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237799#comment-17237799 ] Yun Tang commented on FLINK-20298: -- What's the relationship with FLINK-19998? > Replac

[jira] [Commented] (FLINK-19998) Invalid Links in docs

[ https://issues.apache.org/jira/browse/FLINK-19998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239033#comment-17239033 ] Yun Tang commented on FLINK-19998: -- merged in master c008907d2a629449c8d0ad9725d13b0604

[jira] [Resolved] (FLINK-19998) Invalid Links in docs

[ https://issues.apache.org/jira/browse/FLINK-19998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-19998. -- Resolution: Fixed > Invalid Links in docs > - > > Key: FLINK-19998

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239490#comment-17239490 ] Yun Tang commented on FLINK-20376: -- I think the reported message has given enough hint:

[jira] [Created] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

Yun Tang created FLINK-20420: Summary: ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds Key: FLINK-20420 URL: https://issues.apache.org/jira/browse/FLINK-20420 Project: Flink

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17244922#comment-17244922 ] Yun Tang commented on FLINK-19710: -- [~jherico] Thanks for your care and sorry for not u

[jira] [Commented] (FLINK-20480) Methods from CheckpointedFunction interface in FlinkKafkaConsumerBase are set to final

[ https://issues.apache.org/jira/browse/FLINK-20480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244929#comment-17244929 ] Yun Tang commented on FLINK-20480: -- I think setting {{CheckpointedFunction}} interfaces

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17244945#comment-17244945 ] Yun Tang commented on FLINK-19710: -- Yes, I also heard voice to support ARM platform. As

[jira] [Assigned] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

[ https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-20554: Assignee: mehdi amini > The Checkpointed Data Size of the Latest Completed Checkpoint is incorrec

[jira] [Assigned] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

[ https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-20554: Assignee: ming li (was: mehdi amini) > The Checkpointed Data Size of the Latest Completed Checkp

[jira] [Commented] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

[ https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247073#comment-17247073 ] Yun Tang commented on FLINK-20554: -- I think you're right and I have assigned this ticke

[jira] [Updated] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

[ https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-20554: - Fix Version/s: 1.12.1 1.11.3 > The Checkpointed Data Size of the Latest Completed Che

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247143#comment-17247143 ] Yun Tang commented on FLINK-20376: -- [~Partha Mishra] Could you share the {{_metadata}}

[jira] [Commented] (FLINK-19911) add read buffer for input stream

[ https://issues.apache.org/jira/browse/FLINK-19911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247209#comment-17247209 ] Yun Tang commented on FLINK-19911: -- Since previous PR has been closed after more guys i

[jira] [Commented] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

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

[jira] [Resolved] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

[ https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-20554. -- Resolution: Fixed > The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly > di

[jira] [Commented] (FLINK-19462) Checkpoint statistics for unfinished task snapshots

[ https://issues.apache.org/jira/browse/FLINK-19462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247728#comment-17247728 ] Yun Tang commented on FLINK-19462: -- [~roman_khachatryan] I cannot view your documentati

[jira] [Commented] (FLINK-20581) java.lang.NoClassDefFoundError: Could not initialize class org.apache.flink.util.JavaGcCleanerWrapper

[ https://issues.apache.org/jira/browse/FLINK-20581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248723#comment-17248723 ] Yun Tang commented on FLINK-20581: -- [~Lonie] Have you ever checked whether class {{org

[jira] [Commented] (FLINK-20209) Add missing checkpoint configuration to Flink UI

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

[jira] [Resolved] (FLINK-20209) Add missing checkpoint configuration to Flink UI

[ https://issues.apache.org/jira/browse/FLINK-20209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-20209. -- Resolution: Fixed > Add missing checkpoint configuration to Flink UI > ---

[jira] [Updated] (FLINK-20209) Add missing checkpoint configuration to Flink UI

[ https://issues.apache.org/jira/browse/FLINK-20209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-20209: - Fix Version/s: 1.12.1 1.13.0 > Add missing checkpoint configuration to Flink UI > ---

[jira] [Assigned] (FLINK-19013) Log start/end of state restoration

[ https://issues.apache.org/jira/browse/FLINK-19013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-19013: Assignee: Yun Tang > Log start/end of state restoration > -- > >

[jira] [Commented] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267014#comment-17267014 ] Yun Tang commented on FLINK-12358: -- [~trohrmann] I had a draft two years ago. However,

[jira] [Commented] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267131#comment-17267131 ] Yun Tang commented on FLINK-12358: -- [~trohrmann] Sorry for I misunderstood the role of

[jira] [Updated] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-12358: - Fix Version/s: 1.13.0 > Verify whether rest documenation needs to be updated when building pull > reque

[jira] [Created] (FLINK-21048) Refactor documentation related to switch memory allocator

Yun Tang created FLINK-21048: Summary: Refactor documentation related to switch memory allocator Key: FLINK-21048 URL: https://issues.apache.org/jira/browse/FLINK-21048 Project: Flink Issue Type

[jira] [Commented] (FLINK-17511) "RocksDB Memory Management end-to-end test" fails with "Current block cache usage 202123272 larger than expected memory limit 200000000"

[ https://issues.apache.org/jira/browse/FLINK-17511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268519#comment-17268519 ] Yun Tang commented on FLINK-17511: -- As discussed with Stephen last time, I planed to ve

[jira] [Commented] (FLINK-21056) Streaming checkpointing is failing occasionally

[ https://issues.apache.org/jira/browse/FLINK-21056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269075#comment-17269075 ] Yun Tang commented on FLINK-21056: -- [~nvolynets] From the exception message "{{Timeout

[jira] [Closed] (FLINK-21056) Streaming checkpointing is failing occasionally

[ https://issues.apache.org/jira/browse/FLINK-21056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-21056. Resolution: Invalid > Streaming checkpointing is failing occasionally > --

[jira] [Updated] (FLINK-21057) Streaming checkpointing with small interval leads app to hang

[ https://issues.apache.org/jira/browse/FLINK-21057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21057: - Component/s: (was: Runtime / Checkpointing) Connectors / Kafka > Streaming checkpoi

[jira] [Assigned] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data

[ https://issues.apache.org/jira/browse/FLINK-21073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-21073: Assignee: Yun Tang > Mention that RocksDB ignores equals/hashCode because it works on binary data

[jira] [Commented] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271029#comment-17271029 ] Yun Tang commented on FLINK-21104: -- Another instances: https://myasuka.visualstudio.com

[jira] [Comment Edited] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271029#comment-17271029 ] Yun Tang edited comment on FLINK-21104 at 1/25/21, 2:33 AM:

[jira] [Created] (FLINK-21119) Building Flink Azure FS Hadoop hangs during python CI

Yun Tang created FLINK-21119: Summary: Building Flink Azure FS Hadoop hangs during python CI Key: FLINK-21119 URL: https://issues.apache.org/jira/browse/FLINK-21119 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-21104) UnalignedCheckpointITCase.execute failed with "IllegalStateException"

[ https://issues.apache.org/jira/browse/FLINK-21104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272577#comment-17272577 ] Yun Tang commented on FLINK-21104: -- Another instance: https://myasuka.visualstudio.com

[jira] [Commented] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

[ https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17273480#comment-17273480 ] Yun Tang commented on FLINK-20675: -- Merged in master with three commits: f421c6f72b91b7

[jira] [Updated] (FLINK-21034) Rework jemalloc switch to use an environment variable

[ https://issues.apache.org/jira/browse/FLINK-21034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21034: - Release Note: The docker switch for disabling the jemalloc memory allocator has been reworked from a scr

[jira] [Updated] (FLINK-21048) Refactor documentation related to switch memory allocator

[ https://issues.apache.org/jira/browse/FLINK-21048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21048: - Fix Version/s: 1.12.2 1.13.0 > Refactor documentation related to switch memory alloca

[jira] [Resolved] (FLINK-21048) Refactor documentation related to switch memory allocator

[ https://issues.apache.org/jira/browse/FLINK-21048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-21048. -- Resolution: Fixed > Refactor documentation related to switch memory allocator > -

[jira] [Commented] (FLINK-21048) Refactor documentation related to switch memory allocator

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

[jira] [Commented] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

[ https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274118#comment-17274118 ] Yun Tang commented on FLINK-20675: -- Merged in release-1.12 with two commits: d1f8f41b77

[jira] [Commented] (FLINK-16443) Fix wrong fix for user-code CheckpointExceptions

[ https://issues.apache.org/jira/browse/FLINK-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274119#comment-17274119 ] Yun Tang commented on FLINK-16443: -- Merged into release-1.12 so that FLINK-20675 could

[jira] [Updated] (FLINK-16443) Fix wrong fix for user-code CheckpointExceptions

[ https://issues.apache.org/jira/browse/FLINK-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-16443: - Fix Version/s: 1.12.2 > Fix wrong fix for user-code CheckpointExceptions > -

[jira] [Updated] (FLINK-16443) Fix wrong fix for user-code CheckpointExceptions

[ https://issues.apache.org/jira/browse/FLINK-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-16443: - Fix Version/s: 1.11.4 > Fix wrong fix for user-code CheckpointExceptions > -

[jira] [Commented] (FLINK-16443) Fix wrong fix for user-code CheckpointExceptions

[ https://issues.apache.org/jira/browse/FLINK-16443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274222#comment-17274222 ] Yun Tang commented on FLINK-16443: -- Merged into release-1.11 20c6ed1e2301f578d2ab784fa

[jira] [Resolved] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

[ https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-20675. -- Resolution: Fixed > Asynchronous checkpoint failure would not fail the job anymore > -

[jira] [Commented] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

[ https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17274223#comment-17274223 ] Yun Tang commented on FLINK-20675: -- Merged into release-1.11 with two commits: 43fa9bfe

[jira] [Commented] (FLINK-21030) Broken job restart for job with disjoint graph

[ https://issues.apache.org/jira/browse/FLINK-21030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17276965#comment-17276965 ] Yun Tang commented on FLINK-21030: -- I think returning the complete future to checkpoint

[jira] [Commented] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277074#comment-17277074 ] Yun Tang commented on FLINK-21213: -- [~AHeise] thanks for reminder, I think changing thi

[jira] [Created] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint

Yun Tang created FLINK-21241: Summary: E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint Key: FLINK-21241 URL: https://issues.apache.org/jira/browse/FLINK-21

[jira] [Updated] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21213: - Fix Version/s: 1.13.0 1.12.2 1.11.4 > e2e test fail with 'As task

[jira] [Updated] (FLINK-21213) e2e test fail with 'As task is already not running, no longer decline checkpoint'

[ https://issues.apache.org/jira/browse/FLINK-21213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21213: - Component/s: (was: Connectors / ElasticSearch) Runtime / Task Runti

[jira] [Closed] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-15318. Resolution: Fixed > RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le >

[jira] [Commented] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17279285#comment-17279285 ] Yun Tang commented on FLINK-15318: -- [~maguowei] These tests are dropped in FLINK-18373

[jira] [Updated] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-15318: - Fix Version/s: 1.12.0 > RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le > --

[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=17281569#comment-17281569 ] Yun Tang commented on FLINK-21321: -- I think this is an interesting idea. Though I have

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

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

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

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

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

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

<    2   3   4   5   6   7   8   9   10   11   >