Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
207 commits
Select commit Hold shift + click to select a range
b0a4fcf
[FLINK-4988] [elasticsearch] Restructure Elasticsearch connectors
tzulitai Jan 12, 2017
db8bf2c
[FLINK-5122] [elasticsearch] Retry temporary Elasticsearch request er…
static-max Nov 23, 2016
21f2695
[FLINK-5353] [elasticsearch] User-provided failure handler for Elasti…
tzulitai Jan 30, 2017
2da29bc
[FLINK-5487] [elasticsearch] At-least-once Elasticsearch Sink
tzulitai Feb 20, 2017
f4d26ff
[hotfix] [build] Remove unneeded logback-test.xml files
StephanEwen Apr 28, 2017
2a77ff3
Update Flink version to 1.4-SNAPSHOT
rmetzger May 8, 2017
b8f5097
[FLINK-6414] [build] Use scala.binary.version in place of change-scal…
greghogan Apr 27, 2017
9fd9d7b
[FLINK-6711] Activate strict checkstyle for flink-elasticsearch*
zentol May 24, 2017
b9dcc2b
[FLINK-7133] Exclude optional asm deps from Elasticsearch base module
Adebski Jul 8, 2017
3ad0400
[FLINK-7150] [elasticsearch connector] Various code cleanups in the E…
StephanEwen Jul 11, 2017
9b7e48c
[FLINK-7409] [web] Make WebRuntimeMonitor reactive
tillrohrmann Aug 10, 2017
367ef37
[hotfix][docs][javadocs] Remove double "the"
yew1eb Oct 20, 2017
e9d74dd
Update version to 1.5-SNAPSHOT
aljoscha Nov 6, 2017
4d372d3
[hotfix] Fix many many typos
greghogan Jan 3, 2018
8909dfd
[FLINK-7909] Replace StreamingMultipleProgramsTestBase by AbstractTes…
tillrohrmann Oct 24, 2017
c925a48
[FLINK-8199] [elasticsearch] Properly annotate APIs of Elasticsearch …
Dec 18, 2017
a7192b1
[FLINK-8489][ES] Prevent side-effects when modifying user-config
zentol Jan 29, 2018
fcf3456
Update version to 1.6-SNAPSHOT
tillrohrmann Feb 27, 2018
d91d39b
Update version to 1.7-SNAPSHOT
tillrohrmann Jul 16, 2018
889002c
[FLINK-7386] [elasticsearch] Evolve ES connector API to make it worki…
cjolif May 17, 2018
163917a
[FLINK-8101] [elasticsearch] Elasticsearch 6.X REST support
cjolif Jan 25, 2018
c0faa8e
[FLINK-9885] [elasticsearch] Major cleanup to finalize Elasticsearch …
tzulitai Jul 25, 2018
97c013e
[FLINK-10269] [connectors] Fix Elasticsearch 6 UpdateRequest binary i…
twalthr Sep 12, 2018
bf20298
[hotfix] [connectors] Remove unused BulkProcessorIndexer class
twalthr Oct 1, 2018
05ad4df
[FLINK-3875] [connectors] Add an upsert table sink factory for Elasti…
twalthr Aug 15, 2018
14d0c1c
[FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5
zentol Oct 8, 2018
d74e052
[FLINK-10687] [table] Move TableSchema to flink-table-common
twalthr Oct 26, 2018
cf29979
[FLINK-10687] [table] Move DescriptorProperties to flink-table-common
twalthr Oct 29, 2018
355d1e3
[FLINK-10687] [table] Move format descriptors and validators to flink…
twalthr Oct 27, 2018
c397f1b
[FLINK-10681] Harden ElasticsearchSinkITCase against wrong JNA library
tillrohrmann Oct 25, 2018
b2f1be3
Update version to 1.8-SNAPSHOT
tillrohrmann Nov 3, 2018
15d14b9
[FLINK-11080][ES] Rework shade-plugin filters
zentol Dec 5, 2018
4556937
[FLINK-11026][ES6] Rework creation of fat sql-client jar
zentol Dec 18, 2018
3a10dd8
[FLINK-11023][ES] Add NOTICE file
zentol Jan 3, 2019
ff4e9fb
[hotfix][ES6][SQL] Remove unused version property
zentol Dec 18, 2018
6a9a289
[FLINK-11064] [table] Setup a new flink-table module structure
twalthr Jan 28, 2019
6a5b101
[FLINK-11450][table] Port and move TableSource and TableSink related …
dianfu Feb 1, 2019
690cf74
[FLINK-11046] [elasticsearch] Fix ElasticsearchSink deadlock when ind…
xueyumusic Jan 21, 2019
2bc9fba
[FLINK-11046] [elasticsearch] Simplify failure handler indexer implem…
tzulitai Feb 9, 2019
5a7861d
[FLINK-11046] [elasticsearch] Always re-index buffered failed request…
tzulitai Feb 9, 2019
63e5f66
[hotfix] [elasticsearch] Replace implementation of deprecated invoke …
tzulitai Feb 9, 2019
8e2d4c7
Update version to 1.9-SNAPSHOT
aljoscha Feb 25, 2019
28f2518
[FLINK-11516][table-common] Port and move catalog transitive classes …
dianfu Feb 1, 2019
1a73574
[FLINK-11901][build] Update NOTICE files with year 2019
twalthr Mar 13, 2019
e940ff8
[FLINK-12151][es1] Remove Elasticsearch 1 connector
zentol Apr 11, 2019
ba57ac6
[FLINK-11067][table] port Schema, Rowtime, SchematicDescriptor, Regis…
hequn8128 Apr 23, 2019
3c29399
[hotfix] [connectors] Fix shadowed NPE in elasticsearch sink connector
Jun 24, 2019
84adcb7
[FLINK-12985][core][streaming] Rename StreamTransformation to org.apa…
dawidwys Jun 25, 2019
23069c6
[FLINK-12961][datastream] Add internal StreamExecutionEnvironment.exe…
ifndef-SleePy Jun 25, 2019
1eda4e9
Update version to 1.10-SNAPSHOT
KurtYoung Jul 12, 2019
1c593fc
[FLINK-13341][table][connectors] StreamTableSink#consumeDataStream re…
kaka11chen Jul 20, 2019
13062a7
[FLINK-13544][connectors] Set parallelism of table sink operator to i…
wuchong Aug 2, 2019
4f292b3
[hotfix][build] Use parent's maven-surefire-plugin version in elastic…
zhuzhurk Sep 12, 2019
1b10655
[FLINK-14334][es][docs] Use ExceptionUtils#findThrowable
zentol Oct 7, 2019
4259a05
[FLINK-13025] Elasticsearch 7.x support
yanghua Sep 18, 2019
198f4dc
[FLINK-13025] In ES7 SQL connector, update shading rules and NOTICE
aljoscha Oct 14, 2019
617bdf6
[hotfix][kafka][es] Add missing @PublicEvolving annotation on Kafka a…
wuchong Oct 15, 2019
abaa6bf
[FLINK-14395] Refactor ES 7 connectors to make them keep consistency …
yanghua Oct 22, 2019
24f021c
[FLINK-14104][build] Pin jackson version to 2.10.1
zentol Nov 20, 2019
f4ed19e
[FLINK-14645][connectors] Support new schema properties for SQL conne…
wuchong Dec 3, 2019
1fcd835
[FLINK-14649][kafka][es] Flatten all the connector properties keys to…
leonardBang Dec 9, 2019
f21e80e
Update version to 1.11-SNAPSHOT
GJL Dec 9, 2019
2d96d1c
[FLINK-15191][table][connectors] Fix connector factories that CREATE …
leonardBang Dec 13, 2019
a637dcc
[FLINK-14853][core] Implemented MemorySize formatting
dawidwys Jan 9, 2020
d357fa2
[FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5…
yanghua Jan 15, 2020
5dd3cb4
[FLINK-13689] [Connectors/ElasticSearch] Fix thread leak in Elasticse…
static-max Jan 23, 2020
0bff02d
[FLINK-15868][kinesis] Resolve version conflict between jackson-core …
tweise Feb 3, 2020
139f471
[FLINK-15868] Pin jackson-dataformat-smile dependency to 2.10.1
tillrohrmann Feb 4, 2020
0aefb86
[FLINK-15868] Pin jackson-dataformat-yaml dependency to 2.10.1
tillrohrmann Feb 4, 2020
48def60
[hotfix][es][tests] Remove unused variable
zentol Feb 4, 2020
c377cf0
[hotfix][es][tests] Refactor utils
zentol Feb 4, 2020
bc5856e
[FLINK-15868][es] Add tests for different formats
zentol Feb 4, 2020
eef304e
[FLINK-15992][kafka][es] Use thread context classloader when finding …
jiasheng55 Feb 12, 2020
a21cc0f
[FLINK-16046][es] Drop Elasticsearch 2 connector
zentol Feb 14, 2020
132d07e
[FLINK-15988][json] Make JsonRowSerializationSchema's constructor pri…
libenchao Feb 18, 2020
8bc4e2f
[hotfix] Revert "[FLINK-15992][kafka][es] Use thread context classloa…
wuchong Feb 21, 2020
7bf30d2
[FLINK-15672][build] Migrate to log4j2
zentol Jan 24, 2020
468663f
[FLINK-15672][build][tests] Migrate test log4j configurations to log4j2
zentol Jan 24, 2020
427ce90
[FLINK-16186][es][tests] Reduce connect timeout to 5 seconds
zentol Feb 20, 2020
21523c2
[FLINK-16287][es][build] Remove Log4j2 relocation
zentol Feb 26, 2020
bb73a36
[FLINK-16362][table] Remove deprecated `emitDataStream` method in Str…
godfreyhe Mar 4, 2020
2c5ae1e
[FLINK-11720][connectors] Bump ElasticSearch5 to 5.3.3
rmetzger Feb 18, 2020
11fa310
[FLINK-16454][build] Update the copyright with 2020 year in NOTICE files
zhijiangW Mar 16, 2020
c38b700
[FLINK-16170][elasticsearch] Fix SearchTemplateRequest ClassNotFoundE…
leonardBang Mar 25, 2020
f6bc79d
[FLINK-15400][elasticsearch] Support dynamic index for Elasticsearch …
leonardBang Apr 18, 2020
a3053a1
[FLINK-17483][legal] Update flink-sql-connector-elasticsearch7 NOTICE…
carp84 May 1, 2020
013286e
[FLINK-17027] Introduce a new Elasticsearch 7 connector with new prop…
dawidwys May 15, 2020
51139e2
[FLINK-17027] Introduce a new Elasticsearch 6 connector with new prop…
dawidwys May 15, 2020
52afd8b
Update version to 1.12-SNAPSHOT
pnowojski May 18, 2020
215186d
[FLINK-17027][hotfix] Rename back-off infix to backoff in new Elastic…
dawidwys May 19, 2020
004d183
[FLINK-16021][table-common] Fix DescriptorProperties.putTableSchema d…
danny0405 May 28, 2020
7852834
[FLINK-17887][table][connector] Improve interface of ScanFormatFactor…
wuchong Jun 1, 2020
ab32004
[FLINK-18052] Increase timeout for ES Search API in IT Cases
dawidwys Jun 2, 2020
2bb07ac
[FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDyn…
dawidwys Jun 2, 2020
9f502e5
[FLINK-18208] Fix flink ES connector typos
liuyongvs Jun 9, 2020
d9ccbc7
[FLINK-16495][elasticsearch][table] Improve default flush strategy fo…
wuchong Jun 9, 2020
491bb88
[FLINK-18277][elasticsearch] Fix the returned value of Elasticsearch6…
zhongqishang Jun 12, 2020
e7e46c1
[FLINK-17623][elasticsearch] Support user resource cleanup in Elastic…
yun-wang Jun 12, 2020
87a9ae1
[FLINK-18299][json] Fix the non SQL standard timestamp format in JSON…
fsk119 Jun 17, 2020
b7dcecb
[FLINK-18236] fix es connector test ElasticsearchSinkTestBase.runElas…
liuyongvs Jun 10, 2020
0ad4a26
[FLINK-18359] Log failures in handler instead of ElasticsearchSinkBase
rinkako Jun 18, 2020
26b3ae8
[FLINK-14938] Use ConcurrentLinkedQueue in BufferingNoOpRequestIndexer
ysn2233 Jun 19, 2020
dd86d98
[hotfix][elasticsearch] Fix validation message for 'sink.bulk-flush.m…
liuyongvs Jun 29, 2020
35703c9
[FLINK-18361][es][table] Support username and password options for ne…
KarmaGYZ Jul 10, 2020
4ccce90
[FLINK-18585][elasticsearch] Fix dynamic index doesn't work in new el…
leonardBang Jul 14, 2020
65431b1
[FLINK-18583][elasticsearch] Fix ElasticSearch6 sink uses index as do…
KarmaGYZ Jul 14, 2020
83f1634
[FLINK-18607][build] Give the maven module a human readable name
nielsbasjes Jul 22, 2020
42f39df
[hoxfix] Fix various typos
brandonJY Aug 17, 2020
fae14ee
[FLINK-17159] Harden ElasticsearchSinkITCase
aljoscha Aug 25, 2020
c91bbfb
[FLINK-18337][table] Introduce TableResult#await method to block unti…
godfreyhe Jun 17, 2020
943a7e7
[FLINK-17159] Add sanity check to ES6 ElasticsearchSinkITCase
aljoscha Sep 22, 2020
23fa466
[FLINK-19243][elasticsearch] Bump snakeyaml to 1.27
zentol Sep 22, 2020
79b8b49
[FLINK-19341][table] Update all API related methods to FLIP-107
twalthr Sep 22, 2020
17d83e6
[FLINK-19485] Add the Transformation.getInputs() method
kl0u Oct 6, 2020
4710b23
[hotfix] Make Transformation.getTransitivePredecessors() return a list
kl0u Oct 9, 2020
b952fa7
[FLINK-18999][table-common][table-planner-blink] Add isTemporary flag…
lirui-apache Aug 21, 2020
87ad26a
[FLINK-19459] Add snakeyaml to dependencyManagement
rmetzger Oct 14, 2020
4e14eb3
[FLINK-19781] Upgrade commons-codec to 1.13
rmetzger Oct 23, 2020
84aeb13
[FLINK-17159] Use testcontainers for Elasticsearch ITCases
aljoscha Nov 17, 2020
45a6990
Update version to 1.13-SNAPSHOT
dianfu Nov 26, 2020
3558956
[hotfix][elasticsearch] Fix javadoc of Elasticsearch6Configuration
zhisheng17 Dec 9, 2020
80df704
[FLINK-20651] Format code with Spotless/google-java-format
Dec 28, 2020
5143fe4
[FLINK-20711][docs] Fix failure-handler parameter enumeration value t…
Dec 22, 2020
947c273
[FLINK-20906][legal] Update copyright year to 2021 for NOTICE files.
xintongsong Jan 9, 2021
efbd463
[FLINK-20862] Make raw types of TypeInformation resolvable
twalthr Jan 12, 2021
f10f967
[FLINK-21009] Can not disable certain options in Elasticsearch 7 conn…
dawidwys Jan 18, 2021
7c4af0e
[FLINK-21020][build] Bump Jackson to 2.12.1
HuangXingBo Jan 21, 2021
c7e11ea
[FLINK-21277] Bump testcontainers version
dawidwys Feb 4, 2021
d723c3e
[FLINK-21396][table-planner-blink] Use ResolvedCatalogTable within th…
twalthr Mar 15, 2021
6cdd3f2
[FLINK-21913][table][connectors] Update DynamicTableFactory.Context t…
twalthr Mar 18, 2021
826b67c
Update version to 1.14-SNAPSHOT
guoweiM Apr 18, 2021
8ed425e
[FLINK-22471][connector-elasticsearch] Remove commads from list
Airblader Apr 26, 2021
320bb07
[FLINK-22471][connector-elasticsearch] Do not repeat default value
Airblader Apr 26, 2021
26c2ac2
[FLINK-22810][connector-elasticsearch] Drop usages of legacy planner …
twalthr May 31, 2021
a4eaf30
[FLINK-22744][table] Update and simplify EnvironmentSettings
twalthr Jun 7, 2021
04be9bf
[FLINK-21448] Add dependency for ChangelogStateBackend ITTests
zhangyy91 Jun 24, 2021
2b1b66d
[FLINK-22879][table] Rename flink-table-planner-blink to flink-table-…
twalthr Jul 6, 2021
bfa43ac
[FLINK-23064][connector-elasticsearch] Make connector options PublicE…
Airblader Jun 30, 2021
25914cc
[FLINK-18783] Load Akka with separate classloader
zentol Jun 29, 2021
48994e5
Revert "[FLINK-18783] Load Akka with separate classloader"
pnowojski Jul 14, 2021
adf6fc7
[FLINK-22386][tests] Cache docker images
autophagy Jul 16, 2021
22be0e7
[FLINK-18783] Load Akka with separate classloader
zentol Jun 29, 2021
14a936d
[FLINK-23438] Bump httpclient from 4.5.3 and 4.5.9 to 4.5.13 + Bump …
MartijnVisser Jul 23, 2021
f456444
[FLINK-25313][connector-elasticsearch] Remove legacy Elasticseach con…
Airblader Jul 29, 2021
c4af18e
[hotfix][test/testcontainers] Use Testcontainer BOM to manage version…
PatrickRen Aug 9, 2021
0f508ca
[hotfix][tests] Let ElasticSearch6DynamicSink tests extend TestLogger
tillrohrmann Aug 21, 2021
f3fc497
[FLINK-21538][tests] Set default parallelism to 4 for Elasticsearch6D…
tillrohrmann Aug 21, 2021
401629b
[hotfix] Let Elasticsearch7DynamicSink* test cases extend from TestLo…
tillrohrmann Aug 21, 2021
81ee52c
[FLINK-22333][tests] Harden Elasticsearch7DynamicSinkITCase.testWriti…
tillrohrmann Aug 21, 2021
fa9d345
Update version to 1.15-SNAPSHOT
xintongsong Aug 28, 2021
21d21b7
[FLINK-24034] Upgrade apache commons dependencies
MartijnVisser Sep 8, 2021
0bab586
[FLINK-23607][state/changelog] Make Changelog Backend a transitive de…
rkhachatryan Aug 25, 2021
050d4d3
[FLINK-24399][table-common] Add DynamicTableSource.Context#createType…
slinkydeveloper Sep 29, 2021
6f47268
[FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink base…
fapaul Sep 20, 2021
67dff2b
[FLINK-24018][build] Remove Scala dependencies from Java APIs
zentol Oct 25, 2021
9ecf4ec
[FLINK-24599][table] Replace static methods with convenient methods i…
matriv Oct 22, 2021
7811923
[FLINK-24327][connectors/elasticsearch] Integrate unified Elasticsear…
alpreu Oct 7, 2021
ed9f6da
[FLINK-24715][connectors][filesystems][formats] Update multiple Jacks…
MartijnVisser Nov 3, 2021
1216b5e
[FLINK-24583][connectors/elasticsearch] Improve teststability by bloc…
alpreu Nov 23, 2021
42209e2
[FLINK-25039][build] Disable shading of test jar by default
zentol Nov 25, 2021
154fffe
[FLINK-24325][connectors/elasticsearch] Remove Elasticsearch 5 from c…
alpreu Oct 20, 2021
3cbe860
[FLINK-24325][connectors/elasticsearch] Extract common unified Elasti…
alpreu Oct 21, 2021
b187b8d
[FLINK-24325][connectors/elasticsearch] Integrate common unified Elas…
alpreu Oct 21, 2021
2968a58
[FLINK-24325][connectors/elasticsearch] Migrate KeyExtractorTest to J…
alpreu Oct 21, 2021
a8cfe84
[hotfix][connectors/elasticsearch] Fix license formatting
alpreu Nov 3, 2021
9eca6be
[hotfix][connectors/elasticsearch] Move files from streaming.connecto…
alpreu Nov 3, 2021
8e24b06
[FLINK-24325][connectors/elasticsearch] Make ElasticsearchSinkBuilder…
alpreu Nov 10, 2021
d540ea3
[FLINK-24596][core] Introduce SerializableFunction and unify usages
fapaul Nov 26, 2021
f05f6bc
[FLINK-25060][table-common] Replace projection methods of FLINK-24399…
slinkydeveloper Nov 25, 2021
c151b2a
[FLINK-24687][table][connectors] Move FileSystemTableSink, FileSystem…
slinkydeveloper Nov 24, 2021
ae67acf
[FLINK-24372][connectors/elasticsearch] Deprecate old (pre FLIP-143) …
alpreu Dec 7, 2021
241977c
[FLINK-25189][connectors/elasticsearch] Bump Elasticsearch 7 to v7.15.2
alpreu Dec 1, 2021
5420a27
[FLINK-25189][connectors/elasticsearch] Bump Elasticsearch 6 to 6.8.20
alpreu Dec 3, 2021
c72ed32
[FLINK-25223][connectors/elasticsearch] Disable Elasticsearch 7 Testc…
alpreu Dec 9, 2021
eac7115
[FLINK-21068][connectors/elasticsearch] Support 'connection.request-t…
hackergin Dec 13, 2021
81d2209
[FLINK-25223][connectors/elasticsearch] Limit Elasticsearch testconta…
alpreu Dec 9, 2021
8a5c117
[FLINK-25105][checkpoint] Enables final checkpoint by default
gaoyunhaii Dec 8, 2021
440f632
[FLINK-25141][connector/elasticsearch] Add sink parallelism option
a49a Dec 7, 2021
93cbcb6
[FLINK-25390][table-common] Introduce forwardOptions for table and fo…
slinkydeveloper Jan 6, 2022
014d921
[FLINK-25712][connectors/testing-framework] Merge flink-connector-tes…
PatrickRen Jan 18, 2022
0e34e32
[FLINK-25391][connector-elasticsearch] Forward catalog table options
slinkydeveloper Jan 6, 2022
bb3a894
[FLINK-25754][elsaticsearch] Remove unused private class
snuyanzin Jan 26, 2022
00945bb
[FLINK-25892][elasticsearch6][test] add ArchUnit tests for test code
JingGe Feb 3, 2022
b30b7d3
[FLINK-25892][elasticsearch7][test] add ArchUnit tests for test code
JingGe Feb 3, 2022
716be6f
[FLINK-25892][elasticsearch-base][test] add ArchUnit tests for test code
JingGe Feb 3, 2022
8adace4
[FLINK-25571] Update Elasticsearch Sink to use decomposed interfaces
afedulov Feb 8, 2022
e747a9b
[hotfix] Fix JUnit 5 mini cluster arch unit rules
dawidwys Feb 14, 2022
a81cf11
[FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules
JingGe Feb 22, 2022
86b3dd1
[hotfix][tests] Add instructions for updating archunit stores
slinkydeveloper Feb 22, 2022
83dcc95
[FLINK-24571][connectors/elasticsearch] Supports a system time functi…
hackergin Dec 9, 2021
e3caa30
[FLINK-26252][tests] Refactor MiniClusterExtension to support JUnit 5…
slinkydeveloper Feb 22, 2022
cb8b580
[FLINK-26191][connectors/elasticsearch] Revert Elasticsearch dependen…
alpreu Feb 22, 2022
abd5a79
[FLINK-25927][connectors][build] Consistent flink-connector-base usage
afedulov Mar 14, 2022
9fad48a
Update version to 1.16-SNAPSHOT
gaoyunhaii Mar 14, 2022
eb5789c
[FLINK-26281][connectors/elasticsearch] setting default delivery guar…
alpreu Mar 10, 2022
7277311
[FLINK-26701][connectors] Revert FLINK-25927 apart from adding connec…
afedulov Mar 17, 2022
629f865
[hotfix][elasticsearch] Make TestEmitter#createIndexRequest private
fapaul Mar 17, 2022
7ea06d8
[FLINK-26633][elasticsearch] Add recordSend metric to elasticsearch sink
fapaul Mar 14, 2022
52e9735
[FLINK-26638][connectors/elasticsearch] Revert Table-API implementati…
alpreu Mar 17, 2022
9daadda
[FLINK-26709][table] Replace TableConfig.getConfiguration.set()
matriv Mar 21, 2022
37a8986
[FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max…
alpreu Mar 22, 2022
a831407
[FLINK-25961] [connectors/elasticsearch] Remove transport client from…
reta Feb 4, 2022
91fc0a8
[FLINK-26884] add files about licence, gitingore, editorconfig.
JingGe Apr 1, 2022
732b388
[FLINK-26884] refactoring - move Connectors to the root folder
JingGe Apr 1, 2022
e948d6e
[FLINK-26884] top level pom setup and modification of each pom in sub…
JingGe Apr 1, 2022
7bfc33d
[FLINK-26884] fix dependency convergence issue
JingGe Apr 1, 2022
60464b1
[FLINK-26884] add @deprecated
JingGe Apr 3, 2022
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
276 changes: 276 additions & 0 deletions .editorconfig
Original file line number Diff line number Diff line change
@@ -0,0 +1,276 @@
root = true

[*]
charset = utf-8
end_of_line = lf
insert_final_newline = true
max_line_length = 100
# ij_formatter_off_tag = @formatter:off
# ij_formatter_on_tag = @formatter:on
# ij_formatter_tags_enabled = false
# ij_smart_tabs = false
# ij_wrap_on_typing = false

[*.java]
indent_size = 4
indent_style = space
tab_width = 4
ij_continuation_indent_size = 8
# ij_java_align_consecutive_assignments = false
# ij_java_align_consecutive_variable_declarations = false
# ij_java_align_group_field_declarations = false
# ij_java_align_multiline_annotation_parameters = false
# ij_java_align_multiline_array_initializer_expression = false
# ij_java_align_multiline_assignment = false
# ij_java_align_multiline_binary_operation = false
# ij_java_align_multiline_chained_methods = false
# ij_java_align_multiline_extends_list = false
# ij_java_align_multiline_for = true
# ij_java_align_multiline_method_parentheses = false
# ij_java_align_multiline_parameters = true
# ij_java_align_multiline_parameters_in_calls = false
# ij_java_align_multiline_parenthesized_expression = false
# ij_java_align_multiline_records = true
# ij_java_align_multiline_resources = true
# ij_java_align_multiline_ternary_operation = false
# ij_java_align_multiline_text_blocks = false
# ij_java_align_multiline_throws_list = false
# ij_java_align_subsequent_simple_methods = false
# ij_java_align_throws_keyword = false
# ij_java_annotation_parameter_wrap = off
# ij_java_array_initializer_new_line_after_left_brace = false
# ij_java_array_initializer_right_brace_on_new_line = false
# ij_java_array_initializer_wrap = off
# ij_java_assert_statement_colon_on_next_line = false
# ij_java_assert_statement_wrap = off
# ij_java_assignment_wrap = off
ij_java_binary_operation_sign_on_next_line = true
ij_java_binary_operation_wrap = normal
# ij_java_blank_lines_after_anonymous_class_header = 0
# ij_java_blank_lines_after_class_header = 0
# ij_java_blank_lines_after_imports = 1
# ij_java_blank_lines_after_package = 1
# ij_java_blank_lines_around_class = 1
# ij_java_blank_lines_around_field = 0
# ij_java_blank_lines_around_field_in_interface = 0
# ij_java_blank_lines_around_initializer = 1
# ij_java_blank_lines_around_method = 1
# ij_java_blank_lines_around_method_in_interface = 1
# ij_java_blank_lines_before_class_end = 0
# ij_java_blank_lines_before_imports = 1
# ij_java_blank_lines_before_method_body = 0
# ij_java_blank_lines_before_package = 0
# ij_java_block_brace_style = end_of_line
# ij_java_block_comment_at_first_column = true
ij_java_call_parameters_new_line_after_left_paren = true
# ij_java_call_parameters_right_paren_on_new_line = false
ij_java_call_parameters_wrap = on_every_item
# ij_java_case_statement_on_separate_line = true
# ij_java_catch_on_new_line = false
# ij_java_class_annotation_wrap = split_into_lines
# ij_java_class_brace_style = end_of_line
ij_java_class_count_to_use_import_on_demand = 9999
# ij_java_class_names_in_javadoc = 1
# ij_java_do_not_indent_top_level_class_members = false
# ij_java_do_not_wrap_after_single_annotation = false
# ij_java_do_while_brace_force = never
# ij_java_doc_add_blank_line_after_description = true
ij_java_doc_add_blank_line_after_param_comments = true
ij_java_doc_add_blank_line_after_return = true
# ij_java_doc_add_p_tag_on_empty_lines = true
ij_java_doc_align_exception_comments = false
ij_java_doc_align_param_comments = false
ij_java_doc_do_not_wrap_if_one_line = true
ij_java_doc_enable_formatting = true
# ij_java_doc_enable_leading_asterisks = true
ij_java_doc_indent_on_continuation = true
ij_java_doc_keep_empty_lines = true
# ij_java_doc_keep_empty_parameter_tag = true
# ij_java_doc_keep_empty_return_tag = true
# ij_java_doc_keep_empty_throws_tag = true
# ij_java_doc_keep_invalid_tags = true
# ij_java_doc_param_description_on_new_line = false
ij_java_doc_preserve_line_breaks = false
# ij_java_doc_use_throws_not_exception_tag = true
# ij_java_else_on_new_line = false
# ij_java_entity_dd_suffix = EJB
# ij_java_entity_eb_suffix = Bean
# ij_java_entity_hi_suffix = Home
# ij_java_entity_lhi_prefix = Local
# ij_java_entity_lhi_suffix = Home
# ij_java_entity_li_prefix = Local
# ij_java_entity_pk_class = java.lang.String
# ij_java_entity_vo_suffix = VO
# ij_java_enum_constants_wrap = off
# ij_java_extends_keyword_wrap = off
# ij_java_extends_list_wrap = off
# ij_java_field_annotation_wrap = split_into_lines
# ij_java_finally_on_new_line = false
# ij_java_for_brace_force = never
# ij_java_for_statement_new_line_after_left_paren = false
# ij_java_for_statement_right_paren_on_new_line = false
# ij_java_for_statement_wrap = off
# ij_java_generate_final_locals = false
# ij_java_generate_final_parameters = false
# ij_java_if_brace_force = never
ij_java_imports_layout = org.apache.flink.**,|,org.apache.flink.shaded.**,|,*,|,javax.**,|,java.**,|,scala.**,|,$*
# ij_java_indent_case_from_switch = true
# ij_java_insert_inner_class_imports = false
# ij_java_insert_override_annotation = true
# ij_java_keep_blank_lines_before_right_brace = 2
# ij_java_keep_blank_lines_between_package_declaration_and_header = 2
# ij_java_keep_blank_lines_in_code = 2
# ij_java_keep_blank_lines_in_declarations = 2
# ij_java_keep_control_statement_in_one_line = true
# ij_java_keep_first_column_comment = true
# ij_java_keep_indents_on_empty_lines = false
# ij_java_keep_line_breaks = true
# ij_java_keep_multiple_expressions_in_one_line = false
# ij_java_keep_simple_blocks_in_one_line = false
# ij_java_keep_simple_classes_in_one_line = false
# ij_java_keep_simple_lambdas_in_one_line = false
# ij_java_keep_simple_methods_in_one_line = false
# ij_java_label_indent_absolute = false
# ij_java_label_indent_size = 0
# ij_java_lambda_brace_style = end_of_line
ij_java_layout_static_imports_separately = true
# ij_java_line_comment_add_space = false
# ij_java_line_comment_at_first_column = true
# ij_java_message_dd_suffix = EJB
# ij_java_message_eb_suffix = Bean
# ij_java_method_annotation_wrap = split_into_lines
# ij_java_method_brace_style = end_of_line
ij_java_method_call_chain_wrap = on_every_item
ij_java_method_parameters_new_line_after_left_paren = true
# ij_java_method_parameters_right_paren_on_new_line = false
ij_java_method_parameters_wrap = on_every_item
# ij_java_modifier_list_wrap = false
ij_java_names_count_to_use_import_on_demand = 9999
# ij_java_new_line_after_lparen_in_record_header = false
# ij_java_packages_to_use_import_on_demand = java.awt.*,javax.swing.*
# ij_java_parameter_annotation_wrap = off
# ij_java_parentheses_expression_new_line_after_left_paren = false
# ij_java_parentheses_expression_right_paren_on_new_line = false
# ij_java_place_assignment_sign_on_next_line = false
# ij_java_prefer_longer_names = true
# ij_java_prefer_parameters_wrap = false
# ij_java_record_components_wrap = normal
# ij_java_repeat_synchronized = true
# ij_java_replace_instanceof_and_cast = false
# ij_java_replace_null_check = true
# ij_java_replace_sum_lambda_with_method_ref = true
# ij_java_resource_list_new_line_after_left_paren = false
# ij_java_resource_list_right_paren_on_new_line = false
# ij_java_resource_list_wrap = off
# ij_java_rparen_on_new_line_in_record_header = false
# ij_java_session_dd_suffix = EJB
# ij_java_session_eb_suffix = Bean
# ij_java_session_hi_suffix = Home
# ij_java_session_lhi_prefix = Local
# ij_java_session_lhi_suffix = Home
# ij_java_session_li_prefix = Local
# ij_java_session_si_suffix = Service
# ij_java_space_after_closing_angle_bracket_in_type_argument = false
# ij_java_space_after_colon = true
# ij_java_space_after_comma = true
# ij_java_space_after_comma_in_type_arguments = true
# ij_java_space_after_for_semicolon = true
# ij_java_space_after_quest = true
# ij_java_space_after_type_cast = true
# ij_java_space_before_annotation_array_initializer_left_brace = false
# ij_java_space_before_annotation_parameter_list = false
# ij_java_space_before_array_initializer_left_brace = false
# ij_java_space_before_catch_keyword = true
# ij_java_space_before_catch_left_brace = true
# ij_java_space_before_catch_parentheses = true
# ij_java_space_before_class_left_brace = true
# ij_java_space_before_colon = true
# ij_java_space_before_colon_in_foreach = true
# ij_java_space_before_comma = false
# ij_java_space_before_do_left_brace = true
# ij_java_space_before_else_keyword = true
# ij_java_space_before_else_left_brace = true
# ij_java_space_before_finally_keyword = true
# ij_java_space_before_finally_left_brace = true
# ij_java_space_before_for_left_brace = true
# ij_java_space_before_for_parentheses = true
# ij_java_space_before_for_semicolon = false
# ij_java_space_before_if_left_brace = true
# ij_java_space_before_if_parentheses = true
# ij_java_space_before_method_call_parentheses = false
# ij_java_space_before_method_left_brace = true
# ij_java_space_before_method_parentheses = false
# ij_java_space_before_opening_angle_bracket_in_type_parameter = false
# ij_java_space_before_quest = true
# ij_java_space_before_switch_left_brace = true
# ij_java_space_before_switch_parentheses = true
# ij_java_space_before_synchronized_left_brace = true
# ij_java_space_before_synchronized_parentheses = true
# ij_java_space_before_try_left_brace = true
# ij_java_space_before_try_parentheses = true
# ij_java_space_before_type_parameter_list = false
# ij_java_space_before_while_keyword = true
# ij_java_space_before_while_left_brace = true
# ij_java_space_before_while_parentheses = true
# ij_java_space_inside_one_line_enum_braces = false
# ij_java_space_within_empty_array_initializer_braces = false
# ij_java_space_within_empty_method_call_parentheses = false
# ij_java_space_within_empty_method_parentheses = false
# ij_java_spaces_around_additive_operators = true
# ij_java_spaces_around_assignment_operators = true
# ij_java_spaces_around_bitwise_operators = true
# ij_java_spaces_around_equality_operators = true
# ij_java_spaces_around_lambda_arrow = true
# ij_java_spaces_around_logical_operators = true
# ij_java_spaces_around_method_ref_dbl_colon = false
# ij_java_spaces_around_multiplicative_operators = true
# ij_java_spaces_around_relational_operators = true
# ij_java_spaces_around_shift_operators = true
# ij_java_spaces_around_type_bounds_in_type_parameters = true
# ij_java_spaces_around_unary_operator = false
# ij_java_spaces_within_angle_brackets = false
# ij_java_spaces_within_annotation_parentheses = false
# ij_java_spaces_within_array_initializer_braces = false
# ij_java_spaces_within_braces = false
# ij_java_spaces_within_brackets = false
# ij_java_spaces_within_cast_parentheses = false
# ij_java_spaces_within_catch_parentheses = false
# ij_java_spaces_within_for_parentheses = false
# ij_java_spaces_within_if_parentheses = false
# ij_java_spaces_within_method_call_parentheses = false
# ij_java_spaces_within_method_parentheses = false
# ij_java_spaces_within_parentheses = false
# ij_java_spaces_within_switch_parentheses = false
# ij_java_spaces_within_synchronized_parentheses = false
# ij_java_spaces_within_try_parentheses = false
# ij_java_spaces_within_while_parentheses = false
# ij_java_special_else_if_treatment = true
# ij_java_subclass_name_suffix = Impl
# ij_java_ternary_operation_signs_on_next_line = false
# ij_java_ternary_operation_wrap = off
# ij_java_test_name_suffix = Test
# ij_java_throws_keyword_wrap = off
# ij_java_throws_list_wrap = off
# ij_java_use_external_annotations = false
# ij_java_use_fq_class_names = false
# ij_java_use_relative_indents = false
# ij_java_use_single_class_imports = true
ij_java_variable_annotation_wrap = normal
# ij_java_visibility = public
# ij_java_while_brace_force = never
# ij_java_while_on_new_line = false
# ij_java_wrap_comments = false
ij_java_wrap_first_method_in_call_chain = true
# ij_java_wrap_long_lines = false

[*.xml]
indent_style = tab
indent_size = 4

[*.scala]
indent_style = space
indent_size = 2

[*.py]
indent_style = space
indent_size = 4
38 changes: 38 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
.eslintcache
.cache
scalastyle-output.xml
.classpath
.idea/*
!.idea/vcs.xml
.metadata
.settings
.project
.version.properties
filter.properties
logs.zip
.mvn/wrapper/*.jar
target
tmp
*.class
*.iml
*.swp
*.jar
*.zip
*.log
*.pyc
.DS_Store
build-target
atlassian-ide-plugin.xml
out/
/docs/api
/docs/.bundle
/docs/.rubydeps
/docs/ruby2/.bundle
/docs/ruby2/.rubydeps
/docs/.jekyll-metadata
*.ipr
*.iws
tools/flink
tools/flink-*
tools/releasing/release
tools/japicmp-output
Loading