dev  

Messages by Thread

• [jira] [Created] (FLINK-40045) Upgrade d3-flame-graph to v5 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism peiyu (Jira)
• [jira] [Created] (FLINK-40042) Update JDBC connector version to 4.1.0 Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40041) Update JDBC connector version to 3.4.0 Yuepeng Pan (Jira)
• [jira] [Created] (FLINK-40040) SchemaRegistry loses coordination responses when a failure's cause is a user-classloader-only class (e.g. a JDBC driver exception), causing the job to hang until rpcTimeout and enter a restart loop Jiyong Wang (Jira)
• [jira] [Created] (FLINK-40039) CTAS/RTAS do not work for PTFs with set semantics and PARTITION BY Ramin Gharib (Jira)
• [jira] [Created] (FLINK-40038) [mysql][pipeline] Incremental sync throughput is low in hotspot UPDATE workloads due to deserialization overhead Jira
• [jira] [Created] (FLINK-40037) Local RocksDB working directory leaked (with all file handles held open) when an async-state-v2 task is redeployed onto the same TaskManager after a job restart Grzegorz Liter (Jira)
• [jira] [Created] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses Kaivalya Apte (Jira)
• [jira] [Created] (FLINK-40035) Add smoke-level component specs for the web-dashboard Martijn Visser (Jira)
• [jira] [Created] (FLINK-40034) Refresh web-dashboard lint tooling to prettier 3 and stylelint 17 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40033) Modernize web-dashboard visualization libraries Martijn Visser (Jira)
• [jira] [Created] (FLINK-40031) Exceptions view crashes (NG04008) navigating to an unassigned TaskManager Martijn Visser (Jira)
• [jira] [Created] (FLINK-40032) Migrate web-dashboard eslint to v9 (flat config) Martijn Visser (Jira)
• [jira] [Created] (FLINK-40030) Add architecture tests to flink-connector-http Bharath Reddy Gunapati (Jira)
• [jira] [Created] (FLINK-40029) Use Hadoop 3.4.3 in nightly tests Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40028) Update Angular to v21 and ng-zorro-antd to v21 Martijn Visser (Jira)
• [jira] [Created] (FLINK-40027) Align SavepointKeyFilter with the State Processor API generic convention Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40026) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-40025) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-40024) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-40023) HiveCatalog throws TableNotPartitionedException on partitioned non-hive table Stepan Stepanishchev (Jira)
• [jira] [Created] (FLINK-40022) Table API client hangs when batch query returns an empty result Timo Theusner (Jira)
• [jira] [Created] (FLINK-40021) AND for pushdown filters should be in uppercase Sergey Nuyanzin (Jira)
• [DISCUSS] Model routing for ML_PREDICT (FLINK-39961) Purshotam Shah via dev
  • Re: [DISCUSS] Model routing for ML_PREDICT (FLINK-39961) Purshotam Shah via dev
• [jira] [Created] (FLINK-40020) Flink 2.3: update migration data for tests David Anderson (Jira)
• [jira] [Created] (FLINK-40019) FLIP-588: Support per-job delegation tokens Aleksandr Savonin (Jira)
• [jira] [Created] (FLINK-40018) PTF changelog inference silently drops an unsatisfiable table input, causing IndexOutOfBoundsException Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Samrat Deb (Jira)
• [jira] [Created] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Martijn Visser (Jira)
• [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Han Yin
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Dennis-Mircea Ciupitu
  • Re: [DISCUSS] FLIP-599: State Catalog Zakelly Lan
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Roman Khachatryan
  • Re: [DISCUSS] FLIP-599: State Catalog Shengkai Fang
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Roman Khachatryan
  • Re: [DISCUSS] FLIP-599: State Catalog Jingsong Li
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Jingsong Li
  • Re: [DISCUSS] FLIP-599: State Catalog Weiqing Yang
  • Re: [DISCUSS] FLIP-599: State Catalog gyula . fora
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Weiqing Yang
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Shengkai Fang
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
  • Re: [DISCUSS] FLIP-599: State Catalog Gyula Fóra
• [jira] [Created] (FLINK-40015) Wrap atomic PTF output in Row partition-key prepend & rowtime append in PTF Test Harness Mika Naylor (Jira)
• [jira] [Created] (FLINK-40014) Reject null entries/keys in list/map view in PTF Test Harness Mika Naylor (Jira)
• [jira] [Created] (FLINK-40013) Correctly clear state in ctx.clearState in PTF Test Harness Mika Naylor (Jira)
• [jira] [Created] (FLINK-40012) Inject context into scalar only PTF invocation in PTF Test Harness Mika Naylor (Jira)
• [jira] [Created] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered Martijn Visser (Jira)
• [jira] [Created] (FLINK-40010) RescaleTimelineITCase.testRescaleTerminatedByNoResourcesOrNoParallelismsChange is flaky: requirements-update can miss the in-progress rescale Martijn Visser (Jira)
• [jira] [Created] (FLINK-40009) RescaleTimelineITCase Martijn Visser (Jira)
• [jira] [Created] (FLINK-40008) Replace fixed delegation token renewal retry backoff with exponential backoff Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-40007) Postgres CDC ignores scan.snapshot.fetch.size during snapshot, causing OOM on wide tables Di Wu (Jira)
• [jira] [Created] (FLINK-40006) ElasticsearchRowDataLookupFunction leaks REST client / HTTP connections on task close reswqa (Jira)
• [jira] [Created] (FLINK-40005) [cdc-cli] CliExecutor in application mode parses the pipeline definition file path as YAML content -> "Missing required field 'source'" Jiyong Wang (Jira)
• [jira] [Created] (FLINK-40004) Flink 1.20.x with jdbc-connector 3.3.0 fails to create Catalog due to multiple 'jdbc' CatalogFactory implementations in classpath songbin (Jira)
• [jira] [Created] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Chris Johnson (Jira)
• [jira] [Created] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Jim Hughes (Jira)
• [jira] [Created] (FLINK-40001) Upgrade Calcite version to 1.42.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40000) Remove the redundant testing util class SynchronousComponentMainThreadExecutor ChanBin OH (Jira)
• [jira] [Created] (FLINK-39999) Make Flink Sql calls unparsable as it is required by Calcite 1.42.0 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause Raj (Jira)
• [jira] [Created] (FLINK-39997) Upgrade pemja to 0.6.1 Florian Vazelle (Jira)
• [ANNOUNCE] Apache Flink 2.3.0 released David Anderson
  • Re: [ANNOUNCE] Apache Flink 2.3.0 released Rui Fan
