Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2355 commits
Select commit Hold shift + click to select a range
ec73bc5
[FLINK-22765][test] Hardens ExceptionUtilsITCase#testIsMetaspaceOutOf…
XComp Feb 15, 2024
8cf2996
[hotfix][test] Assert the slot allocation eventually succeed in dedic…
KarmaGYZ Feb 19, 2024
45d4dc1
[FLINK-34434][slotmanager] Complete the returnedFuture when slot remo…
KarmaGYZ Feb 19, 2024
4f7cc9f
[hotfix][docs] Integrate mongodb v1.1 docs
leonardBang Feb 20, 2024
a9bec20
[hotfix][docs] Update the versions of mongodb supported by mongodb-co…
Jiabao-Sun Feb 20, 2024
b7ea090
[hotfix][tests] Disables cool down phase for faster test execution
1996fanrui Feb 1, 2024
c91029b
[FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang som…
1996fanrui Feb 2, 2024
a25fca9
[FLINK-34202][python] Optimize Python nightly CI time (#24321)
HuangXingBo Feb 21, 2024
d19e886
[FLINK-34479][documentation] Fix missed changelog configs in the docu…
masteryhx Feb 21, 2024
f21ee01
[FLINK-34476][table-planner] Consider assignment operator during TVF …
twalthr Feb 22, 2024
dd77ee5
[FLINK-34496] Break circular dependency in static initialization
zentol Feb 23, 2024
0af2540
[FLINK-34265][doc] Add the doc of named parameters (#24377)
hackergin Feb 26, 2024
d743ee3
[FLINK-34518][runtime] Fixes AdaptiveScheduler#suspend bug when the j…
XComp Feb 26, 2024
62d1b8f
[hotfix][runtime] Refactors suspend and cancel logic
XComp Feb 26, 2024
3c04316
[BP-1.19][FLINK-34274][runtime] Implicitly disable resource wait time…
XComp Feb 28, 2024
628ae78
[FLINK-34498] GSFileSystemFactory should not log full Flink config
jeyhunkarimov Feb 22, 2024
5016325
[FLINK-34499] Configuration#toString hides sensitive values
zentol Feb 22, 2024
12ea64c
[FLINK-33436][docs] Add the docs of built-in async-profiler
yuchen-ecnu Feb 28, 2024
161defe
[FLINK-34522][core] Changing the Time to Duration for StateTtlConfig.…
1996fanrui Feb 27, 2024
697d2b6
[hotfix] Fix the StateTtlConfig#newBuilder doc from Time to Duration
1996fanrui Feb 27, 2024
7618bde
[Hotfix] Fix Duration class can't load for pyflink
RocMarshal Mar 1, 2024
fa738bb
[FLINK-34582][realse][python] Updates cibuildwheel to support cpython…
HuangXingBo Mar 6, 2024
837f8e5
Revert "[FLINK-33532][network] Move the serialization of ShuffleDescr…
Mar 6, 2024
75c88fa
[FLINK-34616][python] Fix python dist dir doesn't clean when open met…
liuyongvs Mar 8, 2024
0a85a08
[FLINK-34622][docs] fix typo in execution_mode.md
yuchen-ecnu Mar 8, 2024
c6d96b7
[FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.commo…
Myasuka Mar 7, 2024
943d9a4
[FLINK-33798][statebackend/rocksdb] automatically clean up rocksdb l…
liming30 Mar 13, 2024
4d5327d
[FLINK-29114][connector][filesystem] Fix issue of file overwriting ca…
LadyForest Mar 14, 2024
4f7f6a9
[FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedu…
reswqa Mar 8, 2024
511814b
[FLINK-34593][release] Add release note for version 1.19
lincoln-lil Mar 18, 2024
a6a4667
[FLINK-34716][release] Build 1.19 docs in GitHub Action and mark 1.19…
lincoln-lil Mar 18, 2024
b6ba252
[hotfix] Fix maven property typo in root pom.xml
RyanSkraba Mar 19, 2024
f53c562
[FLINK-34725][dist] Fix wrong config file dir when `config-parser-uti…
JunRuiLee Mar 19, 2024
8fd8b3a
[FLINK-34706][docs] Deprecates 1.17 docs.
lincoln-lil Mar 21, 2024
6eeae5f
Update japicmp configuration for 1.19.0
lincoln-lil Mar 22, 2024
94c3261
[hotfix][tests] Migrate TransformationTest to Junit5
jeyhunkarimov Mar 16, 2024
5ec4bf2
[FLINK-32513][core] Add predecessor caching
jeyhunkarimov Mar 10, 2024
4fc36e9
[FLINK-21400][ci] Enables FileSink and Stateful stream job e2e test f…
XComp Feb 7, 2024
0049263
[FLINK-21450][test] Enables tests that were disabled for the Adaptive…
XComp Feb 7, 2024
7d10796
[FLINK-21535][test] Adds proper comment to test methods that are disa…
XComp Feb 7, 2024
f82ff7c
[FLINK-34409][ci] Enable any still disabled e2e tests for the Adaptiv…
XComp Feb 7, 2024
4069d87
[FLINK-26615][tests] Assert only the minimum delay in RetryingExecuto…
rkhachatryan Mar 26, 2024
b4767ae
[FLINK-26515][tests] Tolerate TimeoutException in RetryingExecutorTes…
rkhachatryan Mar 26, 2024
6b5c48f
[FLINK-34897][test] Enables JobMasterServiceLeadershipRunnerTest#test…
XComp Mar 20, 2024
c11656a
[FLINK-34933][test] Fixes JobMasterServiceLeadershipRunnerTest#testRe…
XComp Mar 25, 2024
faa880c
[FLINK-34922][rest] Support concurrent global failure
zentol Mar 27, 2024
b54edc8
[FLINK-34922] Adds ITCase for GlobalFailureOnRestart
pgaref Mar 28, 2024
e4ac2ee
[FLINK-34956][doc] Fix the config type wrong of Duration
1996fanrui Mar 28, 2024
ece4fae
[FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testT…
Jiabao-Sun Jan 2, 2024
f172171
[FLINK-34955] Upgrade commons-compress to 1.26.0.
mbalassi Apr 3, 2024
eb58599
[FLINK-35000][build] Updates link to test code convention in pull req…
XComp Apr 3, 2024
3008896
[hotfix][table] Fix typo in maven shade configuration (#24620)
rmetzger Apr 4, 2024
4397c9f
[FLINK-34712][release] Generate reference data for state migration te…
lincoln-lil Apr 7, 2024
b1165a8
[FLINK-28693][table] Janino compile failed because of the generated c…
snuyanzin Apr 9, 2024
34c6777
[FLINK-31472][connectors/base] Remove external timer service referenc…
vahmed-hamdy Apr 16, 2024
a2c3d27
[FLINK-35089][runtime] Initialize lastRecordAttributes in AbstractStr…
Sxnan Apr 12, 2024
87ed9cc
[FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment
zentol Apr 18, 2024
6045bd8
[FLINK-35169][runtime] Recycle buffers to freeSegments before releasi…
TanYuxin-tyx Apr 19, 2024
e7816f7
[FLINK-35097][table] Fix 'raw' format deserialization
kumar-mallikarjuna Apr 14, 2024
ff7c00e
[FLINK-35239] [docs] Unset outdated warning
uce Apr 25, 2024
f321970
[FLINK-34379][table] Fix OutOfMemoryError with large queries
jeyhunkarimov Apr 1, 2024
c370b20
[FLINK-32622][table-planner] Optimize mini-batch assignment (#23470)
jeyhunkarimov Apr 29, 2024
ac4aa35
[FLINK-35217] Add missing fsync to #closeForCommit in some subclasses…
StefanRRichter Apr 30, 2024
fa426f1
[FLINK-34517][table]fix environment configs ignored when calling proc…
JustinLeesin May 6, 2024
17e7c3e
[FLINK-35184][table-runtime] Fix mini-batch join hash collision when …
rovboyko May 10, 2024
95fb6c1
[hotfix][ci] Docker might return multiple port bindings
XComp Feb 7, 2024
8707c63
[FLINK-34324][test] Makes all s3 related operations being declared an…
XComp Jan 31, 2024
37bcfb8
[FLINK-34508][ci] Makes FileSink e2e tests run with Minio instead of S3
XComp Feb 7, 2024
500e92c
[hotfix][tests] Removes warning that's produced when removing non-exi…
XComp Apr 2, 2024
d16b20e
[FLINK-35112][python] Correct contains check for Row type (#24756)
wzorgdrager May 11, 2024
e16da86
[FLINK-35098][ORC] Fix incorrect results with literal first expressions
empathy87 May 14, 2024
190522c
[FLINK-27741][table-planner] Fix NPE when use dense_rank() and rank()
snuyanzin May 15, 2024
db05108
[hotfix] Make MockSourceSplit#addRecord calls chainable
pnowojski May 15, 2024
f6c5fee
[hotfix] Allow configuring initial splits in SourceOperatorTestContext
pnowojski May 15, 2024
5aa02cb
[hotfix] Allow to use per split output via SourceOperatorTestContext
pnowojski May 15, 2024
a160f8d
[FLINK-32828] Properly initialize initial splits in WatermarkOutputMu…
pnowojski May 15, 2024
c4af0c3
[FLINK-35383][docs] Update compatibility matrix for 1.19 release
z3d1k May 16, 2024
ddccfb6
[hotfix][rest] Add getter methods for SubtasksTimesInfo to get all va…
1996fanrui May 22, 2024
192f692
[FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to g…
davidradl Apr 29, 2024
a5efed2
[FLINK-35246][test] Fix incorrect address construction in SqlClientSS…
davidradl May 22, 2024
a450980
[FLINK-35429][sqlgateway] Do not introduce new method in SqlGatewayEn…
reswqa May 23, 2024
663eeaf
[FLINK-34379][table] Fix adding catalogtable logic
jeyhunkarimov May 15, 2024
f6caf4e
[FLINK-26808][rest] Add MultipartRoutes utility
uce May 28, 2024
f567ee1
[FLINK-26808][rest] Factor out getHandlerRoutes(RestHandlerSpecificat…
uce May 28, 2024
82dd642
[FLINK-26808][rest] Only accept file upload at multipart routes
uce May 28, 2024
90a71a1
[FLINK-35358][clients] Reintroduce recursive JAR listing in classpath…
ferenc-csaky May 15, 2024
e095657
[hotfix] [streaming] Correct copying StreamPartitioner in rescale case
ldadima May 20, 2024
d6d4090
[FLINK-35351][checkpoint] Fix fail during restore from unaligned chec…
ldadima May 14, 2024
551f4ae
[FLINK-35351][checkpoint] Clean up and unify code for the custom part…
pnowojski May 28, 2024
e5fc647
[FLINK-34569][e2e] fail fast if AWS cli container fails to start (#24…
robobario Jun 5, 2024
b9c666e
[FLINK-35526] Use more up to date jq docker image for Flink e2e tests…
rmetzger Jun 6, 2024
de5793a
[FLINK-35139][docs] Update MongoDB docs for 1.2.0 release
dannycranmer Jun 6, 2024
175ed72
[FLINK-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication…
hlteoh37 Jun 5, 2024
7afa6ea
[FLINK-35522][runtime] Fix the issue that the source task may get stu…
SinBex Jun 5, 2024
72267c4
[FLINK-35537] Fix exception when setting 'state.backend.rocksdb.compr…
Zakelly Jun 6, 2024
cdbc14b
[FLINK-35531] Avoid calling hsync in flush method in BaseHadoopFsReco…
cxzl25 Jun 5, 2024
dc89ffb
[FLINK-35157][runtime] Sources with watermark alignment get stuck onc…
elon-X Jun 14, 2024
5225e81
[FLINK-34252][table] Fix lastRecordTime tracking in WatermarkAssigner…
dchristle Jan 28, 2024
c5dfb57
fixup! [FLINK-34252][table] Optimize WatermarkAssignerOperator to avo…
pnowojski Jun 14, 2024
7ae2557
[hotfix][doc] Update minor version for 1.19.1 release
reswqa Jun 19, 2024
a2d42b7
[hotfix][build] Update japicmp configuration for 1.19.1
reswqa Jun 19, 2024
e2c875a
[FLINK-33936][table] Outputting Identical Results in Mini-Batch Aggre…
hackergin Jun 20, 2024
41837e4
[FLINK-35353][docs-zh]Translate "Profiler" page into Chinese
drymatini May 22, 2024
74a59e0
[FLINK-35699][k8s] Fix shading Jackson through fabric8
ferenc-csaky Jun 25, 2024
80fd671
[FLINK-35728][python] Move conda url from repo.continuum.io to repo.a…
Samrat002 Jul 2, 2024
2581c26
[FLINK-35498][table] Fix unexpected argument name conflicts when extr…
xuyangzhong Jul 4, 2024
6caf576
[FLINK-35731][runtime] Fix incorrect parallelism configured detection…
JunRuiLee Jun 30, 2024
a97c2bb
[FLINK-33192][runtime] Fix Memory Leak in WindowOperator due to Impro…
kartikeypant Jul 7, 2024
040343f
[FLINK-35750][runtime/metrics] Fix that the latency marker metrics ar…
RocMarshal Jul 4, 2024
0cb0ba3
[hotfix] Fix the broken link of standalone deployment
Zakelly Jul 8, 2024
3693d07
[FLINK-35786] Fix NPE BlobServer / shutdownHook
rkhachatryan Jul 8, 2024
ab7d136
[FLINK-33730][doc] Update the Flink upgrade savepoint compatibility t…
1996fanrui Jul 10, 2024
3992539
[hotfix] Set correct available connector version numbers
MartijnVisser Jul 16, 2024
4070e46
[hotfix] Set latest available connector version for Opensearch
MartijnVisser Jul 16, 2024
f761f25
[hotfix] Set Opensearch connector version to v1.2
MartijnVisser Jul 16, 2024
78ba7c9
[FLINK-35832][Table SQL / Planner] Fix IFNULL function returns incorr…
dylanhz Jul 19, 2024
562a53f
[FLINK-35318][table-planner] Use UTC time zone for TIMESTAMP_LTZ type…
lshangq Jul 24, 2024
24732ca
[FLINK-35974][e2e] Use docker compose v2 for E2E tests
PatrickRen Aug 6, 2024
08649fd
[FLINK-35885][table] Prohibit advancing the progress of processing ti…
xuyangzhong Aug 9, 2024
81de170
[FLINK-36000][table-planner] Fix DynamicTableSink#Context's getTarget…
lincoln-lil Aug 9, 2024
9c3c828
[FLINK-35935][table-planner] Fix RTAS not supporting LIMIT
xuyangzhong Aug 15, 2024
204db68
[FLINK-36004] Deep copy the BinaryArrayData in ArrayDataSerializer#co…
xuyangzhong Aug 16, 2024
f10d5e3
[hotfix] Refactor SourceOperatorSlitWatermarkAlignmentTest and suppor…
pnowojski Aug 5, 2024
7582833
[hotfix][test] Do not add three splits with the same splitId in testM…
pnowojski Aug 16, 2024
cc91a02
[FLINK-35886][task] Define RelativeClock interface
pnowojski Aug 5, 2024
7cd9476
[FLINK-35886][task] Support markStart and markEnd listeners in TimerG…
pnowojski Aug 6, 2024
9ecc8c7
[FLINK-35886][task] Implement PausableRelativeClock
pnowojski Aug 5, 2024
0637e96
[FLINK-35886][task] Use RelativeClock in WatermarksWithIdleness
pnowojski Aug 5, 2024
25250a4
[FLINK-35886][task] Expose Clock from ProcessingTimeService
pnowojski Aug 9, 2024
dedd467
[FLINK-35886][task] Hide backpressure from idleness detection in Time…
pnowojski Aug 6, 2024
74d47ef
[FLINK-35886][task] Hide backpressure and watermark alignment from id…
pnowojski Aug 5, 2024
70b0b69
[FLINK-35886][task] Hide backpressure from idleness detection in Wate…
pnowojski Aug 9, 2024
45a2e04
[FLINK-35886][source] Do not track already finished splits in waterma…
pnowojski Aug 14, 2024
5da82f8
[FLINK-35886][source] Exclude japi checks for the API changes
pnowojski Aug 20, 2024
53ce107
[FLINK-35482][parquet][test] Fix timezone handling in ParquetInt64Tim…
xjmdoo Aug 23, 2024
e2ac98a
(1.19 and 1.20 only) fixup! [FLINK-35886][task] Use RelativeClock in …
pnowojski Aug 27, 2024
84aaa7c
[FLINK-36116] Update Javadoc plugin. This closes #25265
MartijnVisser Aug 29, 2024
3d1c416
[FLINK-36189] Skip NPM build during Javadocs generation
MartijnVisser Aug 30, 2024
5e6307b
[hotfix] Add missing backslash to skip webui build during Javadoc gen…
MartijnVisser Aug 30, 2024
194df6c
[FLINK-36191][tests] FsMergingCheckpointStorageLocationTest generates…
snuyanzin Sep 4, 2024
67643bc
[hotfix] Remove unused code in InstantiationUtil
dawidwys Sep 19, 2024
513ed95
[FLINK-36318] Fix deserializing from 1.18 savepoint with RAW<MAP...> …
dawidwys Sep 18, 2024
98f1349
[FLINK-35764][runtime/metrics] Fix TimerGauge when calling update dur…
auroflow Sep 18, 2024
88d162a
[FLINK-36260][metrics] Fix numBytesInLocal and numBuffersInLocal bein…
pnowojski Sep 30, 2024
37c3979
[FLINK-36420][Formats/Avro] Bump avro from 1.11.3 to 1.11.4
dannycranmer Oct 3, 2024
117a219
[FLINK-30899][connector/filesystem] Fix FileSystemTableSource incorre…
mateczagany Oct 12, 2024
61cd5f4
[FLINK-35833][clients] Skip trying to create parents for "user.artifa…
ferenc-csaky Oct 14, 2024
10ac763
[FLINK-36405][runtime] Fix startup issues due to Hive delegation toke…
zhengchenyu Oct 15, 2024
2c0df7f
[FLINK-35109] Bump kafka connector version in doc
AHeise Oct 16, 2024
e6b1884
[1.19][FLINK-36511] Prevent StackOverflow in FlinkSecurityManager
zentol Oct 11, 2024
9d1110b
[FLINK-36533][runtime] Fix detecting bind failure in case of Netty EP…
ferenc-csaky Oct 17, 2024
8c13611
[FLINK-36421][fs][checkpoint] Sync outputStream before returning hand…
Planet-X Oct 18, 2024
21f79d1
[FLINK-36530][state] Fix S3 performance issue with uncompressed state…
gaborgsomogyi Oct 18, 2024
638140a
[FLINK-36591] Remove `flink-contrib`
MartijnVisser Oct 22, 2024
842cd33
[docs] Update Java 17 compatibility docs
ferenc-csaky Oct 26, 2024
d7bd49a
[FLINK-36571][web] Fix issue to allow Busy and Backpressure numbers o…
hlteoh37 Oct 18, 2024
de44f60
[FLINK-36510][rpc] Bump Pekko to 1.1.2, remove Netty 3
gracegrimwood Nov 4, 2024
5b4914b
[FLINK-36417][table] Add support for hints in WatermarkAssigner
snuyanzin Nov 8, 2024
9a8cb75
[FLINK-36289][Connectors/Prometheus][docs] Integrate Prometheus conne…
hlteoh37 Nov 8, 2024
6cad12a
[FLINK-36668][docs] Update AWS docs for v5.0
hlteoh37 Nov 11, 2024
dcb56da
[hotfix] Fix UnifiedSinkMigrationITCase
AHeise Sep 20, 2024
bfd9b9c
[FLINK-25920] Straighten EOI handling in CommittableCollector
AHeise Sep 5, 2024
0e3b45c
[FLINK-25920] Improve sink test assertions
AHeise Sep 5, 2024
f3a33a5
[FLINK-25920] Only process complete batches of committables
AHeise Sep 11, 2024
4934ef8
[FLINK-25920] Refactor & Revise SinkWriterOperatorTestBase
AHeise Sep 10, 2024
054e20e
[FLINK-25920] Handle duplicate EOI in Sink
AHeise Sep 5, 2024
ff5e96f
[FLINK-25920] Improve logging in committable handling of the sink
AHeise Sep 5, 2024
3c968e9
[FLINK-25920] Fix AbstractStreamingWriter sending after EOI
AHeise Sep 15, 2024
de175b4
[FLINK-36287] Migrate SinkITCase to AssertJ
AHeise Sep 16, 2024
a79a649
[FLINK-36287] Disallow UC for inner sink channels
AHeise Sep 16, 2024
1201e9c
[FLINK-35977][docs] Add missing imports in examples in docs
guluo2016 Nov 25, 2024
c70523b
[FLINK-35334][flink-table] Split constructor of generated code if it …
littleeleventhwolf Nov 26, 2024
d917462
[FLINK-36751] Fix PausableRelativeClock does not pause when the sourc…
haishui126 Nov 22, 2024
b86fdf9
[FLINK-35136][docs] Bump HBase connector docs version to v4.0
ferenc-csaky Nov 28, 2024
91f3958
[FLINK-36643][filesystems] Update aws-java-sdk-core to 1.12.779
tomncooper Dec 4, 2024
ba410bc
[FLINK-36368] Do not prematurely merge CommittableManager (#25405)
AHeise Oct 2, 2024
32e9f7c
[FLINK-36379] Refactor sink test assertions
AHeise Oct 2, 2024
ec41c6b
[FLINK-36379] Optimize global committers
AHeise Oct 2, 2024
56cf3b5
[FLINK-36379] Optimize committers with UC disabled
AHeise Oct 4, 2024
91137a3
[FLINK-36788] Fix GlobalCommitter expansion
AHeise Nov 29, 2024
bb04347
[FLINK-36455] Sinks retry synchronously
AHeise Oct 18, 2024
5222a25
[FLINK-36455] Fix PendingCommittable metric in sink
AHeise Oct 23, 2024
ca54ab7
[hotfix][runtime] hasLeadership does not need to be called to protect…
XComp Dec 2, 2024
5bd0477
[hotfix][runtime] JobResultStore#hasJobResultEntryAsync does not need…
XComp Dec 2, 2024
61b1c33
[FLINK-36451][runtime] Makes hasLeadership and confirmLeadership work…
XComp Nov 28, 2024
5c9c45c
[FLINK-35887][core] Fix NPE in TypeExtractor where getSuperclass from…
dylanhz Dec 16, 2024
2eda53a
[FLINK-33117][table][docs] Fix scala example in udfs page (#23439)
CuiYanxiang Dec 17, 2024
ff4243a
[FLINK-36593][runtime] Backport io.airlift:aircompressor upgrade to 0.27
tomncooper Dec 5, 2024
3b334bd
[FLINK-33571][table] Upgrade json-path from 2.7.0 to 2.9.0
tomncooper Nov 26, 2024
b44740b
[FLINK-28091][tests] Replaces ForkJoinPool by TestExecutorExtension
XComp Dec 29, 2024
7dbc646
[FLINK-36941][docs] Update `DATE_FORMAT` Doc and Python Tests
yiyutian1 Jan 8, 2025
1c6540b
[FLINK-37016] ClusterEntrypoint can be closed before initialization
zentol Jan 6, 2025
868f413
[FLINK-37025] Fix generating watermarks in SQL on-periodic (#25921) (…
afedulov Jan 10, 2025
ce44de4
[FLINK-34194] Update CI to Ubuntu 22.04 (Jammy) (#25827)
mehdid93 Jan 3, 2025
1908c77
[FLINK-35721][docs] Fix CAST compatibility table
Jan 9, 2025
e3a65be
[FLINK-35512][tests] Do not depend on the `flink-clients` jar actuall…
SamBarker Jun 13, 2024
60b5cef
[FLINK-36739] Update the NodeJS to v22.11.0 (LTS)
mehdid93 Dec 13, 2024
8485bfb
[FLINK-36689][Runtime/Web Frontend] Update ng-zorro-antd to v18
simplejason Dec 4, 2024
2e9c06d
[FLINK-37108] Use-non terminal savepoint in source/sink suite
AHeise Jan 13, 2025
9bb3960
[FLINK-36740] [WebFrontend] Update frontend dependencies to address v…
mehdid93 Dec 17, 2024
5fe0280
[FLINK-37084][python] Fix TimerRegistration concurrency issue in PyFl…
suez1224 Jan 17, 2025
775fdb9
[FLINK-37168][python] Clean up TimerRegistrationAction in unregistere…
suez1224 Jan 20, 2025
6d4004e
[FLINK-36348][test] Fix the Netty shuffle direct memory test by incre…
Sxnan Sep 27, 2024
1233a25
[FLINK-37183][clients] Fix symbolic links not being followed in "usrlib"
JoeryH Jan 22, 2025
47b10b2
[FLINK-37099][docs] Document memory/performance considerations and co…
ferenc-csaky Jan 23, 2025
3311e57
Revert "[FLINK-36348][test] Fix the Netty shuffle direct memory test …
ferenc-csaky Jan 23, 2025
5ec21ad
[FLINK-37100][tests] Fix `test_netty_shuffle_memory_control.sh` with …
ferenc-csaky Jan 23, 2025
ea72d7f
[FLINK-37196][docs] Use cp to sync local docs
reswqa Jan 24, 2025
af041a2
[FLINK-37205][python] Correct the state cache behavior during bump be…
dianfu Feb 6, 2025
eef910f
[FLINK-34227][runtime] Fixes concurrency issue in JobMaster shutdown …
XComp Feb 6, 2025
216d392
[FLINK-34227][runtime] Fixes IO thread leaking into owner of the sche…
XComp Jan 31, 2025
9e2907d
[FLINK-36549][formats] Fix using the ignore-parse-errors parameter in…
Jan 8, 2025
afaafa2
[hotfix] Fix post-release japicmp update script for macOS
afedulov Feb 20, 2025
40250d3
[FLINK-37361][release] Update japicmp configuration post 1.19.2
afedulov Feb 20, 2025
c680484
[hotfix][docs] Update docs to the latest 1.19 version
afedulov Feb 21, 2025
233e77e
[FLINK-37505][python] Add pyflink YAML based config support
gaborgsomogyi Mar 20, 2025
f258a33
[FLINK-20092] Bump maven-shade-plugin to 3.5.3 and maven-remote-resou…
snuyanzin Oct 8, 2024
315f54e
[FLINK-36695][Formats] Bump Parquet dependency to 1.14.4
MartijnVisser Jan 17, 2025
1c195b0
[FLINK-37609][format] Bump parquet to 1.15.1
snuyanzin Apr 4, 2025
1c6ea6b
[FLINK-37664][docs] Integrate Kudu connector docs
ferenc-csaky Apr 12, 2025
e41211d
[FLINK-37197][docs] Update MongoDB docs for 2.0.0 release
Jiabao-Sun Apr 18, 2025
6989c1e
[hotfix] Use jdbc connector v3.3 in docs (#26494)
ruanhang1993 Apr 22, 2025
f869ae8
[FLINK-37605][runtime] Clarify contract of endInput
AHeise Apr 9, 2025
ad4857e
[FLINK-37605][runtime] Infer checkpoint id on endInput in sink
AHeise Apr 3, 2025
0d7cbc1
[BP-1.19][FLINK-37760][format] Bump parquet from 1.15.1 to 1.15.2
mbalassi May 8, 2025
92b0e80
[FLINK-37783] Auto-disable buffer debloating for hybrid shuffle.
dmvk May 13, 2025
62f6c0f
[FLINK-37803][table] Fix SQL serialization when using LocalTime value…
autophagy May 15, 2025
8348f7d
[FLINK-33977][runtime] Support minimize TM number during downscaling …
RocMarshal May 15, 2025
e9ff7bd
[FLINK-37820][table-planner] Support `AsyncScalarFunction` registrati…
ferenc-csaky May 27, 2025
0b1b88b
[FLINK-34487][ci] Adds Python Wheels nightly GHA workflow
morazow Mar 1, 2024
ecbacfd
[FLINK-34582] Updates cibuildwheel to support cpython 3.11 wheel package
morazow May 23, 2024
858008f
[FLINK-37804][python][build] Fix build mac wheels error on Python3.8 …
HuangXingBo May 23, 2025
278782e
[hotfix] Bump PyFlink grpcio package to fix build
ferenc-csaky May 29, 2025
99c4055
[hotfix] Adapt docs and checks to bumped grpcio version
ferenc-csaky May 29, 2025
b55bba0
[FLINK-37870][checkpoint] Fix the bug that unaligned checkpoint is di…
1996fanrui Jun 3, 2025
aa277c2
[FLINK-37833] [table-runtime] Fix BatchExecExchange codegen for BINAR…
venkata91 Jun 11, 2025
5951536
[hotfix] Exclude numpy 2.3.0 in PyFlink, cause it fails wheel build
ferenc-csaky Jun 12, 2025
15c5517
[FLINK-37946][backport][doc] fix sql syntax of page Table API & SQL E…
slankka Jun 17, 2025
dd865ac
[hotfix][docs] Update docs to the latest 1.19 version
ferenc-csaky Jul 10, 2025
e40bdbd
[FLINK-38092][release] Bump japicmp configuration post 1.19.3
ferenc-csaky Jul 15, 2025
e92ba2d
[FLINK-38143][python] Fix pyflink flat YAML based config support
gaborgsomogyi Jul 26, 2025
4ee1a82
[FLINK-38370] Ensure CommitterOperator commits all pending committabl…
mxm Sep 22, 2025
914c1a4
[FLINK-35556] Fix constant in RocksDBSharedResourcesFactory
rkhachatryan Oct 22, 2025
9ecbcad
[FLINK-35556] Harden RocksDBSharedResourcesFactoryTest
rkhachatryan Oct 22, 2025
16a9d2f
[FLINK-38486] Harden shutdown of system UDFs
AHeise Oct 8, 2025
bd916bd
[FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when ch…
Zakelly Oct 31, 2025
9c2c431
bruh
Jan 29, 2026
6f29508
python version in cfg
Jan 29, 2026
6e2582e
bruh
Jan 29, 2026
0e3f9fd
more setup.py stuff
Jan 29, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
The diff you're trying to view is too large. We only load the first 3000 changed files.
2 changes: 1 addition & 1 deletion .github/PULL_REQUEST_TEMPLATE.md
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@

## Verifying this change

Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing
Please make sure both new and modified tests in this PR follow [the conventions for tests defined in our code quality guide](https://flink.apache.org/how-to-contribute/code-style-and-quality-common/#7-testing).

*(Please pick either of the following options)*

Expand Down
96 changes: 96 additions & 0 deletions .github/actions/job_init/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,96 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
---
name: "Initializes the job"
description: "Does all the necessary steps to set up the job"
inputs:
jdk_version:
description: "The JDK version that's supposed to be used."
required: true
maven_repo_folder:
description: "The location of the local Maven repository (not setting this parameter will omit the caching of Maven artifacts)."
required: false
default: ""
source_directory:
description: "Specifies the directory from which the code should be moved from (needed for containerized runs; not setting this parameter will omit moving the checkout)."
required: false
default: ""
target_directory:
description: "Specifies the directory to which the code should be moved to (needed for containerized runs; not setting this parameter will omit moving the checkout)."
required: false
default: ""
runs:
using: "composite"
steps:
- name: "Initializes GHA_PIPELINE_START_TIME with the job's start time"
shell: bash
run: |
job_start_time="$(date --rfc-3339=seconds)"
echo "GHA_PIPELINE_START_TIME=${job_start_time}" >> "${GITHUB_ENV}"
echo "The job's start time is set to ${job_start_time}."

- name: "Pre-cleanup Disk Info"
shell: bash
run: df -h

- name: "Delete unused binaries"
shell: bash
run: |
# inspired by https://github.com/easimon/maximize-build-space
for label_with_path in \
"Android SDK:/usr/local/lib/android" \
"CodeQL:/opt/hostedtoolcache/CodeQL" \
".NET:/usr/share/dotnet"; do
dependency_name="$(echo "${label_with_path}" | cut -d: -f1)"
dependency_path="$(echo "${label_with_path}" | cut -d: -f2)"

if [ -d "${dependency_path}" ]; then
echo "[INFO] Deleting binaries of ${dependency_name} in ${dependency_path}."
sudo rm -rf "${dependency_path}"
df -h
else
echo "[INFO] The directory '${dependency_path}' doesn't exist. ${dependency_name} won't be removed."
fi
done

- name: "Set JDK version to ${{ inputs.jdk_version }}"
shell: bash
run: |
echo "JAVA_HOME=$JAVA_HOME_${{ inputs.jdk_version }}_X64" >> "${GITHUB_ENV}"
echo "PATH=$JAVA_HOME_${{ inputs.jdk_version }}_X64/bin:$PATH" >> "${GITHUB_ENV}"

- name: "Setup Maven package cache"
if: ${{ inputs.maven_repo_folder != '' }}
uses: actions/cache@v4
with:
path: ${{ inputs.maven_repo_folder }}
key: ${{ runner.os }}-maven-${{ hashFiles('**/pom.xml') }}
restore-keys: ${{ runner.os }}-maven

- name: "Moves checkout content from ${{ inputs.source_directory }} to ${{ inputs.target_directory }}."
if: ${{ inputs.source_directory != '' && inputs.target_directory != '' }}
shell: bash
run: |
mkdir -p ${{ inputs.target_directory }}

# .scalafmt.conf is needed for Scala format checks
# .mvn is needed to make the Maven wrapper accessible in test runs
mv ${{ inputs.source_directory }}/* \
${{ inputs.source_directory }}/.scalafmt.conf \
${{ inputs.source_directory }}/.mvn \
${{ inputs.target_directory }}
42 changes: 42 additions & 0 deletions .github/actions/run_mvn/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
---
name: "Runs Maven Command"
description: "Executes Flink's Maven wrapper with the passed Maven parameters."
inputs:
working_directory:
description: "The directory under which the Maven command should be executed."
default: "${{ github.workspace }}"
maven-parameters:
description: "Any parameters of the Maven command."
default: ""
env:
description: "Any environment-specifics that are meant to be available in the context of the call."
default: ""
runs:
using: "composite"
steps:
- name: "Runs Maven Command"
working-directory: "${{ inputs.working_directory }}"
shell: bash
run: |
# errexit needs to be disabled explicitly here because maven-utils.sh handles the error if a mirror is not available
set +o errexit

${{ inputs.env }} source "./tools/ci/maven-utils.sh"
run_mvn ${{ inputs.maven-parameters }}
42 changes: 42 additions & 0 deletions .github/actions/stringify/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
---
name: "Stringify"
description: "Stringifies the given input value."
inputs:
value:
description: "Input value to stringify."
required: true
outputs:
stringified_value:
description: "Stringified output value."
value: ${{ steps.stringify-step.outputs.stringified_value }}
runs:
using: "composite"
steps:
- name: "Stringify '${{ inputs.value }}'"
id: stringify-step
shell: bash
run: |
# adds a stringified version of the workflow name that can be used for generating unique build artifact names within a composite workflow
# - replaces any special characters (except for underscores and dots) with dashes
# - makes the entire string lowercase
# - condenses multiple dashes into a single one
# - removes leading and following dashes
stringified_value=$(echo "${{ inputs.value }}" | tr -C '[:alnum:]._' '-' | tr '[:upper:]' '[:lower:]' | sed -e 's/--*/-/g' -e 's/^-*//g' -e 's/-*$//g')
echo "stringified_value=${stringified_value}" >> $GITHUB_OUTPUT
40 changes: 40 additions & 0 deletions .github/workflows/ci.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,40 @@
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

# This workflow is meant for as a basic CI run covering the most-important features
# and default Java version. It is meant to run before a PullRequest is merged.

name: "Flink CI (beta)"

on:
push:
workflow_dispatch:

permissions: read-all

jobs:
pre-compile-checks:
name: "Pre-compile Checks"
uses: ./.github/workflows/template.pre-compile-checks.yml
ci:
name: "Default (Java 8)"
uses: ./.github/workflows/template.flink-ci.yml
with:
environment: 'PROFILE="-Dinclude_hadoop_aws"'
jdk_version: 8
secrets:
s3_bucket: ${{ secrets.IT_CASE_S3_BUCKET }}
s3_access_key: ${{ secrets.IT_CASE_S3_ACCESS_KEY }}
s3_secret_key: ${{ secrets.IT_CASE_S3_SECRET_KEY }}
23 changes: 12 additions & 11 deletions .github/workflows/docs.sh
Original file line number Diff line number Diff line change
Expand Up @@ -22,19 +22,20 @@ mvn --version
java -version
javadoc -J-version

# setup hugo
HUGO_REPO=https://github.com/gohugoio/hugo/releases/download/v0.110.0/hugo_extended_0.110.0_Linux-64bit.tar.gz
HUGO_ARTIFACT=hugo_extended_0.110.0_Linux-64bit.tar.gz
if ! curl --fail -OL $HUGO_REPO ; then
echo "Failed to download Hugo binary"
exit 1
fi
tar -zxvf $HUGO_ARTIFACT -C /usr/local/bin
# workaround for a git security patch
git config --global --add safe.directory /root/flink
git submodule update --init --recursive
# Setup the external documentation modules

cd docs

# setup hugo
source setup_hugo.sh

# Setup the external documentation modules
source setup_docs.sh

cd ..

# Build the docs
hugo --source docs

Expand All @@ -51,8 +52,8 @@ mvn clean install -B -DskipTests -Dfast -Pskip-webui-build
# build java/scala docs
mkdir -p docs/target/api
mvn javadoc:aggregate -B \
-DadditionalJOption="-Xdoclint:none --allow-script-in-comments" \
-Dmaven.javadoc.failOnError=false \
-Pskip-webui-build \
-Dmaven.javadoc.failOnError=true \
-Dcheckstyle.skip=true \
-Dspotless.check.skip=true \
-Denforcer.skip=true \
Expand Down
12 changes: 6 additions & 6 deletions .github/workflows/docs.yml
Original file line number Diff line number Diff line change
Expand Up @@ -28,9 +28,9 @@ jobs:
matrix:
branch:
- master
- release-1.16
- release-1.15
- release-1.14
- release-1.19
- release-1.18
- release-1.17
steps:
- uses: actions/checkout@v3
with:
Expand All @@ -42,13 +42,13 @@ jobs:
echo "flink_branch=${currentBranch}" >> ${GITHUB_ENV}

if [ "${currentBranch}" = "master" ]; then
echo "flink_alias=release-1.17" >> ${GITHUB_ENV}
elif [ "${currentBranch}" = "release-1.16" ]; then
echo "flink_alias=release-1.20" >> ${GITHUB_ENV}
elif [ "${currentBranch}" = "release-1.19" ]; then
echo "flink_alias=stable" >> ${GITHUB_ENV}
fi
- name: Build documentation
run: |
docker run --rm --volume "$PWD:/root/flink" chesnay/flink-ci:java_8_11 bash -c "cd /root/flink && ./.github/workflows/docs.sh"
docker run --rm --volume "$PWD:/root/flink" chesnay/flink-ci:java_8_11_17_21_maven_386_jammy bash -c "cd /root/flink && ./.github/workflows/docs.sh"
- name: Upload documentation
uses: burnett01/rsync-deployments@5.2
with:
Expand Down
45 changes: 45 additions & 0 deletions .github/workflows/nightly-trigger.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,45 @@
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

# This workflow is meant as an extended CI run that includes certain features that shall be tested
# and JDK versions that are supported but not considered default.

name: "Nightly trigger (beta)"

on:
schedule:
- cron: '0 2 * * *'

jobs:
Trigger:
permissions:
actions: write
strategy:
matrix:
branch:
- master
- release-1.18
runs-on: ubuntu-latest
steps:
- name: Trigger Workflow
uses: actions/github-script@v7
with:
script: |
github.rest.actions.createWorkflowDispatch({
owner: context.repo.owner,
repo: context.repo.repo,
workflow_id: 'nightly.yml',
ref: '${{ matrix.branch }}'
})
Loading