issues  

Messages by Thread

• [jira] [Created] (FLINK-39516) [web dashboard] Address npm security advisories in flink-runtime-web web-dashboard Purushottam Sinha (Jira)
• [jira] [Updated] (FLINK-39516) [web dashboard] Address npm security advisories in flink-runtime-web web-dashboard Purushottam Sinha (Jira)
  • [jira] [Updated] (FLINK-39516) [web dashboard] Address npm security advisories in flink-runtime-web web-dashboard ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39516) [web dashboard] Address npm security advisories in flink-runtime-web web-dashboard Purushottam Sinha (Jira)
• [jira] [Updated] (FLINK-39515) Add Restore Tests and fix compiled plan restoration for TO and FROM Changelog ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39515) Add Restore Tests and fix compiled plan restoration for TO and FROM Changelog Timo Walther (Jira)
• [PR] [FLINK-39515][table] Fix compiled plan restore for built-in PTFs with default args [flink] via GitHub
  • Re: [PR] [FLINK-39515][table] Fix compiled plan restore for built-in PTFs with default args [flink] via GitHub
  • Re: [PR] [FLINK-39515][table] Fix compiled plan restore for built-in PTFs with default args [flink] via GitHub
  • Re: [PR] [FLINK-39515][table] Fix compiled plan restore for built-in PTFs with default args [flink] via GitHub
  • Re: [PR] [FLINK-39515][table] Fix compiled plan restore for built-in PTFs with default args [flink] via GitHub
  • Re: [PR] [FLINK-39515][table] Fix compiled plan restore for built-in PTFs with default args [flink] via GitHub
  • Re: [PR] [FLINK-39515][table] Fix compiled plan restore for built-in PTFs with default args [flink] via GitHub
  • Re: [PR] [FLINK-39515][table] Fix compiled plan restore for built-in PTFs with default args [flink] via GitHub
• [PR] [hotfix][docs] Fix Custom Flink Resource Mutators documentation code section [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39515) Add Restore Tests and fix compiled plan restoration for TO and FROM Changelog Gustavo de Morais (Jira)
• [PR] [feature] Enable EventLog display in WebUI by default [flink-agents] via GitHub
  • Re: [PR] [feature] Enable EventLog display in WebUI by default [flink-agents] via GitHub
  • Re: [PR] [feature] Enable EventLog display in WebUI by default [flink-agents] via GitHub
• [PR] [FLINK-39511][flink-autoscaler] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-39511][flink-autoscaler] FLIP-514: Custom Evaluator plugin for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-39486][runtime-web] Adapt the size of the job-overview-list section based on screen size [flink] via GitHub
  • Re: [PR] [FLINK-39486][runtime-web] Adapt the size of the job-overview-list section based on screen size [flink] via GitHub
  • Re: [PR] [FLINK-39486][runtime-web] Adapt the size of the job-overview-list section based on screen size [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39486][runtime-web] Adapt the size of the job-overview-list section based on screen size [flink] via GitHub
• [jira] [Commented] (FLINK-39497) Azure nightly doesn't run for 1.20 and 2.1 Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39497) Azure nightly doesn't run for 1.20 and 2.1 Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-39490) [web dashboard] Improve feedback when cluster is unreachable Robert Metzger (Jira)
• [jira] [Assigned] (FLINK-39503) Make Job Overview DAG height viewport-aware and add recenter control Robert Metzger (Jira)
• Re: [PR] [tools]Import Wizard for Installation Setup [flink-agents] via GitHub
  • Re: [PR] [tools]Import Wizard for Installation Setup [flink-agents] via GitHub
• [PR] 39443 debug [flink-benchmarks] via GitHub
• [jira] [Closed] (FLINK-39023) Implement Avro To Variant Type converter Gyula Fora (Jira)
• Re: [PR] [FLINK-39023][Formats][Avro] add avro to variant datatype converter [flink] via GitHub
• [jira] [Commented] (FLINK-39495) FROM_CHANGELOG silently drops rows with unmapped operation codes Timo Walther (Jira)
• [jira] [Commented] (FLINK-39479) Add fromChangelog() to Python Table API Timo Walther (Jira)
• Re: [PR] Bump lodash from 4.17.21 to 4.17.23 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [PR] [draft][hotfix] sokit tests [flink] via GitHub
  • Re: [PR] [draft][hotfix] split tests [flink] via GitHub
  • Re: [PR] [hotfix][ci] Split e2e tests to decrease total ci time [flink] via GitHub
  • Re: [PR] [hotfix][ci] Split e2e tests to decrease total ci time [flink] via GitHub
  • Re: [PR] [hotfix][ci] Split e2e tests to decrease total ci time [flink] via GitHub
  • Re: [PR] [hotfix][ci] Split e2e tests to decrease total ci time [flink] via GitHub
  • Re: [PR] [hotfix][ci] Split e2e tests to decrease total ci time [flink] via GitHub
