Messages by Thread
-
Re: [PR] [runtime] Support async execution for cross language resources. [flink-agents]
via GitHub
-
[I] [Feature] Add daily workflow to label closed issues missing fixVersion [flink-agents]
via GitHub
-
Re: [PR] [hotfix][flink-autoscaler] Skip redundant overrides in JobAutoScalerImpl when job is not running [flink-kubernetes-operator]
via GitHub
-
[jira] [Closed] (FLINK-35154) Javadoc aggregate fails
Dmitriy Linevich (Jira)
-
[jira] [Commented] (FLINK-35154) Javadoc aggregate fails
Dmitriy Linevich (Jira)
-
Re: [I] [Tech Debt] Refactor AgentPlan & ResourceCache [flink-agents]
via GitHub
-
[PR] [FLINK-39390][flink-autoscaler] Add Extensibility to Autoscaler Components via the Plugin Mechanism [flink-kubernetes-operator]
via GitHub
-
[jira] [Created] (FLINK-39390) Add Extensibility to Autoscaler Components via the Plugin Mechanism
Dennis-Mircea Ciupitu (Jira)
-
[PR] [FLINK-39391][cdc-connector] Propagate scan.snapshot.fetch.size to Debezium properties in Oracle, SqlServer, DB2, and Postgres connectors [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39391) scan.snapshot.fetch.size is not propagated to Debezium properties in Oracle/SqlServer/DB2/Postgres connectors, causing severe snapshot performance degradation
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39382] Clarify auto.offset.reset support in Kafka SQL connector [flink-connector-kafka]
via GitHub
-
[jira] [Created] (FLINK-39391) scan.snapshot.fetch.size is not propagated to Debezium properties in Oracle/SqlServer/DB2/Postgres connectors, causing severe snapshot performance degradation
tianfy (Jira)
-
Re: [I] [Feature] Add support for custom job name in Flink Agents Job execution [flink-agents]
via GitHub
-
[jira] [Assigned] (FLINK-39275) Some issues in the "Performance Tuning" document
Weijie Guo (Jira)
-
[jira] [Closed] (FLINK-38372) Introduces whitelist to the flink-metrics-prometheus
Weijie Guo (Jira)
-
[jira] [Assigned] (FLINK-38372) Introduces whitelist to the flink-metrics-prometheus
Weijie Guo (Jira)
-
[jira] [Closed] (FLINK-39375) Add explicit serialVersionUID to WatermarkAlignmentParams
Weijie Guo (Jira)
-
[jira] [Assigned] (FLINK-39375) Add explicit serialVersionUID to WatermarkAlignmentParams
Weijie Guo (Jira)
-
[PR] Bump lodash from 4.17.21 to 4.18.1 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [PR] [hotfix] Fix invalid comments in Committer [flink]
via GitHub
-
Re: [PR] [FLINK-39275][docs] Fix some issues in the "Performance Tuning" document [flink]
via GitHub
-
[jira] [Created] (FLINK-39389) Investigate updating the Apache HTTP connector to support java 8.
David Radley (Jira)
-
[jira] [Resolved] (FLINK-39385) Timestampdiff for time fails with scala.MatchError: (TIME_WITHOUT_TIME_ZONE,TIME_WITHOUT_TIME_ZONE) (of class scala.Tuple2)
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39015) Fix MultiJoin RowData behaviour for HeapStateBackend
Dmitriy Linevich (Jira)
-
[jira] [Updated] (FLINK-39285) Consider the result of filter pushdown rules in the MultiJoin rule
Dmitriy Linevich (Jira)
-
[jira] [Updated] (FLINK-39241) Incorrect row data using in MultiJoinStateViews for HeapStateBackend case
Dmitriy Linevich (Jira)
-
[jira] [Commented] (FLINK-39385) Timestampdiff for time fails with scala.MatchError: (TIME_WITHOUT_TIME_ZONE,TIME_WITHOUT_TIME_ZONE) (of class scala.Tuple2)
Sergey Nuyanzin (Jira)
-
[jira] [Assigned] (FLINK-39359) Introduce integration test cases to ensure that the generated REST-API related documentation stays consistent with the code.
Yuepeng Pan (Jira)
-
[jira] [Commented] (FLINK-39359) Introduce integration test cases to ensure that the generated REST-API related documentation stays consistent with the code.
Yuepeng Pan (Jira)
-
[PR] [FLINK-39359][docs] Introduce integration test cases to ensure that the generated REST-API related documentation stays consistent with the code. [flink]
via GitHub
-
[jira] [Updated] (FLINK-39359) Introduce integration test cases to ensure that the generated REST-API related documentation stays consistent with the code.
Yuepeng Pan (Jira)
-
Re: [PR] [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences [flink]
via GitHub
-
Re: [PR] Bump node-forge from 1.3.1 to 1.3.3 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [PR] [FLINK-38579] [table-planner] Fix incorrect UB drop for filter on non-upsert key [flink]
via GitHub
-
Re: [PR] [FLINK-39277][docs] Fix the problem of missing content display due to format errors [flink]
via GitHub
-
[jira] [Updated] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39388][tests] Fix flaky DataGeneratorSourceITCase#testGatedRateLimiter [flink]
via GitHub
-
[jira] [Created] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter
featzhang (Jira)
-
[jira] [Commented] (FLINK-39387) Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation
Liu (Jira)
-
[jira] [Updated] (FLINK-39359) Introduce RestAPIDocsCompletenessITCase to ensure that the generated REST-API related documentation stays consistent with the code.
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39387) Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39387][Runtime / Coordination] Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation [flink]
via GitHub
-
[jira] [Commented] (FLINK-39386) For Flink 2.x+, support limit the rate at the source
peiyu (Jira)
-
[jira] [Created] (FLINK-39387) Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation
Liu (Jira)
-
[jira] [Created] (FLINK-39386) For Flink 2.x+, support limit the rate at the source
peiyu (Jira)
-
[PR] [runtime] Fix prune state corner cases around checkpoints [flink-agents]
via GitHub
-
[PR] [FLINK-39098] Bump testcontainers to 1.21.4 for Docker API compatibility [flink-connector-aws]
via GitHub
-
[jira] [Created] (FLINK-39385) Timestampdiff for time fails with scala.MatchError: (TIME_WITHOUT_TIME_ZONE,TIME_WITHOUT_TIME_ZONE) (of class scala.Tuple2)
Sergey Nuyanzin (Jira)
-
[PR] [docs] Fix code examples and minor issues in DataStream documentation [flink]
via GitHub
-
[PR] [FLINK-37918][Connectors/Kinesis] Add GetRecords fetch interval for non-empty records to prevent throttling [flink-connector-aws]
via GitHub
-
[PR] [FLINK-39385][table] `TIMESTAMPDIFF` fails for `TIME` [flink]
via GitHub
-
[jira] [Updated] (FLINK-37918) Restore the ability to set an interval for GetRecords calls to Kinesis shards.
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-39385) Timestampdiff for time fails with scala.MatchError: (TIME_WITHOUT_TIME_ZONE,TIME_WITHOUT_TIME_ZONE) (of class scala.Tuple2)
ASF GitHub Bot (Jira)
-
[jira] [Assigned] (FLINK-39334) flink-connector-mongodb fails when write concern is set to zero
Robert Metzger (Jira)
-
Re: [PR] [FLINK-38600] Fix a race condition in consumer creation by adding a retry with delay [flink-connector-pulsar]
via GitHub
-
[jira] [Closed] (FLINK-38600) Pulsar connector fails with 'Exclusive consumer is already connected' due to a race condition
Ferenc Csaky (Jira)
-
[jira] [Updated] (FLINK-38600) Pulsar connector fails with 'Exclusive consumer is already connected' due to a race condition
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed
Chris MacGregor (Jira)
-
[jira] [Created] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed
Chris MacGregor (Jira)
-
[PR] [hotfix][docs/test] Migrate the assertj assertion lines to link-calling. [flink]
via GitHub
-
[PR] Bump org.assertj:assertj-core from 3.23.1 to 3.27.7 [flink-connector-pulsar]
via GitHub
-
[PR] Bump org.apache.logging.log4j:log4j-core from 2.17.2 to 2.25.3 [flink-connector-pulsar]
via GitHub
-
[PR] Bump org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0 [flink-connector-pulsar]
via GitHub
-
[PR] [FLINK-34644][runtime] Fix race condition in RestServerEndpoint shutdown [flink]
via GitHub
-
Re: [PR] Bump com.google.protobuf:protobuf-java from 3.21.9 to 3.25.5 [flink-connector-pulsar]
via GitHub
-
[PR] [hotfix] Fix E2E tests [flink-connector-pulsar]
via GitHub
-
[jira] [Commented] (FLINK-34022) A Duration that cannot be expressed as long in nanoseconds causes an ArithmeticException in TimeUtils.formatWithHighestUnit
Imre Balassa (Jira)
-
[PR] [FLINK-34022][core] Fix ArithmeticException in TimeUtils.formatWithHighestUnit for large Duration values [flink]
via GitHub
-
[jira] [Updated] (FLINK-34022) A Duration that cannot be expressed as long in nanoseconds causes an ArithmeticException in TimeUtils.formatWithHighestUnit
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-38962][connectors/opensearch] Add OpenSearch 3.x support with opensearch-java client [flink-connector-opensearch]
via GitHub
-
[jira] [Closed] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager
Ferenc Csaky (Jira)
-
[jira] [Comment Edited] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager
Ferenc Csaky (Jira)
-
[jira] [Created] (FLINK-39383) [Docs] Improve scan.incremental.snapshot.chunk.key-column documentation for MySQL/PostgreSQL/Oracle/DB2/SQLServer connectors
ericzeng (Jira)
-
[jira] [Comment Edited] (FLINK-36432) FLIP-438: Amazon SQS Source Connector
Jira
-
[jira] [Updated] (FLINK-39382) [Docs][Kafka] Clarify properties.auto.offset.reset support in SQL connector
Kumar Mallikarjuna (Jira)
-
[jira] [Updated] (FLINK-39382) Clarify properties.auto.offset.reset support in Kafka SQL connector
Kumar Mallikarjuna (Jira)
-
[jira] [Updated] (FLINK-39382) [Docs][Kafka Connector] Clarify properties.auto.offset.reset support in SQL connector
Kumar Mallikarjuna (Jira)
-
[jira] [Updated] (FLINK-39382) Clarify properties.auto.offset.reset support in SQL connector
Kumar Mallikarjuna (Jira)
-
[jira] [Created] (FLINK-39382) [Docs][Kafka] Clarify properties.auto.offset.reset support in SQL connector
Kumar Mallikarjuna (Jira)
-
[jira] [Commented] (FLINK-36432) FLIP-438: Amazon SQS Source Connector
Jira
-
[jira] [Comment Edited] (FLINK-39357) FLIP-567: Introduce a ProcessTableFunction Test Harness
Yuepeng Pan (Jira)
-
[jira] [Commented] (FLINK-39357) FLIP-567: Introduce a ProcessTableFunction Test Harness
Yuepeng Pan (Jira)
-
Re: [PR] [FLINK-38046][Connector/JDBC]Solve the issue of missing one piece of data [flink-connector-jdbc]
via GitHub
-
[jira] [Created] (FLINK-39381) Add user facing documentation for ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-39380) Add support for test snapshotting/restoration to ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-39379) Add support for state in ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-39378) Add support for timers in ProcessTableFunctionTestHarness
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-39377) Initial ProcessTableFunctionTestHarness implementation
Mika Naylor (Jira)
-
[jira] [Commented] (FLINK-39359) Introduce a mechanism to ensure that the generated documentation stays consistent with the code.
Rui Fan (Jira)
-
[jira] [Commented] (FLINK-39041) Rebuild REST API docs pages to supplement the missing content.
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39365) [CONNECTOR-HTTP] 支持自定义 HTTP HEADERS VIA CONFIGOPTION
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-39365][connector-http] Support custom HTTP headers via ConfigOption [flink-connector-http]
via GitHub
-
[jira] [Resolved] (FLINK-39342) [Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties
ericzeng (Jira)
-
[jira] [Updated] (FLINK-39376) Show TaskManager IP address in Checkpoint Subtask Statistics
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39376] [checkpoint]Add IP Address of Subtask Running Checkpoint to Flink WebU [flink]
via GitHub
-
[jira] [Created] (FLINK-39376) Show TaskManager IP address in Checkpoint Subtask Statistics
jingzi (Jira)
-
Re: [PR] [FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus [flink]
via GitHub