dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
[jira] [Created] (FLINK-36114) Schema registry should block when handling existing requests
yux (Jira)
[jira] [Created] (FLINK-36113) Condition 'transform instanceof PhysicalTransformation' is always 'false'
tiancx (Jira)
[jira] [Created] (FLINK-36112) Add Support for CreateFlag.NO_LOCAL_WRITE in FLINK on YARN's File Creation to Manage Disk Space and Network Load in Labeled YARN Nodes
liang yu (Jira)
[jira] [Created] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name
MOBIN (Jira)
[jira] [Created] (FLINK-36110) Periodic save points trigger continuously
Gyula Fora (Jira)
[jira] [Created] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering
Gyula Fora (Jira)
[jira] [Created] (FLINK-36108) Wait for state download on cancellation to enforce cleanup
Piotr Nowojski (Jira)
[jira] [Created] (FLINK-36107) schema event support custom callback
melin (Jira)
[jira] [Created] (FLINK-36106) t_flink_autoscaler_event_handler is not cleaned after each testing
Rui Fan (Jira)
[jira] [Created] (FLINK-36105) CDC pipeline job could not restore from state in Flink 1.20
yux (Jira)
[jira] [Created] (FLINK-36104) flink 1.20 not suport logback
xuhaiLong (Jira)
[jira] [Created] (FLINK-36103) Support ESCAPE in built-in function LIKE formally
Dylan He (Jira)
[jira] [Created] (FLINK-36102) Support ESCAPE in built-in function LIKE formally
Dylan He (Jira)
[jira] [Created] (FLINK-36101) Support ESCAPE in built-in function LIKE formally
Dylan He (Jira)
[jira] [Created] (FLINK-36100) Support ESCAPE in built-in function LIKE formally
Dylan He (Jira)
[FLINK-35177] Fix DataGen Connector documentation
Sergei Morozov
[jira] [Created] (FLINK-36099) JobIDLoggingITCase fails due to "Cannot find task to fail for execution [...]" info log message in TM logs
Matthias Pohl (Jira)
[jira] [Created] (FLINK-36098) Add support for Table Comments in Flink SQL ALTER TABLE statements
Steffen Hoellinger (Jira)
[jira] [Created] (FLINK-36097) Add timeseries support for SampleSplitter
Jiabao Sun (Jira)
[jira] [Created] (FLINK-36096) Support sync interface in state v2 api.
wang qian (Jira)
[jira] [Created] (FLINK-36095) KeyedLookupJoinWrapper should shuffle by input upsertKey instead of join key to avoid changelog disordering
lincoln lee (Jira)
[jira] [Created] (FLINK-36094) CDC SchemaRegistryRequestHandler should throw exception which is not SchemaEvolveException
Hongshun Wang (Jira)
[jira] [Created] (FLINK-36093) PreTransform operator wrongly filters out columns when multiple transform rules were defined
yux (Jira)
[jira] [Created] (FLINK-36092) Transform doesn't fully support with schema evolution
yux (Jira)
[jira] [Created] (FLINK-36091) Config passed in via the environment variable FLINK_PROPERTIES which has space not getting processed
lajith (Jira)
[jira] [Created] (FLINK-36090) Bug with IngestDB restore operation for priority queue state in backend
Maxim Vershinin (Jira)
[jira] [Created] (FLINK-36089) clean codegen print function
Jacky Lau (Jira)
[jira] [Created] (FLINK-36088) Fix NopointException in PaimonDataSink.
LvYanquan (Jira)
[jira] [Created] (FLINK-36087) Fix
LvYanquan (Jira)
[jira] [Created] (FLINK-36086) SQL Server source connector skips changes if restarted mid transaction
Sergei Morozov (Jira)
[jira] [Created] (FLINK-36085) Refeactor operation with LIKE/ILIKE
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-36084) Optimze parquet binary getBytes with getBytesUnsafe to avoid copy cost
xy (Jira)
[jira] [Created] (FLINK-36083) Fix kafka table api doc's Connector Options table broken
Zhongqiang Gong (Jira)
[jira] [Created] (FLINK-36082) Fix NotSerializableException for KafkaDataSink
LvYanquan (Jira)
[jira] [Created] (FLINK-36081) Flink CDC MySQL source connector missing some columns data of newly added tables
Mingya Wang (Jira)
[ANNOUNCE] New Apache Flink Committer - Xuannan Su
Xintong Song
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Zakelly Lan
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Qingsheng Ren
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Samrat Deb
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Hong
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Yanquan Lv
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
gongzhongqiang
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Leonard Xu
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Rui Fan
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Feng Jin
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Junrui Lee
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Aleksandr Pilipenko
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Luke Chen
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Guowei Ma
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Jiabao Sun
Re: [ANNOUNCE] New Apache Flink Committer - Xuannan Su
Xuannan Su
[jira] [Created] (FLINK-36080) Add SQL Connector for SQS
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-36079) Add Documentation for SQS Table API connector
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-36078) Add Documentation for PubSubSink Table API connector
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-36077) Implement Table API support for PubSubSink V2
Ahmed Hamdy (Jira)
[jira] [Created] (FLINK-36076) Hotfix: Set isSchemaChangeApplying as isSchemaChangeApplying for thread safe.
Hongshun Wang (Jira)
[jira] [Created] (FLINK-36075) Add paginate partition strategy for mongodb connector
Jiabao Sun (Jira)
[jira] [Created] (FLINK-36074) Supprt insert overwrite semantics for mongodb table sink.
Jiabao Sun (Jira)
[DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization.
Lei Yang
Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization.
Zhu Zhu
Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization.
Lincoln Lee
Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization.
Lei Yang
Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization.
Lincoln Lee
Re: [DISCUSS] FLIP-475: Support Adaptive Skewed Join Optimization.
Lei Yang
SinkV2 framework operators
Rodrigo Meneses
[jira] [Created] (FLINK-36073) ApplicationMode with the K8s operator does not support downloading jars via filesystem plugins
Robert Metzger (Jira)
[jira] [Created] (FLINK-36072) Optimizing the Overhead of the Network Layer in Adaptive Execution Scenarios
Junrui Li (Jira)
[jira] [Created] (FLINK-36071) Using System.nanoTime to measure the elapsed time instead of System.currentTimeMillis
Rui Fan (Jira)
[jira] [Created] (FLINK-36070) Modifying web UI to adapt to Incremental JobGraph Generation
Junrui Li (Jira)
[jira] [Created] (FLINK-36069) Extending job detail rest API to adapt to Incremental JobGraph Generation
Junrui Li (Jira)
[jira] [Created] (FLINK-36068) Support for adaptive job scheduling based on StreamGraph
Junrui Li (Jira)
[jira] [Created] (FLINK-36067) Introducing the StreamGraphOptimizer component
Junrui Li (Jira)
[jira] [Created] (FLINK-36066) Introducing the AdaptiveGraphGenerator component
Junrui Li (Jira)
[jira] [Created] (FLINK-36065) Support for submitting StreamGraph
Junrui Li (Jira)
[jira] [Created] (FLINK-36064) Refactor CollectResultIterator to eliminate dependency on OperatorID
Junrui Li (Jira)
[jira] [Created] (FLINK-36063) Migrate StreamGraph and its related classes to flink-runtime
Junrui Li (Jira)
[jira] [Created] (FLINK-36062) Only the first one in the delayed data will trigger,and it will only be restored when the transition is made to the current day window
Darren_Han (Jira)
[VOTE] Apache Flink CDC Release 3.2.0, release candidate #0
Qingsheng Ren
Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0
Yanquan Lv
Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0
Yanquan Lv
Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0
Leonard Xu
Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0
Qingsheng Ren
Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0
Xiqian YU
Re: [VOTE] Apache Flink CDC Release 3.2.0, release candidate #0
Xiqian YU
[jira] [Created] (FLINK-36061) Support Apache iceberg for pipeline connector
ZhengYu Chen (Jira)
[RESULT][VOTE] FLIP-470: Support Adaptive Broadcast Join
Xia Sun
[jira] [Created] (FLINK-36060) Transform built-in functions could not handle NULL values as arguments
yux (Jira)
[jira] [Created] (FLINK-36059) SqlClientITCase failed due to could not create/start container
Weijie Guo (Jira)
[jira] [Created] (FLINK-36058) OperatorTestHarness is always using checkpointId=0 for state recovery
Rodrigo Meneses (Jira)
[SUMMARY] Flink 2.0 Release Sync 08/14/2024
Xintong Song
[jira] [Created] (FLINK-36057) Allow specifying ARN for AWS connector resources
Elphas Toringepi (Jira)
[jira] [Created] (FLINK-36056) change flink.connector.elasticsearch.version to a release version in branch release-3.2
wuzexian (Jira)
[jira] [Created] (FLINK-36055) Change flink.connector.elasticsearch.version to a release version
wuzexian (Jira)
[jira] [Created] (FLINK-36054) Cleanup Flink CDC pom and release scripts
Qingsheng Ren (Jira)
[jira] [Created] (FLINK-36053) Support multi-version integration test in mongodb connector
Jiabao Sun (Jira)
[jira] [Created] (FLINK-36052) add elasticsearch.md for elasticsearch pipeline connector
wuzexian (Jira)
[jira] [Created] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements
Sergei Morozov (Jira)
[jira] [Created] (FLINK-36049) Add CompiledPlan annotations to BatchExecSortLimit
Jim Hughes (Jira)
[jira] [Created] (FLINK-36048) Add CompiledPlan annotations to BatchExecRank
Jim Hughes (Jira)
[jira] [Created] (FLINK-36047) Add CompiledPlan annotations to BatchExecOverAggregate
Jim Hughes (Jira)
[jira] [Created] (FLINK-36046) Change the existing org.apache.flink.streaming.api.functions.sink#DiscardingSink and org.apache.flink.streaming.api.functions.sink#PrintSinkFunction to use the new interfaces
Min Zhao (Jira)
[jira] [Created] (FLINK-36045) Add support for SharePlex JSON format to Flink Formats.
Will-Hyde (Jira)
[jira] [Created] (FLINK-36044) In Flinkcdc-connect-mysql2.4 version, scan.snapshot.fetch.size does not take effect
zhanghuaibei (Jira)
[jira] [Created] (FLINK-36043) [SQL] Unexpected SinkMaterializer operator generated when use coalesce function on upsert key fields
Yuan Kui (Jira)
[VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Zakelly Lan
Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Yanfei Lei
Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Yuepeng Pan
Re:Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Xuyang
Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Ahmed Hamdy
Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Hangxiang Yu
Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Zakelly Lan
Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Yuan Mei
Re: Re: [VOTE] FLIP-455: Declare async state processing and checkpoint the in-flight requests
Zakelly Lan
[jira] [Created] (FLINK-36042) newly added tables capture
xuhaiLong (Jira)
[jira] [Created] (FLINK-36041) Eliminate Calcite dependency during runtime
yux (Jira)
[jira] [Created] (FLINK-36040) mysql cdc pipeline recover error from ck
xuhaiLong (Jira)
[jira] [Created] (FLINK-36039) Support clean historical event handler records in autoscaler jdbc plugin
RocMarshal (Jira)
[jira] [Created] (FLINK-36038) SHOW CREATE VIEW returns invalid query
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-36037) Add compability for 1.9 last savepoint info on upgrade/recovery
Mate Czagany (Jira)
[ANNOUNCE] Flink CDC release-3.2 branch cut
Qingsheng Ren
Re: [ANNOUNCE] Flink CDC release-3.2 branch cut
Leonard Xu
Re: [ANNOUNCE] Flink CDC release-3.2 branch cut
Qingsheng Ren
Re: [ANNOUNCE] Flink CDC release-3.2 branch cut
Leonard Xu
[jira] [Created] (FLINK-36036) CDC remove unused dependency jar from calcite-core
Hongshun Wang (Jira)
[jira] [Created] (FLINK-36035) Remove zipped dependency files from flink-python
Grace Grimwood (Jira)
[jira] [Created] (FLINK-36034) Remove dependencies of Flink table planner in Transform module
yux (Jira)
[jira] [Created] (FLINK-36033) FLIP-469: Supports Adaptive Optimization of StreamGraph
Junrui Li (Jira)
[jira] [Created] (FLINK-36032) FLIP-468: Introducing StreamGraph-Based Job Submission
Junrui Li (Jira)
[VOTE] FLIP-470: Support Adaptive Broadcast Join
Xia Sun
Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join
Lincoln Lee
Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join
Zhu Zhu
Re: [VOTE] FLIP-470: Support Adaptive Broadcast Join
Ron Liu
[jira] [Created] (FLINK-36031) Migrate kubernetes operator metrics from OKHttp Interceptor API to Fabric8 Interceptor API
Sam Barker (Jira)
[jira] [Created] (FLINK-36030) Don't use negative values for changelog recovery tests
Roman Khachatryan (Jira)
[jira] [Created] (FLINK-36029) Add @Nullable Annotation to ValueState's Value Method Return Type
LEE SOMANG (Jira)
[jira] [Created] (FLINK-36028) Doc: kafka source additional properties
Rich (Jira)
[DISCUSS] re-open FLINK-28842 Add client.id.prefix for the KafkaSink
Rich C.
Re: [DISCUSS] re-open FLINK-28842 Add client.id.prefix for the KafkaSink
Ahmed Hamdy
[jira] [Created] (FLINK-36027) [cdc-connector][MySQL] added metrics numRecordsOut for each OperationType(update, delete, insert)
Lee SeungMin (Jira)
Rebuilding flink
Dan Plyukhin
Re: Rebuilding flink
Gabor Somogyi
Re: Rebuilding flink
Ferenc Csaky
[jira] [Created] (FLINK-36026) Options from OPTIONS hint are not present in compile plan
Sergey Nuyanzin (Jira)
[jira] [Created] (FLINK-36025) Add TO_NUMBER function
Dylan He (Jira)
[jira] [Created] (FLINK-36024) Handle BinaryLogClient exceptions when searching for the starting binlog offset
He Wang (Jira)
[jira] [Created] (FLINK-36023) Flink K8S Native Application Mode add wrong jar url.
Hongshun Wang (Jira)
[RESULT][VOTE] FLIP-469: Supports Adaptive Optimization of StreamGraph
Junrui Lee
[RESULT][VOTE] FLIP-468: Introducing StreamGraph-Based Job Submission
Junrui Lee
[jira] [Created] (FLINK-36022) When scaling.enabled =false, adjust the values of some parameters to provide bette recommendation values.
yuanfenghu (Jira)
[jira] [Created] (FLINK-36021) Give the responsibility of compression to tier itself
Weijie Guo (Jira)
[jira] [Created] (FLINK-36020) exception: Time should be non negative
siyuan zheng (Jira)
[jira] [Created] (FLINK-36019) flink_ha目录下的文件,可以通过配置自定义权限
yanggang (Jira)
[jira] [Created] (FLINK-36018) Support lazy scale down to avoid frequent rescaling
Rui Fan (Jira)
[jira] [Created] (FLINK-36017) Support Passing Metadata to Formats in KafkaDynamicSink
Kevin Lam (Jira)
[jira] [Created] (FLINK-36016) Synchronize initialization time and clock usage
Zdenek Tison (Jira)
[jira] [Created] (FLINK-36015) Align rescale parameters
Zdenek Tison (Jira)
[jira] [Created] (FLINK-36014) Align the desired and sufficient resources definiton in Executing and WaitForResources states
Zdenek Tison (Jira)
[jira] [Created] (FLINK-36013) Introduce the transition from Restarting to CreatingExecutionGraph state
Zdenek Tison (Jira)
[jira] [Created] (FLINK-36012) Integrate StateTransitionManager into WaitingForResources state
Zdenek Tison (Jira)
[jira] [Created] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager
Zdenek Tison (Jira)
[jira] [Created] (FLINK-36010) Duplicate Job Submission returns Succeeded on single execution even if Global state is FAILED
Ahmed Hamdy (Jira)
[RESULT][VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states
Zdenek Tison
[jira] [Created] (FLINK-36009) Change configs to use CondigOptions
Jira
Flink Jackson Exception when using JsonDeserialisationSchema
Taher Koitawala
[jira] [Created] (FLINK-36008) Guidance for connector docs contributions
Lorenzo Nicora (Jira)
[DISCUSS] Release flink-connector-mongodb 2.0.0
Jiabao Sun
Re: [DISCUSS] Release flink-connector-mongodb 2.0.0
Leonard Xu
Re: [DISCUSS] Release flink-connector-mongodb 2.0.0
Ahmed Hamdy
[jira] [Created] (FLINK-36007) cdc load and register factory in once search
Hongshun Wang (Jira)
[DISCUSS] Release flink-connector-pulsar 2.0.0
Jiabao Sun
Re: [DISCUSS] Release flink-connector-pulsar 2.0.0
Jiabao Sun
[jira] [Created] (FLINK-36006) Add documentations for Flink CDC CLI
yux (Jira)
[jira] [Created] (FLINK-36005) Specify to get part of the potgresql field
Jira
[jira] [Created] (FLINK-36004) Flink SQL returns wrong results for Paimon tables with complex schemas
Xingcan Cui (Jira)
[jira] [Created] (FLINK-36003) Add CompiledPlan annotations to BatchExecExpand and BatchExecSortAggregate
Jim Hughes (Jira)
[jira] [Created] (FLINK-36002) Add CompiledPlan annotations to BatchExecMatch
Jim Hughes (Jira)
[Flink SQL Format] How to Process Metadata Columns in KafkaDynamicSink compatible EncodingFormat
Kevin Lam
[DISCUSS] FLIP-474: Store operator name and UID in state metadata
Gabor Somogyi
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Zakelly Lan
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Márton Balassi
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Gabor Somogyi
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Zakelly Lan
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Gabor Somogyi
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
David Morávek
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Gabor Somogyi
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Zakelly Lan
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Gabor Somogyi
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Gabor Somogyi
Re: [DISCUSS] FLIP-474: Store operator name and UID in state metadata
Zakelly Lan
[jira] [Created] (FLINK-36001) Store operator name and UID in state metadata
Gabor Somogyi (Jira)
[jira] [Created] (FLINK-36000) DynamicTableSink#Context's getTargetColumns should not return an array of zero length
lincoln lee (Jira)
[jira] [Created] (FLINK-35999) Remove log4j internal dependency
Siddharth R (Jira)
[jira] [Created] (FLINK-35998) Duplicate common type search in type inference
Dylan He (Jira)
[jira] [Created] (FLINK-35997) Incomplete Table API & Python API of built-in function LTRIM & RTRIM
Dylan He (Jira)
[jira] [Created] (FLINK-35996) Add end-to-end tests for MySQL to Elasticsearch pipeline
wuzexian (Jira)
[jira] [Created] (FLINK-35995) postgresql有字段限制了,全量期间需要select * 的权限
Jira
[jira] [Created] (FLINK-35994) CDC pipeline use SavepointRestoreSettings in flink config flile as a fallback strategy.
Hongshun Wang (Jira)
[jira] [Created] (FLINK-35993) Add UNHEX function
Dylan He (Jira)
[jira] [Created] (FLINK-35992) NettyShuffleMaster not close tiered-storage resources
xuhuang (Jira)
[jira] [Created] (FLINK-35991) Resolve conflicting definitions in transform SqlFunctionTable definition
yux (Jira)
Earlier messages
Later messages