Messages by Thread
-
-
[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
-
[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
-
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
-
Re: [VOTE] Release 1.19.1, release candidate #1
Hong Liang
-
Re: [VOTE] Release 1.19.1, release candidate #1
Xintong Song
-
Re: [VOTE] Release 1.19.1, release candidate #1
Matthias Pohl
-
Re: [VOTE] Release 1.19.1, release candidate #1
Sergey Nuyanzin
-
Re: [VOTE] Release 1.19.1, release candidate #1
Leonard Xu
-
Re: [VOTE] Release 1.19.1, release candidate #1
gongzhongqiang
-
Re: [VOTE] Release 1.19.1, release candidate #1
Hang Ruan
-
Re: [VOTE] Release 1.19.1, release candidate #1
Hong Liang
-
[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
-
[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
-
[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
-
[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
-
[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
-
[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
-
[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
-
[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