Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2294 commits
Select commit Hold shift + click to select a range
9bcad11
[hotfix][docs] Add and update description of local-recovery config op…
KarmaGYZ Dec 2, 2018
0382830
[FLINK-9552][iterations] fix not syncing on checkpoint lock before em…
Oct 30, 2018
156c09c
[FLINK-11123][docs] fix the import of the class is missing in ml quic…
sunjincheng121 Dec 11, 2018
2ab4d41
[FLINK-10743] [runtime] Use 0 processExitCode for ApplicationStatus.C…
uce Oct 31, 2018
bc41b75
[hotfix] [state backend, tests] Certain StateBackendMigrationTestBase…
tzulitai Dec 7, 2018
3b16b4e
[hotfix] [state backends] New namespace serializer in HeapKeyedStateB…
tzulitai Dec 7, 2018
7fe1743
[hotfix] [state backends, tests] Make StateBackendMigrationTestBase m…
tzulitai Dec 8, 2018
b879a49
[FLINK-11094] [rocksdb] Eagerly create meta infos for restored state …
tzulitai Dec 9, 2018
ebc46c5
[FLINK-11094] [state backends] Let meta infos always lazily access re…
tzulitai Dec 9, 2018
97f556e
[FLINK-11094] [state backends] State backends no longer need separate…
tzulitai Dec 10, 2018
735e2f8
[hotfix] [tests] Remove unused enum from StateBackendTestBase
tzulitai Dec 9, 2018
34ca8b7
[hotfix] Cleanup unused methods / appropriate method renames in State…
tzulitai Dec 9, 2018
8b898cd
[FLINK-11087] [state] Incorrect broadcast state K/V serializer snapsh…
tzulitai Dec 6, 2018
a30164b
[FLINK-11087] [docs] Amend compatibility table to notify issue with r…
tzulitai Dec 6, 2018
7067798
[hotfix] [docs] Fix typo in Joining documentation
Dec 11, 2018
30a7c5a
[hotfix] [docs] Fix tEnv in tableApi docs
Dec 6, 2018
0078a7c
[hotfix] [docs] Correct the parameter in Operators Overview doc
KarmaGYZ Dec 3, 2018
de454e5
[FLINK-11029] [docs] Fixed incorrect parameter in Working with state doc
KarmaGYZ Nov 29, 2018
2f7bb1c
[FLINK-10359] [docs] Scala example in DataSet docs is broken
yanghua Dec 10, 2018
927936d
[hotfix][test][streaming] Fix invalid testNotSideOutputXXX in WindowO…
Dec 3, 2018
70b2029
[FLINK-11041][test] ReinterpretDataStreamAsKeyedStreamITCase source s…
StefanRRichter Dec 10, 2018
8c6ff79
[FLINK-11090][streaming api] Remove unused parameter in WindowedStrea…
hequn8128 Dec 11, 2018
7e6feea
[FLINK-10252][metrics] Pass akkaFrameSize to MetricQueryService
yanghua Oct 18, 2018
1cf6d30
[FLINK-10252][metrics] Handle oversized metric messages
yanghua Oct 18, 2018
8492d00
[hotfix][metrics][tests] Ensure ActorSystem is terminated
zentol Dec 7, 2018
f8aee29
[hotfix][metrics][tests] Refactor MetricQueryServiceTest
zentol Dec 6, 2018
a79fb6f
[hotfix][docs][table] Fix string concatenation in avro example
maqingxiang Dec 11, 2018
547a503
[hotfix][build] Add Aliyun FS dependency to flink-dist
zentol Dec 11, 2018
3c5eb92
[FLINK-11080][ES] Rework shade-plugin filters
zentol Dec 5, 2018
183ca20
[hotfix] [docs] Fix typo in dynamic tables documentation
zzchun Dec 11, 2018
ff42f87
[FLINK-11125] clean up useless imports
hequn8128 Dec 11, 2018
ea8373e
[FLINK-11085][build] Fix inheritance of shading filters
zentol Dec 7, 2018
f670cac
[hotfix] [docs] Fix typos in Table and SQL docs
Dec 12, 2018
c8dc83c
[hotfix] [docs] Improve DataSet.partitionCustom() documentation.
KarmaGYZ Dec 10, 2018
ed0aefa
[FLINK-11136] [table] Fix the merge logic of DISTINCT aggregates.
dianfu Dec 10, 2018
ff9b7f1
[FLINK-11001] [table] Fix alias on window rowtime attribute in Java T…
hequn8128 Dec 12, 2018
41d4bf4
[hotfix] [docs] Add notice about buggy DATE_FORMAT function
twalthr Dec 13, 2018
cec17d0
[hotfix] [docs] Add notice about buggy dateFormat() function
twalthr Dec 13, 2018
e546069
[FLINK-11122][core] Change signature of WrappingProxyUtil#stripProxy(T)
GJL Dec 10, 2018
ca28085
[hotfix][core] Fix typo in WrappingProxyUtil Javadoc
GJL Dec 12, 2018
dcddf0b
[FLINK-11144][tests] Make tests runnable on Java 9
GJL Dec 12, 2018
d29848d
[FLINK-11152][core] Use asm 6 in ClosureCleaner
GJL Dec 13, 2018
951ae9a
[FLINK-11145] Fix Hadoop version handling in binary release script
tweise Dec 11, 2018
bc4194a
[FLINK-11040][docs] fixed the Incorrect generic type of output in bro…
KarmaGYZ Dec 14, 2018
2870c7a
[FLINK-10566] Fix exponential planning time of large programs
mxm Dec 11, 2018
1f9f13e
[hotfix] [docs] Improve the correctness in Detecting Patterns doc
KarmaGYZ Dec 14, 2018
ff848d0
[hotfix] [docs] Correct the field name in Connect to External Systems…
KarmaGYZ Dec 14, 2018
9a45fca
[FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBa…
dianfu Dec 6, 2018
eab3ce7
[FLINK-7599][table] Refactored AggregateUtil#transformToAggregateFunc…
dawidwys Nov 26, 2018
04c44f3
[hotfix][table] Move generate runner functions to MatchCodeGenerator …
dawidwys Dec 5, 2018
1458caf
[FLINK-7599][table, cep] Support for aggregates in MATCH_RECOGNIZE
dawidwys Nov 26, 2018
185be98
[FLINK-7599][docs] Updated MATCH_RECOGNIZE documentation with aggrega…
dawidwys Nov 27, 2018
41b3a3b
[FLINK-7599][table] Throw exception on DISTINCT in aggregations in MA…
dawidwys Nov 29, 2018
31665d6
[hotfix][docs] Unified indentation
dawidwys Dec 16, 2018
45f9ccc
[FLINK-11083] [Table&SQL] CRowSerializerConfigSnapshot is not instant…
Dec 10, 2018
b078c80
[FLINK-10457][fs-connector] Add SequenceFile support to StreamingFile…
Sep 28, 2018
cf88590
[FLINK-10457][fs-connector] Add SequenceFile support to StreamingFile…
kl0u Dec 11, 2018
030743f
[FLINK-11100][s3][tests] Add FS type argument to s3_setup
zentol Dec 7, 2018
a431f76
[FLINK-11101][S3] Ban openjdk.jol dependencies
zentol Dec 12, 2018
84b6616
[FLINK-11151][rest] Create parent directories in FileUploadHandler
zentol Dec 13, 2018
68323de
[FLINK-11168][tests] Relax time-constraints for LargePlanTest
mxm Dec 18, 2018
eb7039d
[FLINK-11026][ES6] Rework creation of fat sql-client jar
zentol Dec 18, 2018
4616c60
[FLINK-10784][tests] Update FlinkKafkaConsumerBaseMigrationTest for 1.7
yanghua Dec 18, 2018
aeabfc5
[FLINK-10788][tests] Update ContinuousFileProcessingMigrationTest for…
yanghua Dec 18, 2018
d1e8dd9
[FLINK-10782][tests] Update AbstractKeyedOperatorRestoreTestBase for 1.7
yanghua Dec 18, 2018
ab33429
[FLINK-10787][tests] Update AbstractNonKeyedOperatorRestoreTestBase f…
yanghua Dec 18, 2018
e954ae8
[FLINK-10786][tests][cep] Update CEPMigrationTest for 1.7
yanghua Dec 18, 2018
9d62dbc
[hotfix][docs] Fix typos in documentation
zzchun Dec 18, 2018
6dfeb1a
[hotfix][docs][table] Fix various examples
maqingxiang Dec 18, 2018
a70f503
[hotfix] Fix typo in AbstractStreamOperator
Dec 19, 2018
b02121c
[FLINK-11180][tests] Use random port in ProcessFailureCancelingITCase
hequn8128 Dec 19, 2018
2bd5c4d
[hotfix][javadocs] Fix typo
lamberken Dec 19, 2018
a53b85e
[FLINK-9083][cassandra] Restructure CassandraSinkBase
jparkie Dec 19, 2018
cb9c4fc
[FLINK-9083][cassandra] Refactor CassandraSinkBaseTest
jparkie Dec 19, 2018
42f5f77
[FLINK-9083][cassandra] Add async backpressure support
jparkie Dec 19, 2018
1708260
[FLINK-10461][runtime] Refactor direct executor service
azagrebin Dec 15, 2018
6431b7e
[FLINK-10461][rocksdb] Support multiple threads for downloading resto…
klion26 Sep 24, 2018
b367f8f
[hotfix][docs][scala] Update comment about supported scala version
joerg84 Dec 20, 2018
bab9699
[FLINK-10748] Decouple RestServerEndpoint from Dispatcher (#7295)
tillrohrmann Dec 20, 2018
eadfae0
[FLINK-11201] Update release notes to contain changes for SBT projects
tillrohrmann Dec 20, 2018
bb9b176
[FLINK-11048] Ability to programmatically execute streaming pipeline …
tweise Dec 6, 2018
bc3eb82
[FLINK-4582] [kinesis] Consumer for DynamoDB streams via Kinesis API …
yxu-valleytider Dec 22, 2018
55c0b17
[FLINK-11179][tests] fix testCancelSortMatchWhileDoingHeavySorting bug
sunjincheng121 Dec 17, 2018
f6a3416
[hotfix] [docs] Fix broken links in State Schema Evolution docs
tzulitai Dec 24, 2018
ef3f194
[hotfix] [docs] Correct word spelling errors
suxinglee Dec 24, 2018
946c6bb
[hotfix] [docs] Fix wrong window time unit for window join documenta…
libenchao Dec 21, 2018
4da473e
[hotfix][docs][metrics] Update currentLowWatermark references
Dec 26, 2018
cf7f2ee
[hotfix][docs] Fix typos
xueyumusic Dec 26, 2018
fcbf91d
[FLINK-11142][docs] Point out fields can be projected out for Positio…
hequn8128 Dec 24, 2018
33f6d06
[FLINK-7208][table] Optimize Min/MaxWithRetractAggFunction with DataView
dianfu Nov 30, 2018
1ccc740
[hotfix][cep] Fixed timestamp for timed out partial matches
dawidwys Dec 18, 2018
822b17f
[hotfix][cep] Fixed argument list code style
dawidwys Dec 18, 2018
6f5b9c9
[hotfix][cep] Added test event builder
dawidwys Dec 18, 2018
92eb82b
[hotfix][cep] Added test harness output asserter
dawidwys Dec 18, 2018
4496809
[FLINK-10596][cep] Introduced PatternProcessFunction
dawidwys Dec 18, 2018
bec4a28
[hotfix][cep] Fixed passing runtime context
dawidwys Dec 18, 2018
2b8edec
[FLINK-10596][cep][docs] Updated cep docs with PatternProcessFunction
dawidwys Dec 18, 2018
54fea60
[hotfix][cep] Made PatternStream immutable & changed PatternStreamBui…
dawidwys Dec 19, 2018
0605e84
[hotfix] [docs] fix typos
zzchun Dec 28, 2018
ee81c0f
[hotfix][docs] Fix incorrectly spelled "the" as "teh"
KarmaGYZ Dec 30, 2018
703dc91
[FLINK-11233][core] Fix typo in JobID Javadoc
mousepotato Dec 30, 2018
5c1f458
[hotfix][runtime] Fix typo in FlinkUserCodeClassLoaders Javadoc
leesf Dec 31, 2018
84c2970
[hotfix][docs] Add back-to-top button to connector page
leesf Jan 1, 2019
3d88137
[FLINK-11246][table] Fix distinct AGG visibility issue
dianfu Jan 2, 2019
7ca3e04
[FLINK-11217][docs] Add missing back-to-top buttons
leesf Jan 2, 2019
a4c09d3
[FLINK-10779][tests] Update Java / Scala StatefulJobSavepointMigratio…
hequn8128 Dec 19, 2018
50f4196
Merge pull request #7242 from hequn8128/flink-10781
hequn8128 Jan 2, 2019
7bb63f6
[FLINK-10780][tests] Update Java / Scala StatefulJobWBroadcastStateMi…
hequn8128 Dec 22, 2018
4febcdc
[FLINK-11235][es] Close transportclient if no connection could be est…
lamberken Jan 2, 2019
f6995f0
[FLINK-11181][tests] Fix SimpleRecoveryFailureRateStrategyITBase test…
hequn8128 Jan 3, 2019
903a909
[FLINK-11163][tests] Use random port in RestClusterClientTest
zentol Dec 20, 2018
7ce6375
[hotfix][tests] Remove mocks from RestClusterClientTest
zentol Jan 2, 2019
9f99d4b
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-cassandra
zentol Nov 29, 2018
842e424
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-elastics…
zentol Nov 29, 2018
da57ce7
[hotfix][ES2] Set findbugs to provided
zentol Dec 11, 2018
4d1fd44
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-elastics…
zentol Nov 29, 2018
6e774a2
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-elastics…
zentol Nov 29, 2018
89f8f47
[FLINK-11023] Add LICENSE & NOTICE files for flink-connector-kinesis
zentol Nov 29, 2018
aa92438
[FLINK-10761][metrics] Do not acquire lock for getAllVariables()
zentol Jan 3, 2019
9e0ea45
[FLINK-11079][storm] Skip deployment of storm-examples
zentol Dec 20, 2018
7a0a525
[FLINK-11194][hbase] Use type instead of classifier
zentol Dec 19, 2018
c28250b
[FLINK-11023][ES] Add NOTICE file
zentol Jan 3, 2019
96d6979
[hotfix][docs][kafka] Fix typo
wangzzu Jan 4, 2019
04035ce
[FLINK-11234] [table] Fix ExternalTableCatalogBuilder unable to build…
EronWright Dec 31, 2018
71f8564
[hotfix][ES6][SQL] Remove unused version property
zentol Dec 18, 2018
b623768
[FLINK-11026][kafka][SQL] Rework kafka sql-client jar creation
zentol Dec 18, 2018
cef75fe
[hotfix] [table] Fix typos in Table javadoc.
EronWright Dec 31, 2018
1ee2a88
[hotfix][docs] Fix incorrect example in cep doc
KarmaGYZ Jan 4, 2019
d3f0075
[FLINK-11119][docs] Correct Scala example for Table Function in User-…
wenhuitang Dec 29, 2018
1c3c663
[FLINK-11227] [table] Fix bound checking errors in DescriptorProperties
xccui Dec 25, 2018
c09dc96
[FLINK-11173][table] Fix the exception message of proctime attribute …
wenhuitang Dec 25, 2018
038dc00
[FLINK-11001] [table] Update exception message for time attributes on…
twalthr Jan 4, 2019
b82b24d
[FLINK-11124][table] Add private[flink] to TemporalTableFunction.crea…
hequn8128 Dec 11, 2018
c8675b8
[hotfix] [docs] Update docs regarding missing 'sql-jar' suffix
twalthr Jan 4, 2019
e26d90f
[FLINK-10848][YARN] properly remove YARN ContainerRequest upon contai…
Nov 10, 2018
c0a37f8
[FLINK-10845] [table] Support multiple different DISTINCT aggregates …
xueyumusic Nov 23, 2018
28e0b83
[hotfix] Improve performance of GenericArraySerializer.copy()
StefanRRichter Jun 6, 2018
6f9a884
[hotfix] Remove unused generic parameter from RocksDB states
StefanRRichter Dec 11, 2018
54ef382
[FLINK-9702] Improvement in (de)serialization of keys and values for …
StefanRRichter Nov 27, 2018
ec48bea
[FLINK-11265][docs] AvroSinkWriter → AvroKeyValueSinkWriter
Fokko Jan 7, 2019
11aa9b6
[hotfix][runtime] Remove redundant suppression
tisonkun Jan 7, 2019
1794ea0
[FLINK-11073] [core] Add COMPATIBLE_WITH_RECONFIGURED_SERIALIZER to T…
tzulitai Nov 29, 2018
e03cea5
[FLINK-11073] [state backends] Respect serializer reconfiguration in …
tzulitai Dec 13, 2018
29174f8
[hotfix] Rename keySerializerConfigSnapshot to keySerializerSnapshot …
tzulitai Dec 18, 2018
583b3a2
[hotfix] [doc] Fix an error in state_backends
Jan 3, 2019
3d5b6b1
[hotfix] [doc] Fix incorrect http port in Elasticsearch 6.x Scala doc
lamberken Dec 25, 2018
35d16f9
[FLINK-11165] Refine the task deploying log for easier finding of tas…
zhuzhurk Dec 14, 2018
fe489bd
[FLINK-11189] Deprecated documentation for readSequenceFile function
leesf Dec 23, 2018
0b28bfd
[FLINK-11273][state] Fix shared InputView object between event proces…
StefanRRichter Jan 7, 2019
79f3170
[FLINK-11161][scala-shell] Fix unable to import java packages in scal…
shuiqiangchen Dec 27, 2018
90f3b42
[FLINK-11279] [table] Fix week interval parsing in ExpressionParser
XuQianJin-Stars Jan 8, 2019
392647d
[FLINK-11191] [table] Check for ambiguous columns in MATCH_RECOGNIZE
dawidwys Dec 18, 2018
d77151c
Revert "[FLINK-10848][YARN] properly remove YARN ContainerRequest upo…
tillrohrmann Jan 8, 2019
7a1147b
[FLINK-11280] [rocksdb] Lazily create RocksDBSerializedCompositeKeyBu…
tzulitai Jan 8, 2019
ef08a86
[hotfix] [rocksdb] Only log snapshot restore message when state is ac…
tzulitai Jan 8, 2019
f39fd29
[hotfix] [rocksdb] Remove unused method in RocksDBSerializedComposite…
tzulitai Jan 8, 2019
31685a3
[FLINK-11280] [state backends, tests] Do not set current key before r…
tzulitai Jan 8, 2019
beee5b1
[FLINK-11073] [core] Introduce CompositeTypeSerializerSnapshot
tzulitai Dec 5, 2018
8174854
[FLINK-11079] [core] Let ListSerializerSnapshot extend CompositeTypeS…
tzulitai Dec 5, 2018
9822cc8
[FLINK-11073] [core] Let MapViewSerializerSnapshot be a CompositeType…
tzulitai Dec 5, 2018
383cc9e
[FLINK-11073] [core] Let ArrayListSerializerSnapshot be a CompositeTy…
tzulitai Dec 5, 2018
eda7376
[FLINK-11073] [core] Let LockableTypeSerializerSnapshot be a Composit…
tzulitai Dec 5, 2018
faf093d
[FLINK-11073] [core] Let ListViewSerializerSnapshot be a CompositeTyp…
tzulitai Dec 5, 2018
5e6664d
[FLINK-11073] [core] Let MapSerializerSnapshot be a CompositeTypeSeri…
tzulitai Dec 5, 2018
68fab12
[FLINK-11073] [core] Let ScalaEitherSerializerSnapshot be a Composite…
tzulitai Dec 5, 2018
e791b1a
[FLINK-11073] [core] Replace GenericArraySerializerConfigSnapshot wit…
tzulitai Dec 6, 2018
301be55
[FLINK-11073] [core] Replace EitherSerializerSnapshot with new JavaEi…
tzulitai Jan 7, 2019
25dc483
[hotfix] [core] Assert current serializer snapshot is expected snapsh…
tzulitai Dec 6, 2018
5bcaf2e
[FLINK-11073] [core] Rename CompositeSerializerSnapshot to NestedSeri…
tzulitai Jan 7, 2019
1072bbf
[FLINK-10555] [test] Port AkkaSslITCase to new code base
tisonkun Oct 15, 2018
fc98a1f
[FLINK-10555] Clean-up BlobServerSSLTest
tillrohrmann Jan 8, 2019
f9fbbd7
[FLINK-10700] [cluster managerment] Remove LegacyStandaloneClusterDes…
tisonkun Jan 8, 2019
9ab04da
[FLINK-11232][rest] Fix subtask start-time field name
eaglewatcherwb Jan 9, 2019
9742ef7
[FLINK-11251][metrics] Exclude variable values from logical scope of …
tony810430 Jan 9, 2019
5e46487
[hotfix][cep] Change contract of cep TimerContext#timestamp to never
dawidwys Jan 7, 2019
abe7ae2
[hotfix][cep] Introduced nfa test harness
dawidwys Dec 12, 2018
60f8826
[FLINK-10596][cep] Added access to timer service in IterativeCondition
dawidwys Dec 12, 2018
0a46510
[hotfix][cep] Renamed TimerContext to TimeContext
dawidwys Jan 8, 2019
47e9ccf
[FLINK-10596][cep, docs] Added description of TimeContext to docs
dawidwys Jan 8, 2019
52dd89d
[FLINK-11056] [mesos] Remove MesosApplicationMasterRunner
tisonkun Dec 4, 2018
64f766f
[hotfix][docs] Sync formatting for cli usage examples
intsmaze Jan 9, 2019
9323ef6
[hotfix][test] Remove usage of deprecated method
tisonkun Jan 8, 2019
5b5ec59
[hotfix][test] Reduce test timeout to a reasonable value
tisonkun Jan 8, 2019
4782236
[hotfix][test] Adjust suppressWarnings
tisonkun Jan 8, 2019
a93e91a
[hotfix][docs] Update addShutdownHookThread javadocs
leesf Jan 9, 2019
6a4bc90
[hotfix][docs] Fix javadocs of RandomFibonacciSource
DreamsZM Jan 9, 2019
3702029
[FLINK-11140][fs-connector] Fix empty child path check in Buckets.
Matrix42 Jan 8, 2019
6650d74
[FLINK-11197][tests] Improve migration test comments about how to gen…
hequn8128 Dec 19, 2018
e4bc287
[FLINK-11262][py] Bump jython-standalone to 2.7.1
Fokko Jan 9, 2019
78cc9bc
[FLINK-10783][tests] Update WindowOperatorMigrationTest for 1.7
Jan 9, 2019
f817537
[FLINK-11207][build] Bump commons-compress to 1.18
NicoK Jan 9, 2019
0315f20
[FLINK-10326] Simplify ZooKeeperSubmittedJobGraphStore#constructor
tillrohrmann Sep 12, 2018
1e2aa8e
[FLINK-10436] Add ConfigOption#withFallbackKeys (#6872)
tisonkun Jan 9, 2019
e5ed8c8
[FLINK-11287] [rocksdb] RocksDBListState should be using registered s…
tzulitai Jan 8, 2019
cad0509
[FLINK-11073] [state backends, tests] Activate ignored testKeyedListS…
tzulitai Jan 8, 2019
43a7497
[hotfix][docs] Add missing config option descriptions
KarmaGYZ Jan 9, 2019
7a9a6ad
[FLINK-10571][storm] Remove topology support
zentol Oct 17, 2018
ca9460b
[FLINK-11267][release] Only create hadoop-free binary by default
zentol Jan 4, 2019
4ec77d6
[FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.
kl0u Oct 15, 2018
81ec2d7
[hotfix] Avoid redundant state access in TemporalProcessTimeJoin.
kl0u Nov 26, 2018
f828031
[FLINK-10584][table] Add State Retention support to TemporalRowtimeJoin.
kl0u Nov 27, 2018
120c4fc
[FLINK-10583][table] Add State Retention support to TemporalProcessTi…
kl0u Nov 26, 2018
6826c67
[FLINK-11278] [docs] Add documentation for TableAPI&SQL in scala-shell.
Jan 9, 2019
85dff90
[hotfix][docs] Reverse paragraphs in cli.md to cli enumeration (#7443)
KarmaGYZ Jan 10, 2019
e8182dc
[FLINK-10866] Only load queryable state when explicitly configured
eaglewatcherwb Jan 4, 2019
f692d37
[FLINK-11272][flink-yarn] Support for parsing multiple --yarnship par…
leesf Jan 7, 2019
c06e7a5
[FLINK-11134][rest] Do not log stacktrace for handled exceptions
zentol Dec 20, 2018
1f47c0a
[hotfix][rest] Centralize REST error logging
zentol Jan 3, 2019
4adf23d
[hotfix][rest] Remove unnecessary instanceof check
zentol Jan 3, 2019
5fe918c
[FLINK-11268][release] Deploy multiple flink-shaded-hadoop2 artifacts
zentol Jan 3, 2019
1abf8d1
[FLINK-11253] Add shutdown hook for yarn session client
Jan 4, 2019
a07ce7f
[FLINK-11253] Factor out application report logging
tillrohrmann Jan 10, 2019
2294cdd
[FLINK-10509][storm] Remove flink-storm
zentol Jan 10, 2019
157a267
Fix queryable-state nightly test
aljoscha Jan 11, 2019
e0efabe
[FLINK-11084][datastream] Forbid using two consecutive split transfor…
Clarkkkkk Dec 6, 2018
be47061
[FLINK-11224][scala-shell] Log is missing in scala-shell
zjffdu Jan 11, 2019
1a4eb09
[hotfix][docs] Fix NullPointerException
intsmaze Jan 11, 2019
205f906
[FLINK-11306][jdcs] Bump derby from 10.10.1.1 to 10.14.2.0
Fokko Jan 11, 2019
3903b81
[FLINK-10848] Remove container requests after successful container al…
tillrohrmann Jan 8, 2019
43ec81f
[hotfix] [docs] Fix kafka doc mistake classname
sunjincheng121 Jan 14, 2019
6c8abc1
[FLINK-11312][docs] Fix broken link to Zookeeper getting started
ifndef-SleePy Jan 14, 2019
f305b64
[hotfix] Add dependency snippet for RocksDBStateBackend to state_back…
intsmaze Jan 14, 2019
7206d20
[hotfix] Fix typo in restart strategies documenation (#7479)
libenchao Jan 14, 2019
c9af982
[hotfix][docs] Fix typo in classloading doc
KarmaGYZ Jan 14, 2019
2be178c
[FLINK-11304][docs][table] Fix typo in time attributes doc
Jan 14, 2019
1325599
[hotfix][docs][table] Fix more typos in time attributes doc
twalthr Jan 14, 2019
e5e6274
[hotfix] [docs] Fix typo in Table SQL doc
Jan 15, 2019
baea9a3
[hotfix] [datastream] Remove irrelevant comments and fix typo in Sour…
leesf Jan 14, 2019
e7b02b4
[hotfix] [fs] Add clock as an argument in Javadocs
Fokko Jan 14, 2019
02078e0
[FLINK-11156][tests, runtime] Reconcile ZooKeeperCompletedCheckpointS…
tisonkun Dec 14, 2018
eff261e
[FLINK-11156][tests, runtime] Simplify ZooKeeperCompletedCheckpointSt…
GJL Jan 8, 2019
3846928
Add link to KeyedProcessFunction to side output documentation
aljoscha Jan 15, 2019
ea0f283
[FLINK-11331][table][docs] Fix errors in tableApi.md and functions.md
hequn8128 Jan 15, 2019
ecb57a9
[hotfix][docs] fix some typos
Apr 23, 2018
bfd1302
[FLINK-9222][docs] add documentation for setting up Gradle projects
Apr 23, 2018
bfbf986
[hotfix][quickstart] make the note about IDE memory requirements non-…
Jul 10, 2018
a1c64b9
[FLINK-11023][kafka] Add NOTICE files
zentol Dec 20, 2018
9c07822
[FLINK-11187] [s3] Use file over stream for writes
Jan 8, 2019
b56197a
[hotfix][build] Append shade-plugin transformers in child modules
zentol Jan 10, 2019
979ebd2
[FLINK-11289][examples] Rework examples to account for licensing
zentol Jan 9, 2019
53034cd
[FLINK-11174][prometheus] Add option to not filter label values
tisonkun Jan 16, 2019
4863bc1
[hotfix][docs] Update references to deprecated SinkFunction#invoke(Ob…
intsmaze Jan 16, 2019
9a21cc0
[hotfix] Fix parameter name KeyedCoProcessOperator constructor
leesf Jan 16, 2019
c08db3f
[FLINK-11012][tests] Introduce abstract superclass for filesystem IT …
wujinhu Dec 29, 2018
171a3b1
[FLINK-10945] Add an InputDependencyConstraint to avoid resource dead…
zhuzhurk Dec 6, 2018
94647f1
[FLINK-10945] Mark InputDependencyConstraint as PublicEvolving
tillrohrmann Jan 16, 2019
f61d112
[FLINK-11295][conf] Rename configuration options of queryable-state f…
eaglewatcherwb Jan 13, 2019
291373a
[FLINK-11302][fs-connector] Correctly parse tmp dirs in FlinkS3FileSy…
art4ul Jan 10, 2019
86e06bc
[hotfix][docs] Remove stray character
leesf Jan 16, 2019
e683ba4
[hotfix][runtime] remove RejectedExecutionException code in executeAs…
lamberken Jan 16, 2019
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.
3 changes: 2 additions & 1 deletion .github/PULL_REQUEST_TEMPLATE.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@

<!--
*Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review your contribution in the best possible way, please go through the checklist below, which will get the contribution into a shape in which it can be best reviewed.*

*Please understand that we do not do this to make contributions to Flink a hassle. In order to uphold a high standard of quality for code contributions, while at the same time managing a large number of contributions, we need contributors to prepare the contributions well, and give reviewers enough contextual information for the review. Please also understand that contributions that do not follow this guide will take longer to review and thus typically be picked up with lower priority by the community.*
Expand All @@ -22,6 +22,7 @@


**(The sections below can be removed for hotfixes of typos)**
-->

## What is the purpose of the change

Expand Down
2 changes: 2 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ tmp
*.log
.DS_Store
build-target
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/avro/
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/generated/
flink-runtime-web/web-dashboard/assets/fonts/
flink-runtime-web/web-dashboard/node_modules/
Expand All @@ -34,3 +35,4 @@ out/
*.iws
tools/flink
tools/flink-*
tools/releasing/release
123 changes: 45 additions & 78 deletions .travis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,11 @@ sudo: required
dist: trusty

cache:
# default timeout is too low
timeout: 600
directories:
- $HOME/.m2
- $HOME/flink_cache

# do not cache our own artifacts
before_cache:
Expand All @@ -31,87 +34,20 @@ install: true

language: java

# - define unique cache names in case the auto-generated ones are not unique
# (see https://docs.travis-ci.com/user/caching/#Caches-and-build-matrices)
# - See https://issues.apache.org/jira/browse/FLINK-1072
matrix:
include:
- jdk: "oraclejdk8"
env:
- TEST="core"
- PROFILE="-Dhadoop.version=2.8.3"
- CACHE_NAME=JDK8_H280_CO
- jdk: "oraclejdk8"
env:
- TEST="libraries"
- PROFILE="-Dhadoop.version=2.8.3"
- CACHE_NAME=JDK8_H280_L
- jdk: "oraclejdk8"
env:
- TEST="connectors"
- PROFILE="-Dhadoop.version=2.8.3 -Pinclude-kinesis"
- CACHE_NAME=JDK8_H280_CN
- jdk: "oraclejdk8"
env:
- TEST="tests"
- PROFILE="-Dhadoop.version=2.8.3"
- CACHE_NAME=JDK8_H280_T
- jdk: "oraclejdk8"
env:
- TEST="misc"
- PROFILE="-Dhadoop.version=2.8.3 -Dinclude_hadoop_aws"
- CACHE_NAME=JDK8_H280_M
- jdk: "openjdk8"
env:
- TEST="core"
- PROFILE="-Dhadoop.version=2.4.1"
- CACHE_NAME=JDK8_H241_CO
- jdk: "openjdk8"
env:
- TEST="libraries"
- PROFILE="-Dhadoop.version=2.4.1"
- CACHE_NAME=JDK8_H241_L
- jdk: "openjdk8"
env:
- TEST="connectors"
- PROFILE="-Dhadoop.version=2.4.1 -Pinclude-kinesis"
- CACHE_NAME=JDK8_H241_CN
- jdk: "openjdk8"
env:
- TEST="tests"
- PROFILE="-Dhadoop.version=2.4.1"
- CACHE_NAME=JDK8_H241_T
- jdk: "openjdk8"
env:
- TEST="misc"
- PROFILE="-Dhadoop.version=2.4.1"
- CACHE_NAME=JDK8_H241_M
- jdk: "oraclejdk8"
env:
- TEST="core"
- PROFILE="-Dhadoop.version=2.8.0 -Pflip6"
- CACHE_NAME=JDK8_H280_F6_CO
- jdk: "oraclejdk8"
env:
- TEST="tests"
- PROFILE="-Dhadoop.version=2.8.0 -Pflip6"
- CACHE_NAME=JDK8_H280_F6_T

git:
depth: 100


env:
global:
# Global variable to avoid hanging travis builds when downloading cache archives.
- MALLOC_ARENA_MAX=2
# Build artifacts like logs (variables for apache/flink repo)
- secure: "gL3QRn6/XyVK+Em9RmVqpM6nbTwlhjK4/JiRYZGGCkBgTq4ZnG+Eq2qKAO22TAsqRSi7g7WAoAhUulPt0SJqH7hjMe0LetbO0izbVXDefwf2PJlsNgBbuFG6604++VUaUEyfPYYw9ADjV59LWG7+B/fjbRsevqRBZ30b1gv/tQQ="
- secure: "eM9r8IglvnUKctxz/ga6hwGnCpdOvGyYdGj0H/UiNDEx3Lq1A6yp3gChEIXGJqRUXDI5TaIuidunUGY7KHml8urm8eG2Yk2ttxXehZqLpEaOU2jdNJCdLX8tlVfh14T9bxG5AYHQEV3qJUqDFtfXD3whvzuinrm1oEIA3qUxiA8="
- secure: "EQYDWgJM5ANJ/sAFwmSEwSTOe9CDN/ENyQAr5/ntM67XanhTZj2Amgt9LthCRUU4EEPl/OFUTwNHMpv/+wa3q7dwVFldSIg5wyCndzJSATPyPBVjYgsXIQZVIjsq4TwTyrTteT55V6Oz2+l27Fvung2FPuN83ovswsJePFzMBxI="
global:
# Global variable to avoid hanging travis builds when downloading cache archives.
- MALLOC_ARENA_MAX=2
- DOCKER_COMPOSE_VERSION=1.22.0

before_script:
- "gem install --no-document --version 0.8.9 faraday "
- "export -f travis_nanoseconds"
- "export -f travis_time_start"
- "export -f travis_time_finish"

# Install maven 3.2.5 since trusty uses 3.3.9 for which shading is broken
before_install:
Expand All @@ -122,8 +58,39 @@ before_install:
- "export PATH=$M2_HOME/bin:$PATH"
- "export MAVEN_OPTS=\"-Dorg.slf4j.simpleLogger.showDateTime=true -Dorg.slf4j.simpleLogger.dateTimeFormat=HH:mm:ss.SSS\""
# just in case: clean up the .m2 home and remove invalid jar files
- 'test ! -d $HOME/.m2/repository/ || find $HOME/.m2/repository/ -name "*.jar" -exec sh -c ''if ! zip -T {} >/dev/null ; then echo "deleting invalid file: {}"; rm {} ; fi'' \;'
- 'test ! -d $HOME/.m2/repository/ || find $HOME/.m2/repository/ -name "*.jar" -exec sh -c ''if ! zip -T {} >/dev/null ; then echo "deleting invalid file: {}"; rm -f {} ; fi'' \;'
# Installing the specified docker compose version
- sudo rm /usr/local/bin/docker-compose
- curl -L https://github.com/docker/compose/releases/download/${DOCKER_COMPOSE_VERSION}/docker-compose-`uname -s`-`uname -m` > docker-compose
- chmod +x docker-compose
- sudo mv docker-compose /usr/local/bin

# We run mvn and monitor its output. If there is no output for the specified number of seconds, we
# print the stack traces of all running Java processes.
script: "./tools/travis_mvn_watchdog.sh 300"
# When modifying the matrix you also have to modify travis_controller.sh#getCurrentStage
jdk: "oraclejdk8"
jobs:
include:
# main profile
- stage: compile
script: ./tools/travis_controller.sh
env: PROFILE="-Dhadoop.version=2.8.3 -Pinclude-kinesis -Dinclude_hadoop_aws -Dscala-2.11"
name: compile
- stage: test
script: ./tools/travis_controller.sh
env: PROFILE="-Dhadoop.version=2.8.3 -Pinclude-kinesis -Dinclude_hadoop_aws -Dscala-2.11"
name: core
- script: ./tools/travis_controller.sh
env: PROFILE="-Dhadoop.version=2.8.3 -Pinclude-kinesis -Dinclude_hadoop_aws -Dscala-2.11"
name: libraries
- script: ./tools/travis_controller.sh
env: PROFILE="-Dhadoop.version=2.8.3 -Pinclude-kinesis -Dinclude_hadoop_aws -Dscala-2.11"
name: connectors
- script: ./tools/travis_controller.sh
env: PROFILE="-Dhadoop.version=2.8.3 -Pinclude-kinesis -Dinclude_hadoop_aws -Dscala-2.11"
name: tests
- script: ./tools/travis_controller.sh
env: PROFILE="-Dhadoop.version=2.8.3 -Pinclude-kinesis -Dinclude_hadoop_aws -Dscala-2.11"
name: misc
- stage: cleanup
script: ./tools/travis_controller.sh
env: PROFILE="-Dhadoop.version=2.8.3 -Pinclude-kinesis -Dinclude_hadoop_aws -Dscala-2.11"
name: cleanup
149 changes: 0 additions & 149 deletions LICENSE
Original file line number Diff line number Diff line change
Expand Up @@ -199,152 +199,3 @@
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.


=======================================================================

Apache Flink subcomponents:

The Apache Flink project contains subcomponents in the source code
release with separate copyright notices and license terms. Your use of
the source code for the these subcomponents is subject to the terms and
conditions of their respective licenses.


-----------------------------------------------------------------------
The MIT License
-----------------------------------------------------------------------

The Apache Flink project bundles the following files under the MIT License:

- Angular.JS v1.4.8 (http://angularjs.org) - Copyright (c) 2010-2015 Google, Inc.
- Angular Moment v0.10.3 (http://www.momentjs.com) - Copyright (C) 2013, 2014, 2015, Uri Shaked <[email protected]>
- Angular UI Router v0.2.15 (http://angular-ui.github.io) - Copyright (c) 2013-2015 The AngularUI Team, Karsten Sperling
- angular-drag-and-drop-lists v1.4.0 (https://github.com/marceljuenemann/angular-drag-and-drop-lists) Copyright (c) 2014 Marcel Juenemann <[email protected]>, Copyright (c) 2014-2016 Google Inc.
- Bootstrap v3.3.6 (http://getbootstrap.com) - Copyright (c) 2011-2015 Twitter, Inc
- d3 timeline (https://github.com/jiahuang/d3-timeline) - Copyright (c) 2012-2015 Jia Huang
- dagre v0.7.4 (https://github.com/cpettitt/dagre) - Copyright (c) 2012-2014 Chris Pettitt
- dagre-d3 v0.4.17 (https://github.com/cpettitt/dagre-d3) - Copyright (c) 2013 Chris Pettitt
- EvEmitter v1.0.2 (https://github.com/metafizzy/ev-emitter) - Copyright (C) 2016 David DeSandro
- Font Awesome (code) v4.5.0, v4.6.3 (http://fontawesome.io) - Copyright (c) 2014 Dave Gandy
- graphlib v1.0.7 (https://github.com/cpettitt/graphlib) - Copyright (c) 2012-2014 Chris Pettitt
- imagesloaded v4.1.0 (https://github.com/desandro/imagesloaded) - Copyright (C) 2016 David DeSandro
- JQuery v2.2.0 (http://jquery.com/) - Copyright 2014 jQuery Foundation and other contributors
- lodash v3.10.1 (http://dojofoundation.org) - Copyright 2012-2015 The Dojo Foundation
- moment.js v2.10.6 (http://momentjs.com/docs/) - Copyright (c) 2011-2014 Tim Wood, Iskren Chernev, Moment.js contributors
- moment-duration-format v1.3.0 (https://github.com/jsmreese/moment-duration-format) - Copyright (c) 2013 John Madhavan-Reese
- qTip2 v2.2.1 (http://qtip2.com) - Copyright (c) 2012 Craig Michael Thompson
- Split.js v1.0.6 (https://nathancahill.github.io/Split.js/) - Copyright (c) 2015 Nathan Cahill

All rights reserved.

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
THE SOFTWARE.


-----------------------------------------------------------------------
BSD-style Licenses (BSD-3-clause)
-----------------------------------------------------------------------

The Apache Flink project bundles the following files under BSD-3-clause licenses:
- D3 v3.5.12 (http://d3js.org/) - Copyright (c) 2010-2015, Michael Bostock

All rights reserved.

Redistribution and use in source and binary forms, with or without modification,
are permitted provided that the following conditions are met:

1. Redistributions of source code must retain the above copyright notice, this list
of conditions and the following disclaimer.

2. Redistributions in binary form must reproduce the above copyright notice, this
list of conditions and the following disclaimer in the documentation and/or
other materials provided with the distribution.

3. Neither the name of the copyright holder nor the names of its contributors may
be used to endorse or promote products derived from this software without
specific prior written permission.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
POSSIBILITY OF SUCH DAMAGE.


-----------------------------------------------------------------------
The Open Font License
-----------------------------------------------------------------------

The Apache Flink project bundles the following fonts under the
Open Font License (OFT) - http://scripts.sil.org/OFL

- Font Awesome (http://fortawesome.github.io/Font-Awesome/) - Created by Dave Gandy
-> fonts in "flink-runtime-web/web-dashboard/web/fonts"
-> fonts in "docs/page/font-awesome/fonts"

-----------------------------------------------------------------------
The ISC License
-----------------------------------------------------------------------

The Apache Flink project contains or reuses code that is licensed under the ISC license
from the following projects:

- simplejmx (http://256stuff.com/sources/simplejmx/) Copyright (c) - Gray Watson

Permission to use, copy, modify, and/or distribute this software for any purpose with or without fee is hereby
granted, provided that this permission notice appear in all copies.

THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING
ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL,
DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE
USE OR PERFORMANCE OF THIS SOFTWARE.

-----------------------------------------------------------------------
BSD-style Licenses (BSD-2-clause)
-----------------------------------------------------------------------

The Apache Flink project contains or reuses code that is licensed under the BSD-2-clause license
from the following projects:
- jline-terminal (https://github.com/jline/jline3) Copyright (c) 2002-2016, various authors.
- jline-reader (https://github.com/jline/jline3) Copyright (c) 2002-2016, various authors.

Redistribution and use in source and binary forms, with or without modification, are permitted
provided that the following conditions are met:

1. Redistributions of source code must retain the above copyright notice, this list of conditions
and the following disclaimer.

2. Redistributions in binary form must reproduce the above copyright notice, this list of
conditions and the following disclaimer in the documentation and/or other materials provided
with the distribution.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR
IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR
CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER
IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
56 changes: 45 additions & 11 deletions NOTICE
Original file line number Diff line number Diff line change
Expand Up @@ -4,18 +4,52 @@ Copyright 2014-2018 The Apache Software Foundation
This product includes software developed at
The Apache Software Foundation (http://www.apache.org/).

=======================================================================
This project bundles the following dependencies under the Apache Software License 2.0. (http://www.apache.org/licenses/LICENSE-2.0.txt)

Apache Flink contains subcomponents with separate copyright notices and
license terms. Your use of the source code for the these subcomponents
is subject to the terms and conditions of their respective licenses.
- nvd3#1.8.4

See the LICENSE file for a list of subcomponents and dependencies and
their respective licenses.
This project bundles the following dependencies under the MIT license. (https://opensource.org/licenses/MIT)
See bundled license files for details.

- angular:1.4.8
- angular-drag-and-drop-list:1.4.0
- angular-moment:0.10.3
- angular-ui-router:0.2.15
- bootstrap:3.3.6
- dagre:0.7.5
- dagre-d3:0.4.17
- ev-emitter:1.1.1
- font-awesome:4.5.0 (CSS)
- graphlib:1.0.7
- imagesloaded:4.1.4
- jquery:2.2.0
- lodash:3.10.1
- moment:2.10.6
- moment-duration-format:1.3.0
- qtip2:2.2.1
- Split.js:1.0.6

lodash:
---------
Copyright 2012-2015 The Dojo Foundation <http://dojofoundation.org/>
Based on Underscore.js, copyright 2009-2015 Jeremy Ashkenas,
DocumentCloud and Investigative Reporters & Editors <http://underscorejs.org/>
This project bundles the following dependencies under the BSD license.
See bundled license files for details.

- d3:3.5.12

This project bundles the following dependencies under SIL OFL 1.1 license (https://opensource.org/licenses/OFL-1.1).
See bundled license files for details.

- font-awesome:4.5.0 (Font) (http://fortawesome.github.io/Font-Awesome/) - Created by Dave Gandy
-> fonts in "flink-runtime-web/web-dashboard/web/fonts"
-> fonts in "docs/page/font-awesome/fonts"

The Apache Flink project contains or reuses code that is licensed under the ISC license from the following projects.

- simplejmx (http://256stuff.com/sources/simplejmx/) Copyright (c) - Gray Watson

Permission to use, copy, modify, and/or distribute this software for any purpose with or without fee is hereby
granted, provided that this permission notice appear in all copies.

THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING
ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL,
DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE
USE OR PERFORMANCE OF THIS SOFTWARE.
Loading