Messages by Thread
-
-
[PR] [FLINK-39184][core] Introduce Bitmap type for DataStream API [flink]
via GitHub
-
[jira] [Updated] (FLINK-39184) Introduce Bitmap type for DataStream API
dylanhz (Jira)
-
[jira] [Resolved] (FLINK-39181) Reduce Verbose DEBUG Logging in CI
Martijn Visser (Jira)
-
[jira] [Assigned] (FLINK-39200) Skip deserialization of unsubscribed tables in MySql CDC binary log client
Yanquan Lv (Jira)
-
[jira] [Assigned] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase
Yanquan Lv (Jira)
-
[jira] [Commented] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase
Cong Cheng (Jira)
-
[jira] [Updated] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase
Cong Cheng (Jira)
-
[jira] [Created] (FLINK-39207) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase
Cong Cheng (Jira)
-
Re: [I] [Bug] Java agents fail to connect to MCP servers that do not support prompts [flink-agents]
via GitHub
-
[I] [Feature] Add support for custom job name in Flink Agents Job execution [flink-agents]
via GitHub
-
[jira] [Created] (FLINK-39206) JDBC flaky test: java.lang.RuntimeException: Failed to fetch next result
Yuepeng Pan (Jira)
-
[jira] [Commented] (FLINK-38815) The debug log will print the sensitive information of data security cookie certification in task manager and jobmanager
dengxiang (Jira)
-
[jira] [Reopened] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog
Yuepeng Pan (Jira)
-
[jira] [Resolved] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog
Yuepeng Pan (Jira)
-
[jira] [Updated] (FLINK-39090) [SQL] Enhanced join condition structured display
ASF GitHub Bot (Jira)
-
[jira] [Commented] (FLINK-39205) fluss yaml sink support array/map/row
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-39205) fluss yaml sink support array/map/row
Hongshun Wang (Jira)
-
[jira] [Commented] (FLINK-39204) fluss yaml sink support add column at last
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-39204) fluss yaml sink support add column at last
Hongshun Wang (Jira)
-
Re: [PR] [FLINK-38726][fluss] Bump Fluss version to 0.8.0-incubating [flink-cdc]
via GitHub
-
Re: [PR] [FLINK-39096][table-planner] Enhance EXPLAIN output to display detailed estimated rowcount and cost information [flink]
via GitHub
-
[jira] [Updated] (FLINK-39178) Support cascaded delta join in planner
Xuyang Zhong (Jira)
-
[PR] [FLINK-38828][cdc-common][cdc-runtime] Handle schema evolution upon projection updates via SchemaCoordinator [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-38832) Projection pushdown of count(*) in planner changes
ASF GitHub Bot (Jira)
-
Re: [PR] [FLINK-38832][table-planner] Push down single column when using count star [flink]
via GitHub
-
[jira] [Created] (FLINK-39203) Support Runtime Data Sampling for Operators with WebUI Visualization
Liu (Jira)
-
[jira] [Updated] (FLINK-39079) Add Diagnostic Summary Page in Flink Web UI
ASF GitHub Bot (Jira)
-
[jira] [Updated] (FLINK-38833) Partitioned fixed-bucket Paimon table write parallelism optimization
ASF GitHub Bot (Jira)
-
[PR] [FLINK-38833][paimon] Partitioned fixed-bucket Paimon table write parallelism optimization [flink-cdc]
via GitHub
-
[I] [Tech Debt] Remove temporary installation from the doc [flink-agents]
via GitHub
-
[PR] [FLINK-38857][Model] Add docs for Triton inference model [flink]
via GitHub
-
[jira] [Assigned] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Roman Khachatryan (Jira)
-
[PR] [FLINK-39162][checkpoints] Disable UC for CustomPartitioner [flink]
via GitHub
-
[jira] [Created] (FLINK-39202) Simplify COALESCE expressions referencing equi-join columns
Gustavo de Morais (Jira)
-
[jira] [Closed] (FLINK-38263) Connection and secret factory
Timo Walther (Jira)
-
Re: [PR] [FLINK-38263][table] add secret store related interfaces [flink]
via GitHub
-
Re: [PR] [FLINK-39140][checkpoint] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery [flink]
via GitHub
-
[jira] [Updated] (FLINK-39201) Length constraints cannot handle null values
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39201] Skip null values during length enforcement [flink]
via GitHub
-
[PR] Add HTTP Connector 1.0 [flink-web]
via GitHub
-
[jira] [Created] (FLINK-39201) Length constraints cannot handle null values
Fabian Paul (Jira)
-
[jira] [Assigned] (FLINK-39201) Length constraints cannot handle null values
Fabian Paul (Jira)
-
[jira] [Commented] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode
Sergey Nuyanzin (Jira)
-
[jira] [Resolved] (FLINK-38866) TIMESTAMP_LTZ(6) values with UNION ALL into window TVF produce incorrect results in batch mode
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39200) Skip deserialization of unsubscribed tables in MySql CDC binary log client
Cong Cheng (Jira)
-
[jira] [Commented] (FLINK-39200) Skip deserialization of unsubscribed tables in MySql CDC binary log client
Cong Cheng (Jira)
-
[jira] [Created] (FLINK-39200) Skip deserialization of unsubscribed tables in MySql CDC binary log client
Cong Cheng (Jira)
-
Re: [PR] FLINK-38334: Fix MySQL CDC source stuck in INITIAL_ASSIGNING [flink-cdc]
via GitHub
-
[jira] [Closed] (FLINK-38504) Add restore test for delta join
Xuyang Zhong (Jira)
-
[jira] [Resolved] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API
Wei Zhong (Jira)
-
[jira] [Commented] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API
Wei Zhong (Jira)
-
[jira] [Updated] (FLINK-39199) CREATE OR ALTER AMTERIALIZED TABLE doesn't support table options changes
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39199][table] CREATE OR ALTER AMTERIALIZED TABLE doesn't support table options changes [flink]
via GitHub
-
[jira] [Created] (FLINK-39199) CREATE OR ALTER AMTERIALIZED TABLE doesn't support table options changes
Sergey Nuyanzin (Jira)
-
[jira] [Updated] (FLINK-39140) [FLINK-39140][checkpoint] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery
Rui Fan (Jira)
-
[PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39198) Fix the issue of potential data loss during recovery from a checkpoint.
Hao Yu (Jira)
-
[jira] [Created] (FLINK-39198) Fix the issue of potential data loss during recovery from a checkpoint.
Hao Yu (Jira)
-
[jira] [Commented] (FLINK-38697) TaskInformation blobs accumulate without cleanup causing storage exhaustion
Piotr Rudnicki (Jira)
-
[jira] [Commented] (FLINK-39197) Fix NPE when finding chunk end
Hao Yu (Jira)
-
[jira] [Updated] (FLINK-39197) Fix NPE when finding chunk end
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39197][jdbc&mysql] Fix NPE when finding chunk end [flink-cdc]
via GitHub
-
[jira] [Updated] (FLINK-39196) Oracle pipeline support change column nullable without data type
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39196][pipeline-connector][oracle] Support change column nullable without data type [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-39197) Fix NPE when finding chunk end
Chengbing Liu (Jira)
-
[jira] [Created] (FLINK-39196) Oracle pipeline support change column nullable without data type
Mingliang Zhu (Jira)
-
Re: [D] Agent Skills Investigation [flink-agents]
via GitHub
-
Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink]
via GitHub
-
Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink]
via GitHub
-
Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink]
via GitHub
-
Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink]
via GitHub
-
Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink]
via GitHub
-
Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink]
via GitHub
-
Re: [PR] [FLINK-39065][Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Support additional CsvParser.Feature options for CSV format deserialization [flink]
via GitHub
-
[jira] [Updated] (FLINK-39195) ObjectPath should implement Comparable
ASF GitHub Bot (Jira)
-
[PR] [FLINK-39195][Table SQL/API] ObjectPath should implement Comparable [flink]
via GitHub
-
[jira] [Created] (FLINK-39195) ObjectPath should implement Comparable
Liu (Jira)
-
Re: [PR] [FLINK-38374][SQL API] Introduce new ARTIFACT keyword as an alternative to JAR [flink]
via GitHub
-
[jira] [Updated] (FLINK-39152) The FlussConfig Utils class is not in the correct directory and does not have a private instance
ASF GitHub Bot (Jira)
-
[jira] [Closed] (FLINK-27661) [Metric]Flink-Metrics PrometheusPushGatewayReporter support pushgateway http authentication
Junrui Lee (Jira)
-
[jira] [Updated] (FLINK-27661) [Metric]Flink-Metrics PrometheusPushGatewayReporter support pushgateway http authentication
Junrui Lee (Jira)
-
[jira] [Assigned] (FLINK-27661) [Metric]Flink-Metrics PrometheusPushGatewayReporter support pushgateway http authentication
Junrui Lee (Jira)
-
[PR] [FLINK-XXXX] [table] Support lineage extraction for DataStreamscan/sink providers [flink]
via GitHub
-
Re: [PR] [FLINK-38844][pipeline-connector][postgres]Add metadata column support [flink-cdc]
via GitHub
-
[jira] [Created] (FLINK-39194) Improve PyFlink's support on specifying local resource files
Biao Geng (Jira)
-
[PR] [Feature] Simplify the custom event definition [flink-agents]
via GitHub
-
Re: [PR] [FLINK-38851] Support passing arbitrary database options to JDBC Catalog [flink-connector-jdbc]
via GitHub
-
Re: [PR] [FLINK-39030][Table SQL/API] Support emit-only-on-update mode for CUMULATE window TVF to reduce unnecessary outputs [flink]
via GitHub
-
[jira] [Commented] (FLINK-39021) Support native PersistentVolumeClaim (PVC) mounting for Kubernetes deployments
Liu (Jira)
-
Re: [I] [Feature] Simplify the custom event definition. [flink-agents]
via GitHub