Messages by Thread
-
[jira] [Created] (FLINK-39354) SchemaUtils.applyAddColumnEvent fails when referenced existing column name differs only by case
lllmao (Jira)
-
[jira] [Created] (FLINK-39353) Dark mode text is nearly unreadable after recent Flink website rebuild
Rui Fan (Jira)
-
[jira] [Created] (FLINK-39352) Document START_MODE behavior
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39351) [Flaky Tests] NewlyAddedTableITCase.testJobManagerFailoverForNewlyAddedTableWithAheadBinlog
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-39350) [Flaky Tests] MySqlToPaimonE2eITCase.testSinkToAppendOnlyTable
Yanquan Lv (Jira)
-
[ANNOUNCE] Apache Flink CDC 3.6.0 released
Yanquan Lv
-
[jira] [Created] (FLINK-39349) Support TO_CHANGELOG retract/upsert stream to upsert stream with deletion flag (4.2.2.1)
Gustavo de Morais (Jira)
-
[RESULT][VOTE] Apache Flink CDC Release 3.6.0, release candidate #2
Yanquan Lv
-
[jira] [Created] (FLINK-39348) Add Interval to reuse code for freshness and start mode
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39347) Flink otel reporter doesnt report any metrics
Sujit Joshi (Jira)
-
[jira] [Created] (FLINK-39346) Improve the error message when the AddColumnEvent fails
peiyu (Jira)
-
[RESULT][VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness
Mika Naylor
-
[jira] [Created] (FLINK-39345) Support SELECT * EXCLUDE(columns) syntax in Flink SQL
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39344) [Doc] Fix inconsistencies between MySqlDataSourceOptions and MySQL Pipeline Connector documentation
XiaodongHuan (Jira)
-
[DISCUSS][FLINK-39151] Hide warning about UnixOperatingSystemMXBean missing on Windows - request for review
Piotr Przybylski
-
[jira] [Created] (FLINK-39343) Fix inconsistencies in sql_function documentation
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39342) [Iceberg] Support hadoop.conf.* prefix to pass Hadoop configuration properties
ericzeng (Jira)
-
[jira] [Created] (FLINK-39341) Implement DatabaseMetaData methods for DBeaver compatibility
Navis Ryu (Jira)
-
[jira] [Created] (FLINK-39340) Transform binary multi join back to regular join
Dmitriy Linevich (Jira)
-
[jira] [Created] (FLINK-39339) Consider immutable cols to infer sink required updated mode traits
Xuyang Zhong (Jira)
-
[SUMMARY] Flink 2.3 release sync -- reviews needed for flaky test PRs
David Anderson
-
[DISCUSS] extending the feature freeze date of Flink 2.3
David Anderson
-
[jira] [Created] (FLINK-39338) Fix topic collision in parameterized KafkaWriter tests
Aleksandr Savonin (Jira)
-
[jira] [Created] (FLINK-39336) Clean up code in the `flink-cdc-pipeline-connector-kafka` module that is compatible with older versions of Flink.
peiyu (Jira)
-
[jira] [Created] (FLINK-39337) Clean up the compatibility code for Flink 1.19 in the `e2e-tests` module.
peiyu (Jira)
-
[jira] [Created] (FLINK-39335) Upgrade `flink-connector-starrocks` to no longer require compatibility with Flink 1.19.
peiyu (Jira)
-
[jira] [Created] (FLINK-39334) flink-connector-mongodb fails when write concern is set to zero
Jacob Jona Fahlenkamp (Jira)
-
[jira] [Created] (FLINK-39333) Introduce an alias config option for query-params to allow an alternative key to the column name to be used as the query param key.
David Radley (Jira)
-
[jira] [Created] (FLINK-39332) Ensure body-template error messages associated with exceptions are in the log.
David Radley (Jira)
-
[jira] [Created] (FLINK-39331) Add Experimental Annotations for public API
Samrat Deb (Jira)
-
FLIP-556 wiki edit permission question
dylanhz
-
[jira] [Created] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails
Piotr Nowojski (Jira)
-
[jira] [Created] (FLINK-39329) [MySQL-CDC] Improve error message for tables without primary key in incremental snapshot
ericzeng (Jira)
-
[ANNOUNCE] Apache Flink Agents 0.2.1 released
wenjin
-
[jira] [Created] (FLINK-39328) [BUG] When executing DROP TABLE on the source, the following error occurs: Table not exist.
zexin gong (Jira)
-
[jira] [Created] (FLINK-39327) Rename gaussdws pipeline sink connector to dws
Daishuyuan (Jira)
-
Fwd: Can you check my access?
Robert Thomson
-
[jira] [Created] (FLINK-39326) Flaky DispatcherApplicationTest.testJobResultNotMarkedCleanUntilApplicationTerminates
Piotr Nowojski (Jira)
-
[DISCUSS] FLIP-572: Introduce Flink-Kafka Transactions Management Tool
Aleksandr Savonin
-
[jira] [Created] (FLINK-39325) Dynamically show/hide rescales tab
CHANHAE OH (Jira)
-
[jira] [Created] (FLINK-39324) Allow MultiJoin to respect IS_NOT_DISTINCT_FROM when extracting join keys
Stepan Stepanishchev (Jira)
-
[jira] [Created] (FLINK-39323) Support SHOW CREATE [OR ALTER] with relative time intervals for FROM_NOW(<interval_expression>)
Ramin Gharib (Jira)
-
[VOTE] Apache Flink CDC Release 3.6.0, release candidate #2
Yanquan Lv
-
[jira] [Created] (FLINK-39322) Add some restore tests about cascaded delta join
Xuyang Zhong (Jira)
-
[DISCUSS] Regarding FLINK-28398
Souptik Barman
-
[jira] [Created] (FLINK-39321) When writing to Paimon via FlinkCDC , if 'dynamic-bucket.initial-buckets' = '1' is set and the job parallelism is greater than 1, an error will be reported: This is a bug, record assign id %s should equal to assign id %s.
Jira
-
[jira] [Created] (FLINK-39320) Include Kafka record metadata in deserialization error message
Pritesh Gudge (Jira)
-
[jira] [Created] (FLINK-39319) Add immutable columns constraint in Python API
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-39318) Interruptible timers are not actually enabled for temporal joins
Piotr Nowojski (Jira)
-
[RESULT][VOTE] Apache Flink Agents Release 0.2.1, release candidate #1
wenjin
-
[jira] [Created] (FLINK-39317) [test] Add e2e test for source connector with Flink 2.2
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-39316) BlobServer.getAddress() uses InetAddress.getLocalHost() which fails with VPN networking
Jira
-
[jira] [Created] (FLINK-39315) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase when the MySql table is being continuously written
Cong Cheng (Jira)
-
[jira] [Created] (FLINK-39314) Filter on any upsert key group is sufficient to discard update before in FlinkChangelogModeInferenceProgram
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-39313) NDU analyzer misses non-deterministic functions in ChangelogNormalize filter conditions
Gustavo de Morais (Jira)
-
[DISCUSS] FLIP-571: Support Dynamically Updating Checkpoint Configuration at Runtime via REST API
Jiangang Liu
-
[jira] [Created] (FLINK-39312) Fix Hudi pipeline connector dependency scope for flink-metrics-dropwizard
Shuo Cheng (Jira)
-
[jira] [Created] (FLINK-39311) Flaky tests in DispatcherApplicationTest
Yi Zhang (Jira)
-
[DISCUSS] FLIP-570: Support Runtime Data Sampling for Operators with WebUI Visualization
Jiangang Liu
-
Fw:JIRA account Request for Apache Flink
unigogyk
-
[jira] [Created] (FLINK-39310) Web UI jar.service.ts passes program-args as string instead of programArgsList array, incompatible with Flink 2.0 REST API
Wei H (Jira)
-
[jira] [Created] (FLINK-39309) Duplicate Submission Check Excludes Terminated Applications
Yi Zhang (Jira)
-
[jira] [Created] (FLINK-39308) Skip empty file-merging operator state snapshots for empty operator list state
Ivan Torres (Jira)
-
[jira] [Created] (FLINK-39307) Improve checkpoint deletion speed in CompletedCheckpoint
Shihuan Liu (Jira)
-
[jira] [Created] (FLINK-39306) Non-source vertices do not use per-second rate metrics, producing inaccurate scaling decisions
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Created] (FLINK-39305) Implement START_MODE for ALTER path of Materialized Table
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39304) Support START_MODE clause in the parser
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39303) Implement START_MODE clause for Materialized Table Evolution
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39302) Handling Idempotency in SHOW CREATE [OR ALTER] for Relative Intervals
Ramin Gharib (Jira)
-
[jira] [Created] (FLINK-39301) FLIP-557: Granular Control over Data Reprocessing in Materialized Table Evolution
Ramin Gharib (Jira)
-
[RESULT][VOTE] FLIP-557: Granular Control over Data Reprocessing in Materialized Table Evolution
Ramin Gharib
-
[jira] [Created] (FLINK-39300) [flink-cdc] Reuse ObjectMapper as static constant to avoid repeated instantiation
ericzeng (Jira)
-
[jira] [Created] (FLINK-39299) Parallelism alignment logic in JobVertexScaler#scale can cancel, invert, or overshoot scaling decisions for source partition-aware vertices
Dennis-Mircea Ciupitu (Jira)
-
[jira] [Created] (FLINK-39298) [DOC] Add documentation for Fluss sink complex types support
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-39297) [DOC] Update documentation for sink connector version upgrades
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-39296) [DOC] Add documentation for Fluss pipeline connector AddColumn support
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-39295) [DOC] Add documentation for MySQL 8.4+ support in MySQL CDC connector
Yanquan Lv (Jira)
-
[DISCUSS] FLIP-569: Sunset the Stateful Functions (StateFun) Sub-project
Martijn Visser
-
[jira] [Created] (FLINK-39294) [DOC] Add documentation for PostgreSQL CDC `schema.change.enabled` option
Yanquan Lv (Jira)
-
[DISCUSS] FLIP-XXX: Enhancing HistoryServer with Lazy Loading and Pluggable Storage
zihao chen
-
[jira] [Created] (FLINK-39293) SqlParserException if I select from a view that uses MATCH_RECOGNIZE
Nic Townsend (Jira)
-
[jira] [Created] (FLINK-39292) Split BuiltInFunctionDefinitions to reduce the lines of code file to avoid reaching code check style limitation
RocMarshal (Jira)
-
[jira] [Created] (FLINK-39291) FlinkScalaKryoInstantiator uses StdInstantiatorStrategy directly, bypassing constructors and causing NPE for classes requiring initialization
Liu (Jira)
-
[jira] [Created] (FLINK-39290) Doc generation fails with ExceptionInfo name conflict
Yi Zhang (Jira)
-
[jira] [Created] (FLINK-39289) The truncate command cannot be executed on the paimon table where deletion-vectors.enabled:true is set
zexin gong (Jira)
-
[jira] [Created] (FLINK-39288) Update document description to guide users on using Flink 2. x version
Yanquan Lv (Jira)
-
[jira] [Created] (FLINK-39287) Introduce FlinkRelMdImmutableColumns to implement the derivation logic of some simple nodes
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-39286) Introduce immutable columns constraint in schema
Xuyang Zhong (Jira)
-
[jira] [Created] (FLINK-39285) Consider the result of filter pushdown rules in the MultiJoin rule
Dmitriy Linevich (Jira)
-
[jira] [Created] (FLINK-39284) CREATE OR ALTER MATERIALIZED TABLE doesn't respect schema of existing table
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39283) Upgrade org.apache.avro:avro to 1.12.1
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39282) Translate "Balanced Tasks Scheduling" page into Chinese
Vincent Woo (Jira)
-
[jira] [Created] (FLINK-39281) redis-streams Source connector
Samrat Deb (Jira)
-
[VOTE] Apache Flink CDC Release 3.6.0, release candidate #1
Yanquan Lv
-
[jira] [Created] (FLINK-39280) Add missing State Size Tracking Options to configuration page
Aleksandr Savonin (Jira)
-
[jira] [Created] (FLINK-39279) CREATE OR ALTER MATERIALIZED TABLE doesn't respect distribution change
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39278) Indexing of columns in CREATE [MATERUALIZED ]TABLE should start with 1 in error messages
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39277) Formatting errors in the "Metric Reporters" page result in missing content being displayed.
Vincent Woo (Jira)
-
[jira] [Created] (FLINK-39276) CREATE OR ALTER MATERIALIZED TABLE should respect nullability defined in schema
Sergey Nuyanzin (Jira)
-
[jira] [Created] (FLINK-39275) Some issues in the "Performance Tuning" document
Vincent Woo (Jira)
-
[jira] [Created] (FLINK-39274) TM It is impossible to bypass the KDC login process, yet the TOKEN issued by AM has not been actually utilized.
ruiliang (Jira)
-
[jira] [Created] (FLINK-39273) ScalarFunction throws "Argument name conflict" when eval method contains lambda expression
dylanhz (Jira)
-
[jira] [Created] (FLINK-39272) Changing of REFRESH_MODE for CREATE OF ALTER MATERIALIZED TABLE should fail
Sergey Nuyanzin (Jira)
-
[DISCUSS] FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities
Gustavo de Morais
-
[jira] [Created] (FLINK-39271) Harden session job deletion flow
Gyula Fora (Jira)
-
[jira] [Created] (FLINK-39270) Fix savepoint/last-state upgrade state loss under slow JM
Gyula Fora (Jira)
-
[VOTE] Apache Flink Agents Release 0.2.1, release candidate #1
wenjin
-
[jira] [Created] (FLINK-39269) Keep doc for deprecated config option
Qinghui Xu (Jira)
-
[jira] [Created] (FLINK-39268) Support Common Subexpression Elimination (CSE) in Calc Code Generation
Liu (Jira)
-
[jira] [Created] (FLINK-39267) Support dynamically updating checkpoint configuration at runtime via REST API
Liu (Jira)
-
[jira] [Created] (FLINK-39266) Support metadata column in sql create model ddl
Cong Cheng (Jira)
-
[jira] [Created] (FLINK-39265) [postgres-cdc] PostgreSQL CDC intermittently drops INSERT records after checkpoint recovery due to WalPositionLocator filtering
Di Wu (Jira)
-
[jira] [Created] (FLINK-39264) Add docs for application management
Yi Zhang (Jira)
-
[jira] [Created] (FLINK-39263) Support custom codecs in MongoDB Sink
Jacob Jona Fahlenkamp (Jira)
-
[jira] [Created] (FLINK-39262) Support dynamic namespace selection in MongoDB Sink
Jacob Jona Fahlenkamp (Jira)
-
[jira] [Created] (FLINK-39261) Add FROM_CHANGELOG built-in process table function (4.1.3.1 upsert stream to upsert stream)
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39260) Support multi-compression format python files
raoraoxiong (Jira)
-
[VOTE] FLIP-567: Introduce a ProcessTableFunction Test Harness
Mika Naylor
-
[jira] [Created] (FLINK-39259) Add TO_CHANGELOG built-in process table function (4.2.2.2)
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39258) FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs
Gustavo de Morais (Jira)
-
[jira] [Created] (FLINK-39257) Remove compatibility code for older versions of Flink.
peiyu (Jira)
-
[jira] [Created] (FLINK-39256) Support ORDER BY clause in PTFs
Timo Walther (Jira)
-
[jira] [Created] (FLINK-39255) Support late data in PTFs
Timo Walther (Jira)
-
[jira] [Created] (FLINK-39254) FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Timo Walther (Jira)
-
[RESULT][VOTE] FLIP-565: Improve ProcessTableFunctions for late data handling and state access
Timo Walther
-
[jira] [Created] (FLINK-39253) row() does not preserve field names from AS aliases and field references
Mika Naylor (Jira)
-
[jira] [Created] (FLINK-39252) Flink cdc pipeline support sqlserver source pipeline
Daishuyuan (Jira)
-
[jira] [Created] (FLINK-39251) Support Nanosecond Logical Types in Flink Avro
Talat Uyarer (Jira)
-
[jira] [Created] (FLINK-39250) Use sdk v2 stream instead of file based approach
Samrat Deb (Jira)
-
[jira] [Created] (FLINK-39249) Daily benchmark timeout
Zakelly Lan (Jira)
-
[DISCUSS] AI-Assisted Contributions and AI Tooling Support in Apache Flink
Martijn Visser
-
[jira] [Created] (FLINK-39248) SinkUpsertMaterializerV2 deserialization can fail
Roman Khachatryan (Jira)
-
[jira] [Created] (FLINK-39247) ClassCastException when executing INSERT INTO with nested ROW containing NOT NULL MAP in Flink 2.2.0
Fred Teunissen (Jira)
-
[jira] [Created] (FLINK-39246) ArrayIndexOutOfBoundsException when creating VIEW with inline ARRAY of ROW values in Flink 2.2.0
Fred Teunissen (Jira)
-
[jira] [Created] (FLINK-39245) Support AWS Glue Catalog for Iceberg pipeline connector
Xiao Huang (Jira)
-
[SUMMARY] Flink 2.3 release sync -- 3 weeks to feature freeze
David Anderson