dev  

Messages by Thread

• [jira] [Created] (FLINK-39579) Fix s3.sse.kms.encryption-context config in native s3 connector Gabor Somogyi (Jira)
• [VOTE] Release 2.2.1, release candidate #2 Sergey Nuyanzin
  • RE: [VOTE] Release 2.2.1, release candidate #2 wenjin
  • Re: [VOTE] Release 2.2.1, release candidate #2 Piotr Przybylski
  • Re: [VOTE] Release 2.2.1, release candidate #2 Gustavo de Morais
  • Re: [VOTE] Release 2.2.1, release candidate #2 Gustavo de Morais
  • Re: [VOTE] Release 2.2.1, release candidate #2 Sergey Nuyanzin
• [jira] [Created] (FLINK-39578) Missing py.typed in PyFlink wheel prevents type checking with mypy Florian Vazelle (Jira)
• [jira] [Created] (FLINK-39577) Reuse Calcite's COALESCE to apply simplifications from RexSimplify Sergey Nuyanzin (Jira)
• [DISCUSS] Planning Flink CDC 3.7 release Xiqian YU
  • Re: [DISCUSS] Planning Flink CDC 3.7 release Leonard Xu
• [jira] [Created] (FLINK-39576) Add new PTF StaticArgumentTrait#NO_PASS_THROUGH Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39575) Fix output rowtype in StreamPhysicalProcessTableFunction.toUdfCall when table arg is not first Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39574) Support TO_CHANGELOG retract stream to retract stream with set semantics Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39573) Build documentation CI workflow fails with startup_failure due to burnett01/rsync-deployments action not allowed yuan (Jira)
• [jira] [Created] (FLINK-39571) Improve Flink Kubernetes Operator documentation coverage Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed Biao Geng (Jira)
• [jira] [Created] (FLINK-39570) Update Flink Shaded dependencies Mate Czagany (Jira)
• [jira] [Created] (FLINK-39568) Decouple YAML built-in AI Function and model providers Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39569) YAML pipeline supports HLS live-streaming video source Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39567) Add blob support in Paimon pipeline sink Yanquan Lv (Jira)
• [jira] [Created] (FLINK-39566) [runtime-web] Add checkpoint duration Gantt view Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39565) Eliminate maven build warnings across all modules Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39564) Make ScalingRealizer overrides idempotent Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39563) upgrade paimon to 1.4.1 peiyu (Jira)
• [jira] [Created] (FLINK-39562) Upgrade Netty to 4.2.12.Final Mate Czagany (Jira)
• [VOTE] Release 2.0.2, release candidate #4 Sergey Nuyanzin
  • Re: [VOTE] Release 2.0.2, release candidate #4 Mate Czagany
  • Re: [VOTE] Release 2.0.2, release candidate #4 Gustavo de Morais
  • Re: [VOTE] Release 2.0.2, release candidate #4 Fabian Hueske
  • Re: [VOTE] Release 2.0.2, release candidate #4 Timo Walther
  • Re: [VOTE] Release 2.0.2, release candidate #4 Yuepeng Pan
  • Re: [VOTE] Release 2.0.2, release candidate #4 Yuepeng Pan
  • Re: [VOTE] Release 2.0.2, release candidate #4 Rui Fan
  • Re: [VOTE] Release 2.0.2, release candidate #4 Yanquan Lv
  • Re: [VOTE] Release 2.0.2, release candidate #4 Sergey Nuyanzin
