Messages by Thread
-
[jira] [Created] (FLINK-35394) paimon pipeline support dynamic bucket
melin (Jira)
-
[jira] [Created] (FLINK-35393) Support flink kafka catalog
melin (Jira)
-
[RESULT][VOTE] FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding
Alan Sheinberg
-
[RESULT][VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
-
[jira] [Created] (FLINK-35392) SQL Lookup Join on external database failing when using 'FOR SYSTEM_TIME AS OF' statement
Glauber M Dantas (Jira)
-
[jira] [Created] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0
LvYanquan (Jira)
-
[ANNOUNCE] Apache Flink CDC 3.1.0 released
Qingsheng Ren
-
[jira] [Created] (FLINK-35390) Error reporting in SQL Server connection table structure table in Flink CDC-3.0 version
Jira
-
[jira] [Created] (FLINK-35389) Implement List Async State API for ForStStateBackend
Hangxiang Yu (Jira)
-
[jira] [Created] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory
Jira
-
[jira] [Created] (FLINK-35387) PG CDC source support heart beat
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable
Qingsheng Ren (Jira)
-
[jira] [Created] (FLINK-35385) upgrader flink dependency version to 1.19
Hongshun Wang (Jira)
-
[RESULT][VOTE] Apache Flink CDC Release 3.1.0, release candidate #3
Qingsheng Ren
-
[Discuss] expose TaskIOMetricGroup to custom Partitioner
Steven Wu
-
[jira] [Created] (FLINK-35384) Expose metrics group to custom Partitioner
Steven Zhen Wu (Jira)
-
[jira] [Created] (FLINK-35383) Update compatibility matrix to include 1.19 release
Aleksandr Pilipenko (Jira)
-
[jira] [Created] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE
Ryan Skraba (Jira)
-
[DISCUSS] Merge "flink run" and "flink run-application" in Flink 2.0
Ferenc Csaky
-
[jira] [Created] (FLINK-35381) LocalRecoveryITCase failure on deleting directory
Ryan Skraba (Jira)
-
[jira] [Created] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests
Ryan Skraba (Jira)
-
[jira] [Created] (FLINK-35379) File merging manager is not properly notified about checkpoint
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-35378) [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunc
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-35377) debezium-json support soft deletion.
Tongkai Yin (Jira)
-
[jira] [Created] (FLINK-35376) When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed
Jira
-
[jira] [Created] (FLINK-35375) About a question report "Failed to deserialize data of EventHeaderV4" of flink cdc2.4.2
Jira
-
[jira] [Created] (FLINK-35374) Flink 1.14 kafka connector Demo Error
hongxu han (Jira)
-
[jira] [Created] (FLINK-35373) Beautify Flink CDC Paimon Sink web ui
JunboWang (Jira)
-
[jira] [Created] (FLINK-35372) flink-cdc from mysql to doris, gives an error Unsupported type:TIME(0) when mysql data type is TIME and synchronise table structure or data.
joeb (Jira)
-
[jira] [Created] (FLINK-35371) Allow the keystore and truststore type to configured for SSL
Ammar Master (Jira)
-
[jira] [Created] (FLINK-35370) Create a temp module to test backward compatibility
Jira
-
[VOTE] Release flink-connector-opensearch v2.0.0, release candidate #1
Sergey Nuyanzin
-
[VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Sergey Nuyanzin
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Andrey Redko
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Leonard Xu
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Hang Ruan
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
gongzhongqiang
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Yuepeng Pan
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
weijie guo
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Rui Fan
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Danny Cranmer
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Sergey Nuyanzin
-
Re: [VOTE] Release flink-connector-opensearch v1.2.0, release candidate #1
Sergey Nuyanzin
-
[DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option
Keith Lee
-
[jira] [Created] (FLINK-35369) Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option
Keith Lee (Jira)
-
[RESULT][VOTE] FLIP-449: Reorganization of flink-connector-jdbc
Joao Boto
-
[jira] [Created] (FLINK-35368) Reorganize table code
Jira
-
[jira] [Created] (FLINK-35367) Reorganize datastream sink and source
Jira
-
[jira] [Created] (FLINK-35366) Create all database modules
Jira
-
[jira] [Created] (FLINK-35365) Reorganize catalog and dialect code
Jira
-
[jira] [Created] (FLINK-35364) Create core module and move code
Jira
-
[jira] [Created] (FLINK-35362) Reorganization of flink-connector-jdbc
Jira
-
[jira] [Created] (FLINK-35363) Reorganization of flink-connector-jdbc
Jira
-
Confirmation on Lambda Support for UDFs in FlinkSQL / Table API
Tucker Harvey
-
[jira] [Created] (FLINK-35361) Delete Flinkhistory files that failed to write to the local directory
dengxaing (Jira)
-
[DISCUSSION] FLIP-457: Improve Table/SQL Configuration for Flink 2.0
Jane Chan
-
[jira] [Created] (FLINK-35360) [Feature] Submit Flink CDC pipeline job to yarn Application mode
Jira
-
[jira] [Created] (FLINK-35359) General Improvement to Configuration for Flink 2.0
Xuannan Su (Jira)
-
[VOTE] FLIP-450: Improve Runtime Configuration for Flink 2.0
Xuannan Su
-
[jira] [Created] (FLINK-35358) Breaking change when loading artifacts
Rasmus Thygesen (Jira)
-
Re: [DISCUSS] FLIP suggestion: Flink SQL Scalar Functions.
Сергей Парышев
-
[DISCUSS] Add a JDBC Sink Plugin to Flink-CDC-Pipeline
Jerry
-
Proposal to Add a JDBC Sink Plugin to Flink-CDC-Pipeline
Jerry
-
[jira] [Created] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document
Yang Zhou (Jira)
-
Community over Code EU 2024: The countdown has started!
Ryan Skraba
-
[jira] [Created] (FLINK-35356) Async reducing state
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-35355) Async aggregating state
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-35354) [discuss] Support host mapping in Flink tikv cdc
ouyangwulin (Jira)
-
[jira] [Created] (FLINK-35353) Translate "Profiler" page into Chinese
Juan Zifeng (Jira)
-
[jira] [Created] (FLINK-35352) Add -sae submit task to run for a period of time and automatically cancel
Jira
-
[jira] [Created] (FLINK-35351) Restore from unaligned checkpoint with custom partitioner fails.
Dmitriy Linevich (Jira)
-
[jira] [Created] (FLINK-35350) Add documentation for Kudu
Martijn Visser (Jira)
-
[VOTE] FLIP-453: Promote Unified Sink API V2 to Public and Deprecate SinkFunction
Martijn Visser
-
[jira] [Created] (FLINK-35349) Use connection in openJdbcConnection of SqlServerDialect/Db2Dialect/OracleDialect
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-35348) Implement materialized table refresh rest api
dalongliu (Jira)
-
[jira] [Created] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table
dalongliu (Jira)
-
[jira] [Created] (FLINK-35346) Introduce pluggable workflow scheduler interface for materialized table
dalongliu (Jira)
-
[jira] [Created] (FLINK-35345) FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table
dalongliu (Jira)
-
[RESULT][VOTE] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table
Ron Liu
-
[jira] [Created] (FLINK-35344) Move same code from multiple subclasses to JdbcSourceChunkSplitter
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-35343) NullPointerException in SourceReaderBase
zyh (Jira)
-
[jira] [Created] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status
Ryan Skraba (Jira)
-
[jira] [Created] (FLINK-35341) Retraction stop working with Clock dependent function in Filter
Lim Qing Wei (Jira)
-
[jira] [Created] (FLINK-35340) Flink Kubernetes Operator CRDs not applying correctly
Neil Prasad (Jira)
-
[jira] [Created] (FLINK-35339) Compilation timeout while building flink-dist
Ryan Skraba (Jira)
-
Re: [jira] [Updated] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelism
Keith Lee
-
[jira] [Created] (FLINK-35338) Enable FS Plugins as non-root
Rasmus Thygesen (Jira)
-
[jira] [Created] (FLINK-35337) Keep up with the latest version of tikv client
ouyangwulin (Jira)
-
[jira] [Created] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelismFlink/Flink:User
Keith Lee (Jira)
-
[DISCUSS] FLIP-XXX: Improve JDBC connector extensibility for Table API
lorenzo . affetti
-
[jira] [Created] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code
Ryan Skraba (Jira)
-
Access to Wiki for raising a Flip request
Vikas Garg
-
[VOTE] FLIP-451: Introduce timeout configuration to AsyncSink
Ahmed Hamdy
-
[jira] [Created] (FLINK-35334) Code generation: init method exceeds 64 KB when there is a long array field with Table API
Simon Lee (Jira)
-
[jira] [Created] (FLINK-35333) JdbcXaSinkTestBase fails in weekly Flink JDBC Connector tests
Martijn Visser (Jira)
-
[jira] [Created] (FLINK-35332) Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment
Yao Zhang (Jira)
-
[VOTE] Apache Flink CDC Release 3.1.0, release candidate #3
Qingsheng Ren
-
[VOTE] Apache Flink CDC Release 3.1.0, release candidate #2
Qingsheng Ren
-
[DISCUSSION] HybridSource multiway tree feature
Or Keren
-
[jira] [Created] (FLINK-35331) Download links for binary releases are displayed as source releases on website
Xintong Song (Jira)
-
[jira] [Created] (FLINK-35330) Support for Vertica Connector
Vikas Garg (Jira)
-
FLINK-33759
Frank Yin