• [PR] Fix missing log in AbstractFlinkService [flink-kubernetes-operator] via GitHub
  • Re: [PR] Fix missing log in AbstractFlinkService [flink-kubernetes-operator] via GitHub
  • Re: [PR] Fix missing log in AbstractFlinkService [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-39486) Adapt the size of the job-overview-list section based on screen size. Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39486) Adapt the size of the job-overview-list section based on screen size. Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39486) Adapt the size of the job-overview-list section based on screen size. Chanhae Oh (Jira)
• [jira] [Updated] (FLINK-39486) Adapt the size of the job-overview-list section based on screen size. Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39486) Adapt the size of the job-overview-list section based on screen size. Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39486) Adapt the size of the job-overview-list section based on screen size. Yuepeng Pan (Jira)
• [jira] [Comment Edited] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins Qilong Wang (Jira)
  • [jira] [Comment Edited] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins Qilong Wang (Jira)
  • [jira] [Comment Edited] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins Qilong Wang (Jira)
  • [jira] [Comment Edited] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins Qilong Wang (Jira)
• [jira] [Commented] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins Qilong Wang (Jira)
  • [jira] [Commented] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins Fred Teunissen (Jira)
• [jira] [Updated] (FLINK-39210) Memory Leak Issue in Flink SQL with Multiple Temporal Joins ASF GitHub Bot (Jira)
• [PR] [FLINK-39210][table] Fixed Memory Leak Issue in Flink SQL with Multiple Temporal Joins [flink] via GitHub
  • Re: [PR] [FLINK-39210][table] Fixed Memory Leak Issue in Flink SQL with Multiple Temporal Joins [flink] via GitHub
• [jira] [Commented] (FLINK-39441) Table configuration inside Flink config is not applying at runtime Qilong Wang (Jira)
• Re: [PR] [FLINK-38825][streaming] Add ordered async batch support for AsyncBatchWaitOperator [flink] via GitHub
• Re: [PR] [FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator [flink] via GitHub
• Re: [PR] [FLINK-39076][Web UI] Display slot sharing group in operator nodes [flink] via GitHub
• Re: [PR] [FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator [flink] via GitHub
• Re: [PR] [FLINK-38857][models] Add HTTP connection pool management for Triton inference [flink] via GitHub
  • Re: [PR] [FLINK-38857][models] Add HTTP connection pool management for Triton inference [flink] via GitHub
  • Re: [PR] [FLINK-38857][models] Add HTTP connection pool management for Triton inference [flink] via GitHub
  • Re: [PR] [FLINK-38857][models] Add HTTP connection pool management for Triton inference [flink] via GitHub
  • Re: [PR] [FLINK-38857][models] Add HTTP connection pool management for Triton inference [flink] via GitHub
  • Re: [PR] [FLINK-38857][models] Add HTTP connection pool management for Triton inference [flink] via GitHub
  • Re: [PR] [FLINK-38857][models] Add HTTP connection pool management for Triton inference [flink] via GitHub
• Re: [PR] [FLINK-39092][SQL] Enhance EXPLAIN plan to display watermark specification [flink] via GitHub
• [jira] [Resolved] (FLINK-38900) Introduce the Rescales/Summary sub-page for streaming jobs with the adaptive scheduler enabled Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-39436) Allow late data to enter PTF Yuepeng Pan (Jira)
• Re: [PR] [FLINK-36303] PostgreSQL timestamp precision 0 not supported [flink-connector-jdbc] via GitHub
• [jira] [Comment Edited] (FLINK-38896) Introduce the /jobs/:jobid/rescales/summary endpoint in the REST API Yuepeng Pan (Jira)
• [jira] [Comment Edited] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Purushottam Sinha (Jira)
  • [jira] [Comment Edited] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Purushottam Sinha (Jira)
• [jira] [Updated] (FLINK-39513) CheckpointCoordinator.restoreInitialCheckpointIfPresent ignores allowNonRestoredState ASF GitHub Bot (Jira)
• [PR] [FLINK-39514] Release dynamic Kafka split outputs on metadata shrink [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-39514] Release dynamic Kafka split outputs on metadata shrink [flink-connector-kafka] via GitHub
• [PR] Parameterize allowNonRestoredState in restoreInitialCHeckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
  • Re: [PR] [FLINK-39513][checkpointing] Parameterize allowNonRestoredState in restoreInitialCheckpointIfPresent [flink] via GitHub
• [jira] [Updated] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal Xin Gao (Jira)
  • [jira] [Updated] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-39436) Allow late data to enter PTF Fabian Hueske (Jira)