• [jira] [Created] (FLINK-39561) Extend sensitive key redaction with missing access key patterns and user-configurable additional keys Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-39560) [PROPOSAL] Allow custom, pre-configured AWS S3 clients to be injected into new Native S3 filesystem Badma Ochirov (Jira)
• [jira] [Created] (FLINK-39559) SessionReconciler.recoverSession() creates JobManager Deployment without ownerReferences, causing unrecoverable MISSING / AlreadyExists loop Krzysztof Palka (Jira)
• Re: [DISCUSS] FLIP-545: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
• [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Robert Metzger
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing zl z
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Gustavo de Morais
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Leonard Xu
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yaroslav Tkachenko
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Jark Wu
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Gen Luo
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing FeatZhang
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yong Fang
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing 熊饶饶
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing zihao chen
  • Re:Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing zhangjiaogg
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Xintong Song
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Lincoln Lee
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Jiangang Liu
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Martijn Visser
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Martijn Visser
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Yuan Mei
  • RE: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing David Radley
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Dian Fu
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing FeatZhang
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Roman Khachatryan
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Gen Luo
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Gustavo de Morais
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Martijn Visser
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Zhu Zhu
  • Re: [DISCUSS] FLIP-577: AI-Native Flink — An Umbrella Proposal for Multimodal Data Processing Guowei Ma
• [VOTE] Release 2.2.1, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 2.2.1, release candidate #1 Sergey Nuyanzin
• [jira] [Created] (FLINK-39558) LogicalUnnestRule produces incorrect TableFunctionScan rowType, masking nullability and breaking LEFT JOIN UNNEST Jim Hughes (Jira)
• [jira] [Created] (FLINK-39557) Invalid multi-release JAR for flink-shaded-jackson Piotr Przybylski (Jira)
• [DISCUSS] Make file path optional in COMPILE PLAN Luca Castelli via dev
• [jira] [Created] (FLINK-39556) Make file path optional in COMPILE PLAN to return plan inline as a result set Luca Castelli (Jira)
• [DISCUSS] Hive 4 support for Flink Hive connector (FLINK-35515) Lalwani, Jayesh
• Flink Kubernetes Operator 1.15.0 release planning Gyula Fóra
  • Re: Flink Kubernetes Operator 1.15.0 release planning Gabor Somogyi
  • Re: Flink Kubernetes Operator 1.15.0 release planning Ferenc Csaky
  • Re: Flink Kubernetes Operator 1.15.0 release planning Peter Huang
  • Re: Flink Kubernetes Operator 1.15.0 release planning Ryan van Huuksloot via dev
  • Re: Flink Kubernetes Operator 1.15.0 release planning Gyula Fóra
• [jira] [Created] (FLINK-39555) FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39554) Support multiple custom autoscaler evaluators with deterministic ordering Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39553) Support OpenTelemetry metric reporter Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39552) Add native-s3-fs in DIRECTLY_SUPPORTED_FILESYSTEM Samrat Deb (Jira)
• [jira] [Created] (FLINK-39551) Fix the styling of the ignored badge in the rescale history subpage Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39550) Fix the tab order on the job page Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39549) Compute OBSERVED_TPR for non-source vertices behind a feature flag for Operator Autoscaler Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39548) CommonExecTableSourceScan uses physical row type instead of output type for upsert source key partitioning JingWei Li (Jira)
• [jira] [Created] (FLINK-39547) User-provided Scala library breaks table-planner Piotr Przybylski (Jira)
• [jira] [Created] (FLINK-39546) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Samrat Deb (Jira)
• [jira] [Created] (FLINK-39543) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Samrat Deb (Jira)
• [jira] [Created] (FLINK-39544) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Samrat Deb (Jira)
• [jira] [Created] (FLINK-39545) Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics Samrat Deb (Jira)
• [jira] [Created] (FLINK-39542) Upgrade to avro 1.11.5 Samrat Deb (Jira)
• [jira] [Created] (FLINK-39541) Improve operator metrics documentation and bundle additional metric reporters Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39540) Kinesis Connector - EFO Issue when resharding - IllegalArgumentException Ryan Pelaez (Jira)
• [jira] [Created] (FLINK-39539) Extend planner's Agents.md with more detailed information for our internal table module CDC processing Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39537) Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39538) Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG Ramin Gharib (Jira)
• [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause FeatZhang
  • Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause Timo Walther
  • Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause Ryan van Huuksloot via dev
  • Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause FeatZhang
  • Re: [DISCUSS] Declarative Error Handling in Flink SQL via ON ERROR Clause Robin Moffatt via dev
• [jira] [Created] (FLINK-39536) HTTP Connector Deprecated method HttpSinkWriter David Radley (Jira)
• [jira] [Created] (FLINK-39535) Improve Unit Test & coverage Samrat Deb (Jira)
• [jira] [Created] (FLINK-39534) Upgrade pemja to 0.5.7 Wenjin Xie (Jira)
• [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric Rahul Bhattacharya
  • Re: [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric Gyula Fóra
  • Re: [DISCUSS] FLIP-XXX: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu
• Jira Account Request Han Li
• [jira] [Created] (FLINK-39533) Use abort() instead of drain on close/seek when remaining bytes exceed threshold in NativeS3InputStream Samrat Deb (Jira)
• [jira] [Created] (FLINK-39532) Python AsyncScalarFunctionOperation has race condition when using Cython coder Liu Liu (Jira)
• [jira] [Created] (FLINK-39531) ScalarFunctionSplitter extracts the same Python/Async UDF call multiple times Liu Liu (Jira)
• [jira] [Created] (FLINK-39530) Native S3 connector detects s3 compatible servers wrong without any workaround Gabor Somogyi (Jira)
• [ANNOUNCE] New Apache Flink Committer - Peter Huang Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Ramin Gharib
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang David Radley
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Gustavo de Morais
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Rodrigo Meneses
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Samrat Deb
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Poorvank Bhatia
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Hao Li
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Swapnal Varma
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang 吴晓军
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Sharath
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Hang Ruan
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Jark Wu
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Yuepeng Pan
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Sergey Nuyanzin
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Aleksandr Savonin
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Yanquan Lv
  • Re: [ANNOUNCE] New Apache Flink Committer - Peter Huang Weiqing Yang
• [jira] [Created] (FLINK-39529) Extend planner's Agents.md with more detailed SQL to operator lifecycle Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39528) Upgrade Apache Arrow Java in flink-python Mate Czagany (Jira)
• [jira] [Created] (FLINK-39527) [JUnit5 Migration] Module: flink-end-to-end-tests Mate Czagany (Jira)
• [jira] [Created] (FLINK-39526) Ever-growing checkpoint size in CROSS JOIN with inline VALUE clause causes checkpointing failure Fred Teunissen (Jira)
• [jira] [Created] (FLINK-39525) Release Testing: Verify FLIP-560: Application Capability Enhancement Yi Zhang (Jira)
• [jira] [Created] (FLINK-39524) Integrate OutputWriter into filterAndRewrite flow Rui Fan (Jira)
• [jira] [Created] (FLINK-39523) Support streaming addInputData for spilled recovery data Rui Fan (Jira)
• [jira] [Created] (FLINK-39522) Adapt input channels to consume from RecoveredBufferStore Rui Fan (Jira)
• [jira] [Created] (FLINK-39521) Add OutputWriter for post-filter record dispatch Rui Fan (Jira)
• [jira] [Created] (FLINK-39520) Add spill file I/O and RecoveredBufferStore Rui Fan (Jira)
• [jira] [Created] (FLINK-39519) Allocate pre-filter source buffers from heap in filtering mode Rui Fan (Jira)
• [jira] [Created] (FLINK-39518) Upgrade web-dashboard dependencies to resolve remaining npm advisories Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39517) Resolve SemVer-compatible npm advisories in web-dashboard Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39516) [web dashboard] Address npm security advisories in flink-runtime-web web-dashboard Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39515) Add Restore Tests and fix compiled plan restoration for TO and FROM Changelog Gustavo de Morais (Jira)
• [SUMMARY] Flink 2.3 release sync Hao Li
• [jira] [Created] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal Xin Gao (Jira)
• [jira] [Created] (FLINK-39513) CheckpointCoordinator.restoreInitialCheckpointIfPresent ignores allowNonRestoredState Ryan van Huuksloot (Jira)
• [jira] [Created] (FLINK-39512) Extend plugin interface with default open and close function Zhenqiu Huang (Jira)
• [jira] [Created] (FLINK-39511) FLIP-543: Support Customized Autoscale Algorithm Dennis-Mircea Ciupitu (Jira)
• [RESULT][VOTE] FLIP-574 Metadata Filter Push-Down for Table Sources Jim Hughes via dev
• [VOTE] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler Dennis-Mircea Ciupitu
  • Re: [VOTE] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler Gyula Fóra
  • Re: [VOTE] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler Ryan van Huuksloot via dev
  • Re: [VOTE] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler Márton Balassi
  • Re: [VOTE] FLIP-575: Scaling Executor Plugin SPI for Flink Autoscaler Peter Huang
