Messages by Thread
-
-
Re: [PR] [python] warn when an action declares a return value [flink-agents]
via GitHub
-
[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-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] [Updated] (FLINK-40009) RescaleTimelineITCase.waitUntilConditionWithTimeout never enforces its timeout on a ForkJoinPool worker
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-40009) RescaleTimelineITCase
Martijn Visser (Jira)
-
[PR] [hotfix][docs] Fix broken link in PyFlink documentation [flink]
via GitHub
-
[jira] [Created] (FLINK-40008) Replace fixed delegation token renewal retry backoff with exponential backoff
Gabor Somogyi (Jira)
-
[jira] [Updated] (FLINK-40008) Replace fixed delegation token renewal retry backoff with exponential backoff
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40008][security] Replace fixed delegation token renewal retry backoff with exponential backoff [flink]
via GitHub
-
[PR] Bump @sigstore/core and @angular/cli in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
[PR] [hotfix][docs] Document how to run the S3 end-to-end tests [flink]
via GitHub
-
[PR] [FLINK-39976][pipeline-connector/db2] Add DB2 Pipeline connector [flink-cdc]
via GitHub
-
Re: [PR] Bump pygments from 2.19.2 to 2.20.0 in /flink-python/docs [flink]
via GitHub
-
Re: [PR] [FLINK-39274] TM It is impossible to bypass the KDC login process, yet the TOKEN issued by JM has not been actually utilized. [flink]
via GitHub
-
Re: [PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
Re: [I] [Tech Debt] Update Document version number from 0.2.0 and 0.2.1 [flink-agents]
via GitHub
-
Re: [PR] [FLINK-37781][docs] Add elasticsearch lookup join document [flink-connector-elasticsearch]
via GitHub
-
[jira] [Updated] (FLINK-40006) ElasticsearchRowDataLookupFunction leaks REST client / HTTP connections on task close
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40006] ElasticsearchRowDataLookupFunction leaks REST client / HTTP connections on task close [flink-connector-elasticsearch]
via GitHub
-
[PR] [FLINK-40007][postgres] Fix snapshot fetch size conf does not take effect [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40007) Fix Postgres CDC snapshot fetch size conf does not take effect
Di Wu (Jira)
-
[PR] [FLINK-40007][postgres] Use scan.snapshot.fetch.size for Postgres snapshot to avoid OOM on wide tables [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40007) Postgres CDC ignores scan.snapshot.fetch.size during snapshot, causing OOM on wide tables
Di Wu (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] [Commented] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated
Gunapati Bharath Reddy (Jira)
-
[jira] [Updated] (FLINK-40005) [cdc-cli] CliExecutor in application mode parses the pipeline definition file path as YAML content -> "Missing required field 'source'"
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40005][cdc-cli] CliExecutor application mode reads pipeline definition from local file path [flink-cdc]
via GitHub
-
[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)
-
Re: [PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink]
via GitHub
-
[jira] [Updated] (FLINK-39987) Update docs related to flink-state-processing-api
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39987][state] update doc [flink]
via GitHub
-
[PR] Add JDK-25 to the JDK build matrix [flink-connector-opensearch]
via GitHub
-
[PR] Fix MySQL CDC column comment propagation and complete schema change/comment PR [flink-cdc]
via GitHub
-
[PR] [FLINK-30166][tests] Refactor tests that use the deprecated StreamingFileSink to FileSink [flink]
via GitHub
-
[jira] [Commented] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb
Purushottam Sinha (Jira)
-
[jira] [Commented] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog
Purushottam Sinha (Jira)
-
Re: [PR] [FLINK-37951] Enable VariantSerializerUpgradeTest [flink]
via GitHub
-
[PR] [hotfix][docs] Fix typos in operator documentation [flink-kubernetes-operator]
via GitHub
-
[jira] [Updated] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI
ASF GitHub Bot (Jira)
-
[PR] [FLINK-38961][metrics] Display process metrics (CPU, Memory, I/O) on TaskManager Web UI [flink]
via GitHub
-
[PR] ci: pin GitHub Actions to full commit SHAs [flink]
via GitHub
-
[jira] [Commented] (FLINK-33505) switch away from using netty 3 based Pekko Classic Remoting
PJ Fanning (Jira)
-
[jira] [Comment Edited] (FLINK-33505) switch away from using netty 3 based Pekko Classic Remoting
PJ Fanning (Jira)
-
[jira] [Updated] (FLINK-39770) [JUnit5 Migration] Module: flink-state-processing-api
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink]
via GitHub
-
[PR] [FLINK-39499][tests] Launch the SeaweedFS S3 test backend via 'weed mini' [flink]
via GitHub
-
[PR] [DO_NOT_MERGE] Disable CDR in tests [flink]
via GitHub
-
[PR] [DO_NOT_MERGE] Force CDR in tests [flink]
via GitHub
-
[jira] [Comment Edited] (FLINK-34406) Expose RuntimeContext in FunctionContext
Chen Zhang (Jira)
-
[jira] [Resolved] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39999) Make Flink Sql calls unparsable as it is required by Calcite 1.42.0
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-39999) Make Flink Sql calls unparsable as it is required by Calcite 1.42.0
Sergey Nuyanzin (Jira)
-
[jira] [Commented] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-40000) Remove the redundant testing util class SynchronousComponentMainThreadExecutor
Yuepeng Pan (Jira)
-
[jira] [Commented] (FLINK-40000) Remove the redundant testing util class SynchronousComponentMainThreadExecutor
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-33725) MathUtils.isPowerOf2 does not cover the case of value=0
ASF GitHub Bot (Jira)
-
[PR] [FLINK-33725][core] Return false from MathUtils.isPowerOf2 for non-positive values [flink]
via GitHub
-
Re: [PR] [FLINK-39160][Rpc] Add RPC response frame size metrics [flink]
via GitHub
-
Re: [PR] [FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink]
via GitHub
-
Re: [PR] [FLINK-37431]We should use guava Lists instead of curator shade Lists… [flink]
via GitHub
-
Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore
ASF GitHub Bot (Jira)
-
[PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink]
via GitHub
-
[PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink]
via GitHub
-
[PR] [DO_NOT_MERGE] checkpointing during recovery [flink]
via GitHub
-
[jira] [Updated] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions
Chris Johnson (Jira)
-
[jira] [Created] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions
Chris Johnson (Jira)
-
[PR] [hotfix] Fix typos in documentation source and templates [flink-web]
via GitHub
-
[PR] [hotfix] Fix reader idleness test output [flink-connector-kafka]
via GitHub
-
[jira] [Resolved] (FLINK-39443) Prepare Flink 2.3 release
David Anderson (Jira)
-
[jira] [Resolved] (FLINK-39378) Add support for timers in ProcessTableFunctionTestHarness
Fabian Hueske (Jira)
-
[jira] [Assigned] (FLINK-39378) Add support for timers in ProcessTableFunctionTestHarness
Fabian Hueske (Jira)
-
[PR] [FLINK-38919][docs] Document PyFlink per-cluster offsets [flink-connector-kafka]
via GitHub
-
[jira] [Commented] (FLINK-39979) DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders
Bowen Li (Jira)
-
[jira] [Updated] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal
Bowen Li (Jira)
-
[jira] [Resolved] (FLINK-39979) DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders
Bowen Li (Jira)