• [jira] [Commented] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Purushottam Sinha (Jira)
• [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] [Updated] (FLINK-39512) Extend plugin interface with default open and close function Zhenqiu Huang (Jira)
  • [jira] [Updated] (FLINK-39512) Extend plugin interface with default open and close function ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39512) Extend plugin interface with default open and close function Zhenqiu Huang (Jira)
• [jira] [Closed] (FLINK-39495) FROM_CHANGELOG silently drops rows with unmapped operation codes Timo Walther (Jira)
• Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-39127) Support exported metrics attributes truncation rules ASF GitHub Bot (Jira)
• [PR] [FLINK-39127][metrics] Truncate OTel attribute values via config [flink] via GitHub
  • Re: [PR] [FLINK-39127][metrics] Truncate OTel attribute values via config [flink] via GitHub
• [jira] [Closed] (FLINK-39504) Issues with special chars in VARIANT item Timo Walther (Jira)
• [jira] [Closed] (FLINK-37599) Consider on_time argument for column expansion Timo Walther (Jira)
• [jira] [Updated] (FLINK-39511) FLIP-514: Custom Evaluator plugin for Flink Autoscaler Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39511) FLIP-514: Custom Evaluator plugin for Flink Autoscaler Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39511) FLIP-514: Custom Evaluator plugin for Flink Autoscaler ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-39511) FLIP-543: Support Customized Autoscale Algorithm Dennis-Mircea Ciupitu (Jira)
• [jira] [Closed] (FLINK-39509) Mutating webhook produce spurious object modifications on no-op patches Gyula Fora (Jira)
• [PR] [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39477][infra] Add AGENTS.md for AI-assisted contributions [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39510) Add Chinese translation about AI-assisted contributions Martijn Visser (Jira)
• [jira] [Closed] (FLINK-39479) Add fromChangelog() to Python Table API Timo Walther (Jira)
• [jira] [Closed] (FLINK-39484) NativeS3InputStream: abort unfinished GetObject responses on seek/reopen to avoid ConnectionClosedException on S3-compatible storage macdoor615 (Jira)
• [jira] [Closed] (FLINK-39485) NativeS3FileSystem: support bucket-root paths (empty object key) using HeadBucket instead of HeadObject macdoor615 (Jira)
• [jira] [Updated] (FLINK-39509) Mutating webhook produce spurious object modifications on no-op patches Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39509) Mutating webhook produce spurious object modifications on no-op patches Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-39390) Add Extensibility to Autoscaler Components via the Plugin Mechanism Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39390) Add Extensibility to Autoscaler Components via the Plugin Mechanism Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39390) Add Extensibility to Autoscaler Components via the Plugin Mechanism Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-39306) Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39306) Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-39299) Inconsistent vertex parallelism alignment logic Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39509) Mutating webhook produce spurious object modifications on no-op patches Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39508) Fix and improve flink-kubernetes-webhook module tests Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-39507) Cluster health check should run on terminal / failed jobs ASF GitHub Bot (Jira)
• [PR] [FLINK-39507] Terminal jobs should never be restarted by cluster/job … [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-39507) Cluster health check should run on terminal / failed jobs Gyula Fora (Jira)
• [jira] [Commented] (FLINK-39482) Support configurable maxConnections in S3ClientProvider Gabor Somogyi (Jira)
  • [jira] [Commented] (FLINK-39482) Support configurable maxConnections in S3ClientProvider Gabor Somogyi (Jira)