• [jira] [Created] (FLINK-39510) Add Chinese translation about AI-assisted contributions Martijn Visser (Jira)
• [jira] [Created] (FLINK-39509) Mutating webhook produce spurious object modifications on no-op patches Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39507) Cluster health check should run on terminal / failed jobs Gyula Fora (Jira)
• [jira] [Created] (FLINK-39506) Update Flink HTTP connector to be based on Flink 2 David Radley (Jira)
• [jira] [Created] (FLINK-39505) Add Python-side tests for recently added Table API methods Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39504) Issues with special chars in VARIANT item Timo Walther (Jira)
• 退订 Jimmy Wong
  • Re: 退订 Xiaogang Zhou
  • 退订 [email protected]
  • 退订 wdmcode via dev
  • 退订 林
  • 退订 林
  • 退订 林
  • 退订 林
  • 退订 林
  • 退订 黄新儿
  • 退订 博-阿哥
  • 退订 xh
  • 退订 18524655605
• [ANNOUNCE] 2.3 release testing (help needed) David Anderson
• [jira] [Created] (FLINK-39503) Make Job Overview DAG height viewport-aware and add recenter control Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39502) Performance regression in remoteSortPartition and compressedFilePartition David Anderson (Jira)
• [DISCUSS] Reviving FLIP-202: Introducing ClickHouse Connector for Apache Flink 오찬해
  • Re: [DISCUSS] Reviving FLIP-202: Introducing ClickHouse Connector for Apache Flink Robert Metzger
  • Re: [DISCUSS] Reviving FLIP-202: Introducing ClickHouse Connector for Apache Flink Chanhae Oh
• [jira] [Created] (FLINK-39501) Logback Support in Flink Kubernetes Operator Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39500) test_batch_wordcount.sh presto and presto_minio variants fail due to FileSink batch mode requiring recoverable writer Martijn Visser (Jira)

• Earlier messages
• Later messages