[jira] [Assigned] (FLINK-37181) Failed to validate Maven wrapper SHA-256 on MacOS with mvnw

[ https://issues.apache.org/jira/browse/FLINK-37181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37181: - Assignee: Gabor Somogyi > Failed to validate Maven wrapper SHA-256 on MacOS with mvnw >

[jira] [Created] (FLINK-37181) Failed to validate Maven wrapper SHA-256 on MacOS with mvnw

Gabor Somogyi created FLINK-37181: - Summary: Failed to validate Maven wrapper SHA-256 on MacOS with mvnw Key: FLINK-37181 URL: https://issues.apache.org/jira/browse/FLINK-37181 Project: Flink

[jira] [Commented] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates

[ https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912769#comment-17912769 ] Gabor Somogyi commented on FLINK-37109: --- [~lamgary] Thanks for investing such amou

[jira] [Updated] (FLINK-37311) Fix doc generation issues with new version of hugo

[ https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37311: -- Attachment: Screenshot 2025-02-13 at 8.26.55.png > Fix doc generation issues with new version

[jira] [Commented] (FLINK-37311) Fix doc generation issues with new version of hugo

[ https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926693#comment-17926693 ] Gabor Somogyi commented on FLINK-37311: --- I'm doing it on mac where there is no ins

[jira] [Comment Edited] (FLINK-37311) Fix doc generation issues with new version of hugo

[ https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926693#comment-17926693 ] Gabor Somogyi edited comment on FLINK-37311 at 2/13/25 7:28 AM: --

[jira] [Commented] (FLINK-37311) Fix doc generation issues with new version of hugo

[ https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926696#comment-17926696 ] Gabor Somogyi commented on FLINK-37311: --- In short, now the docker uses v0.124.1 an

[jira] [Comment Edited] (FLINK-37311) Fix doc generation issues with new version of hugo

[ https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926696#comment-17926696 ] Gabor Somogyi edited comment on FLINK-37311 at 2/13/25 7:31 AM: --

[jira] [Commented] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates

[ https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927074#comment-17927074 ] Gabor Somogyi commented on FLINK-37109: --- [{{9bcc41d}}|https://github.com/apache/fl

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

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927160#comment-17927160 ] Gabor Somogyi commented on FLINK-23886: --- [~tommyschnabel] can you give me some con

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

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927161#comment-17927161 ] Gabor Somogyi commented on FLINK-23886: --- This question applies to all the peoples

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

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927381#comment-17927381 ] Gabor Somogyi commented on FLINK-23886: --- Thanks for giving some more insights! Hmm

[jira] [Created] (FLINK-37324) RocksDB keys iterator performance improvement

Gabor Somogyi created FLINK-37324: - Summary: RocksDB keys iterator performance improvement Key: FLINK-37324 URL: https://issues.apache.org/jira/browse/FLINK-37324 Project: Flink Issue Type: I

[jira] [Assigned] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates

[ https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37109: - Assignee: Gabor Somogyi > Improve state processor API performance when reading keyed ro

[jira] [Created] (FLINK-37325) SQL connector for keyed savepoint data Chinese documentation

Gabor Somogyi created FLINK-37325: - Summary: SQL connector for keyed savepoint data Chinese documentation Key: FLINK-37325 URL: https://issues.apache.org/jira/browse/FLINK-37325 Project: Flink

[jira] [Closed] (FLINK-37310) SQL connector for keyed savepoint data documentation

[ https://issues.apache.org/jira/browse/FLINK-37310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37310. - > SQL connector for keyed savepoint data documentation > ---

[jira] [Resolved] (FLINK-37310) SQL connector for keyed savepoint data documentation

[ https://issues.apache.org/jira/browse/FLINK-37310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37310. --- Fix Version/s: 2.0.0 Resolution: Fixed [{{4efbc91}}|https://github.com/apache/flink/c

[jira] [Closed] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates

[ https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37109. - > Improve state processor API performance when reading keyed rocksdb state by > allowing duplicates

[jira] [Resolved] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates

[ https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37109. --- Fix Version/s: 2.0.0 1.20.2 Resolution: Fixed > Improve state proc

[jira] [Commented] (FLINK-37109) Improve state processor API performance when reading keyed rocksdb state by allowing duplicates

[ https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927154#comment-17927154 ] Gabor Somogyi commented on FLINK-37109: --- [{{dd3eb7b}}|https://github.com/apache/fl

[jira] [Commented] (FLINK-37311) Fix doc generation issues with new version of hugo

[ https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927526#comment-17927526 ] Gabor Somogyi commented on FLINK-37311: --- I would vote on clean solution, sooner or

[jira] [Commented] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17929114#comment-17929114 ] Gabor Somogyi commented on FLINK-33155: --- Since it's pluggable it's possible. One t

[jira] [Closed] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues

[ https://issues.apache.org/jira/browse/FLINK-37378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37378. - Resolution: Invalid Cloudera internals don't need apache jira. > Yarn log aggregation fails wit

[jira] [Resolved] (FLINK-37363) Make state.backend.type config optional for state SQL connector

[ https://issues.apache.org/jira/browse/FLINK-37363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37363. --- Fix Version/s: 2.1.0 Resolution: Fixed [{{4deb3a1}}|https://github.com/apache/flink/c

[jira] [Updated] (FLINK-37363) Make state.backend.type config optional for state SQL connector

[ https://issues.apache.org/jira/browse/FLINK-37363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37363: -- Summary: Make state.backend.type config optional for state SQL connector (was: Remove confusi

[jira] [Closed] (FLINK-37363) Make state.backend.type config optional for state SQL connector

[ https://issues.apache.org/jira/browse/FLINK-37363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37363. - > Make state.backend.type config optional for state SQL connector >

[jira] [Created] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector

Gabor Somogyi created FLINK-37363: - Summary: Remove confusing and duplicated state.backend.type config from state SQL connector Key: FLINK-37363 URL: https://issues.apache.org/jira/browse/FLINK-37363

[jira] [Updated] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-31238: -- Fix Version/s: 2.0-preview (was: 1.20.0) > Use IngestDB to speed up Roc

[jira] [Updated] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector

[ https://issues.apache.org/jira/browse/FLINK-37363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-37363: -- Affects Version/s: 2.0-preview > Remove confusing and duplicated state.backend.type config fro

[jira] [Commented] (FLINK-37378) Yarn log aggregation fails with Kerberos DT issues

[ https://issues.apache.org/jira/browse/FLINK-37378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17930335#comment-17930335 ] Gabor Somogyi commented on FLINK-37378: --- > I even did not create pr for Flink. Th

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927845#comment-17927845 ] Gabor Somogyi commented on FLINK-31238: --- Seems like 8.10.0-ververica-1.0 is out.

[jira] [Commented] (FLINK-37344) setup_hugo.sh should install the hugo binary only

[ https://issues.apache.org/jira/browse/FLINK-37344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928169#comment-17928169 ] Gabor Somogyi commented on FLINK-37344: --- [{{9a1e986}}|https://github.com/apache/fl

[jira] [Created] (FLINK-37344) setup_hugo.sh should install the hugo binary only

Gabor Somogyi created FLINK-37344: - Summary: setup_hugo.sh should install the hugo binary only Key: FLINK-37344 URL: https://issues.apache.org/jira/browse/FLINK-37344 Project: Flink Issue Typ

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927982#comment-17927982 ] Gabor Somogyi commented on FLINK-31238: --- Ah ok, I'm just looking at that PR but no

[jira] [Closed] (FLINK-37311) Fix doc generation issues with new version of hugo

[ https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37311. - Resolution: Won't Do > Fix doc generation issues with new version of hugo >

[jira] [Commented] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion

[ https://issues.apache.org/jira/browse/FLINK-17971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927993#comment-17927993 ] Gabor Somogyi commented on FLINK-17971: --- FLINK-31238 has added such functionality

[jira] [Resolved] (FLINK-19303) Disable WAL in RocksDB recovery

[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-19303. --- Resolution: Fixed > Disable WAL in RocksDB recovery > --- > >

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927953#comment-17927953 ] Gabor Somogyi commented on FLINK-31238: --- [~mayuehappy] thanks for sharing! What ar

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927954#comment-17927954 ] Gabor Somogyi commented on FLINK-31238: --- I see `ingestExternalFile` and `clipColum

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927988#comment-17927988 ] Gabor Somogyi commented on FLINK-31238: --- 6bf97674b660dbe1cd96b5b0273c3954f2c16fba

[jira] [Comment Edited] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927988#comment-17927988 ] Gabor Somogyi edited comment on FLINK-31238 at 2/18/25 9:14 AM: --

[jira] [Resolved] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-31238. --- Fix Version/s: 1.20.0 Resolution: Fixed > Use IngestDB to speed up Rocksdb rescaling

[jira] [Closed] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-31238. - > Use IngestDB to speed up Rocksdb rescaling recovery > ---

[jira] [Commented] (FLINK-37311) Fix doc generation issues with new version of hugo

[ https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927975#comment-17927975 ] Gabor Somogyi commented on FLINK-37311: --- I've had a deeper look and seems like the

[jira] [Commented] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load

[ https://issues.apache.org/jira/browse/FLINK-17288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927997#comment-17927997 ] Gabor Somogyi commented on FLINK-17288: --- FLINK-31238 has added such functionality

[jira] [Resolved] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion

[ https://issues.apache.org/jira/browse/FLINK-17971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-17971. --- Resolution: Duplicate > Speed up RocksDB bulk loading with SST generation and ingestion > --

[jira] [Resolved] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load

[ https://issues.apache.org/jira/browse/FLINK-17288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-17288. --- Resolution: Duplicate > Speedup loading from savepoints into RocksDB by bulk load >

[jira] [Closed] (FLINK-19303) Disable WAL in RocksDB recovery

[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-19303. - > Disable WAL in RocksDB recovery > --- > > Key: FLINK-1

[jira] [Closed] (FLINK-37398) State processor API blows up with cryptic error when changelog used

[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37398. - > State processor API blows up with cryptic error when changelog used >

[jira] [Resolved] (FLINK-37398) State processor API blows up with cryptic error when changelog used

[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37398. --- Fix Version/s: 2.1.0 Resolution: Fixed [{{940d746}}|https://github.com/apache/flink/c

[jira] [Assigned] (FLINK-37398) State processor API blows up with cryptic error when changelog used

[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37398: - Assignee: Gabor Somogyi > State processor API blows up with cryptic error when changelo

[jira] [Created] (FLINK-37398) State processor API blows up with cryptic error when changelog used

Gabor Somogyi created FLINK-37398: - Summary: State processor API blows up with cryptic error when changelog used Key: FLINK-37398 URL: https://issues.apache.org/jira/browse/FLINK-37398 Project: Flink

[jira] [Created] (FLINK-37407) Add meta information to SQL state connector

Gabor Somogyi created FLINK-37407: - Summary: Add meta information to SQL state connector Key: FLINK-37407 URL: https://issues.apache.org/jira/browse/FLINK-37407 Project: Flink Issue Type: Imp

[jira] [Assigned] (FLINK-37407) Add meta information to SQL state connector

[ https://issues.apache.org/jira/browse/FLINK-37407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37407: - Assignee: Gabor Somogyi > Add meta information to SQL state connector > ---

[jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933830#comment-17933830 ] Gabor Somogyi commented on FLINK-37445: --- Since this is deprecated what is the plan

[jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933862#comment-17933862 ] Gabor Somogyi commented on FLINK-37445: --- Migration requires quite some efforts bec

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934258#comment-17934258 ] Gabor Somogyi commented on FLINK-37460: --- [~gliter] thanks for the detailed explana

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934230#comment-17934230 ] Gabor Somogyi commented on FLINK-37460: --- This sounds severe, can you confirm that

[jira] [Created] (FLINK-37456) Stream data for SQL state connector in case of List and Map state

Gabor Somogyi created FLINK-37456: - Summary: Stream data for SQL state connector in case of List and Map state Key: FLINK-37456 URL: https://issues.apache.org/jira/browse/FLINK-37456 Project: Flink

[jira] [Commented] (FLINK-37445) Migrate InputFormatSourceFunction to the Source V2 API

[ https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933895#comment-17933895 ] Gabor Somogyi commented on FLINK-37445: --- Sounds great! Thanks for your efforts🙂 >

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934265#comment-17934265 ] Gabor Somogyi commented on FLINK-37460: --- Just filed it, plz report back. > Using

[jira] [Commented] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17934231#comment-17934231 ] Gabor Somogyi commented on FLINK-37460: --- [~martijnvisser] thanks for the context,

[jira] [Assigned] (FLINK-37460) Using State Processor API and Kafka Sink with Exactly once delivery leads to org.apache.kafka.common.errors.InvalidPidMappingException

[ https://issues.apache.org/jira/browse/FLINK-37460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-37460: - Assignee: Gabor Somogyi > Using State Processor API and Kafka Sink with Exactly once de

<    2   3   4   5   6   7