issues  

Messages by Thread

• • Re: [PR] [FLINK-41313][pipeline-connector/fluss] Retire dropped or expired partitions during restore and execution [flink-cdc] litiliu (via GitHub) via issues
  • Re: [PR] [FLINK-41313][pipeline-connector/fluss] Retire dropped or expired partitions during restore and execution [flink-cdc] fxbing (via GitHub) via issues
• [jira] [Commented] (FLINK-41313) Fluss pipeline source does not unsubscribe dropped or expired partitions liting liu (Jira) via issues
• [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
  • [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
  • [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
  • [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions ASF GitHub Bot (Jira) via issues
  • [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
  • [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
  • [jira] [Updated] (FLINK-41313) Fluss pipeline source fails to recover from checkpoints referencing dropped or expired partitions liting liu (Jira) via issues
• [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Naveen Joseph (Jira) via issues
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Naveen Joseph (Jira) via issues
• [jira] [Comment Edited] (FLINK-41290) PyFlink streaming: Python UDTF in a lateral join loses the row kind of the input (NULL-padded LEFT JOIN rows; every row in thread mode) Sangkyoon Nam (Jira) via issues
• Re: [PR] [FLINK-40301][table] Merge Calc nodes before ChangelogNormalize projection pushdown [flink] github-actions[bot] (via GitHub) via issues
• Re: [PR] [FLINK-38489][table] Avoid unnecessary DELETE inference for ChangelogNormalize [flink] github-actions[bot] (via GitHub) via issues
• Re: [PR] [FLINK-40303][table] Skip non-key NOT NULL checks for key-only deletes [flink] github-actions[bot] (via GitHub) via issues
• Re: [PR] [FLINK-35324][formats] Avro format can not perform projection pushdown for specific fields [flink] github-actions[bot] (via GitHub) via issues
• Re: [PR] [FLINK-40320][ci] Exclude author and co-author reviews from community review labeling [flink] github-actions[bot] (via GitHub) via issues
• [jira] [Closed] (FLINK-41312) Preserve source bucket keys when auto-creating Fluss-to-Fluss sink tables liting liu (Jira) via issues
• Re: [PR] [FLINK-40501][datastream] Keep watermark status ordered with queued watermarks in AsyncWaitOperator [flink] kotwal-itpro (via GitHub) via issues
• [jira] [Commented] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Liu Liu (Jira) via issues
  • [jira] [Commented] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Yuepeng Pan (Jira) via issues
• [jira] [Assigned] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE Xiqian Yu (Jira) via issues
• [jira] [Updated] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink Liu Liu (Jira) via issues
• [jira] [Created] (FLINK-41314) Release Testing: Verify FLIP-591: Introducing Python DataFrame API in PyFlink Liu Liu (Jira) via issues
• [jira] [Commented] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE soyeong choe (Jira) via issues
  • [jira] [Commented] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE Xiqian Yu (Jira) via issues
• Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar] Copilot (via GitHub) via issues
  • Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar] poorbarcode (via GitHub) via issues
  • Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar] poorbarcode (via GitHub) via issues
  • Re: [PR] [FLINK-41194][Stream] Use PulsarAdmin to check transaction state [flink-connector-pulsar] poorbarcode (via GitHub) via issues
• [jira] [Closed] (FLINK-40221) Update weekly.yml of jdbc connector for jdbc-3.4.0 and jdbc-4.1.0 Yuepeng Pan (Jira) via issues
• [jira] [Closed] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling Yuepeng Pan (Jira) via issues
• [jira] [Commented] (FLINK-41290) PyFlink streaming: Python UDTF in a lateral join loses the row kind of the input (NULL-padded LEFT JOIN rows; every row in thread mode) Sangkyoon Nam (Jira) via issues
• [jira] [Created] (FLINK-41313) Fluss pipeline source does not unsubscribe dropped or expired partitions liting liu (Jira) via issues
• [PR] [FLINK-41303][runtime-web] Only send job submission parameters in the request body [flink] leosanqing (via GitHub) via issues
  • Re: [PR] [FLINK-41303][runtime-web] Only send job submission parameters in the request body [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-41303][runtime-web] Only send job submission parameters in the request body [flink] leosanqing (via GitHub) via issues
• [jira] [Updated] (FLINK-41312) Preserve source bucket keys when auto-creating Fluss-to-Fluss sink tables liting liu (Jira) via issues
• [jira] [Created] (FLINK-41312) Preserve source bucket keys when auto-creating Fluss-to-Fluss sink tables liting liu (Jira) via issues
• [jira] [Created] (FLINK-41299) Watermark alignment deadlocks checkpoints after source subtasks finish Chen Zhang (Jira) via issues
• [jira] [Resolved] (FLINK-39700) Fix name-based column matching in materialized table schema diff Yuepeng Pan (Jira) via issues
• [jira] [Created] (FLINK-41303) Web UI job submission fails with long program arguments sanqingleo (Jira) via issues
• [PR] [FLINK-41288] Recreating a canary resource leaves duplicate health check loops running [flink-kubernetes-operator] Dennis-Mircea (via GitHub) via issues
• [PR] [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [BP-2.4][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [BP-2.4][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] flinkbot (via GitHub) via issues
• [jira] [Commented] (FLINK-41295) PyFlink: Python UDFs receive TIMESTAMP values before 1901-12-13 or after 2038-01-19 as wrong dates (int32 seconds in the Cython TimestampCoderImpl) Sangkyoon Nam (Jira) via issues
• [jira] [Created] (FLINK-41307) PyFlink TableResult.collect() changes TIMESTAMP values in a DST gap or before 1902 (converted through the JVM and Python local time zones) Yaoxuan Wu (Jira) via issues
• [PR] [FLINK-41305][table-runtime] Require UTF-8 for a VARIANT column in the raw format and parse it from bytes [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41305][table-runtime] Require UTF-8 for a VARIANT column in the raw format and parse it from bytes [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] twalthr (via GitHub) via issues
  • Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column, support the line delimiter only for strings and add a binary encoding [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41305][FLINK-41323][table-runtime] Require UTF-8 for a raw VARIANT column and add a binary encoding [flink] twalthr (via GitHub) via issues
• [PR] [hotfix][api][java] Move ResourceContext lookup factory to test utilities [flink-agents] wenjin272 (via GitHub) via issues
  • Re: [PR] [hotfix][api][java] Move ResourceContext lookup factory to test utilities [flink-agents] wenjin272 (via GitHub) via issues
• [jira] [Created] (FLINK-41298) PARSE_JSON, TRY_PARSE_JSON and the raw format drop content after the first JSON value Ramin Gharib (Jira) via issues
• [PR] FLINK-31737: Hide rescale buttons for batch jobs in WebUI [flink] ankitflow001 (via GitHub) via issues
  • Re: [PR] FLINK-31737: Hide rescale buttons for batch jobs in WebUI [flink] flinkbot (via GitHub) via issues
• [jira] [Commented] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Rui Fan (Jira) via issues
• [jira] [Updated] (FLINK-41309) Expose the JobManager deployment status and the resource age as kubectl printer columns ASF GitHub Bot (Jira) via issues
• [jira] [Created] (FLINK-41310) BatchExecAdaptiveJoin sizes the external buffer from the runtime config instead of the compiled plan Bonnie Varghese (Jira) via issues
• Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] sharpca (via GitHub) via issues
  • Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] semlanghi (via GitHub) via issues
  • Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] semlanghi (via GitHub) via issues
  • Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] wenjin272 (via GitHub) via issues
  • Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] semlanghi (via GitHub) via issues
  • Re: [PR] [runtime][java] Fall back to legacy flink-conf.yaml when loading agent configuration [flink-agents] wenjin272 (via GitHub) via issues
• Re: [PR] [BP-2.4][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] twalthr (via GitHub) via issues
• [jira] [Commented] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Rui Fan (Jira) via issues
• [jira] [Commented] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable Rui Fan (Jira) via issues
• [jira] [Comment Edited] (FLINK-38967) UnalignedCheckpointFailureHandlingITCase fails intermittently Rui Fan (Jira) via issues
• [PR] [FLINK-40333][operator] Record lastStableSpec on FlinkBlueGreenDeploy… [flink-kubernetes-operator] jennifer-xiong25 (via GitHub) via issues
  • Re: [PR] [FLINK-40333][operator] Record lastStableSpec on FlinkBlueGreenDeploy… [flink-kubernetes-operator] jennifer-xiong25 (via GitHub) via issues
• [jira] [Updated] (FLINK-40333) Move setLastReconciledSpec to after successful transition start for BG deployments ASF GitHub Bot (Jira) via issues
• [jira] [Commented] (FLINK-40544) Add raw format support for UUID type Yuepeng Pan (Jira) via issues
• [jira] [Commented] (FLINK-41303) Web UI job submission fails with long program arguments sanqingleo (Jira) via issues
• [jira] [Created] (FLINK-41292) PyFlink batch: pandas UDAF in an aggregation without GROUP BY returns no row for an empty input Yaoxuan Wu (Jira) via issues
• Re: [PR] [FLINK-34195][python] Use python3 as the default Python executable [flink] github-actions[bot] (via GitHub) via issues
• [PR] [FLINK-41309] Expose the JobManager deployment status and the resource age as kubectl printer columns [flink-kubernetes-operator] Dennis-Mircea (via GitHub) via issues
  • Re: [PR] [FLINK-41309] Expose the JobManager deployment status and the resource age as kubectl printer columns [flink-kubernetes-operator] Dennis-Mircea (via GitHub) via issues
  • Re: [PR] [FLINK-41309] Expose the JobManager deployment status and the resource age as kubectl printer columns [flink-kubernetes-operator] gyfora (via GitHub) via issues
• [jira] [Updated] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Rui Fan (Jira) via issues
  • [jira] [Updated] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Rui Fan (Jira) via issues
  • [jira] [Updated] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Rui Fan (Jira) via issues
• [jira] [Created] (FLINK-41290) PyFlink streaming: Python UDTF in a lateral join loses the row kind of the input (NULL-padded LEFT JOIN rows; every row in thread mode) Yaoxuan Wu (Jira) via issues
• [jira] [Created] (FLINK-41311) Unresponsive JobManager is never reported because READY is set without a REST check Dennis-Mircea Ciupitu (Jira) via issues
• [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
  • [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38967] Fix flaky UnalignedCheckpointFailureHandlingITCase [flink] 1996fanrui (via GitHub) via issues
• [jira] [Created] (FLINK-41295) PyFlink: Python UDFs receive TIMESTAMP values before 1901-12-13 or after 2038-01-19 as wrong dates (int32 seconds in the Cython TimestampCoderImpl) Yaoxuan Wu (Jira) via issues
• [PR] [hotfix][e2e] Submit all TPC-H queries in one SQL Client session in test_tpch.sh [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [hotfix][e2e] Submit all TPC-H queries in one SQL Client session in test_tpch.sh [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [hotfix][e2e] Submit all TPC-H queries in one SQL Client session in test_tpch.sh [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [hotfix][e2e] Submit all TPC-H queries in one SQL Client session in test_tpch.sh [flink] snuyanzin (via GitHub) via issues
• [PR] [BP-2.4][FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [BP-2.4][FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [BP-2.4][FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [BP-2.4][FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run [flink] snuyanzin (via GitHub) via issues
• [jira] [Created] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes Ramin Gharib (Jira) via issues
• Re: [PR] [BP-2.1][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] twalthr (via GitHub) via issues
  • Re: [PR] [BP-2.1][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key [flink] twalthr (via GitHub) via issues
• [jira] [Created] (FLINK-41306) Parquet format writes TIMESTAMP values before 1970 with a fractional second one second late (INT96, parquet.utc-timezone=false); Flink cannot read them back Yaoxuan Wu (Jira) via issues
• [jira] [Comment Edited] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Rui Fan (Jira) via issues
  • [jira] [Comment Edited] (FLINK-39984) Thread dump RPC can cause heartbeat timeout and unnecessary JM/TM failover Rui Fan (Jira) via issues
• Re: [PR] [runtime] Fix lifecycle and metric bookkeeping gaps in parallel action execution [flink-agents] wenjin272 (via GitHub) via issues
• [PR] Bump org.xerial.snappy:snappy-java from 1.1.10.7 to 1.1.10.9 [flink-connector-kafka] dependabot[bot] (via GitHub) via issues
• Re: [PR] [FLINK-40368][table-planner] Fix deduplication changelog inference [flink] pnowojski (via GitHub) via issues
  • Re: [PR] [FLINK-40368][table-planner] Fix deduplication changelog inference [flink] pnowojski (via GitHub) via issues
• [jira] [Created] (FLINK-41288) Recreating a canary resource leaves duplicate health check loops running Dennis-Mircea Ciupitu (Jira) via issues
• [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] flinkbot (via GitHub) via issues
  • [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed [flink] 1996fanrui (via GitHub) via issues
• [jira] [Updated] (FLINK-40544) Add raw format support for UUID type Yuepeng Pan (Jira) via issues
• [jira] [Created] (FLINK-41300) [cdc][mysql] MySQL pipeline connector fails the job when a GEOMETRY/POLYGON value cannot be exported to GeoJSON VISHAL B (Jira) via issues
• [PR] [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38534][runtime/tests] Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state [flink] flinkbot (via GitHub) via issues
• Re: [PR] [runtime][java][python] Preserve internal subagent framework faults through tool calls and the Python bridge [flink-agents] eemario (via GitHub) via issues
  • Re: [PR] [runtime][java][python] Preserve internal subagent framework faults through tool calls and the Python bridge [flink-agents] wenjin272 (via GitHub) via issues
• [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38442][test] Make ProfilingServiceTest.testRollingDeletion more stable [flink] flinkbot (via GitHub) via issues
• [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] 1996fanrui (via GitHub) via issues
• [PR] Bump org.xerial.snappy:snappy-java from 1.1.10.7 to 1.1.10.9 [flink-connector-mongodb] dependabot[bot] (via GitHub) via issues
• [jira] [Closed] (FLINK-41244) PTF clearAllTimers() deletes unnamed timers across all keys and corrupts the key context Timo Walther (Jira) via issues
• [jira] [Created] (FLINK-41297) PackagedProgramApplication never closes the PackagedProgram submitted via REST run-application Bharath Reddy Gunapati (Jira) via issues
• [jira] [Created] (FLINK-41296) fullWindowPartition().mapPartition() corrupts output: the end-of-input watermark is emitted on the task thread while the UDF thread is still emitting records Paul King (Jira) via issues
• [jira] [Updated] (FLINK-41298) Document and test that JSON input is read only up to its first value Ramin Gharib (Jira) via issues
  • [jira] [Updated] (FLINK-41298) Document and test that JSON input is read only up to its first value Yuepeng Pan (Jira) via issues
• [jira] [Commented] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter Rui Fan (Jira) via issues
• [PR] [FLINK-41304] Support canary resources on FlinkDeployment only [flink-kubernetes-operator] Dennis-Mircea (via GitHub) via issues
• [jira] [Updated] (FLINK-40843) Add StateCatalog documentation Yuepeng Pan (Jira) via issues
• [jira] [Updated] (FLINK-40438) Add DataFrame inspection and rich display APIs Yuepeng Pan (Jira) via issues
• Re: [PR] [FLINK-39367][connector-http] Add configurable error logging with detailed context [flink-connector-http] bharathgunapati (via GitHub) via issues
• [jira] [Resolved] (FLINK-41277) test_file_sink.sh hangs in the second OpenSSL linkage run Sergey Nuyanzin (Jira) via issues
• [PR] [BP-2.2][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [BP-2.2][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [BP-2.2][FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 [flink] snuyanzin (via GitHub) via issues
• [jira] [Updated] (FLINK-41310) BatchExecAdaptiveJoin sizes the external buffer from the runtime config instead of the compiled plan Bonnie Varghese (Jira) via issues
  • [jira] [Updated] (FLINK-41310) BatchExecAdaptiveJoin sizes the external buffer from the runtime config instead of the compiled plan Bonnie Varghese (Jira) via issues
  • [jira] [Updated] (FLINK-41310) BatchExecAdaptiveJoin sizes the external buffer from the runtime config instead of the compiled plan Bonnie Varghese (Jira) via issues
• [jira] [Updated] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter Rui Fan (Jira) via issues
  • [jira] [Updated] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter Rui Fan (Jira) via issues
  • [jira] [Updated] (FLINK-39388) Fix Flaky DataGeneratorSourceITCase#testGatedRateLimiter Rui Fan (Jira) via issues
• [jira] [Updated] (FLINK-38970) AdaptiveBatchSchedulerTest is unstable Rui Fan (Jira) via issues
• [jira] [Commented] (FLINK-41277) test_file_sink.sh hangs in the second OpenSSL linkage run Sergey Nuyanzin (Jira) via issues
  • [jira] [Commented] (FLINK-41277) test_file_sink.sh hangs in the second OpenSSL linkage run Sergey Nuyanzin (Jira) via issues
• [jira] [Commented] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) Sumaiya Azad (Jira) via issues
• [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink] raminqaf (via GitHub) via issues
  • Re: [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-41298][core] Reject content after the JSON value in `PARSE_JSON` and the raw format [flink] snuyanzin (via GitHub) via issues
  • Re: [PR] [FLINK-41298][table] Document and test that JSON input is read only up to its first value [flink] raminqaf (via GitHub) via issues
• [jira] [Updated] (FLINK-41298) PARSE_JSON, TRY_PARSE_JSON and the raw format drop content after the first JSON value ASF GitHub Bot (Jira) via issues
• [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-38970] Fix flaky AdaptiveBatchSchedulerTest by using synchrono… [flink] 1996fanrui (via GitHub) via issues
• [jira] [Created] (FLINK-41309) Expose the JobManager deployment status and the resource age as kubectl printer columns Dennis-Mircea Ciupitu (Jira) via issues
• [jira] [Created] (FLINK-41308) Web dashboard: TaskManager Metrics "Netty Shuffle Buffers" Available/Total are always blank Purushottam Sinha (Jira) via issues
• [jira] [Assigned] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results Hao Li (Jira) via issues
• [jira] [Updated] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes ASF GitHub Bot (Jira) via issues
  • [jira] [Updated] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes Ramin Gharib (Jira) via issues
  • [jira] [Updated] (FLINK-41305) Require UTF-8 for a VARIANT column in the raw format and parse it from bytes Ramin Gharib (Jira) via issues
• [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
  • [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
  • [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
  • [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
  • [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Sergey Nuyanzin (Jira) via issues
  • [jira] [Commented] (FLINK-41291) Bump snappy-java to 1.1.10.12 Rui Fan (Jira) via issues
• [PR] [FLINK-40640][pipeline-connector/iceberg] Skip redundant before-image delete for UPDATEs that keep key and partition [flink-cdc] dataengineervishal (via GitHub) via issues
  • Re: [PR] [FLINK-40640][pipeline-connector/iceberg] Skip redundant before-image delete for UPDATEs that keep key and partition [flink-cdc] dataengineervishal (via GitHub) via issues
  • Re: [PR] [FLINK-40640][pipeline-connector/iceberg] Skip redundant before-image delete for UPDATEs that keep key and partition [flink-cdc] lvyanquan (via GitHub) via issues
  • Re: [PR] [FLINK-40640][pipeline-connector/iceberg] Skip redundant before-image delete for UPDATEs that keep key and partition [flink-cdc] spoorthibasu (via GitHub) via issues
• [PR] [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] 1996fanrui (via GitHub) via issues
  • Re: [PR] [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] flinkbot (via GitHub) via issues
  • Re: [PR] [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] ykisana (via GitHub) via issues
  • Re: [PR] [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] MartijnVisser (via GitHub) via issues
• Re: [PR] [FLINK-37504] Handle TLS Certificate Renewal [flink] agresch (via GitHub) via issues
• [jira] [Updated] (FLINK-41304) Support canary resources on FlinkDeployment only Dennis-Mircea Ciupitu (Jira) via issues
  • [jira] [Updated] (FLINK-41304) Support canary resources on FlinkDeployment only ASF GitHub Bot (Jira) via issues

• Earlier messages
• Later messages