Messages by Thread
-
[RESULT][VOTE] FLIP-399: Flink Connector Doris
wudi
-
[jira] [Created] (FLINK-35248) Support table/column comment to modify DDL
melin (Jira)
-
[jira] [Created] (FLINK-35247) Upgrade spotless apply to `2.41.1` in flink-connector-parent to work with Java 21
Mason Chen (Jira)
-
[jira] [Created] (FLINK-35246) SqlClientSSLTest.testGatewayMode failed in AZP
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-35245) Add metrics for flink-connector-tidb-cdc
Xie Yi (Jira)
-
[jira] [Created] (FLINK-35244) Move package for flink-connector-tidb-cdc test
Xie Yi (Jira)
-
[jira] [Created] (FLINK-35243) Carry pre-schema payload with SchemaChangeEvents
yux (Jira)
-
[jira] [Created] (FLINK-35242) Add fine-grained schema evolution strategy
yux (Jira)
-
[VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource
Xia Sun
-
[jira] [Created] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ
Alexey Leonov-Vendrovskiy (Jira)
-
[jira] [Created] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong (Jira)
-
[jira] [Created] (FLINK-35239) 1.19 docs show outdated warning
Ufuk Celebi (Jira)
-
[jira] [Created] (FLINK-35238) AZP is not working since some ci agent unhealthy
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-35237) Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization
zhangdingxin (Jira)
-
[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc
Joao Boto
-
[jira] [Created] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website
hongxu han (Jira)
-
[DISCUSSION] FLIP-450: Improve Runtime Configuration for Flink 2.0
Xuannan Su
-
[jira] [Created] (FLINK-35235) Fix missing dependencies in the uber jar
LvYanquan (Jira)
-
CSRF token available in apache flink
Swathi C
-
[jira] [Created] (FLINK-35234) Fix NullPointerException of org.apache.flink.cdc.common.configuration.ConfigurationUtils#convertToString
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-35233) HBase lookup result is wrong when lookup cache is enabled
tanjialiang (Jira)
-
[jira] [Created] (FLINK-35232) Support for retry settings on GCS connector
Vikas M (Jira)
-
[jira] [Created] (FLINK-35231) Test relies on listJobsFunction in TestingClusterClient are broken
Artem Plyusnin (Jira)
-
[jira] [Created] (FLINK-35230) Split FlinkSqlParserImplTest to reduce the code lines.
Feng Jin (Jira)
-
[jira] [Created] (FLINK-35229) join An error occurred when the table was empty
lixu (Jira)
-
[jira] [Created] (FLINK-35228) DynamicKafkaSource does not read re-added topic for the same cluster
Jira
-
[VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD
Mate Czagany
-
[jira] [Created] (FLINK-35227) Remove execution-mode in ExecutionConfigInfo
Rui Fan (Jira)
-
[jira] [Created] (FLINK-35226) Deprecate execution-mode in ExecutionConfigInfo related rest api
Rui Fan (Jira)
-
[jira] [Created] (FLINK-35225) Remove Execution mode in Flink WebUI
Rui Fan (Jira)
-
[jira] [Created] (FLINK-35223) Add jobType in JobDetailsInfo related rest api
Rui Fan (Jira)
-
[jira] [Created] (FLINK-35224) Show the JobType on Flink WebUI
Rui Fan (Jira)
-
[jira] [Created] (FLINK-35222) Adding getJobType for AccessExecutionGraph
Rui Fan (Jira)
-
[jira] [Created] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser
Wencong Liu (Jira)
-
[jira] [Created] (FLINK-35220) the error of mysql cdc
xiaotouming (Jira)
-
[jira] [Created] (FLINK-35219) [Flink SQL]Support deserialize json string into Map
zhihao zhang (Jira)
-
[jira] [Created] (FLINK-35218) Duplicated values caused by expired state TTL
garcia (Jira)
-
[jira] [Created] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage
Marc Aurel Fritz (Jira)
-
[jira] [Created] (FLINK-35216) Support for RETURNING clause of JSON_QUERY
Dawid Wysakowicz (Jira)
-
[SUMMARY] Flink 1.20 Release Sync 04/23/2024
Rui Fan
-
[jira] [Created] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed
Rui Fan (Jira)
-
[jira] [Created] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated
Yuxin Tan (Jira)
-
[jira] [Created] (FLINK-35213) A potential inconsistent table structure issue
LvYanquan (Jira)
-
[jira] [Created] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode
Wei Yuan (Jira)
-
[jira] [Created] (FLINK-35211) when synchronize LOB fields using oracle cdc, an error occurs
wangsw (Jira)
-
[jira] [Created] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions
Nicolas Perrin (Jira)
-
[VOTE] Release flink-connector-kafka v3.2.0, release candidate #1
Danny Cranmer
-
[VOTE] Release flink-connector-cassandra v3.2.0, release candidate #1
Danny Cranmer
-
[jira] [Created] (FLINK-35209) Add a DeserializationSchema decorator that counts deserialize errors
Nicolas Perrin (Jira)
-
[RESULT][VOTE] FLIP-442: General Improvement to Configuration for Flink 2.0
Xuannan Su
-
[DISCUSS] FLIP-XXX Support currentFetchEventTimeLag and processingLag metrics
jialiang tan
-
[jira] [Created] (FLINK-35208) Respect pipeline.cached-files during processing Python dependencies
Dian Fu (Jira)
-
[jira] [Created] (FLINK-35207) Kubernetes session E2E test fails to fetch packages.
Ryan Skraba (Jira)
-
[jira] [Created] (FLINK-35206) Desc table syntax support materialized table
dalongliu (Jira)
-
[jira] [Created] (FLINK-35205) Support the execution of alter materialized table reset options
dalongliu (Jira)
-
[jira] [Created] (FLINK-35203) Support the execution of alter materialized table set refresh mode
dalongliu (Jira)
-
[jira] [Created] (FLINK-35204) Support the execution of alter materialized table set options
dalongliu (Jira)
-
[jira] [Created] (FLINK-35202) Support the execution of set freshness for materialized table
dalongliu (Jira)
-
[jira] [Created] (FLINK-35201) Support the execution of drop materialized table in full refresh mode
dalongliu (Jira)
-
[jira] [Created] (FLINK-35200) Support the execution of suspend, resume materialized table in full refresh mode
dalongliu (Jira)
-
[jira] [Created] (FLINK-35199) Support the execution of create materialized table in full refreshmode
dalongliu (Jira)
-
[jira] [Created] (FLINK-35198) Support the execution of refresh materialized table
dalongliu (Jira)
-
[jira] [Created] (FLINK-35197) Support the execution of suspend, resume materialized table in continuous mode
dalongliu (Jira)
-
[jira] [Created] (FLINK-35196) bouncycastle class not found for flink pulsar connector
Wenbing Shen (Jira)
-
[jira] [Created] (FLINK-35195) Support the execution of materialized table in continuous mode
dalongliu (Jira)
-
[jira] [Created] (FLINK-35194) Support describe job syntax
dalongliu (Jira)
-
[jira] [Created] (FLINK-35193) Support drop materialized table syntax and execution
dalongliu (Jira)
-
[jira] [Created] (FLINK-35192) operator oom
chenyuzhi (Jira)
-
[jira] [Created] (FLINK-35191) Support alter materialized table related syntaxes: suspend, resume, refresh, set and reset
dalongliu (Jira)
-
[jira] [Created] (FLINK-35190) Support the syntaxes of Create, Suspend, Resume, Refresh and Drop materialized table
dalongliu (Jira)
-
[jira] [Created] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table
dalongliu (Jira)
-
[jira] [Created] (FLINK-35188) Introduce CatalogMaterializedTable and related interface to support materialized table
dalongliu (Jira)
-
[jira] [Created] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines
dalongliu (Jira)
-
[jira] [Created] (FLINK-35186) Create State V2 from new StateDescriptor
Zakelly Lan (Jira)
-
[DISCUSS] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table
Ron Liu
-
[RESULT][VOTE] FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines
Ron Liu
-
[DISCUSS] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0
yue ma
-
[jira] [Created] (FLINK-35185) Resuming Externalized Checkpoint(rocks, incremental, no parallelism change) end-to-end test failed
Weijie Guo (Jira)
-
[jira] [Created] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator
Roman Boyko (Jira)
-
[jira] [Created] (FLINK-35183) Expose FlinkMinorVersion as metric for applications in operator
Jira
-
[jira] [Created] (FLINK-35182) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector
Zhongqiang Gong (Jira)
-
[jira] [Created] (FLINK-35181) CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector
Zhongqiang Gong (Jira)
-
[jira] [Created] (FLINK-35180) Instant in row doesn't convert to correct type in python process mode
Wei Yuan (Jira)
-
[jira] [Created] (FLINK-35179) add postgres pipeline data sink connector
melin (Jira)
-
[jira] [Created] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership
elon_X (Jira)
-
[jira] [Created] (FLINK-35177) Datagen examples in documentation do not compile
Sergei Morozov (Jira)
-
[jira] [Created] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table
RocMarshal (Jira)
-
[jira] [Created] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3
Ryan Skraba (Jira)
-
[jira] [Created] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector
Danny Cranmer (Jira)
-
[VOTE] Release flink-connector-aws v4.3.0, release candidate #2
Danny Cranmer
-
[jira] [Created] (FLINK-35173) Debezium Custom Time Serializer
ZhengYu Chen (Jira)
-
[jira] [Created] (FLINK-35172) DDL statement is added to the Schema Change Event
melin (Jira)
-
[jira] [Created] (FLINK-35171) Class 'FlinkSqlParserImpl' is missed
chenyu (Jira)
-
[jira] [Created] (FLINK-35170) SqlServer connector support scanNewlyAddedTableEnabled param
fengfengzai (Jira)
-
[jira] [Created] (FLINK-35169) Recycle buffers to freeSegments before releasing data buffer for sort accumulator
Yuxin Tan (Jira)
-
[jira] [Created] (FLINK-35168) Basic State Iterator for async processing
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-35167) [CDC] Introduce MaxCompute pipeline DataSink
zhangdingxin (Jira)
-
[jira] [Created] (FLINK-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling
Jiang Xin (Jira)
-
[jira] [Created] (FLINK-35165) AdaptiveBatch Scheduler should not restrict the default source parallelism to the max parallelism set
Venkata krishnan Sowrirajan (Jira)
-
[jira] [Created] (FLINK-35164) Support `ALTER CATALOG RESET` syntax
Yubin Li (Jira)
-
[jira] [Created] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access
Jinzhong Li (Jira)
-
[jira] [Created] (FLINK-35162) Support grouping state get and put access
Jinzhong Li (Jira)
-
[jira] [Created] (FLINK-35161) Implement StateExecutor for ForStStateBackend
Jinzhong Li (Jira)
-
[jira] [Created] (FLINK-35160) Support for Thread Dump provides a convenient way to display issues of thread deadlocks in tasks
elon_X (Jira)
-
[jira] [Created] (FLINK-35159) CreatingExecutionGraph can leak CheckpointCoordinator and cause JM crash
Chesnay Schepler (Jira)
-
[jira] [Created] (FLINK-35158) Error handling in StateFuture's callback
Yanfei Lei (Jira)
-
[jira] [Created] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish
Gyula Fora (Jira)
-
[VOTE] Release flink-connector-gcp-pubsub v3.1.0, release candidate #1
Danny Cranmer
-
[VOTE] Release flink-connector-mongodb v1.2.0, release candidate #2
Danny Cranmer
-
[VOTE] Release flink-connector-jdbc v3.2.0, release candidate #2
Danny Cranmer
-
[jira] [Created] (FLINK-35156) Wire new operators for async state with DataStream V2
Zakelly Lan (Jira)
-
[jira] [Created] (FLINK-35155) Introduce TableRuntimeException
Dawid Wysakowicz (Jira)
-
[jira] [Created] (FLINK-35154) Javadoc aggregate fails
Dmitriy Linevich (Jira)
-
[jira] [Created] (FLINK-35153) Internal Async State Implementation and StateDescriptor for Map/List State
Zakelly Lan (Jira)
-
Re: [ DISCUSS ] FLIP-XXX : [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration
Gyula Fóra
-
[jira] [Created] (FLINK-35152) Flink CDC Doris/Starrocks Sink Auto create table event should support setting auto partition fields for each table
tumengyao (Jira)
-
[jira] [Created] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full
Xin Gong (Jira)
-
[jira] [Created] (FLINK-35150) The specified upload does not exist. The upload ID may be invalid
qyw (Jira)
-
[jira] [Created] (FLINK-35149) Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink
Hongshun Wang (Jira)
-
[jira] [Created] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor
Mingliang Liu (Jira)
-
[jira] [Created] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table
Sharon Xie (Jira)
-
[jira] [Created] (FLINK-35146) CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan
Ryan Skraba (Jira)
-
[jira] [Created] (FLINK-35145) Add timeout for cluster termination
Zhanghao Chen (Jira)
-
[jira] [Created] (FLINK-35143) Expose newly added tables capture in mysql pipeline connector
Hongshun Wang (Jira)
-
[VOTE] Release flink-connector-mongodb v1.2.0, release candidate #1
Danny Cranmer