dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Created] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window
Jinzhong Li (Jira)
[jira] [Created] (FLINK-35068) Introduce built-in serialization support for Set
Zhanghao Chen (Jira)
[jira] [Created] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.
Hongshun Wang (Jira)
[jira] [Created] (FLINK-35066) TwoInputOperator in IterationBody cannot use keyBy
Yunfeng Zhou (Jira)
[jira] [Created] (FLINK-35065) Add numFiredTimers and numFiredTimersPerSecond metrics
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-35064) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict
chendaping (Jira)
[jira] [Created] (FLINK-35063) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict
chendaping (Jira)
[DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0
Xuannan Su
Re: [DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0
Zakelly Lan
Re: [DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0
Xuannan Su
Re: [DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0
Muhammet Orazov
Re: [DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0
Rui Fan
Re: [DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0
Rui Fan
Re: [DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0
Xuannan Su
Re: [DISCUSSION] FLIP-442: FLIP-442: General Improvement to Configuration for Flink 2.0
Xuannan Su
[jira] [Created] (FLINK-35062) Migrate RewriteMultiJoinConditionRule
Jacky Lau (Jira)
[jira] [Created] (FLINK-35061) Migrate TemporalJoinUtil
Jacky Lau (Jira)
[jira] [Created] (FLINK-35060) Provide compatibility of old CheckpointMode for connector testing framework
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35059) Bump org.postgresql:postgresql from 42.5.1 to 42.5.5 in flink-connector-jdbc
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-35058) Encountered change event for table db.table whose schema isn't known to this connector
MOBIN (Jira)
[jira] [Created] (FLINK-35057) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink jdbc connector
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-35056) when initial sqlserver table that
yandufeng (Jira)
[jira] [Created] (FLINK-35055) Flink CDC connector release contains jar with incompatible licenses
Xiqian YU (Jira)
[jira] [Created] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule
Jacky Lau (Jira)
[VOTE] FLIP-399: Flink Connector Doris
wudi
Re: [VOTE] FLIP-399: Flink Connector Doris
Yuepeng Pan
Re: [VOTE] FLIP-399: Flink Connector Doris
Ahmed Hamdy
Re: [VOTE] FLIP-399: Flink Connector Doris
Ferenc Csaky
Re: [VOTE] FLIP-399: Flink Connector Doris
Robert Metzger
Re: [VOTE] FLIP-399: Flink Connector Doris
Muhammet Orazov
Re: [VOTE] FLIP-399: Flink Connector Doris
Leonard Xu
Re: [VOTE] FLIP-399: Flink Connector Doris
Jiabao Sun
Re: [VOTE] FLIP-399: Flink Connector Doris
gongzhongqiang
Re: [VOTE] FLIP-399: Flink Connector Doris
Feng Jin
Re: [VOTE] FLIP-399: Flink Connector Doris
Jing Ge
Re: [VOTE] FLIP-399: Flink Connector Doris
Martijn Visser
Re: [VOTE] FLIP-399: Flink Connector Doris
Hang Ruan
Re: [VOTE] FLIP-399: Flink Connector Doris
Samrat Deb
Re: [VOTE] FLIP-399: Flink Connector Doris
Yanquan Lv
Re: [VOTE] FLIP-399: Flink Connector Doris
Aleksandr Pilipenko
Re: [VOTE] FLIP-399: Flink Connector Doris
Samrat Deb
[jira] [Created] (FLINK-35053) TIMESTAMP with TIME ZONE not supported by JDBC connector for Postgres
Pietro (Jira)
[jira] [Created] (FLINK-35052) Webhook validator should reject unsupported Flink versions
Alexander Fedulov (Jira)
[jira] [Created] (FLINK-35051) Weird priorities when processing unaligned checkpoints
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-35050) Remove Lazy Initialization of DynamoDbBeanElementConverter
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-35049) Implement Async State API for ForStStateBackend
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35048) Implement all methods of AsyncKeyedStateBakend
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35047) Introduce ForStStateBackend
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35046) Introduce New KeyedStateBackend related Async interfaces
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35045) Introduce ForStFileSystem to support reading and writing with ByteBuffer
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35044) Introduce statebackend-forst module
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35043) Release beta version of ForSt
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost
Weijie Guo (Jira)
[jira] [Created] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
Weijie Guo (Jira)
[jira] [Created] (FLINK-35040) The performance of serializerHeavyString regresses since April 3
Rui Fan (Jira)
[jira] [Created] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed
JJJJude (Jira)
[jira] [Created] (FLINK-35038) Bump test dependency org.yaml:snakeyaml to 2.2
Ufuk Celebi (Jira)
[jira] [Created] (FLINK-35037) Optimize uniqueKeys and upsertKeys inference of windows with ROW_NUMBER
yisha zhou (Jira)
[jira] [Created] (FLINK-35036) Flink CDC Job cancel with savepoint failed
Fly365 (Jira)
[jira] [Created] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode
yuanfenghu (Jira)
[jira] [Created] (FLINK-35034) codegen compile error raised when use kafka connector and protobuf format
yufeng.sun (Jira)
[jira] [Created] (FLINK-35031) Event timer firing under async execution model
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35030) Introduce Epoch Manager for watermark under async execution
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35029) Store timer in JVM heap when async execution enabled
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35028) Processing timer firing under async execution model
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35026) Introduce async-state configurations
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35024) Implement record order preservation and buffering of AsyncExecutionController
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35023) YARNApplicationITCase failed on Azure
Weijie Guo (Jira)
[jira] [Created] (FLINK-35022) Add TypeInformed Element Converter for DynamoDbSink
Ahmed Hamdy (Jira)
[DISCUSS] FLIP-438: Amazon SQS Sink Connector
Dhingra, Priya
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Ahmed Hamdy
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Samrat Deb
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Dhingra, Priya
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Dhingra, Priya
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Ahmed Hamdy
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Dhingra, Priya
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Samrat Deb
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Dhingra, Priya
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Aleksandr Pilipenko
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Muhammet Orazov
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Danny Cranmer
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Dhingra, Priya
Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector
Muhammet Orazov
[jira] [Created] (FLINK-35021) AggregateQueryOperations produces wrong asSerializableString representation
Dawid Wysakowicz (Jira)
Two potential bugs in Flink ML
Komal M
Re: Two potential bugs in Flink ML
Yunfeng Zhou
Re: Two potential bugs in Flink ML
Komal M
Re: Two potential bugs in Flink ML
Yunfeng Zhou
Re: Two potential bugs in Flink ML
Komal M
[jira] [Created] (FLINK-35020) Model Catalog implementation in Hive etc
Hao Li (Jira)
[jira] [Created] (FLINK-35019) Support show create model syntax
Hao Li (Jira)
[jira] [Created] (FLINK-35017) ML_PREDICT function
Hao Li (Jira)
[jira] [Created] (FLINK-35018) ML_EVALUATE function
Hao Li (Jira)
[jira] [Created] (FLINK-35016) Catalog changes for model CRUD
Hao Li (Jira)
[jira] [Created] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration
Zhenqiu Huang (Jira)
[jira] [Created] (FLINK-35014) SqlNode to operation conversion for models
Hao Li (Jira)
[jira] [Created] (FLINK-35013) Support temporary model
Hao Li (Jira)
[jira] [Created] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35011) The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector
Jiabao Sun (Jira)
[RESULT][VOTE] FLIP-437: Support ML Models in Flink SQL
Hao Li
[jira] [Created] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector
Zhongqiang Gong (Jira)
[jira] [Created] (FLINK-35009) Change on getTransitivePredecessors breaks connectors
Martijn Visser (Jira)
[jira] [Created] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector
Martijn Visser (Jira)
[jira] [Created] (FLINK-35007) Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT
Martijn Visser (Jira)
[jira] [Created] (FLINK-35006) Use try with-resource for StandaloneAutoscalerExecutor
Kirill Plugatarev (Jira)
[FYI] The Azure CI for PRs is currently not triggered
Matthias Pohl
Re: [FYI] The Azure CI for PRs is currently not triggered
lorenzo affetti
Re: [FYI] The Azure CI for PRs is currently not triggered
weijie guo
[IMPROVEMENT] Using ServiceLoader to load ExtendedParseStrategy
Naveen Kumar
Community over Code EU 2024: Start planning your trip!
Ryan Skraba
[jira] [Created] (FLINK-35005) SqlClientITCase Failed to build JobManager image
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35004) SqlGatewayE2ECase could not start container
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35003) Update zookeeper to 3.8.4 to address CVE-2024-23944
Shilun Fan (Jira)
Parallelism is not working as expected for Apache Beam Code Running on a Flink Kubernetes Cluster
Dipak Tandel
Participate in the ASF 25th Anniversary Campaign
Brian Proffitt
[jira] [Created] (FLINK-35002) GitHub action/upload-artifact@v4 can timeout
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35001) Avoid scientific notation for DOUBLE to STRING
Timo Walther (Jira)
[jira] [Created] (FLINK-35000) PullRequest template doesn't use the correct format to refer to the testing code convention
Matthias Pohl (Jira)
[jira] [Created] (FLINK-34999) PR CI stopped operating
Matthias Pohl (Jira)
[jira] [Created] (FLINK-34998) Wordcount on Docker test failed on azure
Weijie Guo (Jira)
[jira] [Created] (FLINK-34997) PyFlink YARN per-job on Docker test failed on azure
Weijie Guo (Jira)
[jira] [Created] (FLINK-34996) Deserializer can't be instantiated when connector-kafka installed into Flink Libs
Hugo Gu (Jira)
Inquiry Regarding Azure Pipelines
Yisha Zhou
Re: Inquiry Regarding Azure Pipelines
Robert Metzger
Re: [External] Inquiry Regarding Azure Pipelines
Yisha Zhou
Re: [External] Inquiry Regarding Azure Pipelines
Robert Metzger
Re: [External] Inquiry Regarding Azure Pipelines
Yisha Zhou
Re: Inquiry Regarding Azure Pipelines
Muhammet Orazov
[jira] [Created] (FLINK-34995) flink kafka connector source stuck when partition leader invalid
yansuopeng (Jira)
[jira] [Created] (FLINK-34994) JobIDLoggingITCase fails because of "checkpoint confirmation for unknown task"
Roman Khachatryan (Jira)
[jira] [Created] (FLINK-34993) Support Model CRUD in parser
Hao Li (Jira)
[jira] [Created] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL
Hao Li (Jira)
[jira] [Created] (FLINK-34991) Flink Operator ClassPath Race Condition Bug
Ryan van Huuksloot (Jira)
[jira] [Created] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table
Xin Gong (Jira)
[jira] [Created] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project
Matthias Pohl (Jira)
[jira] [Created] (FLINK-34988) Class loading issues in JDK17 and JDK21
Matthias Pohl (Jira)
[jira] [Created] (FLINK-34987) Introduce Internal State Interface for Async API
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-34986) Basic framework for async execution of state
Zakelly Lan (Jira)
[jira] [Created] (FLINK-34985) It doesn't support to access fields by name for map function in thread mode
Dian Fu (Jira)
[jira] [Created] (FLINK-34984) Disaggregated State Storage and Management (Umbrella FLIP)
Yuan Mei (Jira)
[RESULT][VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)
Yuan Mei
[jira] [Created] (FLINK-34983) Hive param sink.partition-commit.policy.kind default value is not work in stream mode
yunfan (Jira)
[jira] [Created] (FLINK-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State
Jinzhong Li (Jira)
[jira] [Created] (FLINK-34981) FLIP-426: Grouping Remote State Access
Jinzhong Li (Jira)
[jira] [Created] (FLINK-34980) Translate overview document into Chinese
Caican Cai (Jira)
[jira] [Created] (FLINK-34978) Introduce Asynchronous State APIs
Zakelly Lan (Jira)
[jira] [Created] (FLINK-34979) Implement State Future and related utilities
Zakelly Lan (Jira)
[jira] [Created] (FLINK-34977) FLIP-433: State Access on DataStream API V2
Weijie Guo (Jira)
[jira] [Created] (FLINK-34976) LD_PRELOAD environment may not be effective after su to flink user
xiaogang zhou (Jira)
[jira] [Created] (FLINK-34975) FLIP-427: ForSt - Disaggregated state Store
Hangxiang Yu (Jira)
[jira] [Created] (FLINK-34974) FLIP-424: Asynchronous State APIs
Zakelly Lan (Jira)
[jira] [Created] (FLINK-34973) FLIP-423: Disaggregated State Storage and Management
Zakelly Lan (Jira)
[RESULT][VOTE] FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State
Jinzhong Li
[RESULT][VOTE] FLIP-424: Asynchronous State APIs
Zakelly Lan
[RESULT][VOTE] FLIP-426: Grouping Remote State Access
Jinzhong Li
[RESULT][VOTE] FLIP-427: Disaggregated state Store
Hangxiang Yu
[jira] [Created] (FLINK-34972) MigrationTestsSnapshotGenerator does not work properly for all subclasses of SnapshotMigrationTestBase
lincoln lee (Jira)
[RESULT][VOTE] FLIP-425: Asynchronous Execution Model
Yanfei Lei
[jira] [Created] (FLINK-34971) Add the function of History Server cleaning job archives regularly
dengxaing (Jira)
[jira] [Created] (FLINK-34970) Translate architecture documents into Chinese
Caican Cai (Jira)
[jira] [Created] (FLINK-34969) Error due to Flink CDC using deprecated flink-conf.yaml in light of Flink's full YAML 1.2 support since version 1.19
skymilong (Jira)
[jira] [Created] (FLINK-34968) Update flink-web copyright to 2024
Yu Chen (Jira)
[jira] [Created] (FLINK-34967) Update Website copyright footer to 2024
Yun Tang (Jira)
[jira] [Created] (FLINK-34966) Support to read snapshot by table partitions in MySQL CDC Source
He Wang (Jira)
[DISCUSS] FLIP-438: Make Flink's Hadoop and YARN configuration probing consistent
Venkatakrishnan Sowrirajan
Re: [DISCUSS] FLIP-438: Make Flink's Hadoop and YARN configuration probing consistent
Ferenc Csaky
Re: [DISCUSS] FLIP-438: Make Flink's Hadoop and YARN configuration probing consistent
Venkatakrishnan Sowrirajan
Re: [DISCUSS] FLIP-438: Make Flink's Hadoop and YARN configuration probing consistent
Ferenc Csaky
[VOTE] FLIP-437: Support ML Models in Flink SQL
Hao Li
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
Timo Walther
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
Jark Wu
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
Yu Chen
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
Piotr Nowojski
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
Leonard Xu
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
Martijn Visser
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
David Radley
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
David Morávek
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
Hao Li
Re: [VOTE] FLIP-437: Support ML Models in Flink SQL
Hao Li
[jira] [Created] (FLINK-34965) optimize code of ServiceType
bai sui (Jira)
[jira] [Created] (FLINK-34964) ScheduledTask leak in registering the processing timer
zoucao (Jira)
[jira] [Created] (FLINK-34963) Compilation error in ProcessFunctionTestHarnesses
Ryan Skraba (Jira)
Iceberg table maintenance
Péter Váry
RE: Iceberg table maintenance
wenjin
Re: Iceberg table maintenance
Péter Váry
RE: Re: Iceberg table maintenance
wenjin
Re: Re: Iceberg table maintenance
Péter Váry
Iceberg table maintenance
Péter Váry
Re: Iceberg table maintenance
Ahmed Hamdy
[jira] [Created] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata
Yubiao Feng (Jira)
[jira] [Created] (FLINK-34961) GitHub Actions statistcs can be monitored per workflow name
Matthias Pohl (Jira)
[jira] [Created] (FLINK-34960) NullPointerException while applying parallelism overrides for session jobs
Kunal Rohitas (Jira)
[VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)
Yuan Mei
Re: [VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)
Piotr Nowojski
Re:Re: [VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)
Feifan Wang
Re: Re: [VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)
Jing Ge
Re: Re: [VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)
Rui Fan
Re: Re: [VOTE] FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)
Xintong Song
Earlier messages
Later messages