Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1475 commits
Select commit Hold shift + click to select a range
bfceafd
[hotfix][docs][python] Fix the invalid url in state.md
dianfu Apr 21, 2021
a012400
[hotfix][table-planner-blink] Fix bug for window join: plan is wrong …
beyond1920 Apr 21, 2021
17bc2d0
[hotfix][docs] Fix the invalid urls in iterations.md
dianfu Apr 21, 2021
a3437d5
[FLINK-16384][table][sql-client] Support 'SHOW CREATE TABLE' statement
fsk119 Jul 24, 2020
ae4f20e
[FLINK-16384][table][sql-client] Improve implementation of 'SHOW CREA…
LadyForest Apr 12, 2021
3fa191b
[hotfix][docs][python] Add missing pages for PyFlink documentation
dianfu Apr 21, 2021
8b2fada
[FLINK-22348][python] Fix DataStream.execute_and_collect which doesn'…
HuangXingBo Apr 19, 2021
48b8018
[FLINK-22350][python][docs] Add documentation for user-defined window…
HuangXingBo Apr 21, 2021
d304373
[FLINK-22354][table-planner] Fix the timestamp function return value …
leonardBang Apr 21, 2021
f4f0fb5
[FLINK-22354][table] Remove the strict precision check of time attrib…
leonardBang Apr 21, 2021
3a2d825
[FLINK-22354][table] Fix TIME field display in sql-client
leonardBang Apr 21, 2021
4ad4e87
[hotfix] Set default value of resource-stabilization-timeout to 10s
tillrohrmann Apr 21, 2021
02e7db8
[FLINK-22345][coordination] Remove incorrect assertion in scheduler
StephanEwen Apr 21, 2021
84ce237
[hotfix][table-planner-blink] Fix the incorrect ExecNode's id in test…
godfreyhe Apr 21, 2021
3fc77ad
[FLINK-20654] Fix double recycling of Buffers in case of an exception…
pnowojski Apr 21, 2021
27efcd2
[hotfix] Regenerate html configuration after 4be9aff3eccb3808df1f10ef…
rmetzger Apr 22, 2021
75d27d1
[FLINK-22001] Fix forwarding of JobMaster exceptions to user
tillrohrmann Apr 15, 2021
bdc4c10
[FLINK-22396][legal] Remove unnecessary entries from sql hbase connec…
dawidwys Apr 21, 2021
a493a6b
[FLINK-22396][hbase] Remove unnecessary entries from shaded plugin co…
dawidwys Apr 21, 2021
c54a15d
[FLINK-19980][table-common] Add a ChangelogMode.upsert() shortcut
twalthr Apr 19, 2021
923e161
[FLINK-19980][table-common] Add a ChangelogMode.all() shortcut
twalthr Apr 20, 2021
4b5e8cc
[FLINK-19980][table] Support fromChangelogStream/toChangelogStream
twalthr Apr 13, 2021
fa0be65
[hotfix][table-api] Properly deprecate StreamTableEnvironment.execute
twalthr Apr 22, 2021
e3cfa40
[FLINK-22345][coordination] Catch pre-mature state restore for Operat…
StephanEwen Apr 22, 2021
04ce600
[FLINK-22168][table] Partition insert can not work with union all
JingsongLi Apr 22, 2021
0270244
[FLINK-22341][hive] Fix describe table for hive dialect
lirui-apache Apr 22, 2021
0d29b23
[FLINK-22000][io] Set a default character set in InputStreamReader
dbgp2021 Apr 22, 2021
4ab8cea
[FLINK-22385][runtime] Fix type cast error in NetworkBufferPool
Apr 21, 2021
58a7c80
[FLINK-22085][tests] Update TestUtils::tryExecute() to cancel the job…
lindong28 Apr 21, 2021
59cb0b4
[hotfix][runtime] fix typo in ResourceProfile
simenliuxing Apr 22, 2021
68e6316
[hotfix] Fix typo in TestingTaskManagerResourceInfoProvider
KarmaGYZ Apr 19, 2021
7407891
[FLINK-21174][coordination] Optimize the performance of DefaultResour…
KarmaGYZ Apr 20, 2021
223dd2b
[FLINK-22177][docs][table] Add documentation for time functions and t…
leonardBang Apr 19, 2021
9c3613f
[FLINK-22398][runtime] Fix incorrect comments in InputOutputFormatVer…
kanata163 Apr 23, 2021
4d290d5
[FLINK-22384][docs] Fix typos in Chinese "fault-tolerance/state" pag…
simenliuxing Apr 23, 2021
a0512ef
[FLINK-21903][docs-zh] Translate "Importing Flink into an IDE" page i…
Apr 22, 2021
ef03c9d
[FLINK-21659][coordination] Properly expose checkpoint settings for i…
zentol Apr 23, 2021
8af7391
[hotfix][tests] Remove unnecessary field
zentol Apr 21, 2021
862ae89
[FLINK-20723][tests] Ignore expected exception when retrying
zentol Apr 21, 2021
d7bfb39
[FLINK-20723][tests] Allow retries to be defined per class
zentol Apr 21, 2021
2cbaf4e
[FLINK-20723][cassandra][tests] Retry on NoHostAvailableException
zentol Apr 21, 2021
bcea572
[hotfix][docs] Fix typo in jdbc execution options
cemremengu Apr 23, 2021
6a7a1d9
[hotfix][docs] Fix typos
paul8263 Apr 23, 2021
a4dcd91
[FLINK-12351][DataStream] Fix AsyncWaitOperator to deep copy StreamEl…
wuchong Apr 24, 2021
aea79b9
[FLINK-22119][hive][doc] Update document for hive dialect
lirui-apache Apr 25, 2021
a886497
[FLINK-20720][docs][python] Add documentation about output types for …
dianfu Apr 23, 2021
0f8adc0
[FLINK-20720][python][docs] Add documentation for ProcessFunction in …
dianfu Apr 23, 2021
6071f96
[FLINK-22294][hive] Hive reading fail when getting file numbers on di…
zuston Apr 15, 2021
bddcbc4
[FLINK-22356][hive][filesystem] Fix partition-time commit failure whe…
leonardBang Apr 23, 2021
e676442
[FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work wit…
StephanEwen Apr 23, 2021
14ae6fe
[hotfix][tests] Remove timout rule from KafkaTableTestBase
StephanEwen Apr 25, 2021
033cdea
[FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…
cshuo Apr 26, 2021
b2e65a4
[FLINK-21923][table-planner-blink] Fix ClassCastException in SplitAgg…
Tartarus0zm Apr 6, 2021
362f4ae
[FLINK-19449][doc] Fix wrong document for lead and lag
JingsongLi Apr 26, 2021
9b9d4f0
[FLINK-19449][table] Introduce LinkedListSerializer
JingsongLi Apr 26, 2021
bf8f998
[FLINK-19449][table] Pass isBounded to AggFunctionFactory
JingsongLi Apr 26, 2021
075b0b2
[FLINK-19449][table-planner] LEAD/LAG cannot work correctly in stream…
JingsongLi Apr 26, 2021
664b29d
[FLINK-18199][doc] translate FileSystem SQL Connector page into chinese
michaelli916 Apr 26, 2021
f9d3245
[FLINK-22444][docs] Drop async checkpoint description of state backen…
Myasuka Apr 25, 2021
e63c342
[FLINK-22445][python][docs] Add documentation for row-based operations
HuangXingBo Apr 26, 2021
1f31505
[FLINK-22463][table-planner-blink] Fix IllegalArgumentException in Wi…
godfreyhe Apr 26, 2021
fb31e28
[hotfix] Do not use ExecutorService.submit since it can swallow excep…
tillrohrmann Apr 16, 2021
6be9668
[FLINK-22431] Add information when and why the AdaptiveScheduler rest…
tillrohrmann Apr 23, 2021
b88b290
[hotfix] Add debug logging to the states of the AdaptiveScheduler
tillrohrmann Apr 23, 2021
df301ed
[hotfix] Harden against FLINK-21376 by checking for null failure cause
tillrohrmann Apr 23, 2021
394c69c
[FLINK-22301][runtime] Statebackend and CheckpointStorage type is not…
SteNicholas Apr 23, 2021
9fcff08
[hotfix][network] Remove unused method BufferPool#getSubpartitionBuff…
pnowojski Apr 23, 2021
19ca330
[FLINK-22424][network] Prevent releasing PipelinedSubpartition while …
pnowojski Apr 23, 2021
e905db9
[FLINK-22085][tests] Remove timeouts from KafkaSourceLegacyITCase
dawidwys Apr 26, 2021
33d98e1
[FLINK-19606][table-runtime-blink] Refactor utility class JoinConditi…
beyond1920 Apr 27, 2021
4c9ecac
[hotfix][coordination] Add log for slot allocation in FineGrainedSlot…
KarmaGYZ Apr 25, 2021
6236473
[FLINK-22074][runtime][test] Harden FineGrainedSlotManagerTest#testRe…
KarmaGYZ Apr 25, 2021
bef98cf
[FLINK-22470][python] Make sure that the root cause of the exception …
dianfu Apr 26, 2021
c8f4733
[hotfix][docs] Removed duplicate word
mans2singh Apr 27, 2021
0177a27
[hotfix][python][docs] Add missing debugging page for PyFlink documen…
HuangXingBo Apr 27, 2021
42b9d73
[FLINK-22136][e2e] Odd parallelism for resume_externalized_checkpoint…
akalash Apr 26, 2021
7973bbc
[FLINK-22136][e2e] Exception instead of system out is used for errors…
akalash Apr 26, 2021
0fc09d2
[hotfix][python][docs] Clarify python.files option (#15779)
t0t07 Apr 27, 2021
bed991f
[FLINK-22476][docs] Extend the description of the config option `exec…
tony810430 Apr 26, 2021
981bed0
[FLINK-18952][python][docs] Add "10 minutes to DataStream API" docume…
dianfu Apr 26, 2021
47ac28b
[hotfix][table-planner-blink] Fix unstable itcase in OverAggregateITC…
beyond1920 Apr 27, 2021
fb13a27
[FLINK-22378][table] Derive type of SOURCE_WATERMARK() from time attr…
twalthr Apr 22, 2021
9085da4
[hotfix][python][docs] Fix compile issues
dianfu Apr 27, 2021
fa19ba2
[FLINK-22469][runtime-web] Fix NoSuchFileException in HistoryServer
gaborgsomogyi Apr 26, 2021
334dae6
[FLINK-22289] Update JDBC XA sink docs
curcur Apr 27, 2021
821a01d
[FLINK-22428][docs][table] Translate "Timezone" page into Chinese (#1…
hackergin Apr 28, 2021
ff6ef3c
[FLINK-22471][connector-elasticsearch] Remove commads from list
Airblader Apr 26, 2021
64c6bb9
[FLINK-22471][connector-elasticsearch] Do not repeat default value
Airblader Apr 26, 2021
ba6bc7c
[FLINK-22471][connector-jdbc] Improve spelling and avoid repeating de…
Airblader Apr 26, 2021
3a435cd
[FLINK-22471][connector-kafka] Use proper Description for connector o…
Airblader Apr 26, 2021
c4889f1
[FLINK-22471][connector-kinesis] Remove required from ConfigOption
Airblader Apr 26, 2021
e77dfdf
[FLINK-22471][connector-kinesis] Use proper Description for connector…
Airblader Apr 26, 2021
0a9fb05
[FLINK-22471][table-runtime-blink] Remove repetition of default values
Airblader Apr 26, 2021
ae9a3a7
[FLINK-22471][table-runtime-blink] Use proper Description for connect…
Airblader Apr 26, 2021
23ae97a
[hotfix][python][docs] Fix flat_aggregate example in Python Doc
HuangXingBo Apr 28, 2021
42f9d6e
[hotfix][python][docs] Add documentation to remind users to bundle Py…
t0t07 Apr 28, 2021
86da866
[FLINK-17783][orc] Add array,map,row types support for orc row writer
Apr 25, 2021
778483a
[FLINK-22489][webui] Fix displaying individual subtasks backpressure-…
pnowojski Apr 27, 2021
11f5abc
[FLINK-22479[Kinesis][Consumer] Potential lock-up under error condition
dannycranmer Apr 26, 2021
538d1d9
[FLINK-22304][table] Refactor some interfaces for TVF based window to…
Apr 15, 2021
d5ce949
[hotfix][python][docs] Fix python.archives docs
t0t07 Apr 27, 2021
c593209
[FLINK-20086][python][docs] Add documentation about how to override o…
t0t07 Apr 28, 2021
56c61dd
[FLINK-22438][metrics] Add numRecordsOut metric for Async IO
Apr 28, 2021
26da1bf
[FLINK-22373][docs] Add Flink 1.13 release notes
dawidwys Apr 20, 2021
0ddda1b
[FLINK-22495][docs] Add Reactive Mode section to K8s
rmetzger Apr 28, 2021
79a521e
[FLINK-21967] Add documentation on the operation of blocking shuffle
gaoyunhaii Apr 20, 2021
9a94509
[FLINK-22232][tests] Add UnalignedCheckpointsStressITCase
pnowojski Apr 7, 2021
72cec55
[FLINK-22232][network] Add task name to output recovery tracing.
Apr 17, 2021
b4e8cd3
[FLINK-22232][network] Add task name to persist tracing.
Apr 17, 2021
082f127
[FLINK-22232][network] More logging of network stack.
Apr 21, 2021
115101c
[FLINK-22109][table-planner-blink] Resolve misleading exception messa…
Apr 8, 2021
16c2e46
[FLINK-22426][table] Fix several shortcomings that prevent schema exp…
twalthr Apr 23, 2021
00584d3
[FLINK-22493] Increase test stability in AdaptiveSchedulerITCase.
rmetzger Apr 29, 2021
89c6c03
[FLINK-22510][core] Format durations with highest unit
Airblader Apr 29, 2021
bf7b58d
[FLINK-22250][sql-parser] Add missing 'createSystemFunctionOnlySuppor…
chaozwn Apr 30, 2021
4eae089
[FLINK-22524][docs] Fix the incorrect Java groupBy clause in Table AP…
Huachao Apr 30, 2021
bf40fa5
[FLINK-22522][table-runtime-blink] BytesHashMap prints many verbose I…
wuchong Apr 30, 2021
b7d5116
[FLINK-22539][python][docs] Restructure the Python dependency managem…
dianfu May 1, 2021
393e3bd
[FLINK-22544][python][docs] Add the missing documentation about the c…
dianfu May 1, 2021
a76e1f8
Update japicmp configuration for 1.13.0
guoweiM May 1, 2021
95390fa
[hotfix][python][docs] Correct a few invalid links and typos in PyFli…
dianfu May 2, 2021
6e3ccd5
[FLINK-22368] Deque channel after releasing on EndOfPartition
rkhachatryan Apr 21, 2021
a1b3fba
[FLINK-14393][webui] Add an option to enable/disable cancel job in we…
fangyuefy Apr 30, 2021
07bf9b8
[FLINK-22323] Fix typo in JobEdge#connecDataSet (#15647)
lqjack May 3, 2021
d895c47
[hotfix][python] Add missing space to exception message
t0t07 May 3, 2021
180ab7e
[hotfix][docs] Fix typo
ChaomingZhangCN May 3, 2021
9253543
[FLINK-22535][runtime] CleanUp is invoked for task even when the task…
akalash Apr 30, 2021
5926c4a
[FLINK-22535][runtime] CleanUp is invoked despite of fail inside of c…
akalash Apr 30, 2021
66dd22c
[FLINK-22432] Update upgrading.md with 1.13.x
dawidwys Apr 23, 2021
baf27ef
[FLINK-22253][docs] Update back pressure monitoring docs with new Web…
pnowojski Apr 29, 2021
368b264
[hotfix][docs] Update unaligned checkpoint docs
pnowojski Apr 29, 2021
5c17f4a
[hotfix][network] Remove redundant word from comment
May 4, 2021
53cf103
[FLINK-21131][webui] Alignment timeout displayed in checkpoint config…
akalash Apr 26, 2021
1554292
[FLINK-22548][network] Remove illegal unsynchronized access to Pipeli…
pnowojski May 4, 2021
f6d93e8
[FLINK-22563][docs] Add migration guide for new StateBackend interfaces
sjwiesman May 4, 2021
ae402bc
[FLINK-22379][runtime] CheckpointCoordinator checks the state of all …
akalash Apr 22, 2021
567c900
[FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause …
lindong28 Apr 27, 2021
cb0d8eb
[FLINK-22442][CEP] Using scala api to change the TimeCharacteristic o…
Apr 24, 2021
56e292b
[FLINK-22573][datastream] Fix AsyncIO calls timeout on completed elem…
May 5, 2021
0790768
[FLINK-22573][datastream] Fix AsyncIO calls timeout on completed elem…
May 5, 2021
ba010e3
[FLINK-22233][table] Fix "constant" typo in PRIMARY KEY exception mes…
wysstartgo May 6, 2021
da421e6
[hotfix][hive] Add an ITCase that checks partition-time commit pretty…
leonardBang Apr 29, 2021
c688bf3
[FLINK-22512][hive] Fix issue of calling current_timestamp with hive …
luoyuxia Apr 30, 2021
14295d2
[FLINK-22362][network] Improve error message when taskmanager can not…
gentlewangyu Apr 20, 2021
cb4efe6
[FLINK-22581][docs] Keyword CATALOG is missing in sql client doc (#15…
youngwookim May 6, 2021
a42d679
[hotfix][docs] Replace local failover with partial failover
tillrohrmann May 6, 2021
2ea188c
[FLINK-22266][hotfix] Do not clean up jobs in AbstractTestBase if the…
dawidwys May 4, 2021
5954122
[hotfix][docs] Fix code tabs for state backend migration
sjwiesman May 6, 2021
5b32d87
[hotfix][docs][python] Fix the example in intro_to_datastream_api.md
dianfu May 7, 2021
9554321
[hotfix][docs][python] Add an overview page for Python UDFs
dianfu May 7, 2021
9283897
[hotfix] Make reactive warning less strong, clarifications
rmetzger May 6, 2021
bb586ed
[hotfix][docs] Re-introduce note about FLINK_CONF_DIR
rmetzger May 6, 2021
c31178d
[hotfix][docs][python] Add introduction about the open method in Pyth…
dianfu May 7, 2021
323c662
[FLINK-21095][ci] Remove legacy slot management profile
zentol May 7, 2021
a1c1846
[FLINK-22406][tests] Add RestClusterClient to MiniClusterWithClientRe…
zentol May 5, 2021
271ac1b
[FLINK-22406][coordination][tests] Stabilize ReactiveModeITCase
zentol Apr 23, 2021
8199f1e
[FLINK-22419][coordination][tests] Rework RpcEndpoint delay tests
zentol Apr 23, 2021
6f86326
[FLINK-22560][build] Move generic filters/transformers into general s…
zentol May 5, 2021
06b3e26
[FLINK-22560][build] Filter maven metadata directory
zentol May 4, 2021
d5622b6
[FLINK-22560][build] Add dedicated name to flink-dist shade-plugin ex…
zentol May 5, 2021
8f3d483
[FLINK-22555][build][python] Exclude leftover jboss files
zentol May 4, 2021
aca4328
[hotfix] Ignore failing test reported in FLINK-22559
rmetzger May 7, 2021
fe4ce45
[hotfix][docs] Fix typo in dependency_management.md
dianfu May 7, 2021
c1b4c0f
[hotfix][docs] Mention new StreamTableEnvironment.fromDataStream in r…
twalthr May 7, 2021
f39af7e
[hotfix][docs] Mention new StreamTableEnvironment.fromDataStream in C…
twalthr May 7, 2021
ce9d642
[FLINK-22505][core] Limit the scale of Resource to 8
KarmaGYZ Apr 30, 2021
89e81c2
[FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and W…
beyond1920 May 8, 2021
963fd5d
[FLINK-22536][runtime] Promote the critical log in FineGrainedSlotMan…
KarmaGYZ May 7, 2021
e6ef269
[FLINK-22355][docs] Fix simple task manager memory model image
Shawn-Hx May 8, 2021
3eef1cb
[FLINK-19606][table-planner] Introduce StreamExecWindowJoin and windo…
beyond1920 May 8, 2021
34acdf1
[hotfix][docs] Correct the examples in Python DataStream API
dianfu May 8, 2021
442dc76
[FLINK-17170][kinesis] Move KinesaliteContainer to flink-connector-ki…
May 4, 2021
49d9092
[FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.
May 4, 2021
420eb6e
[FLINK-21181][runtime] Wait for Invokable cancellation before releasi…
rkhachatryan Apr 27, 2021
625ef0f
[FLINK-22609][runtime] Generalize AllVerticesIterator
RocMarshal May 9, 2021
a8d53cf
[hotfix][docs] Fix image links
mans2singh May 9, 2021
9251286
[FLINK-22525][table-api] Fix gmt format in Flink from GMT-8:00 to GMT…
leonardBang May 10, 2021
1ef7843
[FLINK-22559][table-planner] The consumed DataType of ExecSink should…
leonardBang May 8, 2021
9e1cc0a
[hotfix][core] Remove unused import
paul8263 May 10, 2021
2348420
[FLINK-22537][docs] Add documentation how to interact with DataStream…
twalthr May 3, 2021
e0193ce
[FLINK-22596] Active timeout is not triggered if there were no barriers
dawidwys May 7, 2021
855d2e9
[hotfix][test] Adds -e flag to interpret newline in the right way
XComp May 7, 2021
56a7a11
[FLINK-22566][test] Adds log extraction for the worker nodes
XComp May 7, 2021
fbf84ac
[FLINK-22577][tests] Harden KubernetesLeaderElectionAndRetrievalITCase
tillrohrmann May 6, 2021
6daa30f
[FLINK-22604][table-runtime-blink] Fix NPE on bundle close when task …
lincoln-lil May 10, 2021
464e0d0
[hotfix] Disable broken savepoint tests tracked in FLINK-22067
rmetzger May 10, 2021
1cbc003
[FLINK-22407][build] Bump log4j to 2.24.1
zentol May 10, 2021
3c342c9
[FLINK-22313][table-planner-blink] Redundant CAST in plan when select…
wuchong May 11, 2021
3d20144
[FLINK-22523][table-planner-blink] Window TVF should throw helpful ex…
wuchong May 11, 2021
f667629
[FLINK-22624][runtime] Utilize the remain resource of new pending tas…
KarmaGYZ May 11, 2021
dc45656
[FLINK-22413][WebUI] Hide Checkpointing page for batch jobs
SteNicholas May 11, 2021
15e870d
[FLINK-22364][doc] Translate the page of "Data Sources" to Chinese. (…
Senhongl May 11, 2021
8cac615
[FLINK-22586][table] Improve the precision dedivation for decimal ari…
cshuo May 11, 2021
12010db
[hotfix][e2e] Output and collect the logs for Kubernetes IT cases
wangyang0918 May 7, 2021
35ca4cf
[FLINK-17857][test] Make K8s e2e tests could run on Mac
wangyang0918 Nov 10, 2020
0fcf44e
[hotfix][ci] Use static methods
zentol May 10, 2021
214f936
[FLINK-22556][ci] Extend JarFileChecker to search for traces of incom…
zentol May 10, 2021
3a1b2e1
[FLINK-21700][security] Add an option to disable credential retrieval…
zuston May 12, 2021
3b5f399
[FLINK-22408][sql-parser] Fix SqlDropPartitions unparse Error
aidenma-develop May 11, 2021
62f91de
[FLINK-21469][runtime] Implement advanceToEndOfEventTime for Multiple…
curcur May 10, 2021
0f15bb2
[hotfix][docs] Fix all broken images
Shawn-Hx May 8, 2021
17064da
[hotfix][docs] Fix typo in k8s docs
kbohinski May 10, 2021
ad86adf
[FLINK-22628][docs] Update state_processor_api.md
yangqu May 11, 2021
728cddc
[hotfix] Add missing TestLogger to Kinesis tests
rmetzger May 10, 2021
02d30ac
[FLINK-22574] Adaptive Scheduler: Fix cancellation while in Restartin…
rmetzger May 7, 2021
e5435bb
[FLINK-22640] [datagen] Fix DataGen SQL Connector does not support de…
lincoln-lil May 13, 2021
dc53dce
[FLINK-22534][runtime][yarn] Set delegation token's service name as c…
zuston May 12, 2021
e510b3a
[FLINK-22618][runtime] Fix incorrect free resource metrics of task ma…
paul8263 May 11, 2021
d241759
[FLINK-15064][table-planner-blink] Remove XmlOutput util class in bli…
godfreyhe May 14, 2021
0f51995
[FLINK-19796][table] Explicit casting shoule be made if the type of a…
cshuo May 14, 2021
61e8a92
[FLINK-22475][table-common] Document usage of '#' placeholder in opti…
Airblader May 11, 2021
6be47cc
[FLINK-22475][table-common] Exclude options with '#' placeholder from…
Airblader May 11, 2021
abd3da9
[FLINK-22475][table-api-java-bridge] Add placeholder options for data…
Airblader May 11, 2021
b83e64e
[FLINK-22511][python] Fix the bug of non-composite result type in Pyt…
HuangXingBo Apr 28, 2021
2ef03c4
[[hotfix][docs] Changed argument for toDataStream to Table
mans2singh May 16, 2021
cb4b4d3
[FLINK-22654][sql-parser] Fix SqlCreateTable#toString()/unparse() los…
zjuwangg May 17, 2021
5ff7f73
[FLINK-22658][table] Remove Deprecated util class TableConnectorUtil …
wangxianghu May 17, 2021
6c62561
[FLINK-22592][runtime] numBuffersInLocal is always zero when using un…
SteNicholas May 13, 2021
d76d50c
[FLINK-22400][hive] fix NPE problem when convert flink object for Map
Apr 21, 2021
ab6dc01
[FLINK-22649][python][table-planner-blink] Support StreamExecPythonCa…
HuangXingBo May 13, 2021
4579be7
[FLINK-22502][checkpointing] Don't tolerate checkpoint retrieval fail…
rkhachatryan May 5, 2021
5fab2da
[FLINK-22667][docs] Add missing slash
lys0716 May 17, 2021
d09745a
[FLINK-22650][python][table-planner-blink] Support StreamExecPythonCo…
HuangXingBo May 15, 2021
5eebab4
[FLINK-22652][python][table-planner-blink] Support StreamExecPythonGr…
HuangXingBo May 17, 2021
099a18e
[FLINK-22666][table] Make structured type's fields more lenient durin…
twalthr May 17, 2021
5746385
[hotfix][table-planner-blink] Give more helpful exception for codegen…
twalthr May 17, 2021
80ef986
[FLINK-22620][orc] Drop BatchTableSource OrcTableSource and related c…
twalthr May 10, 2021
06dec01
[FLINK-22651][python][table-planner-blink] Support StreamExecPythonGr…
HuangXingBo May 17, 2021
4d33e85
[FLINK-22653][python][table-planner-blink] Support StreamExecPythonOv…
HuangXingBo May 17, 2021
057f86b
[FLINK-12295][table] Fix comments in MinAggFunction and MaxAggFunction
JingsongLi May 18, 2021
8cf6f84
[FLINK-20695][ha] Clean ha data for job if globally terminated
yittg Apr 12, 2021
0528f84
[FLINK-22067][tests] Wait for vertices to using API
rkhachatryan May 7, 2021
7399bb4
[hotfix][tests] Remove try/catch from SavepointWindowReaderITCase.tes…
rkhachatryan May 10, 2021
ce3631a
[FLINK-22622][parquet] Drop BatchTableSource ParquetTableSource and r…
twalthr May 11, 2021
aa9f474
[hotfix] Ignore failing KinesisITCase traacked in FLINK-22613
rmetzger May 18, 2021
f15d277
[FLINK-19545][e2e] Add e2e test for native Kubernetes HA
wangyang0918 May 8, 2021
1846bed
[FLINK-22656] Fix typos
LeeJiangchuan May 13, 2021
73fcaa1
[hotfix][runtime] Fixes JavaDoc for RetrievableStateStorageHelper
XComp May 11, 2021
15eafd9
[hotfix][runtime] Cleans up unnecessary annotations
XComp May 11, 2021
9d2e2d9
[FLINK-22494][kubernetes] Introduces PossibleInconsistentStateException
XComp May 3, 2021
cc59ad5
[FLINK-22494][ha] Refactors TestingLongStateHandleHelper to operate o…
XComp May 4, 2021
417cf78
[FLINK-22494][ha] Introduces PossibleInconsistentState to StateHandle…
XComp May 4, 2021
e632591
[FLINK-22494][runtime] Refactors CheckpointsCleaner to handle also di…
XComp May 4, 2021
fa0d1dc
[FLINK-22494][runtime] Adds PossibleInconsistentStateException handli…
XComp May 4, 2021
7d2a325
[FLINK-22515][docs] Add documentation for GSR-Flink Integration
LinyuYao1021 May 4, 2021
1a1a729
[FLINK-20487][table-planner-blink] Remove restriction on StreamPhysic…
beyond1920 May 18, 2021
9761019
[FLINK-22623][hbase] Drop BatchTableSource/Sink HBaseTableSource/Sink…
twalthr May 11, 2021
927a21c
[hotfix][hbase] Fix warnings around decimals in HBaseTestBase
twalthr May 18, 2021
79936be
[FLINK-22636][zk] Group job specific zNodes under /jobs zNode
tillrohrmann May 11, 2021
cf3c8b1
[FLINK-22696][tests] Enable Confluent Schema Registry e2e test on jdk 11
fapaul May 18, 2021
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.
5 changes: 4 additions & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -23,9 +23,12 @@ flink-runtime-web/web-dashboard/node/
flink-runtime-web/web-dashboard/node_modules/
flink-runtime-web/web-dashboard/web/
flink-python/dist/
flink-python/apache-flink-libraries/dist/
flink-python/build/
flink-python/apache-flink-libraries/build
flink-python/pyflink.egg-info/
flink-python/apache_flink.egg-info/
flink-python/apache-flink-libraries/apache_flink_libraries.egg-info/
flink-python/docs/_build
flink-python/.tox/
flink-python/dev/download
Expand All @@ -34,12 +37,12 @@ flink-python/dev/log/
flink-python/dev/.stage.txt
flink-python/.eggs/
flink-python/apache-flink-*.dev0/
flink-python/apache-flink-libraries/apache_flink_libraries-*.dev0/
flink-python/**/*.c
flink-python/**/*.so
atlassian-ide-plugin.xml
out/
/docs/api
/docs/content
/docs/.bundle
/docs/.rubydeps
/docs/ruby2/.bundle
Expand Down
3 changes: 3 additions & 0 deletions .gitmodules
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
[submodule "docs/themes/book"]
path = docs/themes/book
url = https://github.com/alex-shpak/hugo-book
14 changes: 4 additions & 10 deletions azure-pipelines.yml
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ resources:
containers:
# Container with Maven 3.2.5, SSL to have the same environment everywhere.
- container: flink-build-container
image: rmetzger/flink-ci:ubuntu-amd64-f009d96
image: rmetzger/flink-ci:ubuntu-amd64-7ac4e28
# On AZP provided machines, set this flag to allow writing coredumps in docker
options: --privileged

Expand All @@ -49,13 +49,16 @@ resources:
variables:
MAVEN_CACHE_FOLDER: $(Pipeline.Workspace)/.m2/repository
E2E_CACHE_FOLDER: $(Pipeline.Workspace)/e2e_cache
E2E_TARBALL_CACHE: $(Pipeline.Workspace)/e2e_artifact_cache
MAVEN_OPTS: '-Dmaven.repo.local=$(MAVEN_CACHE_FOLDER)'
CACHE_KEY: maven | $(Agent.OS) | **/pom.xml, !**/target/**
CACHE_FALLBACK_KEY: maven | $(Agent.OS)
FLINK_ARTIFACT_DIR: $(Pipeline.Workspace)/flink_artifact
SECRET_S3_BUCKET: $[variables.IT_CASE_S3_BUCKET]
SECRET_S3_ACCESS_KEY: $[variables.IT_CASE_S3_ACCESS_KEY]
SECRET_S3_SECRET_KEY: $[variables.IT_CASE_S3_SECRET_KEY]
SECRET_GLUE_SCHEMA_ACCESS_KEY: $[variables.IT_CASE_GLUE_SCHEMA_ACCESS_KEY]
SECRET_GLUE_SCHEMA_SECRET_KEY: $[variables.IT_CASE_GLUE_SCHEMA_SECRET_KEY]


stages:
Expand All @@ -79,16 +82,7 @@ stages:
pool:
vmImage: 'ubuntu-16.04'
steps:
- task: UseRubyVersion@0
inputs:
versionSpec: '= 2.4'
addToPath: true
- script: ./tools/ci/docs.sh
# upload spider.log for debugging
- task: PublishPipelineArtifact@1
inputs:
targetPath: ./docs/spider.log
artifact: spider.log
# CI / Special stage for release, e.g. building PyFlink wheel packages, etc:
- stage: ci_release
displayName: "CI build (release)"
Expand Down
4 changes: 2 additions & 2 deletions docs/.gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
.jekyll-metadata
.jekyll-cache/
.rubydeps/
content/
content_*/
ruby2/.bundle/
ruby2/.rubydeps/
public/
resources/
26 changes: 0 additions & 26 deletions docs/404.md

This file was deleted.

26 changes: 0 additions & 26 deletions docs/404.zh.md

This file was deleted.

35 changes: 0 additions & 35 deletions docs/Gemfile

This file was deleted.

96 changes: 0 additions & 96 deletions docs/Gemfile.lock

This file was deleted.

Loading