dev  

Messages by Thread

• • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Konstantin Knauf
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Jim Hughes
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re:Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Xuyang
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) David Anderson
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) David Anderson
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Shengkai Fang
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Fabian Hüske
  • RE: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) David Radley
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Fabian Hüske
  • Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Timo Walther
• [jira] [Created] (FLINK-36353) Allow adding affinity for the pod template in the helm chart Naresh Kumar Reddy Gaddam (Jira)
• Request to work on FLINK-33926 Gantigmaa Selenge
  • Re: Request to work on FLINK-33926 Gantigmaa Selenge
• [jira] [Created] (FLINK-36352) Remove scala `Datastream` in docs xuyang (Jira)
• RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD David Radley
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Gyula Fóra
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
  • RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD David Radley
  • RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Ferenc Csaky
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
  • RE: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD David Radley
  • Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD Lajith Koova
• [jira] [Created] (FLINK-36351) Doris pipeline sink does not support Flink TIME type wenli xiao (Jira)
• [jira] [Created] (FLINK-36350) IllegalAccessError detected in JDK17+ runs Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36349) ClassNotFoundException due to org.apache.flink.runtime.types.FlinkScalaKryoInstantiator missing Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36348) Netty shuffle direct memory consumption end-to-end test failed due to direct memory OOM Weijie Guo (Jira)
• [jira] [Created] (FLINK-36347) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics. Zhongmin Qiao (Jira)
• [jira] [Created] (FLINK-36346) Remove deprecated API in flink-streaming-java module Weijie Guo (Jira)
• [jira] [Created] (FLINK-36345) [feature][cdc-connector][oracle] Oracle cdc support partition table zhuxuetong (Jira)
• [jira] [Created] (FLINK-36344) Introduce lastCompletedCheckpointTimestamp metrics Yun Tang (Jira)
• [jira] [Created] (FLINK-36343) The description on max-parallelism is misleading and needs to be more specific Da Huo (Jira)
• [jira] [Created] (FLINK-36342) Rename misleading variable names Xu Hao (Jira)
• [jira] [Created] (FLINK-36341) Does FlinkSQL have a setting to prohibit CodeGen generation Wang Qilong (Jira)
• [jira] [Created] (FLINK-36340) Can not stop with savepoint chenyuzhi (Jira)
• [jira] [Created] (FLINK-36339) Remove java serialization from SQL serializers Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-36338) Correct handle KeyContext when using AsyncKeyedStateBackendAdaptor Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36337) Recursively check if the parent class is org.apache.avro.specific.SpecificRecordBase to confirm whether it is an Avro type xuyang (Jira)
• [jira] [Created] (FLINK-36336) Remove deprecated dataset API xuhuang (Jira)
• [jira] [Created] (FLINK-36335) Improving Method Reusability in StreamGraphGenerator with JobVertexBuildContext Lei Yang (Jira)
• [jira] [Created] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses that have been moved from the flink-table-api-scala module xuyang (Jira)
• [jira] [Created] (FLINK-36333) FLIP-475: Support Adaptive Skewed Join Optimization Lei Yang (Jira)
• [jira] [Created] (FLINK-36332) Allow the Operator http client to be customised Sam Barker (Jira)
• [jira] [Created] (FLINK-36331) Support multiGet when DB all in local Yanfei Lei (Jira)
• [jira] [Created] (FLINK-36330) Session Window TVFs with named parameters don't support column expansion Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions Abhi Gupta (Jira)
• [RESULT][VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Lei Yang
• [jira] [Created] (FLINK-36328) Making the log for child not found as debug Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36327) Remove the dependencies of the flink-scala and flink-streaming-scala modules from the table module. xuyang (Jira)
• [jira] [Created] (FLINK-36326) Newly added table failed in mysql pipeline connector linqigeng (Jira)
• [jira] [Created] (FLINK-36324) MiscAggFunctionITCase expected to raise Throwable Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36323) Remove deprecated MemoryStateBackend and RocksDBStateBackend Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36325) Implement basic restore from checkpoint for ForStStateBackend Feifan Wang (Jira)
• [jira] [Created] (FLINK-36322) Fix compile error of flink benchmark caused by breaking changes Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36321) Execute read/write state request in different executor Yanfei Lei (Jira)
• [jira] [Created] (FLINK-36320) Use Protobuf Nested timestamp field as event time column and watermark haiqingchen (Jira)
• [jira] [Created] (FLINK-36319) FAIL behavior on non-retriable write errors causes an infinite loop when restarting from checkpoint Lorenzo Nicora (Jira)
• [jira] [Created] (FLINK-36317) Populate the ArchivedExecutionGraph with CheckpointStatsSnapshot data if in WaitingForResources state with a previousExecutionGraph being set Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36316) Move PortRange util to flink-core Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-36315) The flink-cdc-base module supports source metric statistics liuxiaodong (Jira)
• [jira] [Created] (FLINK-36314) Support state V1 interface Yanfei Lei (Jira)
• [jira] [Created] (FLINK-36313) Support pipeline sink hudi melin (Jira)
• [jira] [Created] (FLINK-36312) Remove deprecated host and port options for prometheus metric reporter Weijie Guo (Jira)
• [jira] [Created] (FLINK-36311) Remove deprecated flink-formats config options Xuannan Su (Jira)
• [jira] [Created] (FLINK-36310) Remove per-job and run-application deprecated APIs xuhuang (Jira)
• [jira] [Created] (FLINK-36309) Flink CDC Paimon Sink Commit failed should log StackTrace JunboWang (Jira)
• [jira] [Created] (FLINK-36308) Remove deprecated CEP config options Xuannan Su (Jira)
• [jira] [Created] (FLINK-36307) Remove deprecated config options Xuannan Su (Jira)
• [jira] [Created] (FLINK-36306) Remove deprecated API for 2.0-preview Weijie Guo (Jira)
• [NOTICE] Flink 2.0 Release Sync Canceled for 09/18/2024 Xintong Song
• [jira] [Created] (FLINK-36305) Remove deprecated Table/SQL config options Xuannan Su (Jira)
• [jira] [Created] (FLINK-36304) Remove deprecated Statebackend config options Xuannan Su (Jira)
• [jira] [Created] (FLINK-36303) PostgreSQL timestamp precision 0 not supported Ken Geis (Jira)
• [jira] [Created] (FLINK-36302) FileSourceTextLinesITCase timed out Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36301) TPC-H end-to-end test fails due to TimeoutException Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36300) TableEnvHiveConnectorITCase.testDateTimestampPartitionColumns times out Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36299) AdaptiveSchedulerTest.testStatusMetrics times out Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Matthias Pohl (Jira)
• Non-nullable children of nullable arrays and objects in SQL not working with Avro format David Radley
• [jira] [Created] (FLINK-36297) SIGSEGV caused CI failure Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36296) Add incremental shard discovery for DDB Streams source Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36295) AdaptiveSchedulerClusterITCase. testCheckpointStatsPersistedAcrossRescale failed with Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36294) table stage failed with general junit5 TestEngine failure Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36292) SplitFetcherManagerTest.testCloseCleansUpPreviouslyClosedFetcher times out Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36290) OutOfMemoryError in connect test run Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36289) Create Prometheus Flink connector release Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-36288) Set up architectural test Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-36287) Sink with topologies should not participate in UC Arvid Heise (Jira)
• [jira] [Created] (FLINK-36286) Set up pull request template Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-36285) Modify column type failed when downstream's column with defalut value linqigeng (Jira)
• [jira] [Created] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class<T> targetClass) is not suitable for setting targetClass as a class generated by Avro. xuyang (Jira)
• [jira] [Created] (FLINK-36283) The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name lincoln lee (Jira)
• [jira] [Created] (FLINK-36282) Incorrect data type mysql pipeline connector linqigeng (Jira)
• [jira] [Created] (FLINK-36281) resourceSpec replace SlotSharingGroupUtils.extractResourceSpec(slotSharingGroup) Caican Cai (Jira)
• [jira] [Created] (FLINK-36280) Snapshot scan mode do not support batch execution mode, and not as expected in mode streaming HunterXHunter (Jira)
• FLINK-36240 assignment request Arek Dankiewicz
  • Re: FLINK-36240 assignment request Ferenc Csaky
