commits
Thread
Date
Earlier messages
Later messages
Messages by Date
2024/02/01
(flink-connector-opensearch) annotated tag v updated (0f659cc -> 4f3008a)
dannycranmer
2024/02/01
svn commit: r67094 - in /dev/flink/flink-connector-jdbc-3.1.2-rc3: ./ flink-connector-jdbc-3.1.2-src.tgz flink-connector-jdbc-3.1.2-src.tgz.asc flink-connector-jdbc-3.1.2-src.tgz.sha512
snuyanzin
2024/02/01
(flink-connector-jdbc) annotated tag v3.1.2-rc3 updated (fb383ab9 -> bf6be327)
snuyanzin
2024/02/01
svn commit: r67092 - /dev/flink/flink-connector-jdbc-3.1.2-rc2/
snuyanzin
2024/02/01
(flink) 01/05: [hotfix][test] Moves ConfigMap lifecycle management into @BeforeEach/@AfterEach methods
mapohl
2024/02/01
(flink) 03/05: [hotfix][test] Refactors TestingLeaderCallbackHandler to allow async calls
mapohl
2024/02/01
(flink) 04/05: [FLINK-34007][k8s] fabric8io LeaderElector is created with every new #run() call
mapohl
2024/02/01
(flink) 02/05: [hotfix][test] Makes ManuallyTriggeredScheduledExecutorService#execute rely on a BlockingQueue
mapohl
2024/02/01
(flink) branch master updated (dd3e60a4b1e -> 95417a4857e)
mapohl
2024/02/01
(flink) 05/05: [FLINK-34007][k8s] Upgrade k8s client to v6.9.2 to cover client issue #5464
mapohl
2024/02/01
(flink) branch master updated (2be1ea801cf -> dd3e60a4b1e)
zhuzh
2024/01/31
(flink) branch master updated: [FLINK-34126][configuration] Correct the description of config option jobmanager.scheduler
zhuzh
2024/01/31
(flink) branch master updated: [FLINK-34206][runtime] Fix potential job failure due to concurrent global failure and source paralelism inference
zhuzh
2024/01/31
(flink) branch master updated: [FLINK-33358][sql-client] Fix Flink SQL Client fail to start in Flink on YARN (#23629)
shengkai
2024/01/31
(flink) branch master updated (8e11b6005c9 -> 98e1d079f6e)
libenchao
2024/01/31
(flink) branch master updated (cb9e220c229 -> 8e11b6005c9)
dmvk
2024/01/31
(flink-connector-jdbc) branch v3.1 updated: [hotfix] Use 1.16.x as minimum supported version in pom
snuyanzin
2024/01/31
(flink-kubernetes-operator) branch main updated: [FLINK-34311] Do not change min resource requirements when rescaling for adaptive scheduler
gyfora
2024/01/31
(flink) branch master updated: [FLINK-34271][table-planner] Fix unstable GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT
jchan
2024/01/31
(flink) branch master updated: [FLINK-34316] Reduce instantiation of ScanRuntimeProvider in streaming mode
twalthr
2024/01/31
(flink) branch master updated (697d328f6bb -> ff9a3c85f69)
mapohl
2024/01/31
(flink) branch release-1.18 updated: [FLINK-33915][ci] Adds workflow release-1.18 nightly CI workflow
mapohl
2024/01/31
(flink) branch master updated: [FLINK-33915][ci] Adds workflow for extended master CI workflow
mapohl
2024/01/31
(flink) 03/07: [hotfix][build] Adds Maven and Java version to Maven command
mapohl
2024/01/31
(flink) 07/07: [FLINK-33914][ci] Introduces a basic GitHub Actions workflow
mapohl
2024/01/31
(flink) 02/07: [hotfix][ci] Fixes condition for filtering NOTICE files
mapohl
2024/01/31
(flink) 05/07: [hotfix][ci] Adds proper log message at the end of a successful CI run
mapohl
2024/01/31
(flink) 04/07: [hotfix][ci] Replaces spaces with tabs
mapohl
2024/01/31
(flink) 01/07: [hotfix][ci] Fixes find commands where touch might cause a failure if no files were found
mapohl
2024/01/31
(flink) branch release-1.18 updated (d903990e1ed -> a64e1c98533)
mapohl
2024/01/31
(flink) 06/07: [FLINK-27082][ci] Updates github-actions profile.
mapohl
2024/01/31
(flink) 04/08: [hotfix][ci] Replaces spaces with tabs
mapohl
2024/01/31
(flink) 06/08: [FLINK-34062][build] Adds JDK 21 surefire configuration.
mapohl
2024/01/31
(flink) 07/08: [FLINK-27082][ci] Updates github-actions profile.
mapohl
2024/01/31
(flink) 05/08: [hotfix][ci] Adds proper log message at the end of a successful CI run
mapohl
2024/01/31
(flink) 02/08: [hotfix][ci] Fixes condition for filtering NOTICE files
mapohl
2024/01/31
(flink) 08/08: [FLINK-33914][ci] Introduces a basic GitHub Actions workflow
mapohl
2024/01/31
(flink) 01/08: [hotfix][ci] Fixes find commands where touch might cause a failure if no files were found
mapohl
2024/01/31
(flink) 03/08: [hotfix][build] Adds Maven and Java version to Maven command
mapohl
2024/01/31
(flink) branch master updated (b5a2ee4e988 -> 85edd784fc7)
mapohl
2024/01/31
(flink) branch master updated (0ba3e76b147 -> b5a2ee4e988)
chesnay
2024/01/31
(flink-connector-jdbc) branch main updated (5a90eb0a -> 611b45cf)
guoweijie
2024/01/31
(flink-connector-elasticsearch) branch dependabot/maven/org.yaml-snakeyaml-2.0 created (now 60c726d)
github-bot
2024/01/31
(flink-connector-elasticsearch) branch main updated (153b8fc -> 4914929)
leonard
2024/01/31
(flink-connector-gcp-pubsub) branch main updated: [hotfix][ci] Make CI against multiple Flink versions
leonard
2024/01/31
(flink-connector-hbase) branch main updated (42870d5 -> 91d166d)
leonard
2024/01/31
(flink-connector-pulsar) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/30
(flink) branch master updated: [docs] Fix typo in ide_setup.md (#20877)
mxm
2024/01/30
svn commit: r67002 - in /dev/flink/flink-connector-mongodb-1.1.0-rc2: ./ flink-connector-mongodb-1.1.0-src.tgz flink-connector-mongodb-1.1.0-src.tgz.asc flink-connector-mongodb-1.1.0-src.tgz.sha512
leonard
2024/01/30
(flink-connector-mongodb) annotated tag v1.1.0-rc2 updated (6c620cd -> d59567a)
leonard
2024/01/30
(flink) branch master updated: [FLINK-32684][rpc] Introduces RpcOptions and deprecates AkkaOptions (#24188)
mapohl
2024/01/29
(flink) branch release-1.18 updated: [FLINK-34115][table-planner] Fix TableAggregateITCase unstable test
jchan
2024/01/29
(flink) 02/03: [FLINK-34225][runtime] Fix the race condition in UnionResultSubpartitionView
guoweijie
2024/01/29
(flink) 01/03: [hotfix][runtime] Fix resource releasing and recovery logic in shuffle
guoweijie
2024/01/29
(flink) 03/03: [FLINK-34233][runtime] Avoid enqueuing input channel before subpartitions initialized
guoweijie
2024/01/29
(flink) branch master updated (bb01c3070ea -> 973190e8ca5)
guoweijie
2024/01/29
(flink-kubernetes-operator) branch main updated: [FLINK-34104][autoscaler] Improve the ScalingReport format of autoscaling
fanrui
2024/01/29
(flink) branch master updated: [FLINK-34115][table-planner] Fix TableAggregateITCase unstable test
jchan
2024/01/29
(flink) 01/02: [hotfix][test] Update test_configuration.py to test test_parse_jars_value.
zhuzh
2024/01/29
(flink) 02/02: [FLINK-34257][core] Update Flink YAML Parser to Support YAML 1.2 Specification.
zhuzh
2024/01/29
(flink) branch master updated (3b4fa6c424b -> 081051a2cac)
zhuzh
2024/01/29
(flink-connector-kafka) branch main updated: [hotfix] Update copyright year to 2024 (#82)
leonard
2024/01/29
(flink-connector-aws) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink) branch master updated: [FLINK-34103][examples] Include flink-connector-datagen for AsyncIO example and bundle it into the dist by default
guoweijie
2024/01/29
(flink) branch master updated: [FLINK-34059][docs][table] Add documentation on STATE_TTL hint
jchan
2024/01/29
(flink) branch master updated: [FLINK-34053][table-planner] Support state ttl hint for group aggregate
jchan
2024/01/29
svn commit: r66995 - /dev/flink/flink-connector-jdbc-3.1.2-rc1/
snuyanzin
2024/01/29
svn commit: r66994 - in /dev/flink/flink-connector-jdbc-3.1.2-rc2: ./ flink-connector-jdbc-3.1.2-src.tgz flink-connector-jdbc-3.1.2-src.tgz.asc flink-connector-jdbc-3.1.2-src.tgz.sha512
snuyanzin
2024/01/29
svn commit: r66993 - /dev/flink/flink-connector-jdbc-3.1.2-rc2/
snuyanzin
2024/01/29
svn commit: r66991 - in /dev/flink/flink-connector-jdbc-3.1.2-rc2: ./ flink-connector-jdbc-3.1.2-src.tgz flink-connector-jdbc-3.1.2-src.tgz.asc flink-connector-jdbc-3.1.2-src.tgz.sha512
snuyanzin
2024/01/29
(flink-connector-jdbc) annotated tag v3.1.2-rc2 updated (911da002 -> 871196c5)
snuyanzin
2024/01/29
(flink) branch master updated: [FLINK-34058][table] Support optional parameters for named arguments (#24183)
shengkai
2024/01/29
(flink) branch master updated: [FLINK-34204][core] spotless:apply
mapohl
2024/01/29
(flink) 06/07: fixup! [FLINK-33976] Populate `scalingInterval{Min,Max}` options from the JobMaster's configuration instead of a Job configuration.
dmvk
2024/01/29
(flink) 07/07: fixup! [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.
dmvk
2024/01/29
(flink) 02/07: [FLINK-33976] Populate `scalingInterval{Min,Max}` options from the JobMaster's configuration instead of a Job configuration.
dmvk
2024/01/29
(flink) 01/07: [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.
dmvk
2024/01/29
(flink) 04/07: [hotfix] Speed up AdaptiveSchedulerClusterITCase by setting scalingIntervalMin to 1ms.
dmvk
2024/01/29
(flink) 03/07: [hotfix] Speed up AdaptiveSchedulerTest by setting scalingIntervalMin to 1ms.
dmvk
2024/01/29
(flink) 05/07: fixup! [FLINK-33976] Consolidate AdaptiveScheduler options into AdaptiveSchduler#Settings object.
dmvk
2024/01/29
(flink) branch master updated (ce67b7d7c38 -> e945a36de8c)
dmvk
2024/01/29
svn commit: r66912 - in /dev/flink/flink-connector-mongodb-1.1.0-rc1: ./ flink-connector-mongodb-1.1.0-src.tgz flink-connector-mongodb-1.1.0-src.tgz.asc flink-connector-mongodb-1.1.0-src.tgz.sha512
leonard
2024/01/29
(flink-connector-mongodb) annotated tag v1.1.0-rc1 updated (6c620cd -> b763ad5)
leonard
2024/01/29
(flink-connector-mongodb) branch main updated: [hotfix][Connector/MongoDB] Add release tools as submodule
leonard
2024/01/29
(flink-connector-mongodb) branch v1.1 updated: [hotfix][Connector/MongoDB] Add release tools as submodule
leonard
2024/01/29
(flink) branch master updated: [FLINK-34230][doc] Add -Pskip-webui-build to the config doc generation command
huweihua
2024/01/29
(flink-connector-mongodb) branch main updated: Update version to 1.2-SNAPSHOT
leonard
2024/01/29
(flink-connector-mongodb) branch v1.1 created (now a66f57e)
leonard
2024/01/29
(flink-connector-opensearch) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink-connector-gcp-pubsub) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink-connector-cassandra) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink-connector-mongodb) branch main updated: [hotfix] Update copyright year to 2024
leonard
2024/01/29
(flink-connector-mongodb) branch main updated: [FLINK-33899][connectors/mongodb] Support Java 17 and Java 21 for mongodb connector
leonard
2024/01/28
(flink) 01/02: [FLINK-34052][examples] Install the shaded streaming example jars in the maven repo
guoweijie
2024/01/28
(flink) 02/02: [hotfix][examples] Doc on why MatrixVectorMul example is not bundled with Flink dist nor deployed in Maven repo
guoweijie
2024/01/28
(flink) branch master updated (20450485b20 -> 324a5e45c80)
guoweijie
2024/01/28
(flink) branch master updated: [FLINK-34222][table-planner] Supports mini-batch for streaming regular join
ron
2024/01/28
(flink) branch master updated: [FLINK-34249][runtime] Remove DefaultSlotTracker related logic.
fanrui
2024/01/28
(flink-connector-mongodb) branch main updated: [hotfix][test][connectors/mongodb] Update MongoWriterITCase to be compatible with updated SinkV2 interfaces
leonard
2024/01/28
(flink) branch master updated (2e56caf11c0 -> ddbf87f2a7a)
zhuzh
2024/01/27
(flink) branch master updated (11631cb5956 -> 2e56caf11c0)
guoweijie
2024/01/26
(flink-kubernetes-operator) branch main updated: [FLINK-33006] add e2e for flink operator ha
gyfora
2024/01/26
(flink-connector-jdbc) branch v3.1 updated: [FLINK-33365] include filters with Lookup joins
snuyanzin
2024/01/26
(flink) branch master updated: [FLINK-34145][connector/filesystem] support dynamic source parallelism inference in batch jobs
zhuzh
2024/01/26
(flink) branch master updated: [FLINK-33264][table] Support source parallelism setting for DataGen connector
libenchao
2024/01/26
(flink-connector-jdbc) branch main updated: [FLINK-33365] include filters with Lookup joins
snuyanzin
2024/01/26
svn commit: r66870 - in /dev/flink/flink-connector-kafka-3.1.0-rc1: ./ flink-connector-kafka-3.1.0-src.tgz flink-connector-kafka-3.1.0-src.tgz.asc flink-connector-kafka-3.1.0-src.tgz.sha512
martijnvisser
2024/01/26
(flink-connector-kafka) annotated tag v3.1.0-rc1 updated (e51adab0 -> 87b8d74d)
martijnvisser
2024/01/26
(flink-connector-kafka) branch v3.0 updated: [hotfix] Update copyright year to 2024
martijnvisser
2024/01/26
(flink-connector-kafka) branch v3.1 updated: [hotfix] Update copyright year to 2024
martijnvisser
2024/01/26
(flink-connector-kafka) branch main updated: [hotfix] Update copyright year to 2024
martijnvisser
2024/01/26
(flink-connector-kafka) annotated tag v3.1.0-rc1 deleted (was b28baaff)
martijnvisser
2024/01/26
svn commit: r66869 - /dev/flink/flink-connector-kafka-3.1.0-rc1/
martijnvisser
2024/01/26
svn commit: r66867 - in /dev/flink/flink-connector-kafka-3.1.0-rc1: ./ flink-connector-kafka-3.1.0-src.tgz flink-connector-kafka-3.1.0-src.tgz.asc flink-connector-kafka-3.1.0-src.tgz.sha512
martijnvisser
2024/01/26
(flink-connector-kafka) annotated tag v3.1.0-rc1 updated (4d298aba -> b28baaff)
martijnvisser
2024/01/26
(flink-connector-kafka) branch main updated: [hotfix] Add missing JDK17 test for 1.18 against v3.1
martijnvisser
2024/01/26
(flink-connector-kafka) branch main updated: [hotfix] Remove weekly test against 1.19-SNAPSHOT since that's currently broken and tracked under FLINK-34193
martijnvisser
2024/01/26
(flink-connector-kafka) branch main updated: [release] Update weekly CI to check against new release branch `v3.1`
martijnvisser
2024/01/26
(flink-connector-kafka) branch v3.1 created (now 4f300991)
martijnvisser
2024/01/26
(flink) branch master updated: [FLINK-34206][test] Temporarily disable CacheITCase#testRetryOnCorruptedClusterDataset
zhuzh
2024/01/26
(flink) branch master updated (d55f5f16c23 -> 8fceb101e7e)
zhuzh
2024/01/26
(flink) branch master updated (36feab0fb6d -> d55f5f16c23)
mapohl
2024/01/26
(flink-kubernetes-operator) branch main updated: [FLINK-33803] Set observedGeneration at end of reconciliation
gyfora
2024/01/26
(flink) branch master updated: [FLINK-31511][table][doc][doc-zh] Translate JSON functions and fix typo in sql_functions.yml
leonard
2024/01/26
(flink) branch master updated: [FLINK-34237] Revert the breaking changes to SourceReaderContext
xtsong
2024/01/26
(flink) branch release-1.18 updated: [FLINK-34117][filesystem] Fix CompactCoordinator data loss upon termination
leonard
2024/01/25
(flink) branch master updated: [FLINK-34196][Connectors][FLIP-389] Annotate SingleThreadFetcherManager as PublicEvolving
renqs
2024/01/25
(flink) branch master updated: [FLINK-33263][table-planner] Implement ParallelismProvider for sources in the table planner
libenchao
2024/01/25
(flink) branch master updated: [FLINK-34221][table-runtime] Introduce MiniBatchStreamingJoinOperator
ron
2024/01/25
(flink-connector-kafka) branch main updated: [FLINK-32417] Add DynamicKafkaSource documentation for setter methods, metrics, and config options. This closes #80
martijnvisser
2024/01/25
(flink-connector-mongodb) branch main updated: [FLINK-33257][connectors/mongodb] Support filter pushdown in MongoDB connector
leonard
2024/01/25
(flink) branch master updated: [FLINK-33577][dist] Change the default config file to config.yaml in flink-dist.
zhuzh
2024/01/25
(flink) 03/06: [FLINK-34100][table] Introduce UnalignedWindowTableFunctionOperator for unaligned window
ron
2024/01/25
(flink) 04/06: [FLINK-34100][table] Support session window table function without pulling up with window agg
ron
2024/01/25
(flink) branch master updated (78e31f0dcc4 -> 80f6e063310)
ron
2024/01/25
(flink) 05/06: [FLINK-34100][table] Fix the window table function outputs wrong row kind
ron
2024/01/25
(flink) 02/06: [FLINK-34100][table] Extract a WindowTableFunctionOperatorBase from WindowTableFunctionOperator to prepare for introducing unaligned window table function
ron
2024/01/25
(flink) 06/06: [FLINK-34100][table] Merge SlicingWindowOperator and UnslicingWindowOperator
ron
2024/01/25
(flink) 01/06: [FLINK-34100][table] Add function getDescription for internal interface WindowAssigner
ron
2024/01/25
(flink) branch master updated: [FLINK-34144][docs] Update the documentation about dynamic source parallelism inference
zhuzh
2024/01/25
(flink) branch master updated: [FLINK-34209] Migrate FileSink to the new SinkV2 API
gyfora
2024/01/25
(flink) branch master updated: [FLINK-34231][doc] fix typo for show partition doc in Hive dialect (#24192)
yuxia
2024/01/25
(flink) branch master updated (de7322112cb -> eb848dc0676)
shengkai
2024/01/25
(flink) 01/03: [FLINK-34055][table] Introduce a new annotation for named parameters
shengkai
2024/01/25
(flink) 02/03: [FLINK-34057][table] Support named parameters for functions
shengkai
2024/01/25
(flink) 03/03: [FLINK-34056][table] Support named parameters for procedures
shengkai
2024/01/25
(flink) 02/03: [FLINK-34048][table] introduce basic interface and class for unslicing window
ron
2024/01/25
(flink) 03/03: [FLINK-34048][table] introduce unslicing window agg for session window tvf
ron
2024/01/25
(flink) 01/03: [FLINK-34048][table-planner] Add isAlignedWindow for WindowSpec interface
ron
2024/01/25
(flink) branch master updated (1bf27c63624 -> de7322112cb)
ron
2024/01/25
(flink) branch master updated: [FLINK-34220][table-runtime] Introduce BufferBundle for minibatch join
ron
2024/01/25
(flink) 01/02: [FLINK-28915][k8s] Kubernetes client supports s3 jar location
mbalassi
2024/01/25
(flink) 02/02: [FLINK-28915][k8s] Support fetching remote job jar and additional dependencies on Kubernetes
mbalassi
2024/01/25
(flink) branch master updated (4f7725aa790 -> e63aa122528)
mbalassi
2024/01/24
(flink) branch master updated (806970c4b47 -> 4f7725aa790)
hangxiang
2024/01/24
(flink) branch master updated (4c1ae285fb6 -> 806970c4b47)
guoweijie
2024/01/24
(flink) branch release-1.18 updated: [FLINK-34166][table] Fix KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty
lincoln
2024/01/24
(flink) branch release-1.18 updated: [FLINK-34115][table-planner] Fix unstable TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate
jchan
2024/01/24
(flink) branch master updated (2cf213ec9e4 -> bed79d33fb7)
hangxiang
2024/01/24
(flink) 03/03: [FLINK-34190][checkpoint][cli] Deprecation message of RestoreMode#LEGACY in CLI
hangxiang
2024/01/24
(flink) 02/03: [FLINK-34190][checkpoint][rest] Deprecation message of RestoreMode#LEGACY in REST API
hangxiang
2024/01/24
(flink) 01/03: [FLINK-34190][checkpoint] Deprecate RestoreMode#LEGACY
hangxiang
2024/01/24
(flink-kubernetes-operator) branch main updated: [FLINK-33287] Using the flink shaded jackson for flink-autoscaler
fanrui
2024/01/24
(flink) branch master updated: [FLINK-34208] Migrate SinkV1Adapter to the new SinkV2 API
gyfora
2024/01/24
(flink) branch master updated (551bb9ebdc4 -> 1d0f34e5a4a)
leonard
2024/01/23
(flink-docker) branch dev-master updated: [FLINK-34205] Use BashJavaUtils for Flink configuration management
zhuzh
2024/01/23
(flink) branch master updated (393ef1cc439 -> 551bb9ebdc4)
fanrui
2024/01/23
(flink) branch master updated (533ead6ae94 -> 393ef1cc439)
fanrui
2024/01/23
(flink) branch release-1.18 updated: [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect (#24149)
yuxia
2024/01/23
(flink) branch release-1.17 updated: [FLINK-33233][hive] Fix NPE when non-native udf is used in join condition with Hive dialect (#24148)
yuxia
2024/01/23
(flink) branch master updated: [FLINK-33198][format/avro] Properly map Avro timestamp types in Flink Avro format
leonard
2024/01/23
(flink) branch master updated: [FLINK-34143] Modify the effective strategy of `execution.batch.adaptive.auto-parallelism.default-source-parallelism`
zhuzh
2024/01/23
(flink) branch master updated (287634b77fd -> efbd8c40e6c)
hangxiang
2024/01/23
(flink) branch master updated: [hotfix] Apply spotless
mapohl
2024/01/23
(flink-shaded) branch dependabot/maven/flink-shaded-zookeeper-parent/flink-shaded-zookeeper-36/org.apache.zookeeper-zookeeper-3.7.2 created (now b9f8e4a)
github-bot
2024/01/23
(flink-shaded) branch master updated: [hotfix] Put correct version of Jackson in comment in pom.xml
snuyanzin
2024/01/23
(flink-shaded) branch dependabot/maven/flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35/org.apache.zookeeper-zookeeper-3.7.2 created (now 3843171)
github-bot
2024/01/23
(flink-shaded) branch master updated: [hotfix] Update version to 19.0
snuyanzin
2024/01/23
(flink) branch release-1.17 updated: [FLINK-34166][table] Fix KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty
lincoln
2024/01/23
(flink) branch master updated (ad3f13f1d5b -> ecd7efc2522)
jchan
2024/01/23
(flink) 03/05: [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging
fanrui
2024/01/23
(flink) 05/05: [hotfix] Remove the wrong `@Nullable` annotation of FailureHandlingResult due to the constructor checks `verticesToRestart` is not null
fanrui
2024/01/23
(flink) branch master updated (580c4ae0e4e -> ad3f13f1d5b)
fanrui
2024/01/23
(flink) 02/05: [FLINK-33565][Exception] Restart strategy checks whether current failure is a new attempt
fanrui
2024/01/23
(flink) 04/05: [FLINK-33565][Scheduler] Correct the numberOfRestarts metric
fanrui
2024/01/23
(flink) 01/05: [FLINK-33565][Exception] Archive exceptions into the exception history immediately when they occur, instead of archiving them when restarting
fanrui
2024/01/23
(flink-docker) branch dev-master updated: [FLINK-34165] update the apache download url
jingge
2024/01/23
(flink) branch master updated: [FLINK-33975] Tests for the new Sink V2 transformations
gyfora
2024/01/22
(flink-kubernetes-operator) branch main updated: [FLINK-33403] Bump flink version to 1.18.1 for flink-kubernetes-operator
fanrui
2024/01/22
(flink-docker) branch dev-1.15 updated: [FLINK-34165] update the apache download url for asc
jingge
2024/01/22
(flink-docker) branch dev-1.16 updated: [FLINK-34165] update the apache download url for asc
jingge
2024/01/22
(flink-docker) branch master updated: [FLINK-34165] update the apache download url for asc in the dockerfiles
jingge
2024/01/22
(flink-docker) branch dev-1.17 updated: [FLINK-34165] update the apache download url for asc
jingge
2024/01/22
(flink) 03/03: [FLINK-33721][core] Extend BashJavaUtils to support reading and writing standard yaml file.
zhuzh
2024/01/22
(flink) 02/03: [FLINK-33721][core] Support dump configuration as nested yaml data.
zhuzh
2024/01/22
(flink) 01/03: [hotfix] Migrate BashJavaUtilsITCase and JavaBashTestBase to Junit5 and assertJ.
zhuzh
2024/01/22
(flink) branch master updated (4db6e72ed76 -> c148b62166d)
zhuzh
2024/01/22
(flink) branch master updated: [FLINK-34029][runtime-web] Support different profiling mode on Flink WEB
tangyun
2024/01/22
svn commit: r66750 - /release/flink/flink-1.18.0/
renqs
2024/01/22
(flink) branch master updated: [FLINK-34090][core] Introduce SerializerConfig
guoweijie
Earlier messages
Later messages