dev
Thread
Date
Earlier messages
Messages by Thread
Re: [DISCUSS] FLIP-299 Pub/Sub Lite Connector
Ahmed Hamdy
[jira] [Created] (FLINK-35559) Shading issue cause class conflict
Aleksandr Pilipenko (Jira)
[DISCUSS] FLIP-463: Schema Definition in CREATE TABLE AS Statement
Sergio Pena
[jira] [Created] (FLINK-35558) [docs] "Edit This Page" tool does not follow contribution guidelines
Matt Braymer-Hayes (Jira)
[jira] [Created] (FLINK-35557) MemoryManager only reserves memory per consumer type once
Roman Khachatryan (Jira)
[jira] [Created] (FLINK-35556) Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED
Roman Khachatryan (Jira)
[jira] [Created] (FLINK-35555) Serializing List with null values throws NPE
Zhanghao Chen (Jira)
[ANNOUNCE] Apache flink-connector-kafka 3.2.0 released
Danny Cranmer
[ANNOUNCE] Apache flink-connector-jdbc 3.2.0 released
Danny Cranmer
[RESULT][VOTE] flink-connector-kafka 3.2.0, release candidate #1
Danny Cranmer
[RESULT][VOTE] flink-connector-jdbc 3.2.0, release candidate #1
Danny Cranmer
Re: [RESULT][VOTE] flink-connector-jdbc 3.2.0, release candidate #1
Danny Cranmer
[ANNOUNCE] Apache flink-connector-cassandra 3.2.0 released
Danny Cranmer
[RESULT][VOTE] flink-connector-cassandra 3.2.0, release candidate #1
Danny Cranmer
[ANNOUNCE] Apache flink-connector-aws 4.3.0 released
Danny Cranmer
[RESULT][VOTE] flink-connector-aws 4.3.0, release candidate #2
Danny Cranmer
[jira] [Created] (FLINK-35554) usrlib is not added to classpath when using containers
Josh England (Jira)
[ANNOUNCE] Apache flink-connector-gcp-pubsub 3.1.0 released
Danny Cranmer
[jira] [Created] (FLINK-35553) Integrate newly added trigger interface with checkpointing
Matthias Pohl (Jira)
[jira] [Created] (FLINK-35552) Move CheckpointStatsTracker out of ExecutionGraph into Scheduler
Matthias Pohl (Jira)
[jira] [Created] (FLINK-35551) Introduces RescaleManager#onTrigger endpoint
Matthias Pohl (Jira)
[jira] [Created] (FLINK-35550) Introduce new component RescaleManager
Matthias Pohl (Jira)
[jira] [Created] (FLINK-35549) FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler
Matthias Pohl (Jira)
[RESULT][VOTE] flink-connector-gcp-pubsub 3.1.0, release candidate #1
Danny Cranmer
Request :: delta-flink sample Example/use case
SNEHASISH DUTTA
[VOTE] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
Yuxin Tan
Re: [VOTE] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
Xintong Song
Re: [VOTE] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
Zhu Zhu
Re: [VOTE] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
weijie guo
Re: [VOTE] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
Jim Hughes
Re: [VOTE] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
Jeyhun Karimov
Re: [VOTE] FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
Ahmed Hamdy
[jira] [Created] (FLINK-35548) Add E2E tests for PubSubSinkV2
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-35547) Sources support HybridSource implements
linqigeng (Jira)
Savepoints not considered during failover
Gyula Fóra
Re: Savepoints not considered during failover
Matthias Pohl
Re: Savepoints not considered during failover
Mate Czagany
[jira] [Created] (FLINK-35546) Elasticsearch 8 connector fails fast for non-retryable bulk request items
Mingliang Liu (Jira)
[jira] [Created] (FLINK-35545) Miss 3.0.1 version in snapshot flink-cdc doc version list
Zhongqiang Gong (Jira)
[jira] [Created] (FLINK-35544) No description of Flink Operator in the Deployment of Kubernetes document
linqigeng (Jira)
[DISCUSS] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join
weijie guo
Re: [DISCUSS] FLIP-462: Support Custom Data Distribution for Input Stream of Lookup Join
Xintong Song
Question about v2 committer guarantees
Scott Sandre
[VOTE] Release 1.19.1, release candidate #1
Hong Liang
Re: [VOTE] Release 1.19.1, release candidate #1
Rui Fan
Re: [VOTE] Release 1.19.1, release candidate #1
Xiqian YU
Re: [VOTE] Release 1.19.1, release candidate #1
weijie guo
Re: [VOTE] Release 1.19.1, release candidate #1
Jeyhun Karimov
Re: [VOTE] Release 1.19.1, release candidate #1
Ahmed Hamdy
[jira] [Created] (FLINK-35543) Upgrade Hive 2.3 connector to version 2.3.10
Cheng Pan (Jira)
[jira] [Created] (FLINK-35542) ClassNotFoundException when deserializing CheckpointedOffset
Jan Gurda (Jira)
[ANNOUNCE] Apache flink-connector-mongodb 1.2.0 released
Danny Cranmer
[RESULT][VOTE] flink-connector-mongodb 1.2.0, release candidate #2
Danny Cranmer
[jira] [Created] (FLINK-35541) Introduce retry limiting for AWS connector sinks
Aleksandr Pilipenko (Jira)
[jira] [Created] (FLINK-35540) flink-cdc-pipeline-connector-mysql lost table which database and table with the same name
Qigeng Lin (Jira)
[jira] [Created] (FLINK-35539) The artifactId of flink-migration-test-utils module has a typo
Zhen Wang (Jira)
[jira] [Created] (FLINK-35538) pipeline sink support caseSensitive
melin (Jira)
[jira] [Created] (FLINK-35537) Error parsing list of enum in legacy yaml configuration
Zakelly Lan (Jira)
[Discuss] Non-retriable (partial) errors in Elasticsearch 8 connector
Mingliang Liu
Re: [Discuss] Non-retriable (partial) errors in Elasticsearch 8 connector
Ahmed Hamdy
[jira] [Created] (FLINK-35536) FileSystem sink on S3 produces invalid Avros when compaction is disabled
Juliusz Nadberezny (Jira)
[jira] [Created] (FLINK-35535) Enable benchmark profiling in daily run
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35534) Support profiler for benchmarks
Zakelly Lan (Jira)
[jira] [Created] (FLINK-35533) FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn
Yuxin Tan (Jira)
Poor Load Balancing across TaskManagers for Multiple Kafka Sources
Kevin Lam
Re: Poor Load Balancing across TaskManagers for Multiple Kafka Sources
Kevin Lam
Re: Poor Load Balancing across TaskManagers for Multiple Kafka Sources
Kevin Lam
Re: Poor Load Balancing across TaskManagers for Multiple Kafka Sources
Zhanghao Chen
Re: Poor Load Balancing across TaskManagers for Multiple Kafka Sources
Kevin Lam
[jira] [Created] (FLINK-35532) Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard
Hong Liang Teoh (Jira)
[jira] [Created] (FLINK-35531) Avoid calling hsync in flush method in BaseHadoopFsRecoverableFsDataOutputStream
dzcxzl (Jira)
[jira] [Created] (FLINK-35530) protobuf-format support discard unknow field Improve deserialization performance
JingWei Li (Jira)
[jira] [Created] (FLINK-35529) protobuf-format compatible protobuf bad indentifier
JingWei Li (Jira)
[jira] [Created] (FLINK-35528) Skip execution of interruptible mails when yielding
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-35527) Polish quickstart guide & clean stale links in docs
yux (Jira)
[jira] [Created] (FLINK-35526) Remove deprecated stedolan/jq Docker image from Flink e2e tests
Robert Metzger (Jira)
[ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Piotr Nowojski
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Zakelly Lan
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
weijie guo
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Yun Tang
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Zhanghao Chen
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Jiabao Sun
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Luke Chen
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Yanfei Lei
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Feng Jin
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
xiangyu feng
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Rodrigo Meneses
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Lijie Wang
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Lincoln Lee
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Wei Zhong
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Hangxiang Yu
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Xuannan Su
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Yuxin Tan
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Samrat Deb
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Hang Ruan
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Junrui Lee
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Paul Lam
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Xia Sun
Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui
Yuepeng Pan
[jira] [Created] (FLINK-35525) HDFS delegation token fetched by custom DelegationTokenProvider is not passed to Yarn AM
Zhen Wang (Jira)
[jira] [Created] (FLINK-35524) Clear connections pools when reader exist.
Hongshun Wang (Jira)
[jira] [Created] (FLINK-35523) When using the Hive connector to read a Hive table in Parquet format, a null pointer exception is thrown.
Jichao Wang (Jira)
Re: flink cdc 是否支持oracle rac
Leonard Xu
[jira] [Created] (FLINK-35522) The source task may get stuck after a failover occurs in batch jobs
xingbe (Jira)
[jira] [Created] (FLINK-35521) Flink FileSystem SQL Connector Generating SUCESS File Multiple Times
EMERSON WANG (Jira)
[DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
Matthias Pohl
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
ConradJam
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
Matthias Pohl
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
Rui Fan
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
Matthias Pohl
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
Zakelly Lan
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
Matthias Pohl
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
David Morávek
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
Zakelly Lan
Re: [DISCUSS] FLIP-461: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing
Matthias Pohl
[jira] [Created] (FLINK-35520) Nightly build can't compile as problems were detected from NoticeFileChecker
Weijie Guo (Jira)
[jira] [Created] (FLINK-35519) Flink Job fails with SingleValueAggFunction received more than one element
Dawid Wysakowicz (Jira)
[June 15 Feature Freeze][SUMMARY] Flink 1.20 Release Sync 06/04/2024
weijie guo
[jira] [Created] (FLINK-35518) CI Bot doesn't run on PRs
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-35517) CI pipeline triggered by pull request seems unstable
Weijie Guo (Jira)
[ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Xintong Song
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Rui Fan
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Junrui Lee
Re:[ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Yuepeng Pan
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Yuxin Tan
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Weihua Hu
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Yangze Guo
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Leonard Xu
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Yanfei Lei
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Hang Ruan
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Zhanghao Chen
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Hangxiang Yu
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Yun Tang
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Biao Geng
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
ConradJam
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Lincoln Lee
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Jiabao Sun
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Xuannan Su
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Samrat Deb
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Mingliang Liu
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Shawn Huang
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
gongzhongqiang
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Guowei Ma
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Matthias Pohl
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Ahmed Hamdy
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Abdulquddus Babatunde Ekemode
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Aleksandr Pilipenko
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
spoon_lz
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Jark Wu
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Sergey Nuyanzin
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Zakelly Lan
Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Lijie Wang
Re:Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Wencong Liu
Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Feng Jin
Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo
Jeyhun Karimov
[jira] [Created] (FLINK-35516) Update the Experimental annotation to PublicEvolving for files connector
RocMarshal (Jira)
[jira] [Created] (FLINK-35515) Upgrade hive version to 4.0.0
vikasap (Jira)
[jira] [Created] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace
Zhongqiang Gong (Jira)
[jira] [Created] (FLINK-35513) ArtifactFetchManager unit tests are failing
Elphas Toringepi (Jira)
[jira] [Created] (FLINK-35512) ArtifactFetchManagerTest unit tests fail
Hong Liang Teoh (Jira)
[jira] [Created] (FLINK-35511) Enhance metrics. The incremental and full phases count the number of records separately
melin (Jira)
[jira] [Created] (FLINK-35510) Implement basic incremental checkpoint for ForStStateBackend
Feifan Wang (Jira)
[jira] [Created] (FLINK-35509) Slack community invite link has expired
Ufuk Celebi (Jira)
[jira] [Created] (FLINK-35508) Use OceanBase LTS version Docker image in testing
He Wang (Jira)
[jira] [Created] (FLINK-35507) Support For Individual Job Level Resource Allocation in Session Cluster in k8s
Amarjeet (Jira)
[jira] [Created] (FLINK-35506) disable kafka auto-commit and rely on flink’s checkpointing if both are enabled
elon_X (Jira)
[jira] [Created] (FLINK-35505) RegionFailoverITCase.testMultiRegionFailover has never ever restored state
Weijie Guo (Jira)
Native Kubernetes Task Managers
Alexis Sarda-Espinosa
Re: Native Kubernetes Task Managers
Xintong Song
Re: Native Kubernetes Task Managers
Alexis Sarda-Espinosa
Re: Native Kubernetes Task Managers
Xintong Song
Re: Native Kubernetes Task Managers
Alexis Sarda-Espinosa
Re: Native Kubernetes Task Managers
spoon_lz
[jira] [Created] (FLINK-35504) Improve Elasticsearch 8 connector observability
Mingliang Liu (Jira)
[jira] [Created] (FLINK-35503) OracleE2eITCase fails with error ORA-12528 on Mac M2
Saketh Kurnool (Jira)
[jira] [Created] (FLINK-35502) compress the checkpoint metadata ZK/ETCD HA Services
Ying Z (Jira)
[jira] [Created] (FLINK-35501) Use common thread pools when transferring RocksDB state files
Roman Khachatryan (Jira)
[jira] [Created] (FLINK-35500) DynamoDb SinkWriter fails to delete elements due to key not found
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing
Ryan Skraba (Jira)
[jira] [Created] (FLINK-35498) Unexpected argument name conflict error when do extract method params from udf
lincoln lee (Jira)
[jira] [Created] (FLINK-35497) The wrong enum value was used to get month in timestampDiff
haishui (Jira)
[jira] [Created] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving
RocMarshal (Jira)
[jira] [Created] (FLINK-35495) The native metrics for column family are not reported
Yanfei Lei (Jira)
[jira] [Created] (FLINK-35494) Reorganize sources
Jira
Flink 1.18.2 release date
Yang LI
Re: Flink 1.18.2 release date
weijie guo
[jira] [Created] (FLINK-35493) Make max history age and count configurable for FlinkStateSnapshot resources
Mate Czagany (Jira)
[jira] [Created] (FLINK-35492) Add metrics for FlinkStateSnapshot resources
Mate Czagany (Jira)
[jira] [Created] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules
Muhammet Orazov (Jira)
[jira] [Created] (FLINK-35490) [JUnit5 Migration] Module: Flink CDC flink-cdc-connect/flink-cdc-source-connectors
Muhammet Orazov (Jira)
[jira] [Created] (FLINK-35489) Add capability to set min taskmanager.memory.managed.size when enabling autotuning
Nicolas Fraison (Jira)
Slack Invite
Nelson de Menezes Neto
Re: Slack Invite
gongzhongqiang
Re: Slack Invite
Robert Metzger
Slack invite
Sai Sankeerth Rao
Re: Slack invite
gongzhongqiang
[jira] [Created] (FLINK-35488) DataType Support Geometry Type
Leopold (Jira)
[jira] [Created] (FLINK-35487) ContinuousFileProcessingCheckpointITCase crashed as process exit with code 127
Weijie Guo (Jira)
[jira] [Created] (FLINK-35486) Potential sql expression generation issues on SQL gateway
Xingcan Cui (Jira)
[jira] [Created] (FLINK-35485) JobMaster failed with "the job xx has not been finished"
Xingcan Cui (Jira)
Earlier messages