commits
Thread
Date
Earlier messages
Later messages
Messages by Thread
(flink) 01/02: [FLINK-36117] Setup internal interface hierarchy for state v2
zakelly
(flink) branch master updated: [FLINK-35412][State/Runtime] Batch execution of async state request callback (#24832)
zakelly
(flink) branch master updated: [FLINK-36015] [runtime] Align rescale parameters
mapohl
(flink-connector-kafka) branch main updated: [FLINK-36209] Remove redundant operations in the initialization of KafkaSourceEnumState (#116)
arvid
(flink) branch master updated (df412add389 -> ffd05220ffe)
zakelly
(flink) branch master updated: [FLINK-36250][streaming-java] Remove CheckpointStorage-related configuration getters/setters that return/set complex Java objects.
zhuzh
(flink-cdc) branch master updated: [FLINK-35503] Add support for running Oracle connector unit test on ARM architecture (#3600)
gongzhongqiang
(flink) branch master updated: [FLINK-36016] [runtime] Synchronize initialization time and clock usage in DefaultStateTransitionManager
mapohl
(flink-connector-aws) branch main updated: [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff
hong
(flink) branch master updated (cfd532d5520 -> 488a4ce4eae)
mbalassi
(flink-benchmarks) branch master updated: [hotfix] Use `Duration` instead of `Time` (#95)
zakelly
(flink) branch master updated: [FLINK-36283][table-planner] Fix udaf incorrectly accessing the built-in function PERCENTILE's implementation with the same name
lincoln
(flink) branch master updated (ffde2d34c02 -> 4e825107c34)
zhuzh
(flink) 01/02: [FLINK-36249][streaming-java] Align DataSet API with DataStream API to support job configuration passing.
zhuzh
(flink) branch master updated (6d60f41a9b1 -> ffde2d34c02)
sxnan
(flink) 03/04: [FLINK-33750][config] Remove deprecated StreamPipelineOptions
sxnan
(flink) 02/04: [FLINK-33750][config] Remove deprecated option in flink-metrics-prometheus
sxnan
(flink) 04/04: [FLINK-33750][config] Update config docs
sxnan
(flink) branch master updated (96b84258b6e -> 6d60f41a9b1)
arvid
(flink) 02/08: [FLINK-25920] Turn CommittableManager#merge functional
arvid
(flink) 06/08: [FLINK-25920] Handle duplicate EOI in Sink
arvid
(flink) 03/08: [FLINK-25920] Improve sink test assertions
arvid
(flink) 05/08: [FLINK-25920] Refactor & Revise SinkWriterOperatorTestBase
arvid
(flink) 07/08: [FLINK-25920] Improve logging in committable handling of the sink
arvid
(flink) 01/08: [FLINK-25920] Straighten EOI handling in CommittableCollector
arvid
(flink) 08/08: [FLINK-25920] Fix AbstractStreamingWriter sending after EOI
arvid
(flink) 04/08: [FLINK-25920] Only process complete batches of committables
arvid
(flink) branch master updated: [FLINK-36208][core] Use ThreadLocalRandom in AbstractID
fcsaky
(flink-connector-kafka) branch main updated: [FLINK-34470][Connectors/Kafka] Fix indefinite blocking by adjusting stopping condition on split reader (#100)
arvid
(flink) branch master updated: [FLINK-36281][runtime] resourceSpec replace SlotSharingGroupUtils.extractResourceSpec(slotSharingGroup) (#25333)
fanrui
(flink) branch master updated (0d3be65c06b -> 15361471676)
mapohl
(flink) branch master updated (ed7f57c9ccb -> 0d3be65c06b)
mapohl
(flink) 03/03: [hotfix][test] Adds back timestamp to log output
mapohl
(flink) 01/03: [FLINK-36279][runtime] Making desired resources being calculated based on all available slots for the job
mapohl
(flink) 02/03: [hotfix][test] Adds some additional logging to RescaleOnCheckpointITCase
mapohl
(flink-connector-pulsar) branch main updated: [hotfix] Refactor callers that use deprecated get/setXXX of Configuration
fanrui
(flink) branch master updated: [FLINK-36258][config] set `HADOOP_CONF_DIR` to config hadoop in YarnFileStageTestS3ITCase
sxnan
(flink-connector-pulsar) branch hotfix/refactor-callers-conf created (now d9bb2cf)
fanrui
(flink-connector-pulsar) 01/01: [hotfix] Refactor callers that use deprecated get/setXXX of Configuration
fanrui
(flink) branch master updated: [FLINK-35667][state/forst] Implement Reducing Async State API for ForStStateBackend (#25308)
leiyanfei
(flink) branch master updated: [FLINK-36001][state] Hotfix for OperatorIDPairTest missing header
gaborgsomogyi
(flink) branch master updated: [FLINK-35927][state/forst] Make ForStFlinkFileSystem write misc file in local filesystem (#25310)
leiyanfei
(flink-connector-prometheus) branch dependabot/maven/flink-connector-prometheus/org.xerial.snappy-snappy-java-1.1.10.4 deleted (was 047bd4c)
github-bot
(flink-connector-prometheus) branch main updated: Bump org.xerial.snappy:snappy-java in /flink-connector-prometheus
hong
(flink-connector-prometheus) branch dependabot/maven/flink-connector-prometheus/com.github.tomakehurst-wiremock-jre8-2.35.1 deleted (was 86af5f0)
github-bot
(flink-connector-prometheus) branch main updated: Bump com.github.tomakehurst:wiremock-jre8 in /flink-connector-prometheus
hong
(flink-connector-prometheus) branch dependabot/maven/flink-connector-prometheus/org.xerial.snappy-snappy-java-1.1.10.4 created (now 047bd4c)
github-bot
(flink-connector-prometheus) branch dependabot/maven/flink-connector-prometheus/com.github.tomakehurst-wiremock-jre8-2.35.1 created (now 86af5f0)
github-bot
(flink) branch master updated: [FLINK-36001][state] Store operator name and UID in state metadata
gaborgsomogyi
(flink-connector-aws) branch main updated: [FLINK-36270][Connectors/DynamoDB] Assign only children splits of a split when it is marked as finished
hong
(flink) branch master updated (8d4e98503fd -> 36103ff3a97)
ron
(flink) 01/02: [FLINK-36242][test] Fix inconsistent logic between listTable and getTable in TestFileSystemCatalog
ron
(flink) 02/02: [FLINK-36242][table] Drop all materialized tables manually instead of automatically dropping them in the after method.
ron
(flink) branch master updated: [FLINK-36225][core] Remove deprecated method marked in FLIP-382
guoweijie
(flink) branch master updated (e94d433dd0b -> 644c027390a)
guoweijie
(flink) 01/02: [FLINK-5336][core] Remove IOReadableWritable from Path
guoweijie
(flink) 02/02: fixup! [FLINK-5336][core] Remove IOReadableWritable from Path
guoweijie
[I] The flink-cdc-base module supports source metric statistics [flink-cdc]
via GitHub
Re: [I] The flink-cdc-base module supports source metric statistics [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-35027][Runtime/Checkpoint] Drain async state request before snapshot barrier (#25317)
zakelly
(flink) branch master updated (8dc40ab70c9 -> 6a5fa9962a9)
mapohl
(flink) 02/02: [FLINK-36147][runtime] Removes deprecated location field (was deprecated in 1.19)
mapohl
(flink) 01/02: [hotfix] Fixes JobExceptionsInfoWithHistory equals method
mapohl
(flink) branch master updated: [FLINK-32688][runtime] Removes deprecated JobExceptionsInfo. (#25248)
mapohl
(flink) branch master updated: [FLINK-36207][build] Disables deprecated API from japicmp
mapohl
(flink) branch master updated: [FLINK-36168][runtime] Replaces goToFinished with the cancel method (#25305)
mapohl
(flink-connector-aws) branch main updated: [FLINK-36138] Add a message to KinesisStreamsSource null checks (#161)
hong
(flink) branch master updated (740a5674fd9 -> 77da0414929)
mapohl
(flink) 01/02: [FLINK-36013] [runtime] Introduce the transition from Restarting to CreatingExecutionGraph state
mapohl
(flink) 02/02: [hotfix] Added ExecutionGraph validation while transiting to WaitingForResources state in RestartingTest
mapohl
(flink-connector-kafka) branch main updated: [FLINK-36210] Optimize the logic for fetching topic metadata in the TopicPatternSubscriber mode (#117)
arvid
(flink) branch config-2.0 deleted (was 6de8869e519)
sxnan
(flink) branch master updated (356e2af4b27 -> 4d131705b19)
guoweijie
(flink) 01/02: [hotfix][API] DataStream should also support connectAndProcess with ProcessConfigurableStream
guoweijie
(flink) 02/02: [FLINK-35795][API] Introduce the framework of ProcessFunction Attribute
guoweijie
(flink) branch master updated (8c6f13cead9 -> 356e2af4b27)
zhuzh
(flink) 02/04: [FLINK-36185][e2e] Rewrite end to end cases with new Kafka source.
zhuzh
(flink) 04/04: [FLINK-36185][e2e] Disable PyFlink end-to-end case that uses Kafka legacy source.
zhuzh
(flink) 01/04: [FLINK-36185][state-processor] Remove deprecated internal class BoundedOneInputStreamTaskRunner.
zhuzh
(flink) 03/04: [FLINK-36185][core] Remove RuntimeContext#getExecutionConfig
zhuzh
(flink) branch master updated: [FLINK-36230][pyflink-table] Fix the incorrect calling of REGEXP_EXTRACT Python Table API
lincoln
(flink) branch master updated: [FLINK-36262][table] Avoid unnecessary String concatenations in the RexFieldAccess constructor
snuyanzin
(flink) branch master updated: [FLINK-36243][state/forst] Store namespace in state request and contextKey (#25300)
leiyanfei
(flink) branch master updated: [FLINK-35827][table-planner] Fix equivalence comparison between row type fields and constants
lincoln
(flink) branch master updated (db682b9869d -> c749a1b61c9)
lincoln
(flink) 02/04: [FLINK-36123][table-planner] Refactor error test for built-in agg functions
lincoln
(flink) 01/04: [FLINK-36123][table-common] Add ArgumentTypeStrategy for percentage (array) value
lincoln
(flink) 03/04: [FLINK-36123][table-planner] Support creating AggregateInfo through BuiltInFunctionDefinition directly to avoid an extra SqlAggFunction conversion
lincoln
(flink) 04/04: [FLINK-36123][table] Add the built-in function PERCENTILE
lincoln
(flink) branch master updated (1d5b214eb68 -> db682b9869d)
mapohl
(flink) branch master updated: [FLINK-36246] Move async state related operators flink-runtime (#25306)
zakelly
(flink) branch string-key deleted (was 1211e9d57e7)
sxnan
(flink) branch config-2.0 updated (432ff6b27e7 -> 6de8869e519)
sxnan
(flink) branch master updated (c0176fd6794 -> e3a48c2a58a)
sxnan
(flink-docker) branch dev-master updated: [FLINK-33677][core] Remove flink-conf.yaml from flink dist.
zhuzh
(flink) branch master updated: [FLINK-33677][core] Remove flink-conf.yaml from flink dist.
zhuzh
(flink) branch master updated (1f303a218f4 -> 62e986da8e3)
dannycranmer
(flink) branch master updated: [FLINK-36012] [runtime] Integrate StateTransitionManager into WaitingForResources state
mapohl
(flink) branch master updated (7adeecd3445 -> 95ef07b789b)
srichter
(flink) 06/08: [FLINK-35580] Fix synchronization issue when closing RocksDBWriteBatchWrapper
srichter
(flink) 02/08: [FLINK-35580] Register async compact task with the backend's lifecycle instead of the restore lifecycle.
srichter
(flink) 01/08: [FLINK-35580] Prevent potential JVM crashes from async compaction when RocksDB is already closed.
srichter
(flink) 05/08: [FLINK-35580] Improve logging and problem analysis in RockDBHandle.
srichter
(flink) 07/08: [FLINK-35580] Ensure RocksDB working directory is created before opening DB.
srichter
(flink) 01/02: [FLINK-34085][config] Remove deprecated string configuration keys
sxnan
(flink) 02/02: [FLINK-34085][config] Remove deprecated string configuration keys
sxnan
(flink) branch config-2.0 updated (ef57966dd23 -> 432ff6b27e7)
sxnan
(flink) branch config-2.0 created (now ef57966dd23)
sxnan
(flink) 05/07: [FLINK-34079][config] Refactor callers that use get/setInt
sxnan
(flink) 04/07: [FLINK-34079][config] Refactor callers that use get/setFloat
sxnan
(flink) 03/07: [FLINK-34079][config] Refactor callers that use get/setDouble
sxnan
(flink) 06/07: [FLINK-34079][config] Refactor callers that use get/setLong
sxnan
(flink) branch master updated: [FLINK-34510][Runtime/State]Rename RestoreMode to RecoveryClaimMode (#25192)
leiyanfei
(flink) branch flink-36241 created (now 4450ccaf7b6)
dwysakowicz
(flink) 01/01: [FLINK-36241] Table API .plus should support string concatenation
dwysakowicz
(flink) branch FLINK-35580 created (now 4f058c8f221)
srichter
(flink) 06/08: [FLINK-35580] Fix synchronization issue when closing RocksDBWriteBatchWrapper
srichter
(flink) 05/08: [FLINK-35580] Improve logging and problem analysis in RockDBHandle.
srichter
(flink) 07/08: [FLINK-35580] Ensure RocksDB working directory is created before opening DB.
srichter
(flink-connector-kafka) branch main updated: [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks (#109)
arvid
(flink-kubernetes-operator) branch main updated: [FLINK-36018][autoscaler] Support lazy scale down to avoid frequent rescaling (#875)
fanrui
(flink-connector-aws) branch main updated: [FLINK-36187][Connectors/Kinesis] Implement UniformShardAssigner using Kinesis shard hashes in the KinesisStreamsSource
hong
svn commit: r71343 - /release/flink/flink-cdc-3.1.0/
renqs
(flink) branch master updated: [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level. (#25257)
zakelly
(flink-connector-aws) branch main updated: [FLINK-36206][Connectors/AWS] Adding support for custom override configuration
hong
(flink) branch master updated (13cd826b51d -> 3f39a7b0822)
zakelly
(flink) branch master updated (c58a6ebbae5 -> 13cd826b51d)
guoweijie
(flink) 03/03: [FLINK-36198][network] Change document related to hybrid shuffle
guoweijie
(flink) 02/03: [FLINK-36198][network] Remove deprecated config options related to legacy hybrid shuffle
guoweijie
(flink) branch master updated: [FLINK-35389][State/ForSt] Async list state (#25126)
zakelly
(flink) branch release-1.20 updated: [FLINK-36125][checkpoint] Fix concurrent duplicated discard of logical file in cp file-merging (#25279)
zakelly
(flink) branch master updated (c869326d089 -> 2c16d884abd)
zakelly
(flink-connector-jdbc) branch main updated: [FLINK-36051] Re-prepare invalid statement even if connection is valid (#138)
jiabaosun
(flink) branch master updated: [FLINK-36011] [runtime] Generalize RescaleManager to become StateTransitionManager
mapohl
(flink-kubernetes-operator) branch main updated: [FLINK-36179] bump log4j version
gyfora
(flink) branch master updated: [FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates test data not in tmp folder
snuyanzin
(flink) branch release-1.20 updated (55e4fca0b4d -> b8e4a8b0aab)
martijnvisser
(flink) 02/03: [FLINK-36189] Skip NPM build during Javadocs generation
martijnvisser
(flink) 01/03: [FLINK-36116] Update Javadoc plugin. This closes #25265
martijnvisser
(flink) 03/03: [hotfix] Add missing backslash to skip webui build during Javadoc generation
martijnvisser
(flink) branch release-1.19 updated (e2ac98a2b34 -> 5e6307bc76e)
martijnvisser
(flink) 03/03: [hotfix] Add missing backslash to skip webui build during Javadoc generation
martijnvisser
(flink) 01/03: [FLINK-36116] Update Javadoc plugin. This closes #25265
martijnvisser
(flink) 02/03: [FLINK-36189] Skip NPM build during Javadocs generation
martijnvisser
(flink) branch release-1.18 updated (852a2254bd2 -> fb504734777)
martijnvisser
(flink) 02/03: [FLINK-36189] Skip NPM build during Javadocs generation
martijnvisser
(flink) 01/03: [FLINK-36116] Update Javadoc plugin. This closes #25265
martijnvisser
(flink) 03/03: [hotfix] Add missing backslash to skip webui build during Javadoc generation
martijnvisser
(flink) branch release-1.17 updated (12b2c02bac9 -> c9acb4e03e9)
martijnvisser
(flink) 01/03: [FLINK-36116] Update Javadoc plugin. This closes #25265
martijnvisser
(flink) 03/03: [hotfix] Add missing backslash to skip webui build during Javadoc generation
martijnvisser
(flink) 02/03: [FLINK-36189] Skip NPM build during Javadocs generation
martijnvisser
(flink) branch master updated: [hotfix] Add missing backslash to skip webui build during Javadoc generation
martijnvisser
(flink) branch master updated: [FLINK-36189] Skip NPM build during Javadocs generation
martijnvisser
(flink) branch release-1.20 updated: [FLINK-36173][docs] Fix invalid link in checkpoint documentation
gaborgsomogyi
(flink) branch master updated (d8d69005033 -> 26ce997052b)
gaborgsomogyi
(flink) branch master updated: [FLINK-27885][tests][JUnit5 migration] Module: flink-csv
snuyanzin
(flink) branch master updated: [FLINK-35581] Remove comments from the code related to ingestDB (#25263)
srichter
(flink-kubernetes-operator) branch main updated: [FLINK-36162] Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference
gyfora
(flink-connector-kafka) branch main updated: [FLINK-36176] Remove support for Kafka 0.1 (#115)
arvid
(flink-cdc) annotated tag release-3.2.0-rc1 updated (6b9dda39c -> 7887e67f1)
renqs
svn commit: r71160 - in /dev/flink/flink-cdc-3.2.0-rc1: ./ flink-cdc-3.2.0-bin.tar.gz flink-cdc-3.2.0-bin.tar.gz.asc flink-cdc-3.2.0-bin.tar.gz.sha512 flink-cdc-3.2.0-src.tgz flink-cdc-3.2.0-src.tgz.asc flink-cdc-3.2.0-src.tgz.sha512
renqs
(flink-connector-kafka) branch f35886 deleted (was c4d6662f)
pnowojski
(flink-connector-kafka) branch main updated: [FLINK-35886] Leave a note for future Flink 2.0 upgrade
pnowojski
(flink-cdc) branch release-3.2 updated: [BP-3.2][FLINK-36183][cdc-runtime] Fix lenient schema evolution failure with route blocks (#3584)
ruanhang1993
(flink-cdc) branch master updated: [FLINK-36183] Fix lenient schema evolution failure with route blocks (#3583)
ruanhang1993
(flink-cdc) branch release-3.2 updated: [FLINK-36184][transform] Fix transform operator swallows schema changes from tables not present in transform rules (#3591)
ruanhang1993
(flink-cdc) branch master updated: [FLINK-36184][transform] Fix transform operator swallows schema changes from tables not present in transform rules (#3589)
ruanhang1993
(flink) branch master updated: [FLINK-36117] Add an adaptor to convert KeyedStateBackend into AsyncKeyedStateBackend (#25233)
zakelly
(flink-kubernetes-operator) branch main updated: [FLINK-36170] bump assert4j version
fanrui
(flink) branch master updated (2ca359a140b -> 7cff1da89cb)
mapohl
(flink) 02/02: [FLINK-36168][runtime] Refactors AdaptiveSchedulerTest to execute proper lifecycle management (i.e. closing the scheduler before shutting down the main thread executor)
mapohl
(flink) 01/02: [hotfix][runtime] Adds ComponentMainThread to thread name of ComponentMainThreadExecutorServiceAdapter
mapohl
(flink) branch master updated: [FLINK-36116] Update Javadoc plugin. This closes #25265
martijnvisser
(flink) branch master updated: [FLINK-35988][table-runtime] Reduce the number of state lookups in AppendOnlyFirstNFunction
lincoln
(flink) branch release-1.19 updated: (1.19 and 1.20 only) fixup! [FLINK-35886][task] Use RelativeClock in WatermarksWithIdleness
pnowojski
(flink-connector-kafka) branch f35886 updated (9bf5c029 -> c4d6662f)
pnowojski
(flink-connector-kafka) branch f35886 updated (b08efd31 -> 9bf5c029)
pnowojski
(flink-connector-kafka) branch f35886 created (now b08efd31)
pnowojski
(flink-connector-kafka) 01/01: [FLINK-35886] Leave a note for future Flink 2.0 upgrade
pnowojski
Re: [I] Flink Sql Mongo 使用的版本是2.1.1 执行同步mongo数据 ,控制台报错: java.lang.ClassCastException: com.ververica.cdc.connectors.mongodb.internal.MongoDBConnectorSourceConnector cannot be cast to com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.source.SourceConnector at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:668) [flink-sql-connector-mysql-cdc-2.1.1.jar:2.1.1] at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) [flink-sql-connector-mysql-cdc-2.1.1.jar:2.1.1] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_281] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_281] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_281] [flink-cdc]
via GitHub
Re: [I] 问题:生产环境下connector可能会对mysql server的造成i/o压力? 是否支持mysql server的主从切换? [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-35579] Bump frocksdb version to 8.10.0-ververica-beta-1.0 (#25253)
zakelly
(flink) branch release-1.20 updated: [FLINK-35177] Fix DataGen Connector documentation (#25259)
gongzhongqiang
(flink-cdc) branch master updated: [minor][tests] Fix test testDanglingDroppingTableDuringBinlogMode due to imprecise timestamp startup
leonard
(flink-cdc) branch release-3.2 updated: [hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax
leonard
(flink-cdc) branch master updated: [hotfix][pipeline-connector/mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax
leonard
(flink-kubernetes-operator) branch main updated: [FLINK-35266][snapshot] Add E2E tests for FlinkStateSnapshot
gyfora
(flink) branch master updated (20e6d634663 -> 55dc9fa6922)
snuyanzin
(flink) 02/02: [FLINK-35054][table] Migrate TemporalJoinRewriteWithUniqueKeyRule to java
snuyanzin
(flink) 01/02: [FLINK-34896][table] Migrate CorrelateSortToRankRule to java
snuyanzin
(flink) branch release-1.20 updated: (1.19 and 1.20 only) fixup! [FLINK-35886][task] Use RelativeClock in WatermarksWithIdleness
pnowojski
(flink) branch master updated: [FLINK-35773][docs] Document s5cmd
pnowojski
(flink) branch release-1.20 updated: [FLINK-35992][runtime] Close the TieredStorageMasterClient when NettyShuffleMaster close
guoweijie
(flink) branch master updated: [FLINK-35177] Fix DataGen Connector documentation (#24692)
gongzhongqiang
(flink-cdc) branch release-3.2 updated (ab64eb3b5 -> 1ebefd6d2)
leonard
(flink-cdc) 10/12: [FLINK-36128][cdc-runtime] Fix potential unrecoverable in-flight data exception by promoting LENIENT as the default schema change behavior
leonard
(flink-cdc) 02/12: [FLINK-36088][pipeline-connector][paimon] Fix NPE in BucketAssignOperator when job restoration
leonard
(flink-cdc) 05/12: [FLINK-36094][cdc-runtime] Improve the Exception that SchemaRegistryRequestHandler thrown
leonard
(flink-cdc) 04/12: [FLINK-36081][cdc-connector][mysql] Remove the schemas of outdated tables in the BinlogSplit when restart (#3548)
leonard
Earlier messages
Later messages