dev  

Messages by Thread

• • 退订 黄新儿
  • 退订 博-阿哥
  • 退订 xh
  • 退订 18524655605
  • 退订 arctan(∞)
  • 退订 黄新儿
  • 退订 林
• [jira] [Created] (FLINK-39621) Incremental-snapshot based sources may get stuck in binlog-backfill stage Xiqian Yu (Jira)
• [jira] [Created] (FLINK-39620) Cumulative window re-emits old windows after recovery due to stale InternalTimerService.currentWatermark in GlobalAggCombiner haiqingchen (Jira)
• [jira] [Created] (FLINK-39619) Add release note for flink 2.3 release Hao Li (Jira)
• [jira] [Created] (FLINK-39618) FlinkDeployment deletion deadlocks when FlinkSessionJobs are running with default block-on-* options Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39617) Add batch REST endpoints for aggregated subtask metrics across multiple job vertices Herbert Wang (Jira)
• Re: [VOTE] Release 2.2.1, release candidate #3 Fabian Hueske
  • Re: [VOTE] Release 2.2.1, release candidate #3 Timo Walther
  • Re: [VOTE] Release 2.2.1, release candidate #3 Yuepeng Pan
  • Re: [VOTE] Release 2.2.1, release candidate #3 Yuepeng Pan
  • Re: [VOTE] Release 2.2.1, release candidate #3 Yanquan Lv
  • Re: [VOTE] Release 2.2.1, release candidate #3 Rui Fan
  • Re: [VOTE] Release 2.2.1, release candidate #3 Sergey Nuyanzin
• Re: [VOTE] Release 2.1.2, release candidate #2 Fabian Hueske
  • Re: [VOTE] Release 2.1.2, release candidate #2 Timo Walther
  • Re: [VOTE] Release 2.1.2, release candidate #2 Yuepeng Pan
  • Re: [VOTE] Release 2.1.2, release candidate #2 Yuepeng Pan
  • Re: [VOTE] Release 2.1.2, release candidate #2 Rui Fan
  • Re: [VOTE] Release 2.1.2, release candidate #2 Yanquan Lv
  • Re: [VOTE] Release 2.1.2, release candidate #2 Sergey Nuyanzin
• 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
• [FLINK-30514] Review request for HybridSourceReader bug fix yun . er . run
  • Re: [FLINK-30514] Review request for HybridSourceReader bug fix Leonard Xu
• [jira] [Created] (FLINK-39616) Add instructions on how to fix ordering with ORDER BY when using FROM_CHANGELOG Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39615) Translate documentation in changelog.md to chinese Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39614) Support TO_CHANGELOG: retract stream -> retract stream with set semantics Gustavo de Morais (Jira)
• [ANNOUNCE] New Apache Flink PMC Member – David Anderson Timo Walther
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Rion Williams
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Ryan van Huuksloot via dev
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Yuepeng Pan
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Leonard Xu
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Sergey Nuyanzin
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Hang Ruan
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Gustavo de Morais
  • Re:Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Xuyang
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Purushottam Sinha via dev
  • RE: [ANNOUNCE] New Apache Flink PMC Member – David Anderson David Radley
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Austin Cawley-Edwards
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Hao Li via dev
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Samrat Deb
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Mayank Juneja
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson 吴晓军
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Yanquan Lv
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Peter Huang
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Ramin Gharib
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Weiqing Yang
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Guowei Ma
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Rodrigo Meneses
  • Re: [ANNOUNCE] New Apache Flink PMC Member – David Anderson Jiangang Liu
• [ANNOUNCE] Apache Flink 1.20.4 released Sergey Nuyanzin
  • Re: [ANNOUNCE] Apache Flink 1.20.4 released Gustavo de Morais
  • Re: [ANNOUNCE] Apache Flink 1.20.4 released Efrat Levitan
  • Re: [ANNOUNCE] Apache Flink 1.20.4 released Peter Huang
  • Re: [ANNOUNCE] Apache Flink 1.20.4 released Ramin Gharib
  • Re: [ANNOUNCE] Apache Flink 1.20.4 released Aleksandr Savonin
  • RE: [ANNOUNCE] Apache Flink 1.20.4 released wenjin
• Re:Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Xuyang
  • Re: Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views 熊饶饶
  • Re:Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Xuyang
  • Re: Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
  • Re:Re: Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Xuyang
  • Re: Re: Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Timo Walther
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views FeatZhang
  • Re: [DISCUSS] FLIP-XXX: Support Watermark Definition in SQL Views Gustavo de Morais
• Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Hongshun Wang
  • Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
  • Re: [DISCUSS] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
• Re: [DISCUSS] FLIP-XXX: Filter-Aware Source Reuse in Table Planner Hongshun Wang
  • Re: [DISCUSS] FLIP-XXX: Filter-Aware Source Reuse in Table Planner Daniel Rossos via dev