• [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
  • Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Rui Fan
  • Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Aleksandr Savonin
  • Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Roman Khachatryan
  • Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Yanquan Lv
  • Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Sergey Nuyanzin
  • Re: [VOTE] FLIP-562: Topic integrity checks in Kafka Connector Efrat Levitan
• [jira] [Created] (FLINK-39996) Migrate KafkaSink EOS recovery to Kafka public PreparedTxnState API Shekhar Prasad Rajak (Jira)
• [jira] [Created] (FLINK-39995) Add ISO-8601 timestamp format with explicit timezone offset support Jira
• [DISCUSS] FLIP-598: [Filesystems] Gen2 Datalake SDK Native FileSystem for Azure Aleksandr Iushmanov
• [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
  • Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
  • Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Aleksandr Iushmanov
  • Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
  • Re: [DISCUSS] FLIP-597: [Filesystems] Hadoop-less Flink filesystems Samrat Deb
• [jira] [Created] (FLINK-39994) Allow the use of primitive scalar arguments in ProcessTableFunctionTestHarness Mika Naylor (Jira)
• [jira] [Created] (FLINK-39993) Correct documentation examples for ProcessTableFunctionTestHarness Mika Naylor (Jira)
• [jira] [Created] (FLINK-39992) Drop ReplaceIntersectWithSemiJoinRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-39991) Drop ReplaceIntersectWithSemiJoinRule Jacky Lau (Jira)
• [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 주수민
  • Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Ferenc Csaky
  • Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Yuepeng Pan
  • Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Ferenc Csaky
  • Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Yuepeng Pan
  • Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Chanhae Oh
  • Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 오찬빈
  • Re: [DISCUSS] flink-connector-jdbc Release Plan Sync - v3.4.0 / v5.0.0 / v6.0.0 Ferenc Csaky
• [jira] [Created] (FLINK-39990) Expose DynamicKafkaSource.activeSplitCount metric per source reader Bowen Li (Jira)
• [jira] [Created] (FLINK-39989) flinksessionjob stuck on "Job Not Found" if jobmanager terminates before operator learns about new job state transitions Filippo Ghibellini (Jira)
• [jira] [Created] (FLINK-39988) Support composite types in filter push-down for savepoint Table API connector Ilya Soin (Jira)
• [jira] [Created] (FLINK-39987) Update docs related to flink-state-processing-api Ilya Soin (Jira)
• [jira] [Created] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs raoraoxiong (Jira)
• [jira] [Created] (FLINK-39985) Drop ReplaceMinusWithAntiJoinRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-39984) `requestThreadDump` blocks the JM/TM main thread and can cause heartbeat timeout / job failure xingsuo-zbz (Jira)
• [jira] [Created] (FLINK-39983) Drop FlinkPruneEmptyRules Jacky Lau (Jira)
• [jira] [Created] (FLINK-39982) Drop SqlCollectionTypeNameSpec and SqlJsonQueryFunction from Flink codebase Sergey Nuyanzin (Jira)
• 退订 wdmcode via dev
  • 退订 林
  • 退订 林
  • 退订 林
  • 退订 林
  • 退订 林
  • 退订 黄新儿
  • 退订 博-阿哥
  • 退订 xh
  • 退订 18524655605
  • 退订 arctan(∞)
  • 退订 黄新儿
  • 退订 林
  • 退订 唐大彪
• [jira] [Created] (FLINK-39981) Autoscaler cannot trigger source rebalance after active split removal on dynamic Kafka source Xin Gao (Jira)
• [jira] [Created] (FLINK-39980) Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes Bowen Li (Jira)
• [jira] [Created] (FLINK-39979) DynamicKafkaSource does not mark reader idle when metadata removal leaves a subtask with no active subreaders Bowen Li (Jira)
• [jira] [Created] (FLINK-39978) Web dashboard: restyle Cancel Job/Application action as a danger button Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework Zakelly Lan (Jira)
• [jira] [Created] (FLINK-39976) Flink cdc pipeline support db2 source pipeline connector Daishuyuan (Jira)
• [jira] [Created] (FLINK-39975) Flaky DerbyDynamicTableSourceITCase.testLimit: JdbcSourceSplitReader does not recover from a connection closed during source cancellation Tomoyuki NAKAMURA (Jira)
• [jira] [Created] (FLINK-39974) Release flink-connector-jdbc v6.0.0 for Flink 2.2 Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39973) Release flink-connector-jdbc v4.0.0 for Flink 2.0 Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39972) Release flink-connector-jdbc v3.4.0 for Flink 1.20 Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39971) Support and Release Connectors for Flink 2.2 Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39970) Kubernetes Operator proceeds with cluster resubmission after Deployment deletion wait timeout, causing AlreadyExists / object-is-being-deleted race Bowen Li (Jira)
• [jira] [Created] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• [jira] [Created] (FLINK-39968) [Optimization] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance yyka (Jira)
• [jira] [Created] (FLINK-39967) FlinkStateSnapshot with default backoffLimit=-1 (documented as "unlimited retries") never retries and fails immediately on first error Santwana Verma (Jira)
• [DISCUSS] FLIP-592: First-Class Accelerator Resource Support Yi Zhang
• [jira] [Created] (FLINK-39966) FlinkRelMdModifiedMonotonicity wrongly reports a non-time-attribute Top-1 Rank as insert-only lincoln lee (Jira)
• [VOTE] FLIP-545: Hardening the Event Reporter with an Asynchronous Core Kartikey Pant
  • Re: [VOTE] FLIP-545: Hardening the Event Reporter with an Asynchronous Core Li Wang
