[jira] [Updated] (FLINK-36190) Completed checkpoint's file cannot be discarded due to network issues

[ https://issues.apache.org/jira/browse/FLINK-36190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-36190: -- Description: I have a job that uses RocksDB with incremental checkpointing, wh

[jira] [Updated] (FLINK-36190) Completed checkpoint's file cannot be discarded due to network issues

[ https://issues.apache.org/jira/browse/FLINK-36190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-36190: -- Description: I have a job that uses RocksDB with incremental checkpointing, wh

[jira] [Updated] (FLINK-36190) Completed checkpoint's file cannot be discarded due to network issues

[ https://issues.apache.org/jira/browse/FLINK-36190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-36190: -- Description: I have a job that uses RocksDB with incremental checkpointing, wh

[jira] [Updated] (FLINK-36190) Completed checkpoint's file cannot be discarded due to network issues

[ https://issues.apache.org/jira/browse/FLINK-36190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-36190: -- Description: I have a job that uses RocksDB with incremental checkpointing, wh

[jira] [Created] (FLINK-36190) Completed checkpoint's file cannot be discarded due to network issues

Alexis Sarda-Espinosa created FLINK-36190: - Summary: Completed checkpoint's file cannot be discarded due to network issues Key: FLINK-36190 URL: https://issues.apache.org/jira/browse/FLINK-36190

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871595#comment-17871595 ] Alexis Sarda-Espinosa commented on FLINK-25920: --- Hi Arvid, unfortunately I

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865154#comment-17865154 ] Alexis Sarda-Espinosa edited comment on FLINK-25920 at 7/11/24 4:53 PM: --

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865154#comment-17865154 ] Alexis Sarda-Espinosa commented on FLINK-25920: --- [^trace_again.zip] This

[jira] [Updated] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-25920: -- Attachment: trace_again.zip > Allow receiving updates of CommittableSummary >

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864710#comment-17864710 ] Alexis Sarda-Espinosa commented on FLINK-25920: --- We don't use transactions

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864369#comment-17864369 ] Alexis Sarda-Espinosa commented on FLINK-25920: --- [^trace.zip] Oddly enoug

[jira] [Updated] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-25920: -- Attachment: trace.zip > Allow receiving updates of CommittableSummary > --

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864102#comment-17864102 ] Alexis Sarda-Espinosa commented on FLINK-25920: --- Hi Arvid, are there speci

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856606#comment-17856606 ] Alexis Sarda-Espinosa edited comment on FLINK-25920 at 6/20/24 9:02 PM: --

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856606#comment-17856606 ] Alexis Sarda-Espinosa commented on FLINK-25920: --- Sure thing, I still have

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855519#comment-17855519 ] Alexis Sarda-Espinosa commented on FLINK-25920: --- I'm also seeing this in F

[jira] [Comment Edited] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855232#comment-17855232 ] Alexis Sarda-Espinosa edited comment on FLINK-30530 at 6/15/24 1:38 PM: --

[jira] [Commented] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855232#comment-17855232 ] Alexis Sarda-Espinosa commented on FLINK-30530: --- Wouldn't this be a good w

[jira] [Comment Edited] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823102#comment-17823102 ] Alexis Sarda-Espinosa edited comment on FLINK-34400 at 3/4/24 9:32 AM: ---

[jira] [Commented] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823102#comment-17823102 ] Alexis Sarda-Espinosa commented on FLINK-34400: --- Hi [~fanrui], sorry for t

[jira] [Comment Edited] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815253#comment-17815253 ] Alexis Sarda-Espinosa edited comment on FLINK-34400 at 2/7/24 10:50 PM: --

[jira] [Comment Edited] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815253#comment-17815253 ] Alexis Sarda-Espinosa edited comment on FLINK-34400 at 2/7/24 11:27 AM: --

[jira] [Comment Edited] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815253#comment-17815253 ] Alexis Sarda-Espinosa edited comment on FLINK-34400 at 2/7/24 11:27 AM: --

[jira] [Comment Edited] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815253#comment-17815253 ] Alexis Sarda-Espinosa edited comment on FLINK-34400 at 2/7/24 11:26 AM: --

[jira] [Commented] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815253#comment-17815253 ] Alexis Sarda-Espinosa commented on FLINK-34400: --- Ah, let me clarify. The s

[jira] [Comment Edited] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815253#comment-17815253 ] Alexis Sarda-Espinosa edited comment on FLINK-34400 at 2/7/24 11:24 AM: --

[jira] [Commented] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815239#comment-17815239 ] Alexis Sarda-Espinosa commented on FLINK-34400: --- I actually thought idlene

[jira] [Comment Edited] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815196#comment-17815196 ] Alexis Sarda-Espinosa edited comment on FLINK-34400 at 2/7/24 9:38 AM: ---

[jira] [Comment Edited] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815196#comment-17815196 ] Alexis Sarda-Espinosa edited comment on FLINK-34400 at 2/7/24 9:33 AM: ---

[jira] [Commented] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815196#comment-17815196 ] Alexis Sarda-Espinosa commented on FLINK-34400: --- Hi [~fanrui], yes I'm tes

[jira] [Updated] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34400: -- Attachment: alignment_lags.png > Kafka sources with watermark alignment sporad

[jira] [Commented] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814996#comment-17814996 ] Alexis Sarda-Espinosa commented on FLINK-34400: --- I'm using Kafka connector

[jira] [Updated] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34400: -- Description: I have 2 Kafka sources that read from different topics. I have as

[jira] [Updated] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34400: -- Description: I have 2 Kafka sources that read from different topics. I have as

[jira] [Updated] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34400: -- Description: I have 2 Kafka sources that read from different topics. I have as

[jira] [Created] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

Alexis Sarda-Espinosa created FLINK-34400: - Summary: Kafka sources with watermark alignment sporadically stop consuming Key: FLINK-34400 URL: https://issues.apache.org/jira/browse/FLINK-34400

[jira] [Updated] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34325: -- Description: I have a job that uses broadcast state to maintain a cache of req

[jira] [Updated] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34325: -- Description: I have a job that uses broadcast state to maintain a cache of req

[jira] [Commented] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813238#comment-17813238 ] Alexis Sarda-Espinosa commented on FLINK-34325: --- I will say that, while I

[jira] [Comment Edited] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813238#comment-17813238 ] Alexis Sarda-Espinosa edited comment on FLINK-34325 at 2/1/24 1:49 PM: ---

[jira] [Updated] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34325: -- Description: I have a job that uses broadcast state to maintain a cache of req

[jira] [Updated] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-34325: -- Summary: Inconsistent state with data loss after OutOfMemoryError (was: Incon

[jira] [Comment Edited] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812760#comment-17812760 ] Alexis Sarda-Espinosa edited comment on FLINK-34325 at 1/31/24 3:46 PM: --

[jira] [Comment Edited] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812760#comment-17812760 ] Alexis Sarda-Espinosa edited comment on FLINK-34325 at 1/31/24 3:41 PM: --

[jira] [Commented] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812760#comment-17812760 ] Alexis Sarda-Espinosa commented on FLINK-34325: --- I just did a quick test w

[jira] [Comment Edited] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812752#comment-17812752 ] Alexis Sarda-Espinosa edited comment on FLINK-34325 at 1/31/24 3:33 PM: --

[jira] [Commented] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

[ https://issues.apache.org/jira/browse/FLINK-34325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812752#comment-17812752 ] Alexis Sarda-Espinosa commented on FLINK-34325: --- I had interpreted that as

[jira] [Created] (FLINK-34325) Inconsistent state with data loss after OutOfMemoryError in Job Manager

Alexis Sarda-Espinosa created FLINK-34325: - Summary: Inconsistent state with data loss after OutOfMemoryError in Job Manager Key: FLINK-34325 URL: https://issues.apache.org/jira/browse/FLINK-34325

[jira] [Commented] (FLINK-24150) Support to configure cpu resource request and limit in pod template

[ https://issues.apache.org/jira/browse/FLINK-24150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17793105#comment-17793105 ] Alexis Sarda-Espinosa commented on FLINK-24150: --- Sorry, I don't follow. An

[jira] [Commented] (FLINK-24150) Support to configure cpu resource request and limit in pod template

[ https://issues.apache.org/jira/browse/FLINK-24150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792886#comment-17792886 ] Alexis Sarda-Espinosa commented on FLINK-24150: --- This was indeed implement

[jira] [Comment Edited] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761031#comment-17761031 ] Alexis Sarda-Espinosa edited comment on FLINK-16686 at 9/4/23 1:30 PM: ---

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761031#comment-17761031 ] Alexis Sarda-Espinosa commented on FLINK-16686: --- cc [~yunta] I wanted to

[jira] [Comment Edited] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662 ] Alexis Sarda-Espinosa edited comment on FLINK-32241 at 7/10/23 3:45 PM: --

[jira] [Comment Edited] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662 ] Alexis Sarda-Espinosa edited comment on FLINK-32241 at 7/10/23 3:27 PM: --

[jira] [Commented] (FLINK-32241) UnsupportedFileSystemException when using the ABFS Hadoop driver for checkpointing in Flink 1.17

[ https://issues.apache.org/jira/browse/FLINK-32241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741662#comment-17741662 ] Alexis Sarda-Espinosa commented on FLINK-32241: --- [I am seeing this same is

[jira] [Commented] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727498#comment-17727498 ] Alexis Sarda-Espinosa commented on FLINK-28853: --- I guess FLINK-31519 can b

[jira] [Commented] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17712648#comment-17712648 ] Alexis Sarda-Espinosa commented on FLINK-31305: --- I understand the external

[jira] [Commented] (FLINK-31140) Load additional dependencies in operator classpath

[ https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694408#comment-17694408 ] Alexis Sarda-Espinosa commented on FLINK-31140: --- It does, I just wanted to

[jira] [Updated] (FLINK-21763) Extend Data Stream's batch mode to handle partitioning/grouping/ordering

[ https://issues.apache.org/jira/browse/FLINK-21763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-21763: -- Description: In the DataSet API, an undocumented (?) feature is using [SplitD

[jira] [Commented] (FLINK-24150) Support to configure cpu resource request and limit in pod template

[ https://issues.apache.org/jira/browse/FLINK-24150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694197#comment-17694197 ] Alexis Sarda-Espinosa commented on FLINK-24150: --- [~wangyang0918] this has

[jira] [Commented] (FLINK-31140) Load additional dependencies in operator classpath

[ https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694194#comment-17694194 ] Alexis Sarda-Espinosa commented on FLINK-31140: --- If you don't mind me aski

[jira] [Comment Edited] (FLINK-30306) Audit utils can expose potentially sensitive information

[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679760#comment-17679760 ] Alexis Sarda-Espinosa edited comment on FLINK-30306 at 1/23/23 11:04 AM: -

[jira] [Commented] (FLINK-30306) Audit utils can expose potentially sensitive information

[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17679760#comment-17679760 ] Alexis Sarda-Espinosa commented on FLINK-30306: --- A few more thoughts from

[jira] [Updated] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30638: -- Priority: Minor (was: Critical) > Operator doesn't forward allowNonRestoredSt

[jira] [Commented] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675635#comment-17675635 ] Alexis Sarda-Espinosa commented on FLINK-30638: --- All right, thanks. I unde

[jira] [Commented] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675626#comment-17675626 ] Alexis Sarda-Espinosa commented on FLINK-30638: --- I see. Do you know if thi

[jira] [Commented] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675616#comment-17675616 ] Alexis Sarda-Espinosa commented on FLINK-30638: --- When you say the flag is

[jira] [Updated] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30638: -- Description: My Flink image is currently based on 1.15, and I'm using last-sta

[jira] [Updated] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30638: -- Description: My Flink image is currently based on 1.15, and I'm using last-sta

[jira] [Updated] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30638: -- Description: My Flink image is currently based on 1.15, I'm using last-state u

[jira] [Updated] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30638: -- Description: My Flink image is currently based on 1.15, I'm using last-state u

[jira] [Updated] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30638: -- Attachment: flink-kubernetes-operator_json.txt > Operator doesn't forward allo

[jira] [Created] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

Alexis Sarda-Espinosa created FLINK-30638: - Summary: Operator doesn't forward allowNonRestoredState flag Key: FLINK-30638 URL: https://issues.apache.org/jira/browse/FLINK-30638 Project: Flink

[jira] [Closed] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa closed FLINK-30305. - Resolution: Later > Operator deletes HA metadata during stateful upgrade, preven

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644056#comment-17644056 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- I see, I guess I'll close

[jira] [Comment Edited] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644047#comment-17644047 ] Alexis Sarda-Espinosa edited comment on FLINK-30305 at 12/6/22 10:37 PM: -

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644047#comment-17644047 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- So, for example, if HA is

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643919#comment-17643919 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- All right, understood. Th

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643599#comment-17643599 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- I briefly looked through

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643566#comment-17643566 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- I understand why this is

[jira] [Comment Edited] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643494#comment-17643494 ] Alexis Sarda-Espinosa edited comment on FLINK-30305 at 12/5/22 6:17 PM: --

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643494#comment-17643494 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- Since I saw "Deleting Job

[jira] [Comment Edited] (FLINK-30306) Audit utils can expose potentially sensitive information

[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643485#comment-17643485 ] Alexis Sarda-Espinosa edited comment on FLINK-30306 at 12/5/22 6:05 PM: --

[jira] [Commented] (FLINK-30306) Audit utils can expose potentially sensitive information

[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643485#comment-17643485 ] Alexis Sarda-Espinosa commented on FLINK-30306: --- In my case, there are som

[jira] [Updated] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30305: -- Description: I was testing resiliency of jobs with Kubernetes-based HA enabled

[jira] [Created] (FLINK-30306) Audit utils can expose potentially sensitive information

Alexis Sarda-Espinosa created FLINK-30306: - Summary: Audit utils can expose potentially sensitive information Key: FLINK-30306 URL: https://issues.apache.org/jira/browse/FLINK-30306 Project: Fl

[jira] [Created] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

Alexis Sarda-Espinosa created FLINK-30305: - Summary: Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback Key: FLINK-30305 URL: https://issues.apache.org/jira/browse/F

[jira] [Updated] (FLINK-30115) Include log4j-layout-template-json jar in the default operator image

[ https://issues.apache.org/jira/browse/FLINK-30115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30115: -- Description: Ussing logging processors/forwarders in Kubernetes is pretty comm

[jira] [Created] (FLINK-30115) Include log4j-layout-template-json jar in the default operator image

Alexis Sarda-Espinosa created FLINK-30115: - Summary: Include log4j-layout-template-json jar in the default operator image Key: FLINK-30115 URL: https://issues.apache.org/jira/browse/FLINK-30115

[jira] [Updated] (FLINK-30115) Include log4j-layout-template-json jar in the default operator image

[ https://issues.apache.org/jira/browse/FLINK-30115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30115: -- Issue Type: Improvement (was: Bug) > Include log4j-layout-template-json jar i

[jira] [Closed] (FLINK-29716) Separate slf4j jar in the lib folder from the distribution

[ https://issues.apache.org/jira/browse/FLINK-29716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa closed FLINK-29716. - Resolution: Won't Do > Separate slf4j jar in the lib folder from the distributio

[jira] [Commented] (FLINK-29716) Separate slf4j jar in the lib folder from the distribution

[ https://issues.apache.org/jira/browse/FLINK-29716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625336#comment-17625336 ] Alexis Sarda-Espinosa commented on FLINK-29716: --- I see, all right. > Sepa

[jira] [Created] (FLINK-29716) Separate slf4j jar in the lib folder from the distribution

Alexis Sarda-Espinosa created FLINK-29716: - Summary: Separate slf4j jar in the lib folder from the distribution Key: FLINK-29716 URL: https://issues.apache.org/jira/browse/FLINK-29716 Project:

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558119#comment-17558119 ] Alexis Sarda-Espinosa commented on FLINK-16686: --- It seems I spoke to soon,

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557997#comment-17557997 ] Alexis Sarda-Espinosa commented on FLINK-16686: --- The test I did was using

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555307#comment-17555307 ] Alexis Sarda-Espinosa commented on FLINK-16686: --- [~yunta] I did some limit

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552732#comment-17552732 ] Alexis Sarda-Espinosa commented on FLINK-16686: --- The reported problems wer

[jira] [Commented] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend

[ https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540227#comment-17540227 ] Alexis Sarda-Espinosa commented on FLINK-27504: --- What I meant is that ther

[jira] [Commented] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend

[ https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539448#comment-17539448 ] Alexis Sarda-Espinosa commented on FLINK-27504: --- Thanks a lot [~yunta], ju

[jira] [Commented] (FLINK-27504) State compaction not happening with sliding window and incremental RocksDB backend

[ https://issues.apache.org/jira/browse/FLINK-27504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537788#comment-17537788 ] Alexis Sarda-Espinosa commented on FLINK-27504: --- But that wouldn't be a pr

  1   2   >