• [jira] [Created] (FLINK-39613) Flink pipeline cdc primary-keys / partition-keys cannot resolve backtick-quoted identifiers that are used as projection aliases Ran Tao (Jira)
• [jira] [Created] (FLINK-39612) [Model] Add HTTP connection pool management for Triton inference featzhang (Jira)
• [jira] [Created] (FLINK-39611) [Model] Add sequence ID auto-increment support for Triton inference featzhang (Jira)
• [jira] [Created] (FLINK-39610) Mongo CDC connector supports specifying SSL context Xiqian Yu (Jira)
• [SUMMARY] Release 2.3 sync, blocked on cross-team testing David Anderson
  • Re: [SUMMARY] Release 2.3 sync, blocked on cross-team testing Hao Li
  • Re: [SUMMARY] Release 2.3 sync, blocked on cross-team testing Xiqian YU
  • Re: [SUMMARY] Release 2.3 sync, blocked on cross-team testing Yuepeng Pan
• Re: [DISCUSS] Compress file benchmark regression resolution for Flink 2.3 release Yuepeng Pan
• [jira] [Created] (FLINK-39609) update Dynamic Kafka Source doc with new python/sql examples and other improvement details Bowen Li (Jira)
• Hackathon at Community Over Code Glasgow — is Flink interested? Rich Bowen
  • Re: Hackathon at Community Over Code Glasgow — is Flink interested? Ramin Gharib
• [jira] [Created] (FLINK-39608) KafkaDatasetFacet should extend DatasetConfigFacet to avoid classloader issues with OpenLineage Swapna Marru (Jira)
• [jira] [Created] (FLINK-39607) Add right Nullable annotation and precondition for config Samrat Deb (Jira)
• [DISCUSS] Release flink-connector-pulsar for Flink 1.20 Ferenc Csaky
  • Re: [DISCUSS] Release flink-connector-pulsar for Flink 1.20 Mate Czagany
• 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 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
• [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Roman Khachatryan
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Roman Khachatryan
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Gabor Somogyi
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Gabor Somogyi
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Gabor Somogyi
  • Re: [DISCUSS] FLIP-576 Filesystem-Plugin Observability (flink-s3-fs-native) Samrat Deb
• [jira] [Created] (FLINK-39606) Allow callers of ShowCreateUtil.buildShowCreateMaterializedTableRow to suppress FRESHNESS and REFRESH_MODE clauses Ramin Gharib (Jira)
• [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Zakelly Lan
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Zakelly Lan
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Yuan Mei
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Martijn Visser
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • RE: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Han Yin
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Fwd: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Roman Khachatryan
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
  • Re: [DISCUSS] FLIP-XXX Support ReducingMergeState and AggregatingMergeState backed by Java based associative merge operators Soumitra Kumar
• [jira] [Created] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization Swapna Marru (Jira)
• [DISCUSS] Request for help with publishing docker images Sergey Nuyanzin
  • Re: [DISCUSS] Request for help with publishing docker images Sergey Nuyanzin
• [jira] [Created] (FLINK-39604) Extend DESCRIBE FUNCTION EXTENDED to support PTF fields Natea Eshetu Beshada (Jira)
• Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
  • Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Vamshi G via dev
  • RE: Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Jing-Jia Hung
  • Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
  • Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
  • Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
  • Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Ryan van Huuksloot via dev
  • Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo
  • Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Sergio Chong Loo via dev
  • Re: FLIP-504: Blue/Green Deployments for Flink on Kubernetes - Phase 2 (WIP/Draft PR) Ryan van Huuksloot via dev
• [jira] [Created] (FLINK-39603) Optimize NativeS3InputStream via seeks and reduce IOPS Samrat Deb (Jira)
• Re: Flink Kubernetes Operator 1.15.0 release planning Gyula Fóra
• Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Márton Balassi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Dennis-Mircea Ciupitu
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.15.0, release candidate #1 Gyula Fóra
• [jira] [Created] (FLINK-39602) Add IS_VALID_UTF8 and MAKE_VALID_UTF8 built-in functions Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39601) Add UTF-8 validation utilities and StringData.fromUtf8Bytes connector API Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-39600) FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Gustavo de Morais (Jira)
• [DISCUSS] FLINK-25672: FileSource enumerator remembers paths of all already processed files Sophia Izokun via dev
• Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Ryan van Huuksloot via dev
  • Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
  • Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Ryan van Huuksloot via dev
  • Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin
  • Re: [DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Ryan van Huuksloot via dev
• Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Piotr Nowojski
  • Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Farooq Qaiser via dev
  • Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Rion Williams
  • Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Efrat Levitan
  • Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Gustavo de Morais
  • Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Sergey Nuyanzin
  • Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Leonard Xu
  • Re: [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Ramin Gharib
  • [RESULT] [VOTE] FLIP-572: Introduce Flink-Kafka Transactions Management Tool Aleksandr Savonin

• Later messages