[jira] [Commented] (FLINK-28867) Parquet reader support nested type in array/map type

[ https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905510#comment-17905510 ] Nicolas Ferrario commented on FLINK-28867: -- Same issue here on Flink 1.17.2, an

[jira] [Commented] (FLINK-33039) Avro Specific Record Logical timestamp is not serialized in Parquet

[ https://issues.apache.org/jira/browse/FLINK-33039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874152#comment-17874152 ] Nicolas Ferrario commented on FLINK-33039: -- Same here. It also happens when rea

[jira] [Closed] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Ferrario closed FLINK-35720. Resolution: Not A Problem > flink-connector-kafka fails to restore from checkpoint when us

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863018#comment-17863018 ] Nicolas Ferrario commented on FLINK-35720: -- Hi [~martijnvisser], I am very sorr

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862468#comment-17862468 ] Nicolas Ferrario commented on FLINK-35720: -- [~martijnvisser] yes, Kafka certain

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862432#comment-17862432 ] Nicolas Ferrario commented on FLINK-35720: -- [~martijnvisser] I'm using Flink 1.

[jira] [Comment Edited] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862432#comment-17862432 ] Nicolas Ferrario edited comment on FLINK-35720 at 7/2/24 12:48 PM: ---

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862402#comment-17862402 ] Nicolas Ferrario commented on FLINK-35720: -- Hi [~martijnvisser] , those are the

[jira] [Commented] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

[ https://issues.apache.org/jira/browse/FLINK-35720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861372#comment-17861372 ] Nicolas Ferrario commented on FLINK-35720: -- Hi [~martijnvisser], this also happ

[jira] [Created] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

Nicolas Ferrario created FLINK-35720: Summary: flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink Key: FLINK-35720 URL: https://issues.apache.org/jira/browse/FLINK-35720

[jira] [Commented] (FLINK-28057) LD_PRELOAD is hardcoded to x64 on flink-docker

[ https://issues.apache.org/jira/browse/FLINK-28057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597702#comment-17597702 ] Nicolas Ferrario commented on FLINK-28057: -- [~chesnay] this happens because the

[jira] [Commented] (FLINK-28057) LD_PRELOAD is hardcoded to x64 on flink-docker

[ https://issues.apache.org/jira/browse/FLINK-28057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572626#comment-17572626 ] Nicolas Ferrario commented on FLINK-28057: -- Hi [~yunta] [https://github.com/ap

[jira] [Commented] (FLINK-28057) LD_PRELOAD is hardcoded to x64 on flink-docker

[ https://issues.apache.org/jira/browse/FLINK-28057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554111#comment-17554111 ] Nicolas Ferrario commented on FLINK-28057: -- Hi [~yunta]. Flink is building offi

[jira] [Updated] (FLINK-28057) LD_PRELOAD is hardcoded to x64 on flink-docker

[ https://issues.apache.org/jira/browse/FLINK-28057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Ferrario updated FLINK-28057: - Description: ARM images are not using jemalloc because LD_PRELOAD is hardcoded to use an

[jira] [Created] (FLINK-28057) LD_PRELOAD is hardcoded to x64 on flink-docker

Nicolas Ferrario created FLINK-28057: Summary: LD_PRELOAD is hardcoded to x64 on flink-docker Key: FLINK-28057 URL: https://issues.apache.org/jira/browse/FLINK-28057 Project: Flink Issue

[jira] [Commented] (FLINK-5964) Change TypeSerializers to allow construction of immutable types

[ https://issues.apache.org/jira/browse/FLINK-5964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436499#comment-17436499 ] Nicolas Ferrario commented on FLINK-5964: - Agree. We started to replace our Scala

[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=17436498#comment-17436498 ] Nicolas Ferrario commented on FLINK-21321: -- This would be really useful for us.

[jira] [Commented] (FLINK-21409) Add Avro to DataTypes & Serialization docs

[ https://issues.apache.org/jira/browse/FLINK-21409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436496#comment-17436496 ] Nicolas Ferrario commented on FLINK-21409: -- I think this is important. We learn

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427194#comment-17427194 ] Nicolas Ferrario commented on FLINK-22533: -- [~igal] just tested and it works gr

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426259#comment-17426259 ] Nicolas Ferrario commented on FLINK-22533: -- Hi [~igal], I just tested it and it

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17424504#comment-17424504 ] Nicolas Ferrario commented on FLINK-22533: -- [~igal] sorry, didn't have a chance

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420837#comment-17420837 ] Nicolas Ferrario commented on FLINK-22533: -- [~igal] awesome, I'll make sure to

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420729#comment-17420729 ] Nicolas Ferrario commented on FLINK-22533: -- Sounds great, thanks! > Allow crea

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420714#comment-17420714 ] Nicolas Ferrario commented on FLINK-22533: -- Hi [~igal], That'd be sweet!! We'r

[jira] [Commented] (FLINK-22533) Allow creating custom metrics

[ https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17419254#comment-17419254 ] Nicolas Ferrario commented on FLINK-22533: -- This would be really useful to us!

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352240#comment-17352240 ] Nicolas Ferrario commented on FLINK-18229: -- Hi [~xintongsong], thank you very m

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17352093#comment-17352093 ] Nicolas Ferrario commented on FLINK-18229: -- Hey [~xintongsong], what's the stat

[jira] [Created] (FLINK-21825) AvroInputFormat doesn't honor -1 length on FileInputSplits

Nicolas Ferrario created FLINK-21825: Summary: AvroInputFormat doesn't honor -1 length on FileInputSplits Key: FLINK-21825 URL: https://issues.apache.org/jira/browse/FLINK-21825 Project: Flink