• [jira] [Closed] (FLINK-39482) Support configurable maxConnections in S3ClientProvider Gabor Somogyi (Jira)
• [jira] [Resolved] (FLINK-39482) Support configurable maxConnections in S3ClientProvider Gabor Somogyi (Jira)
• [jira] [Assigned] (FLINK-39482) Support configurable maxConnections in S3ClientProvider Gabor Somogyi (Jira)
• [PR] [release-2.3][FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
  • Re: [PR] [release-2.3][FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
  • Re: [PR] [release-2.3][FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
• [jira] [Created] (FLINK-39506) Update Flink HTTP connector to be based on Flink 2 David Radley (Jira)
• Re: [PR] [FLINK-39366][connector-http] Add retry support with exponential backoff for HTTP Sink [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39366][connector-http] Add retry support with exponential backoff for HTTP Sink [flink-connector-http] via GitHub
• [jira] [Created] (FLINK-39505) Add Python-side tests for recently added Table API methods Ramin Gharib (Jira)
• [PR] [FLINK-39062][table] Add APPLY_WATERMARK built-in function for flexible watermark assignment [flink] via GitHub
  • Re: [PR] [FLINK-39062][table] Add APPLY_WATERMARK built-in function for flexible watermark assignment [flink] via GitHub
  • Re: [PR] [FLINK-39062][table] Add APPLY_WATERMARK built-in function for flexible watermark assignment [flink] via GitHub
  • Re: [PR] [FLINK-39062][table] Add APPLY_WATERMARK built-in function for flexible watermark assignment [flink] via GitHub
  • Re: [PR] [FLINK-39062][table] Add APPLY_WATERMARK built-in function for flexible watermark assignment [flink] via GitHub
  • Re: [PR] [FLINK-39062][table] Add APPLY_WATERMARK built-in function for flexible watermark assignment [flink] via GitHub
  • Re: [PR] [FLINK-39062][table] Add APPLY_WATERMARK built-in function for flexible watermark assignment [flink] via GitHub
• [jira] [Updated] (FLINK-39364) [CONNECTOR-HTTP] Add request timeout as typed ConfigOption for HTTP lookup source and sink ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-39364][connector-http] Add request timeout config option [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39364][connector-http] Add request timeout config option [flink-connector-http] via GitHub
• Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39368][connector-http] Add User-Agent configuration support for HTTP sink and lookup [flink-connector-http] via GitHub
• Re: [PR] [FLINK-39367][connector-http] Add configurable error logging with detailed context [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39367][connector-http] Add configurable error logging with detailed context [flink-connector-http] via GitHub
  • Re: [PR] [FLINK-39367][connector-http] Add configurable error logging with detailed context [flink-connector-http] via GitHub
• [jira] [Updated] (FLINK-39504) Issues with special chars in VARIANT item ASF GitHub Bot (Jira)
• [PR] [FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
  • Re: [PR] [FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
  • Re: [PR] [FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
  • Re: [PR] [FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
  • Re: [PR] [FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
  • Re: [PR] [FLINK-39504][table-planner] Handle special chars in VARIANT ITEM call [flink] via GitHub
• Re: [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.3 [flink] via GitHub
  • Re: [PR] [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.3 [flink] via GitHub
• Re: [PR] [FLINK-38689] [flink-protobuf] Add support for protobuf 4.x field name conflict resolution [flink] via GitHub
  • Re: [PR] [FLINK-38689] [flink-protobuf] Add support for protobuf 4.x field name conflict resolution [flink] via GitHub
• [jira] [Created] (FLINK-39504) Issues with special chars in VARIANT item Timo Walther (Jira)
• Re: [PR] [FLINK-39324][table-planner] Allow MultiJoin to respect IS_NOT_DISTICT_FROM when extracting join keys [flink] via GitHub
• [jira] [Comment Edited] (FLINK-38900) Introduce the Rescales/Summary sub-page for streaming jobs with the adaptive scheduler enabled Yuepeng Pan (Jira)
  • [jira] [Comment Edited] (FLINK-38900) Introduce the Rescales/Summary sub-page for streaming jobs with the adaptive scheduler enabled Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-38900) Introduce the Rescales/Summary sub-page for streaming jobs with the adaptive scheduler enabled Yuepeng Pan (Jira)
• [PR] [FLINK-39413][runtime] Speed up TaskExecutorSubmissionTest#testRemotePartitionNotFound by configuring partition request timeout [flink] via GitHub
  • Re: [PR] [FLINK-39413][runtime] Speed up TaskExecutorSubmissionTest#testRemotePartitionNotFound by configuring partition request timeout [flink] via GitHub
  • Re: [PR] [FLINK-39413][runtime] Speed up TaskExecutorSubmissionTest#testRemotePartitionNotFound by configuring partition request timeout [flink] via GitHub
• [jira] [Resolved] (FLINK-37128) Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill Ruan Hang (Jira)
• [jira] [Updated] (FLINK-37128) Binlog reader skip `shouldEmit` filter when snapshot reader skip backfill Ruan Hang (Jira)
• [jira] [Commented] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Bowen Li (Jira)
  • [jira] [Commented] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Bowen Li (Jira)
  • [jira] [Commented] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Bowen Li (Jira)
• [jira] [Assigned] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Bowen Li (Jira)
• [jira] [Updated] (FLINK-39226) pemja.core.object.PyIterator ClassCastException Bowen Li (Jira)
• [PR] [FLINK-TBD][Connectors/Kinesis] Removed resubscription for EFO subscriptions when they are completed [flink-connector-aws] via GitHub
  • Re: [PR] [FLINK-TBD][Connectors/Kinesis] Removed resubscription for EFO subscriptions when they are completed [flink-connector-aws] via GitHub

• Earlier messages
• Later messages