commits
Thread
Date
Earlier messages
Later messages
Messages by Thread
(flink) branch master updated (20450485b20 -> 324a5e45c80)
guoweijie
(flink) 02/02: [hotfix][examples] Doc on why MatrixVectorMul example is not bundled with Flink dist nor deployed in Maven repo
guoweijie
(flink) 01/02: [FLINK-34052][examples] Install the shaded streaming example jars in the maven repo
guoweijie
(flink) branch master updated: [FLINK-34222][table-planner] Supports mini-batch for streaming regular join
ron
(flink) branch master updated: [FLINK-34249][runtime] Remove DefaultSlotTracker related logic.
fanrui
(flink-connector-mongodb) branch main updated: [hotfix][test][connectors/mongodb] Update MongoWriterITCase to be compatible with updated SinkV2 interfaces
leonard
(flink) branch master updated (2e56caf11c0 -> ddbf87f2a7a)
zhuzh
(flink) branch master updated (11631cb5956 -> 2e56caf11c0)
guoweijie
(flink-kubernetes-operator) branch main updated: [FLINK-33006] add e2e for flink operator ha
gyfora
(flink-connector-jdbc) branch v3.1 updated: [FLINK-33365] include filters with Lookup joins
snuyanzin
(flink) branch master updated: [FLINK-34145][connector/filesystem] support dynamic source parallelism inference in batch jobs
zhuzh
(flink) branch master updated: [FLINK-33264][table] Support source parallelism setting for DataGen connector
libenchao
(flink-connector-jdbc) branch main updated: [FLINK-33365] include filters with Lookup joins
snuyanzin
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
(flink-connector-kafka) annotated tag v3.1.0-rc1 updated (e51adab0 -> 87b8d74d)
martijnvisser
(flink-connector-kafka) branch v3.0 updated: [hotfix] Update copyright year to 2024
martijnvisser
(flink-connector-kafka) branch v3.1 updated: [hotfix] Update copyright year to 2024
martijnvisser
(flink-connector-kafka) branch main updated: [hotfix] Update copyright year to 2024
martijnvisser
(flink-connector-kafka) annotated tag v3.1.0-rc1 deleted (was b28baaff)
martijnvisser
svn commit: r66869 - /dev/flink/flink-connector-kafka-3.1.0-rc1/
martijnvisser
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
(flink-connector-kafka) annotated tag v3.1.0-rc1 updated (4d298aba -> b28baaff)
martijnvisser
(flink-connector-kafka) branch main updated: [hotfix] Add missing JDK17 test for 1.18 against v3.1
martijnvisser
(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
(flink-connector-kafka) branch main updated: [release] Update weekly CI to check against new release branch `v3.1`
martijnvisser
(flink-connector-kafka) branch v3.1 created (now 4f300991)
martijnvisser
(flink) branch master updated: [FLINK-34206][test] Temporarily disable CacheITCase#testRetryOnCorruptedClusterDataset
zhuzh
(flink) branch master updated (d55f5f16c23 -> 8fceb101e7e)
zhuzh
(flink) branch master updated (36feab0fb6d -> d55f5f16c23)
mapohl
(flink-kubernetes-operator) branch main updated: [FLINK-33803] Set observedGeneration at end of reconciliation
gyfora
(flink) branch master updated: [FLINK-31511][table][doc][doc-zh] Translate JSON functions and fix typo in sql_functions.yml
leonard
(flink) branch master updated: [FLINK-34237] Revert the breaking changes to SourceReaderContext
xtsong
(flink) branch release-1.18 updated: [FLINK-34117][filesystem] Fix CompactCoordinator data loss upon termination
leonard
(flink) branch master updated: [FLINK-34196][Connectors][FLIP-389] Annotate SingleThreadFetcherManager as PublicEvolving
renqs
(flink) branch master updated: [FLINK-33263][table-planner] Implement ParallelismProvider for sources in the table planner
libenchao
(flink) branch master updated: [FLINK-34221][table-runtime] Introduce MiniBatchStreamingJoinOperator
ron
(flink-connector-kafka) branch main updated: [FLINK-32417] Add DynamicKafkaSource documentation for setter methods, metrics, and config options. This closes #80
martijnvisser
(flink-connector-mongodb) branch main updated: [FLINK-33257][connectors/mongodb] Support filter pushdown in MongoDB connector
leonard
(flink) branch master updated: [FLINK-33577][dist] Change the default config file to config.yaml in flink-dist.
zhuzh
(flink) branch master updated (78e31f0dcc4 -> 80f6e063310)
ron
(flink) 01/06: [FLINK-34100][table] Add function getDescription for internal interface WindowAssigner
ron
(flink) 06/06: [FLINK-34100][table] Merge SlicingWindowOperator and UnslicingWindowOperator
ron
(flink) 02/06: [FLINK-34100][table] Extract a WindowTableFunctionOperatorBase from WindowTableFunctionOperator to prepare for introducing unaligned window table function
ron
(flink) 05/06: [FLINK-34100][table] Fix the window table function outputs wrong row kind
ron
(flink) 04/06: [FLINK-34100][table] Support session window table function without pulling up with window agg
ron
(flink) 03/06: [FLINK-34100][table] Introduce UnalignedWindowTableFunctionOperator for unaligned window
ron
(flink) branch master updated: [FLINK-34144][docs] Update the documentation about dynamic source parallelism inference
zhuzh
(flink) branch master updated: [FLINK-34209] Migrate FileSink to the new SinkV2 API
gyfora
(flink) branch master updated: [FLINK-34231][doc] fix typo for show partition doc in Hive dialect (#24192)
yuxia
(flink) branch master updated (de7322112cb -> eb848dc0676)
shengkai
(flink) 03/03: [FLINK-34056][table] Support named parameters for procedures
shengkai
(flink) 02/03: [FLINK-34057][table] Support named parameters for functions
shengkai
(flink) 01/03: [FLINK-34055][table] Introduce a new annotation for named parameters
shengkai
(flink) branch master updated (1bf27c63624 -> de7322112cb)
ron
(flink) 01/03: [FLINK-34048][table-planner] Add isAlignedWindow for WindowSpec interface
ron
(flink) 03/03: [FLINK-34048][table] introduce unslicing window agg for session window tvf
ron
(flink) 02/03: [FLINK-34048][table] introduce basic interface and class for unslicing window
ron
(flink) branch master updated: [FLINK-34220][table-runtime] Introduce BufferBundle for minibatch join
ron
(flink) branch master updated (4f7725aa790 -> e63aa122528)
mbalassi
(flink) 02/02: [FLINK-28915][k8s] Support fetching remote job jar and additional dependencies on Kubernetes
mbalassi
(flink) 01/02: [FLINK-28915][k8s] Kubernetes client supports s3 jar location
mbalassi
(flink) branch master updated (806970c4b47 -> 4f7725aa790)
hangxiang
(flink) branch master updated (4c1ae285fb6 -> 806970c4b47)
guoweijie
(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
(flink) branch release-1.18 updated: [FLINK-34115][table-planner] Fix unstable TableAggregateITCase.testFlagAggregateWithOrWithoutIncrementalUpdate
jchan
(flink) branch master updated (2cf213ec9e4 -> bed79d33fb7)
hangxiang
(flink) 01/03: [FLINK-34190][checkpoint] Deprecate RestoreMode#LEGACY
hangxiang
(flink) 02/03: [FLINK-34190][checkpoint][rest] Deprecation message of RestoreMode#LEGACY in REST API
hangxiang
(flink) 03/03: [FLINK-34190][checkpoint][cli] Deprecation message of RestoreMode#LEGACY in CLI
hangxiang
(flink-kubernetes-operator) branch main updated: [FLINK-33287] Using the flink shaded jackson for flink-autoscaler
fanrui
(flink) branch master updated: [FLINK-34208] Migrate SinkV1Adapter to the new SinkV2 API
gyfora
(flink) branch master updated (551bb9ebdc4 -> 1d0f34e5a4a)
leonard
(flink-docker) branch dev-master updated: [FLINK-34205] Use BashJavaUtils for Flink configuration management
zhuzh
(flink) branch master updated (393ef1cc439 -> 551bb9ebdc4)
fanrui
(flink) branch master updated (533ead6ae94 -> 393ef1cc439)
fanrui
(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
(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
(flink) branch master updated: [FLINK-33198][format/avro] Properly map Avro timestamp types in Flink Avro format
leonard
(flink) branch master updated: [FLINK-34143] Modify the effective strategy of `execution.batch.adaptive.auto-parallelism.default-source-parallelism`
zhuzh
(flink) branch master updated (287634b77fd -> efbd8c40e6c)
hangxiang
(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
(flink-shaded) branch master updated: [hotfix] Put correct version of Jackson in comment in pom.xml
snuyanzin
(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
(flink-shaded) branch master updated: [hotfix] Update version to 19.0
snuyanzin
(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
(flink) branch master updated (ad3f13f1d5b -> ecd7efc2522)
jchan
(flink) branch master updated (580c4ae0e4e -> ad3f13f1d5b)
fanrui
(flink) 01/05: [FLINK-33565][Exception] Archive exceptions into the exception history immediately when they occur, instead of archiving them when restarting
fanrui
(flink) 04/05: [FLINK-33565][Scheduler] Correct the numberOfRestarts metric
fanrui
(flink) 02/05: [FLINK-33565][Exception] Restart strategy checks whether current failure is a new attempt
fanrui
(flink) 05/05: [hotfix] Remove the wrong `@Nullable` annotation of FailureHandlingResult due to the constructor checks `verticesToRestart` is not null
fanrui
(flink) 03/05: [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging
fanrui
(flink-docker) branch dev-master updated: [FLINK-34165] update the apache download url
jingge
(flink) branch master updated: [FLINK-33975] Tests for the new Sink V2 transformations
gyfora
(flink-kubernetes-operator) branch main updated: [FLINK-33403] Bump flink version to 1.18.1 for flink-kubernetes-operator
fanrui
(flink-docker) branch dev-1.15 updated: [FLINK-34165] update the apache download url for asc
jingge
(flink-docker) branch dev-1.16 updated: [FLINK-34165] update the apache download url for asc
jingge
(flink-docker) branch master updated: [FLINK-34165] update the apache download url for asc in the dockerfiles
jingge
(flink-docker) branch dev-1.17 updated: [FLINK-34165] update the apache download url for asc
jingge
(flink) branch master updated (4db6e72ed76 -> c148b62166d)
zhuzh
(flink) 01/03: [hotfix] Migrate BashJavaUtilsITCase and JavaBashTestBase to Junit5 and assertJ.
zhuzh
(flink) 02/03: [FLINK-33721][core] Support dump configuration as nested yaml data.
zhuzh
(flink) 03/03: [FLINK-33721][core] Extend BashJavaUtils to support reading and writing standard yaml file.
zhuzh
(flink) branch master updated: [FLINK-34029][runtime-web] Support different profiling mode on Flink WEB
tangyun
svn commit: r66750 - /release/flink/flink-1.18.0/
renqs
(flink) branch master updated: [FLINK-34090][core] Introduce SerializerConfig
guoweijie
(flink-connector-hive) branch dependabot/maven/flink-connector-hive/org.apache.derby-derby-10.17.1.0 created (now fc3b5d6)
github-bot
(flink-docker) branch dev-1.18 updated: [FLINK-34165] Update apache download url
jingge
(flink-kubernetes-operator) branch main updated: [FLINK-34198] Remove e2e test operator log error check
gaborgsomogyi
(flink) branch master updated (c8f27c25e87 -> f9f9299f6e2)
yuanmei
(flink) branch master updated: [hotfix][table] Avoid sending duplicate delete record for left join when state expired
lincoln
(flink) branch master updated (27e6ac83617 -> c3c836216ea)
zhuzh
(flink) 01/02: [hotfix] Remove redundant lazy initialization of LazyInitializedCoordinatorContext.
zhuzh
(flink) 02/02: [FLINK-33768] Support dynamic source parallelism inference for batch jobs
zhuzh
(flink) branch master updated: [FLINK-34166][table] Fix KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty
lincoln
(flink) branch master updated: [FLINK-33221][core][config] Add config options for administrator JVM options
fanrui
(flink-kubernetes-operator) branch main updated (775bc5f4 -> 6e78221e)
fanrui
(flink-kubernetes-operator) 02/04: [FLINK-33450][autoscaler] Support the JDBCAutoScalerStateStore
fanrui
(flink-kubernetes-operator) 03/04: [FLINK-33450][autoscaler] StandaloneAutoscalerEntrypoint supports the JDBCAutoScalerStateStore
fanrui
(flink-kubernetes-operator) 04/04: [FLINK-33450][autoscaler] Document the JDBC Autoscaler State Store
fanrui
(flink-kubernetes-operator) 01/04: [FLINK-33450][autoscaler] Extract the AbstractAutoScalerStateStoreTest and add the InMemoryAutoScalerStateStoreTest
fanrui
(flink) branch master updated (fd673a2f462 -> e345ffb453a)
shengkai
(flink-kubernetes-operator) branch main updated: [FLINK-34131] Ensure cluster.health-check.checkpoint-progress.window is well configure
gyfora
(flink) branch release-1.18 updated: [FLINK-33850][doc] Update minor version for 1.18.1 release
jingge
(flink) branch release-1.18 updated: [FLINK-33844][doc] Update japicmp configuration for 1.18.1
jingge
(flink-web) branch asf-site updated (2b8b6a3a7 -> 7ac86254e)
jingge
(flink-web) 01/02: [hotfix] fix typo in the 1.18.1 release announcement
jingge
(flink) branch release-1.18 updated (6e96772f8d5 -> e39559895ab)
dmvk
(flink) 05/05: [FLINK-34063][runtime] Fix OperatorState repartitioning when compression is enabled. We should only write compression headers once, at the end of the "value" part of the serialized stream, to make sure we can always seek to a split point.
dmvk
(flink) 03/05: [FLINK-34063][runtime] Fix CompressibleFSDataInputStream#seek in case of partial reads.
dmvk
(flink) 01/05: [FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.
dmvk
(flink) 02/05: [FLINK-34063][test-utils] Add ExecutionOptions.SNAPSHOT_COMPRESSION to randomized checkpointing options.
dmvk
(flink) 04/05: [FLINK-34063][runtime] Operator states need to be restored in an order they've been written for the compression to work properly on empty states.
dmvk
(flink) branch master updated: [FLINK-33974] Implement the Sink transformation depending on the new SinkV2 interfaces
gyfora
(flink-web) branch asf-site updated: [FLINK-33888] Add a note for a blocker issue FLINK-34063 which will be fixed in 1.18.2
jingge
(flink) branch master updated (8dd28a2e8bf -> b309ceb8de0)
lindong
(flink) branch master updated: [hotfix] peekNextBufferSubpartitionId shouldn't throw UnsupportedDataTypeException
dwysakowicz
(flink) branch master updated (3a3b724136e -> b7c314b46ac)
dmvk
(flink) 01/05: [FLINK-34063][runtime] Always flush compression buffers, when retrieving stream position during OperatorState snapshot.
dmvk
(flink) 04/05: [FLINK-34063][runtime] Operator states need to be restored in an order they've been written for the compression to work properly on empty states.
dmvk
(flink) 03/05: [FLINK-34063][runtime] Fix CompressibleFSDataInputStream#seek in case of partial reads.
dmvk
(flink) 02/05: [FLINK-34063][test-utils] Add ExecutionOptions.SNAPSHOT_COMPRESSION to randomized checkpointing options.
dmvk
(flink) 05/05: [FLINK-34063][runtime] Fix OperatorState repartitioning when compression is enabled. We should only write compression headers once, at the end of the "value" part of the serialized stream, to make sure we can always seek to a split point.
dmvk
(flink) branch release-1.17 updated: [FLINK-34150][ci] Enables local file sink e2e tests in general CI setups
mapohl
(flink) branch release-1.18 updated: [FLINK-34150][ci] Enables local file sink e2e tests in general CI setups
mapohl
(flink) branch master updated (8dbce40b305 -> 3a3b724136e)
mapohl
(flink) branch master updated: [FLINK-33907][ci] Moves jar generation in flink-clients into pre-integration-tests
mapohl
(flink) branch release-1.18 updated: [FLINK-33907][ci] Moves jar generation in flink-clients into pre-integration-tests
mapohl
(flink-web) branch asf-site updated: [FLINK-33888] Add release flink-1.18.1
jingge
(flink-benchmarks) branch master updated: [FLINK-34164] Fix compilation issue (#85)
hangxiang
(flink-connector-kafka) branch dependabot/maven/org.apache.zookeeper-zookeeper-3.7.2 deleted (was 58ab6c12)
martijnvisser
(flink-connector-kafka) branch main updated: [FLINK-34154] Bump org.apache.zookeeper:zookeeper from 3.5.9 to 3.7.2. This closes #72
martijnvisser
(flink) branch master updated (38f7b51d0cc -> 3d088f6e154)
dwysakowicz
(flink) branch master updated (0b4c6f9c9ef -> 38f7b51d0cc)
fanrui
(flink) 02/02: [FLINK-34083][config] Deprecate string configuration keys and unused constants in ConfigConstants
fanrui
(flink) 01/02: [FLINK-34083][yarn][refactor] Move BootstrapTools#getTaskManagerShellCommand to flink-yarn Utils
fanrui
(flink) branch master updated (725b3edc05a -> 0b4c6f9c9ef)
hangxiang
(flink) branch master updated (82fcdfe5634 -> 725b3edc05a)
fanrui
(flink) 01/03: [FLINK-34080][configuration] Add the `T get(ConfigOption<T> configOption, T overrideDefault)` for Configuration
fanrui
(flink) 02/03: [FLINK-34080][configuration] Deprecate all getXxx and setXxx methods for Configuration
fanrui
(flink) 03/03: [FLINK-34080][configuration] Remove the `@Deprecated` for `getString(String key, String defaultValue)` of Configuration
fanrui
(flink) branch master updated: [FLINK-33928][table-planner] Should not throw exception while creating view with specify field names (#24096)
shengkai
(flink) branch release-1.18 updated: [FLINK-33694][gs-fs-hadoop] Support overriding GCS root URL
mapohl
(flink) branch master updated: [FLINK-33694][gs-fs-hadoop] Support overriding GCS root URL
mapohl
(flink) branch release-1.17 updated: [FLINK-33694][gs-fs-hadoop] Support overriding GCS root URL
mapohl
(flink) branch master updated (201571b486f -> bdf31327775)
srichter
(flink) 06/06: [FLINK-34134] Add documentation.
srichter
(flink) 03/06: [FLINK-34134] Add methods to determine local directory sizes to FileUtils.
srichter
(flink) 04/06: [FLINK-34134] Implement handle-specific size/location reporting methods.
srichter
(flink) 02/06: [FLINK-34134] Introduce size/location statistics reporting to StateObject interface.
srichter
(flink) 01/06: [FLINK-34134] Minor cleanup of unused parameters in RocksDB backend.
srichter
(flink) 05/06: [FLINK-34134] Collect and report size/location statistics during task restore.
srichter
(flink-connector-kafka) branch dependabot/maven/org.apache.zookeeper-zookeeper-3.7.2 updated (d66ab6e7 -> 58ab6c12)
martijnvisser
(flink-connector-shared-utils) branch release_utils updated: [FLINK-33401][connectors/kafka] Fix the wrong download link and version in the connector doc. This closes #64
martijnvisser
(flink-connector-kafka) branch dependabot/maven/org.apache.commons-commons-compress-1.24.0 deleted (was f3ca94fb)
martijnvisser
(flink-connector-kafka) branch main updated: [FLINK-33329] Bump org.apache.commons:commons-compress from 1.22 to 1.25.0. This closes #73
martijnvisser
(flink) branch master updated: [FLINK-27992] Set ALWAYS chaining strategy for CepOperator in ExecMatch
dwysakowicz
(flink) branch master updated (551b776a821 -> 4bee4e6e8dd)
tangyun
(flink) 03/03: [hotfix] Add logs for ProfilingServiceTest
tangyun
(flink) 01/03: [FLINK-33434][runtime] Generalize TaskManager file upload function to support different fileType (baseDir)
tangyun
(flink) 02/03: [FLINK-33434][runtime-web] Support invoke async-profiler on TaskManager via REST API
tangyun
(flink-kubernetes-operator) branch main updated: [FLINK-33771] Add cluster capacity awareness to autoscaler (#751)
mxm
(flink-connector-kafka) branch dependabot/maven/org.apache.commons-commons-compress-1.24.0 updated (f701ac25 -> f3ca94fb)
martijnvisser
(flink-connector-kafka) branch main updated: [hotfix] Synchronize CI pipeline setup. This closes #78
martijnvisser
(flink) branch master updated: [FLINK-34072][scripts] Replace java command to JAVA_RUN in config.sh
tangyun
(flink) branch master updated: [FLINK-34119][doc] Improve description about changelog in document
hangxiang
(flink-connector-kafka) branch main updated: [FLINK-32416] Fix flaky tests by ensuring test utilities produce records with consistency and cleanup notify no more splits to ensure it is sent. This closes #79
martijnvisser
(flink) branch master updated: [FLINK-34070][test] Adds dedicated tests in MiniClusterITCase for scenarios where there are not enough slots available.
mapohl
(flink) branch master updated: [FLINK-34097] Remove JobMasterGateway#requestJobDetails
chesnay
(flink) branch master updated: [FLINK-34084][config] Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat
xtsong
(flink-docker) branch master updated: [FLINK-33842][docs] Update minor version for 1.18.1 release
jingge
(flink-docker) branch dev-1.18 updated: [FLINK-33842][docker] Add GPG key for 1.18.1 release
jingge
(flink) branch master updated (cdf314d30b5 -> a886339dbb3)
guoweijie
(flink) branch master updated (a20d57b18bb -> cdf314d30b5)
zhuzh
(flink) branch master updated (fb7324b05bb -> a20d57b18bb)
fanrui
(flink) 01/02: [FLINK-33988][configuration] Fix the invalid configuration when using initialized root logger level on yarn deployment mode
fanrui
(flink) 02/02: [FLINK-34102][configuration] Fix the invalid configuration when using 'env.log.max' on yarn deployment mode
fanrui
(flink) branch master updated: [FLINK-33679][checkpointing] Fix the misleading description about RestoreMode#LEGACY(#24101)
hangxiang
(flink) branch master updated (488d60a1d39 -> 534df6490e0)
dwysakowicz
(flink) annotated tag release-1.18.1 updated (a8c8b1c0e2c -> 1a713e5ac88)
jingge
Earlier messages
Later messages