commits
Thread
Date
Earlier messages
Later messages
Messages by Thread
(flink) branch master updated: [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily
fanrui
(flink) branch master updated: [FLINK-32706][table] Add built-in SPLIT_STRING function (#24365)
dwysakowicz
(flink-cdc) branch master updated: [minor][docs] Improve the answer of MySQL CDC FAQ docs
leonard
(flink-cdc) branch release-3.1 updated: [minor][docs] Rectify names of CDC sources for Flink and improve the content directory
leonard
(flink-cdc) branch release-3.0 updated: [minor][docs] Rectify names of CDC sources for Flink and improve the content directory
leonard
(flink-connector-elasticsearch) branch v3.0 updated: [FLINK-33493][connectors/elasticsearch] Fix ElasticsearchWriterITCase test
guoweijie
(flink-connector-elasticsearch) branch v3.0 updated: [FLINK-31696] ElasticSearch nightly CI failure
guoweijie
(flink-connector-elasticsearch) branch v3.0 updated (4e122f7 -> 83cc429)
guoweijie
(flink-connector-elasticsearch) 01/01: [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded
guoweijie
(flink-connector-elasticsearch) branch v3.0 updated (f94649a -> 4e122f7)
guoweijie
(flink-connector-elasticsearch) 02/02: fixup! [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded
guoweijie
(flink-connector-elasticsearch) 01/02: [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded
guoweijie
[I] DataStreamSource oracle ID [flink-cdc]
via GitHub
Re: [I] DataStreamSource oracle ID [flink-cdc]
via GitHub
Re: [I] DataStreamSource oracle ID [flink-cdc]
via GitHub
[I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
[I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
Re: [I] Information that has disappeared from github appears on the web page. [flink-cdc]
via GitHub
(flink-connector-elasticsearch) branch dependabot/maven/flink-connector-elasticsearch-base/org.elasticsearch-elasticsearch-7.17.19 deleted (was 64a24ed)
github-bot
(flink-connector-elasticsearch) branch main updated: [FLINK-35287] Builder builds NetworkConfig for Elasticsearch connector 8
guoweijie
(flink) branch master updated (c1baf07d760 -> e502d2371ff)
guoweijie
(flink) 07/11: [FLINK-34549][API] Implement TaskInfo and expose it via RuntimeContext
guoweijie
(flink) 03/11: [FLINK-34549][API] Introduces and implements ProcessConfigurable
guoweijie
(flink) 06/11: [FLINK-34549][API] Implement JobInfo and expose it via RuntimeContext
guoweijie
(flink) 02/11: [FLINK-34549][API] Introduce SlotSharingGroup for v2 and move MemorySize to flink-core-api
guoweijie
(flink) 01/11: [hotfix] Temporarily revert the change that makes the v2 operator inherit from the async operator
guoweijie
(flink) 05/11: [FLINK-34549][API] Split partition-wise context from RuntimeContext
guoweijie
(flink) 04/11: [FLINK-34549][API] Introduce related components for runtime context
guoweijie
(flink) 08/11: [FLINK-34549][API] Implement StateManager and expose it via PartitionedContext
guoweijie
(flink) 10/11: [FLINK-34549][API] Expose MetricGroup via RuntimeContext
guoweijie
(flink) 09/11: [FLINK-34549][API] Implement ProcessingTimeManager and expose it via PartitionedContext
guoweijie
(flink) 11/11: [FLINK-34549][API] Implement applyToAllPartitions for non-partitioned context
guoweijie
(flink) branch master updated (8b73ca955bc -> c1baf07d760)
fanrui
(flink) 01/02: Revert "[FLINK-34954][core] Kryo Input bug fix"
fanrui
(flink) 02/02: [FLINK-35215][core] Fix the bug when Kryo serialize length is 0
fanrui
(flink) branch release-1.19 updated: [FLINK-35383][docs] Update compatibility matrix for 1.19 release
hong
(flink) branch master updated (5a2c1e07194 -> 8b73ca955bc)
hong
(flink) branch master updated: [hotfix][state] Create new copy for each SerializedCompositeKeyBuilder in ForStStateBackend (#24816)
hangxiang
(flink) branch master updated: [hotfix] [streaming] Correct copying StreamPartitioner in rescale case
pnowojski
(flink) branch master updated: [FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance
guoweijie
(flink-kubernetes-operator) branch main updated: [FLINK-35192] support jemalloc in image
gaborgsomogyi
(flink) branch master updated: [FLINK-35395][core] Fix the example code of KeyedStateStore#getState
guoweijie
(flink) branch master updated: [FLINK-35382][test] Disable snapshot-file-merging in ChangelogCompatibilityITCase (#24813)
leiyanfei
(flink) branch master updated: [FLINK-35379][Checkpoint] Fix incorrect checkpoint notification handling in file merging (#24806)
zakelly
(flink) branch master updated: [FLINK-33983][runtime] Introduce JobEvent and JobEventStore
zhuzh
(flink) branch release-1.18 updated: [FLINK-20539][table-planner] Fix type mismatch when using ROW in computed column
snuyanzin
(flink-web) branch asf-site updated: Add Flink CDC 3.1.0 download links
renqs
(flink-connector-aws) branch main updated: [FLINK-35269] Log information about failed records as warnings instead of debug for Kinesis and Firehose sinks
hong
(flink-web) branch asf-site updated (6356efb0c -> edace5b76)
renqs
(flink-web) 01/02: Add release announcement for Flink CDC 3.1.0
renqs
(flink) branch release-1.18 updated (1e1a7f16b6f -> 4848a50d735)
pnowojski
(flink) 03/04: [hotfix] Allow to use per split output via SourceOperatorTestContext
pnowojski
(flink) 04/04: [FLINKCC-1283] Properly initialize initial splits in WatermarkOutputMultiplexer
pnowojski
(flink) 01/04: [hotfix] Make MockSourceSplit#addRecord calls chainable
pnowojski
(flink) 02/04: [hotfix] Allow configuring initial splits in SourceOperatorTestContext
pnowojski
(flink) branch release-1.19 updated (190522c2c05 -> a160f8db1f7)
pnowojski
(flink) 02/04: [hotfix] Allow configuring initial splits in SourceOperatorTestContext
pnowojski
(flink) 04/04: [FLINK-32828] Properly initialize initial splits in WatermarkOutputMultiplexer
pnowojski
(flink) 01/04: [hotfix] Make MockSourceSplit#addRecord calls chainable
pnowojski
(flink) 03/04: [hotfix] Allow to use per split output via SourceOperatorTestContext
pnowojski
(flink) branch master updated (f1ecb9e4701 -> f5a8edbcb91)
zakelly
(flink) 01/03: [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `CheckpointConfig` and move it to flink-core.
zakelly
(flink) 03/03: [FLINK-34615]Create a new class `ExternalizedCheckpointRetention` in python and replace the original class `ExternalizedCheckpointCleanup`.
zakelly
(flink) 02/03: [FLINK-34615]Renamed class "ExternalizedCheckpointCleanup" to "ExternalizedCheckpointRetention" in Java section.
zakelly
(flink-cdc) branch master updated: [FLINK-35386][cdc][docs] Shorten GHA names and disable fail-fast to isolate branches (#3331)
renqs
(flink-cdc) branch release-3.1 updated: [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable (#3317)
renqs
(flink-cdc) branch master updated: [FLINK-35386][cdc][docs] Build release-3.1 documentation and mark it as stable (#3330)
renqs
(flink) branch master updated: [FLINK-35030][runtime] Introduce Epoch Manager for under async execution (#24748)
leiyanfei
(flink-benchmarks) branch master updated: [hotfix] Fix compilation error due to constructor removal of MockSourceReader (#89)
zakelly
(flink-cdc) branch release-3.1 updated: [FLINK-35314][cdc] Add Flink CDC pipeline transform user document (#3308)
renqs
(flink-cdc) annotated tag release-3.1.0 updated (5452f30b7 -> c134441aa)
renqs
svn commit: r69245 - in /dev/flink: flink-cdc-3.1.0-rc0/ flink-cdc-3.1.0-rc1/ flink-cdc-3.1.0-rc2/
renqs
svn commit: r69244 - /dev/flink/flink-cdc-3.1.0-rc3/ /release/flink/flink-cdc-3.1.0/
renqs
(flink) branch master updated: [FLINK-35356][State] State descriptor and implementation for async reducing state (#24798)
zakelly
(flink) branch master updated: [hotfix] Mention mTLS in SSL documentation page (#24755)
rmetzger
(flink) branch master updated (1378979f02e -> 7fd6c6da26c)
pnowojski
(flink) 02/04: [hotfix] Allow configuring initial splits in SourceOperatorTestContext
pnowojski
(flink) 03/04: [hotfix] Allow to use per split output via SourceOperatorTestContext
pnowojski
(flink) 04/04: [FLINK-32828] Properly initialize initial splits in WatermarkOutputMultiplexer
pnowojski
(flink) 01/04: [hotfix] Make MockSourceSplit#addRecord calls chainable
pnowojski
(flink) branch master updated: [FLINK-35346][table-common] Introduce workflow scheduler interface for materialized table
ron
(flink) branch master updated (0c28e1ca7ea -> 48c14fe5d2b)
fanrui
(flink) branch master updated: [FLINK-35226][rest] Deprecate execution-mode in ExecutionConfigInfo related rest api
fanrui
[I] Exception in thread "main" java.lang.NoSuchMethodError: 'void org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory.<init>(org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink, boolean, boolean)' [flink-cdc]
via GitHub
Re: [I] Exception in thread "main" java.lang.NoSuchMethodError: 'void org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory.<init>(org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink, boolean, boolean)' [flink-cdc]
via GitHub
Re: [I] Exception in thread "main" java.lang.NoSuchMethodError: 'void org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory.<init>(org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink, boolean, boolean)' [flink-cdc]
via GitHub
Re: [I] Exception in thread "main" java.lang.NoSuchMethodError: 'void org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory.<init>(org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink, boolean, boolean)' [flink-cdc]
via GitHub
Re: [I] Exception in thread "main" java.lang.NoSuchMethodError: 'void org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory.<init>(org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink, boolean, boolean)' [flink-cdc]
via GitHub
(flink) branch master updated: [FLINK-32082][docs] Documentation of checkpoint file-merging (#24766)
leiyanfei
(flink-kubernetes-operator) branch main updated: [FLINK-34537] Autoscaler JDBC Support HikariPool (#785)
fanrui
(flink) branch master updated: [FLINK-32092][tests] Integrate snapshot file-merging with existing IT cases (#24789)
leiyanfei
[I] flink cdc 2.4.2版本关于报错io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4 的问题 [flink-cdc]
via GitHub
Re: [I] flink cdc 2.4.2版本关于报错io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4 的问题 [flink-cdc]
via GitHub
Re: [I] flink cdc 2.4.2版本关于报错io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4 的问题 [flink-cdc]
via GitHub
(flink-connector-opensearch) annotated tag v2.0.0-rc1 updated (11cde7b -> c104392)
snuyanzin
(flink-connector-opensearch) branch os200 created (now 11cde7b)
snuyanzin
(flink-connector-opensearch) 01/01: Update version to 2.0.0
snuyanzin
svn commit: r69233 - in /dev/flink/flink-connector-opensearch-2.0.0-rc1: ./ flink-connector-opensearch-2.0.0-src.tgz flink-connector-opensearch-2.0.0-src.tgz.asc flink-connector-opensearch-2.0.0-src.tgz.sha512
snuyanzin
(flink-connector-opensearch) annotated tag v1.2.0-rc1 updated (30e94d6 -> 607bf4f)
snuyanzin
(flink-connector-opensearch) branch 120rc0 created (now 30e94d6)
snuyanzin
(flink-connector-opensearch) 01/01: Update version to 1.2.0
snuyanzin
(flink) branch FLIP-410-update3 created (now 90ebaa47f54)
guoweijie
(flink) 06/07: [FLINK-34549][API] Expose MetricGroup via RuntimeContext
guoweijie
(flink) 02/07: [FLINK-34549][API] Implement JobInfo and expose it via RuntimeContext
guoweijie
(flink) 05/07: [FLINK-34549][API] Implement ProcessingTimeManager and expose it via PartitionedContext
guoweijie
(flink) 01/07: [FLINK-34549][API] Split partition-wise context from RuntimeContext
guoweijie
(flink) 07/07: [FLINK-34549][API] Implement applyToAllPartitions for non-partitioned context
guoweijie
(flink) 03/07: [FLINK-34549][API] Implement TaskInfo and expose it via RuntimeContext
guoweijie
(flink) 04/07: [FLINK-34549][API] Implement StateManager and expose it via PartitionedContext
guoweijie
(flink) branch master updated (40fb49dd17b -> 73a7e1cc461)
zakelly
(flink-cdc) branch master updated: [FLINK-35314][cdc] Add Flink CDC pipeline transform user document (#3308)
renqs
(flink) branch release-1.18 updated: [FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank()
snuyanzin
(flink) branch release-1.19 updated: [FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank()
snuyanzin
(flink) branch master updated: [FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank()
snuyanzin
(flink) branch master updated (65d31e26534 -> 94d861b08fe)
ron
(flink) 02/04: [FLINK-35193][table] Support convert drop materialized table node to operation
ron
(flink) 04/04: [FLINK-35342][table] Fix MaterializedTableStatementITCase test can check for wrong status
ron
(flink) 03/04: [FLINK-35193][table] Support execution of drop materialized table
ron
(flink) 01/04: [FLINK-35193][table] Support drop materialized table syntax
ron
(flink) branch master updated: [FLINK-33986][runtime] Extend ShuffleMaster to support snapshot and restore state.
zhuzh
(flink) branch master updated: [FLINK-32087][checkpoint] Introduce space amplification statistics of file merging (#24762)
leiyanfei
(flink) branch release-1.18 updated: [FLINK-35098][ORC] Fix incorrect results with literal first expressions
snuyanzin
(flink) branch release-1.19 updated: [FLINK-35098][ORC] Fix incorrect results with literal first expressions
snuyanzin
(flink) branch master updated: [FLINK-35098][ORC] Fix incorrect results with literal first expressions
snuyanzin
(flink-connector-kudu) branch main updated: [hotfix] Remove non-existing branches for Weekly tests
martijnvisser
(flink-connector-kudu) branch main updated: [FLINK-34961] Use dedicated CI name for JDBC connector to differentiate it in infra-reports
martijnvisser
(flink-connector-kudu) branch main updated (d837674 -> 8674446)
martijnvisser
(flink-connector-kudu) 03/44: [BAHIR-99] kudu connector
martijnvisser
(flink-connector-kudu) 13/44: Add support "upsert part of columns of a kudu table" (#70)
martijnvisser
(flink-connector-kudu) 07/44: [BAHIR-199] Bump kudu version to 1.9.0
martijnvisser
(flink-connector-kudu) 02/44: [FLINK-34930] Remove Python CI
martijnvisser
(flink-connector-kudu) 22/44: [BAHIR-293] Fix documentation tables
martijnvisser
(flink-connector-kudu) 04/44: [BAHIR-179] Fail Docker integration tests silently
martijnvisser
(flink-connector-kudu) 15/44: Fix NotSerializableException in Kudu connector (#74)
martijnvisser
(flink-connector-kudu) 14/44: Fix "the client has already been closed" bug (#75)
martijnvisser
(flink-connector-kudu) 23/44: [BAHIR-291] Bump flink to 1.14.0 (#136)
martijnvisser
(flink-connector-kudu) 24/44: [BAHIR-296] Unify log4j libs
martijnvisser
(flink-connector-kudu) 08/44: [BAHIR-202] Improve KuduSink throughput using async FlushMode
martijnvisser
(flink-connector-kudu) 09/44: [BAHIR-200] Move tests from docker to kudu-test-utils (#49)
martijnvisser
(flink-connector-kudu) 29/44: [maven-release-plugin] prepare for next development iteration
martijnvisser
(flink-connector-kudu) 01/44: [FLINK-34930] Initialize tools/ and vcs.xml
martijnvisser
(flink-connector-kudu) 10/44: [BAHIR-209] upgrade kudu version to 1.10.0 (#61)
martijnvisser
(flink-connector-kudu) 27/44: [BAHIR-243] Change KuduTestHarness with TestContainers
martijnvisser
(flink-connector-kudu) 12/44: [BAHIR-214] Improve speed and solve eventual consistence issues (#64)
martijnvisser
(flink-connector-kudu) 31/44: [BAHIR-312] Add license header to README.md files
martijnvisser
(flink-connector-kudu) 21/44: [BAHIR-260] Add kudu table writer config (#109)
martijnvisser
(flink-connector-kudu) 26/44: [BAHIR-302] Add enforcers
martijnvisser
(flink-connector-kudu) 33/44: [BAHIR-308] Remove support for scala 2.11
martijnvisser
(flink-connector-kudu) 32/44: [BAHIR-321] Make KuduFilterInfo handle String literals
martijnvisser
(flink-connector-kudu) 19/44: [BAHIR-241] Upgrade all connectors to Flink 1.11 (#99)
martijnvisser
(flink-connector-kudu) 36/44: [BAHIR-324] Closing KuduReader at JobManager
martijnvisser
(flink-connector-kudu) 05/44: [BAHIR-194] bump kudu version to 1.8.0
martijnvisser
(flink-connector-kudu) 20/44: [BAHIR-263] Update flink to 1.12.2 (#115)
martijnvisser
(flink-connector-kudu) 37/44: [FLINK-34930] Adapt POM files to the new structure, remove flink-shaded Guava usage
martijnvisser
(flink-connector-kudu) 39/44: [FLINK-34930] Rename base package
martijnvisser
(flink-connector-kudu) 28/44: [BAHIR-302] Group declaration of flink dependencies on parent pom
martijnvisser
(flink-connector-kudu) 35/44: [BAHIR-308] Remove scala prefix where we can
martijnvisser
(flink-connector-kudu) 11/44: [BAHIR-207] Add tests for scala 2.12 on travis (#59)
martijnvisser
(flink-connector-kudu) 06/44: [BAHIR-180] Improve eventual consistence for Kudu connector
martijnvisser
(flink-connector-kudu) 18/44: BAHIR-240: replace docker test by testcontainer (#89)
martijnvisser
(flink-connector-kudu) 34/44: [BAHIR-308] Bump flink version to 1.15.3
martijnvisser
(flink-connector-kudu) 44/44: [FLINK-34930] Migrate Bahir NOTICE
martijnvisser
(flink-connector-kudu) 43/44: [FLINK-34930] Enable module opens for tests for newer JDKs
martijnvisser
(flink-connector-kudu) 17/44: Add batch table env support and filter push down to Kudu connector (#82)
martijnvisser
(flink-connector-kudu) 41/44: [FLINK-34930] State Bahir fork
martijnvisser
(flink-connector-kudu) 42/44: [FLINK-34930] Skip spotless for JDK 21+
martijnvisser
(flink-connector-kudu) 25/44: BAHIR-296: Unify mockito version to 1.10.19
martijnvisser
(flink-connector-kudu) 40/44: [FLINK-34930] Fix KuduTableSourceITCase
martijnvisser
(flink) branch master updated: [FLINK-35293][hive] Hive source supports dynamic parallelism inference
zhuzh
(flink) branch master updated: [FLINK-35168][State] Basic State Iterator for async processing (#24690)
zakelly
(flink) branch master updated (36b1d2acd6d -> 4e6b42046ad)
zhuzh
(flink) branch master updated: [FLINK-35302][rest] Ignore unknown fields in REST request deserialization
gaborgsomogyi
(flink) branch master updated (9fe8d7bf870 -> e4972c003f6)
ron
(flink) 01/01: [FLINK-35197][table] Support the execution of suspend, resume materialized table in continuous refresh mode
ron
(flink-connector-gcp-pubsub) branch main updated: [FLINK-35322][Connectors/Google PubSub] Remove weekly tests of 1.19 for unsupporting version v3.0
snuyanzin
svn commit: r69108 - in /dev/flink/flink-connector-opensearch-1.2.0-rc1: ./ flink-connector-opensearch-1.2.0-src.tgz flink-connector-opensearch-1.2.0-src.tgz.asc flink-connector-opensearch-1.2.0-src.tgz.sha512
snuyanzin
svn commit: r69107 - /dev/flink/flink-connector-opensearch-1.2.0-rc1/
snuyanzin
(flink-connector-opensearch) branch main updated: [hotfix] Use 1.1 branch during weekly instead of 1.0
snuyanzin
(flink-connector-opensearch) branch test_11 updated (1f4508a -> 60e1a4a)
snuyanzin
(flink-connector-opensearch) branch test_11 updated (cf1bcab -> 1f4508a)
snuyanzin
(flink-connector-opensearch) 02/02: [hotfix] Use 1.1 branch during weekly instead of 1.0
snuyanzin
(flink-connector-opensearch) 01/02: [hotfix] Revert revisions
snuyanzin
(flink) branch master updated (86c8304d735 -> 9fe8d7bf870)
ron
(flink) branch master updated: [FLINK-35041][test] Fix the IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed
fanrui
(flink) branch master updated: [hotfix][test] Fix InstantiationUtilTest cannot find assertFalse
fanrui
(flink-connector-opensearch) branch test_11 updated (635317e -> cf1bcab)
snuyanzin
(flink-connector-opensearch) 01/01: [hotfix] Use 1.1 branch during weekly instead of 1.0
snuyanzin
(flink-cdc) branch master updated: [hotfix][docs] Fix dead links in documentations
leonard
(flink-connector-opensearch) branch test_11 updated: Update weekly.yml
snuyanzin
(flink-connector-opensearch) branch test_11 created (now 31b09c3)
snuyanzin
(flink-connector-opensearch) 02/02: [hotfix] Use 1.1 branch during weekly instead of 1.0
snuyanzin
(flink-connector-opensearch) 01/02: [hotfix] Revert revisions
snuyanzin
Earlier messages
Later messages