• [jira] [Created] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails Matthias Pohl (Jira)
• PR 25290 Robin Moffatt
• [jira] [Created] (FLINK-36278) Fix Kafka connector logs getting too big Arvid Heise (Jira)
• [jira] [Created] (FLINK-36277) Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` xuyang (Jira)
• [jira] [Created] (FLINK-36276) Fix the description of MySqlDataSourceOptions.`scan.startup.mode`. HunterXHunter (Jira)
• [jira] [Created] (FLINK-36275) Remove deprecated ProgramArgsQueryParameter Weijie Guo (Jira)
• [jira] [Created] (FLINK-36274) Remove legacy ExternalizedCheckpointCleanup Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36273) Remove deprecated Table/SQL configuration in 2.0 xuyang (Jira)
• [jira] [Created] (FLINK-36272) YarnFileStageTestS3ITCase fails on master Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36271) Support json and jsonb type in PostgreSQL JDBC Dialect Jira
• [jira] [Created] (FLINK-36270) DDB Streams Connector performance issue due to splitsAvailableForAssignment function Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36269) Remove `fromTableSource` in python module xuyang (Jira)
• [jira] [Created] (FLINK-36268) Disable Avro Confluent Schema Registry nightly end-to-end test for 2.0 breaking change Weijie Guo (Jira)
• [VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Lei Yang
  • Re: [VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Zhu Zhu
  • Re: [VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Rui Fan
  • Re: [VOTE] FLIP-475: Support Adaptive Skewed Join Optimization Lincoln Lee
• [jira] [Created] (FLINK-36267) SPLIT doesn't support SMP characters if delimiter is empty Dylan He (Jira)
• [jira] [Created] (FLINK-36266) Insert into as select * behaves incorrect Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36265) List and track the deprecated APIs for the 2.0-preview release. Jiangjie Qin (Jira)
• [jira] [Created] (FLINK-36264) Unable to customize rest-service.exposed.type parameter chenyuzhi (Jira)
• [jira] [Created] (FLINK-36263) Include only changed columns in old for canal format in Kakfa Sink LvYanquan (Jira)
• [SUMMARY] Flink 2.0 Release Sync 09/11/2024 Xintong Song
• [jira] [Created] (FLINK-36262) Port fix for CALCITE-5965 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36261) Revisit all breaking changes before Flink 2.0 Preview Xintong Song (Jira)
• [jira] [Created] (FLINK-36260) numBytesInLocal and numBuffersInLocal being reported as remote Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-36259) TPC-H E2E test failed due to TM heartbeat timeout Weijie Guo (Jira)
• [jira] [Created] (FLINK-36258) testRecursiveUploadForYarnS3n failed due to no AWS Credentials provided Weijie Guo (Jira)
• [jira] [Created] (FLINK-36257) Remove simple deprecated APIs Weijie Guo (Jira)
• Flink CDC 3.3 Kick Off Proposal Yanquan Lv
  • Re: Flink CDC 3.3 Kick Off Proposal Xiqian YU
  • Re: Flink CDC 3.3 Kick Off Proposal Leonard Xu
  • Re: Flink CDC 3.3 Kick Off Proposal Jerry
• [jira] [Created] (FLINK-36256) flink sql optimization exception wenhao.yu (Jira)
• [jira] [Created] (FLINK-36255) Some hive IT case failed with exit code 239 Weijie Guo (Jira)
• [jira] [Created] (FLINK-36254) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-36253) Wordcount on Docker test failed due to mismatch output hash Weijie Guo (Jira)
• [jira] [Created] (FLINK-36252) AsyncWaitOperatorTest.testProcessingTimeUnorderedWithRetry failed on AZP Weijie Guo (Jira)
• [jira] [Created] (FLINK-36251) Remove StateBackend-related configuration getters/setters that return/set complex Java objects Junrui Li (Jira)
• [jira] [Created] (FLINK-36250) Remove CheckpointStorage-related configuration getters/setters that return/set complex Java objects Junrui Li (Jira)
• [jira] [Created] (FLINK-36249) Remove RestartStrategy-related configuration getters/setters Junrui Li (Jira)
• [jira] [Created] (FLINK-36248) Introduce new Join Operator with Async State API xuyang (Jira)
• [jira] [Created] (FLINK-36247) Potential transaction leak during MySQL snapshot phase Xin Gong (Jira)
• Re: [ANNOUNCE] Apache Flink CDC 3.2.0 released Ahmed Hamdy
• [jira] [Created] (FLINK-36246) Move async state related operators flink-runtime Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API in 2.0 Qingsheng Ren (Jira)
• [jira] [Created] (FLINK-36244) Remove Queryable State Zakelly Lan (Jira)
• [jira] [Created] (FLINK-36243) Store namespace in ContextKey Yanfei Lei (Jira)
• [jira] [Created] (FLINK-36242) Fix unstable test in MaterializedTableITCase Feng Jin (Jira)
• [jira] [Created] (FLINK-36239) DDB Streams Connector reprocessing due to DescribeStream inconsistencies for trimmed shards Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36236) JdbcSourceBuilder overrides set connection provider Jira
• [DISCUSS] (FLINK-23598) DataOutputSerializer.writeBytes updates position twice shalini manohar
• Re: .ClassNotFoundException: org.apache.flink.table.data.util.DataFormatConverters$RowConverter Taher Koitawala
  • Re: .ClassNotFoundException: org.apache.flink.table.data.util.DataFormatConverters$RowConverter Feng Jin
• [jira] [Created] (FLINK-36233) Reuseable view in Flink SQL Yi Cai (Jira)
• [jira] [Created] (FLINK-36232) Incorrect vararg handling in Python Table API Dylan He (Jira)
• [jira] [Created] (FLINK-36231) Optimize built-in function REGEXP_EXTRACT and REGEXP_REPLACE with regex cache Dylan He (Jira)
• Flink Releases David Radley
  • Re: Flink Releases Aleksandr Pilipenko
• [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format #2 David Mariassy
• [jira] [Created] (FLINK-36228) MongoDB sink should be asynchronous Jacob Jona Fahlenkamp (Jira)
• [jira] [Created] (FLINK-36224) Add the version mapping between pipeline connectors and flink Thorne (Jira)
• [jira] [Created] (FLINK-36223) SplitFetcher thread 0 received unexpected exception while polling the records zjf (Jira)
• [jira] [Created] (FLINK-36221) Add specification about CAST ... AS ... built-in functions yux (Jira)
• [jira] [Created] (FLINK-36218) Documentations clean up before CDC 3.2.0 release yux (Jira)
• [jira] [Created] (FLINK-36217) Remove powermock usage Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36214) Error log when building flink-cdc-pipeline-udf-examples from source code lincoln lee (Jira)
• [jira] [Created] (FLINK-36213) CDC Datastream API sync error zigaai (Jira)
• [jira] [Created] (FLINK-36211) Shade kafka related package in Kafka Pipeline connector. LvYanquan (Jira)
• [jira] [Created] (FLINK-36210) Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode xiaochen.zhou (Jira)
• [jira] [Created] (FLINK-36209) Reduce some redundant operations in the initialization of KafkaSourceEnumState xiaochen.zhou (Jira)
• [jira] [Created] (FLINK-36208) use ThreadLocalRandom in Flink AbstractID Sean Sullivan (Jira)
• [jira] [Created] (FLINK-36207) Disabling japicmp plugin for deprecated APIs Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36206) Support flink-connector-aws-base to allow custom override configuration Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36205) DDB Streams connector should be able to resolve the stream ARN from given Table name Hong Liang Teoh (Jira)
• [jira] [Created] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36202) Remove all deprecated datastream api Weijie Guo (Jira)
• [jira] [Created] (FLINK-36201) StateLocalitySlotAssigner will be used even if local recovery is disable for Adaptive Scheduler Rui Fan (Jira)
• [jira] [Created] (FLINK-36200) Breaking changes for Flink 3.0 Xintong Song (Jira)
• [jira] [Created] (FLINK-36199) Remove RuntimeContext#getExecutionConfig Weijie Guo (Jira)
• [jira] [Created] (FLINK-36198) Remove legacy hybrid shuffle mode Weijie Guo (Jira)
• [jira] [Created] (FLINK-36197) Bump curator-test version Siddharth R (Jira)
• [jira] [Created] (FLINK-36196) Have a UX for customer where customer just gives table name and gets the stream arn which is enabled Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base Abhi Gupta (Jira)
• [jira] [Created] (FLINK-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions Matthias Pohl (Jira)
• [jira] [Created] (FLINK-36193) Allow applying new SchemaChangeEvents to sink connectors yux (Jira)
• [jira] [Created] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task. yuanfenghu (Jira)
• [jira] [Created] (FLINK-36191) FsMergingCheckpointStorageLocationTest generates test data not in tmp folder Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-36190) Completed checkpoint's file cannot be discarded due to network issues Alexis Sarda-Espinosa (Jira)
• Match recognize references old type system in docs. David Radley
• [jira] [Created] (FLINK-36189) Documentation build is failing with NPM installation problem Martijn Visser (Jira)
• Flink aggregation docs David Radley
  • Re: Flink aggregation docs Martijn Visser

• Earlier messages
• Later messages