• [DISCUSSION] Native GCS Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Aleksandr Iushmanov
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Ryan van Huuksloot via dev
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Poorvank Bhatia
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Samrat Deb
  • Re: [DISCUSSION] Native GCS Filesystem in Apache Flink Xi
• [jira] [Created] (FLINK-39965) Flink CDC should clear schema state and table-level caches after DropTableEvent Ran Tao (Jira)
• 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-39964) Incremental checkpoint taken after a CLAIM-mode restore from a native savepoint is not restorable Aleksandr Savonin (Jira)
• [ANNOUNCE] Apache Flink Agents 0.3.0 released wenjin
• [jira] [Created] (FLINK-39963) Runtime: ExecutionTimeBasedSlowTaskDetectorTest.testBalancedInput flaky Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39962) Runtime: DeclarativeSlotPoolBridgeTest.testAcceptingOfferedSlotsWithoutResourceManagerConnected flaky Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-39961) Support routing across models in Flink SQL (ML_PREDICT) Purshotam Shah (Jira)
• [jira] [Created] (FLINK-39960) Remove broken JavaDoc shortcode usage from JDBC datastream docs Dennis-Mircea Ciupitu (Jira)
• [PR] [hotfix] Add `.gitignore` [flink-ci-docker] via GitHub
  • Re: [PR] [hotfix] Add `.gitignore` [flink-ci-docker] via GitHub
• [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re:Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xuyang
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xingcan Cui
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Xingcan Cui
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: [DISCUSS] (Restarted) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
• [jira] [Created] (FLINK-39959) Improve the autoscaler context structure and propagation Dennis-Mircea Ciupitu (Jira)
• [RESULT] [VOTE] FLIP-583: Expose JobInfo on Source contexts Aleksandr Savonin
• [VOTE] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Roman Khachatryan
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Gabor Somogyi
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Rui Fan
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Piotr Nowojski
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens weijie guo
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Sergey Nuyanzin
  • Re: [VOTE] FLIP-588: Support per-job delegation tokens Ryan van Huuksloot via dev
  • [RESULT] [VOTE] FLIP-588: Support per-job delegation tokens Aleksandr Savonin
• [RESULT][VOTE] Apache Flink Agents Release 0.3.0, release candidate #1 wenjin
• [jira] [Created] (FLINK-39958) Autoscaler Flink REST client timeout is silently overridden by the operator client timeout Dennis-Mircea Ciupitu (Jira)
• [RESULT][VOTE] Release flink-connector-aws v6.0.1, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-39957) Support EXPLAIN CREATE [OR ALTER] MATERIALIZED TABLE statements Ramin Gharib (Jira)
• [jira] [Created] (FLINK-39956) Expose per-pool heap CollectionUsage gauges Zhenqiu Huang (Jira)
• Request for PMC to get PyPI access Yuepeng Pan
  • Re: Request for PMC to get PyPI access Yuepeng Pan

• Earlier messages
• Later messages