Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
327 commits
Select commit Hold shift + click to select a range
641fbd5
[Test][unit test] add jdbc-base unit test (#1243)
Paddy0523 Sep 13, 2022
0610bc7
[feat-#1246][rabbitmq] add rabbitmq sql source plugin (#1247)
ll076110 Sep 13, 2022
9f18c87
[feat-#1244][sybase] add sybase reader plugin (#1245)
ll076110 Sep 13, 2022
aac7615
[feat-#1229][emqx]improve connection stability (#1234)
mggger Sep 13, 2022
1929524
[feat-#1251][s3] add s3 reader and writer plugin (#1252)
ll076110 Sep 13, 2022
da55988
[hotfix-#1253][db2] db2 support clob type (#1254)
ll076110 Sep 14, 2022
717137e
[feat-#1249][vertica11] add vertica11 sink plugin (#1250)
ll076110 Sep 14, 2022
c455e77
[Feat][Connector] Add Iceberg Connector (#1242)
Kyofin Sep 14, 2022
411384c
[README] Remove expired content. (#1257)
FlechazoW Sep 15, 2022
cac4515
[hotfix-#1256][kudu]Fix SQLMode datatype mapping (#1259)
Paddy0523 Sep 16, 2022
972f42f
[feat][jdbc] Separate the relationship between incrementColumn with R…
Paddy0523 Sep 16, 2022
3f0c72e
[Test][Unit Test] Add unit test for kafka.
yanghuaiGit Sep 16, 2022
47d3d02
[hotfix]oracle type modify on sql & adjust to get unique key method (…
yanghuaiGit Sep 16, 2022
764546d
[hotfix][main]Sync jobs disable operator chains (#1263)
Paddy0523 Sep 16, 2022
37b8916
[hotfix][column]Fix the issue of timestampColumn convert to long erro…
Paddy0523 Sep 16, 2022
4e5e741
[hotfix-#1272][pgwal]fix pgwal does not support uppercase schema or u…
momisabuilder Sep 21, 2022
e7cbdf8
[Hotfix-#987][HDFS] Fix HdfsOrcOutputFormat can't get fullColumnType …
lordk911 Sep 23, 2022
47b2618
[hotfix-#565][chunjun-hdfs-connector] hadoop3.x version support orc (…
liumengkai Sep 23, 2022
96a60f0
[hotfix-1282][ftp] ftp writer error (#1264)
chenghb606 Sep 28, 2022
dc59a91
[Feature][JDBC]init column info in factory. (#1280)
Paddy0523 Sep 28, 2022
9e26702
[hotfix][kudu]GenericRowData can not cast ColumnRowData. (#1277)
JaryZhen Sep 28, 2022
79c02b8
[hotfix -#774][oraclelogminer] Fix the issue of UNISTR cannot parse …
364220158 Sep 28, 2022
52df2c7
[code-format] Format the code.
FlechazoW Sep 28, 2022
2683734
[Github][Workflow] Remove the 'Unit Test' task of workflow.
FlechazoW Sep 28, 2022
d35e785
[hotfix-#1289][jdbc-base] change column size used (#1290)
liumengkai Sep 30, 2022
37c1d28
[Hotfix][POM] Fix the missing dependency, and rename. (#1291)
FlechazoW Sep 30, 2022
6b4add6
[feat-#1284][jdbc]1.get metadata from resultSetMetaData 2.support cus…
Paddy0523 Oct 1, 2022
a2f6b22
[feat-#1293][chunjun-connector-hdfs] add assembleFieldProps for hdfs-…
liumengkai Oct 9, 2022
663febe
[feat-#1295][e2e]add ftp container (#1296)
mggger Oct 9, 2022
84776cc
[bin] display Reference site while submitting job. (#1299)
lvyanquan Oct 11, 2022
f27cbdd
[Improve][Connector][Kafka] update com.alibaba:fastjson 1.2.79 to 1.2…
645775992 Oct 13, 2022
4881c4d
[hotfix-#1304][binlog] Adjust binlog dependency. (#1305)
qumaosihaozi Oct 13, 2022
6db1f24
update org.apache.hive:hive-exec 3.1.1 to 3.1.3 (#1310)
vvsd Oct 14, 2022
cdb3e04
update com.amazonaws:aws-java-sdk-s3 1.11.1001 to 1.12.261 (#1308)
vvsd Oct 14, 2022
b044c34
update com.fasterxml.jackson.dataformat:jackson-dataformat-cbor 2.9.1…
vvsd Oct 14, 2022
1fb6f1c
update com.jcraft:jsch 0.1.51 to 0.1.54 (#1311)
lvyanquan Oct 14, 2022
8b037c0
[Improve][README.md] Update the description of 'ChunJun'. (#1326)
FlechazoW Oct 17, 2022
e7abe26
[Improve][Readme] Add Slack.
FlechazoW Oct 17, 2022
41e6489
[feat][jdbc-#1300]Set the parameter 'pollingFromMax=true' so that the…
Paddy0523 Oct 18, 2022
c8ca2a6
[Improve][Assembly] Adjust the output and package of assembly. (#1327)
FlechazoW Oct 18, 2022
c09a4c1
[doc-#1329][chunjun-connector-kafka] doc problem (#1330)
liumengkai Oct 19, 2022
b3ec771
[Feature][CDC] support mysql cdc (#1332)
liugddx Oct 22, 2022
00d280f
[Improve][Licenses] Add Apache 2.0 license. (#1335)
FlechazoW Oct 22, 2022
6be6935
[Feature][DDL] Support for processing DDL data. (#1288)
FlechazoW Oct 24, 2022
69ad566
[Improve][standalone-#1338]Remove classpath, userJars, and Artifacts …
Paddy0523 Oct 24, 2022
a62b374
[Improve][Connector][HDFS] Fix the path problem of writing to HDFS. (…
zhengchaoken Oct 24, 2022
49f97e0
[Improve][DDL][POM] Change the scope of 'ddl-base' to 'compile' and c…
FlechazoW Oct 24, 2022
26a3ca5
[HotFix][CORE] Fix the mistaken logic of judging ddl conf. (#1343)
FlechazoW Oct 24, 2022
027eb63
[HOTFIX][DDL-Base] Fix the error that the antrun-maven plugin moves t…
FlechazoW Oct 24, 2022
d809666
[HOTFIX][DDL-Base] Fix the error that 'mvn package' failed. (#1345)
FlechazoW Oct 24, 2022
2c88dea
[hotfix][mysql][e2e] mysql silent unclassified size copy,table names …
chaozwn Oct 24, 2022
57437ce
[Improve][core] Change all common lang packages to common lang3 packa…
chaozwn Oct 24, 2022
52f8f3e
[doc] add notes about starting a Flink standalone cluster with chunju…
lvyanquan Oct 25, 2022
dde6452
[Improve][License] File add license. (#1349)
FlechazoW Oct 26, 2022
0052d8d
[Improve][Connector][Doris] Improve doris source. (#1359)
FlechazoW Oct 27, 2022
7b4d788
[Improve][Connector][ES7] es7 connector fix support keyword type (#1361)
fangxy-7010 Oct 27, 2022
8395d05
chore: typo fix of readme (#1365)
wey-gu Oct 30, 2022
3958a70
[Feature][Connector] sql type data type,add [ROW,ARRAY,MAP,MULTISET] …
gaoasi Oct 31, 2022
f6ab2fb
[Hotfix][Connector] Fix the jvm throws "java.lang.SecurityException: …
FlechazoW Nov 1, 2022
c9fd382
[feature-#1353][kafka-connector] add value deocder (#1371)
liumengkai Nov 3, 2022
2b088ad
[Improve][Connector][FTP] Reactor "ftp-connector", supports ftp read …
FlechazoW Nov 4, 2022
65c25e0
[Feat-#1368][Connector][logminer]add enableFetchAll (#1369)
mggger Nov 4, 2022
47fa8d7
[Improve-#1379][ftp][docs] add maxFetchSize (#1380)
mggger Nov 4, 2022
12dc5e7
[hotfix][core] fix in local dev run sql mode can't load core jar. (#1…
chaozwn Nov 5, 2022
9ece5fb
[hotfix][connector][ftp]fix ftp sql job run error (#1382)
fangxy-7010 Nov 6, 2022
67604a0
[Improve][License] Add apache-2.0 license check. (#1386)
FlechazoW Nov 8, 2022
9fcfde3
[hotfix][jdbc-connector] pgsql query metadata exception (#1391)
kinoxyz1 Nov 11, 2022
964388b
[bugfix][hana]fix hana special char error (#1390)
fangxy-7010 Nov 11, 2022
ecc9b8b
[Feat-#1392][core] add parameters in json format (#1393)
aubdiy Nov 12, 2022
1248cc2
[Improve][Connector][bin-log] Unified exception of MapMakerHelper (#1…
TyrantLucifer Nov 14, 2022
43e8893
[Doc][#1402] fix '\r' problems caused by windows (#1403)
zhengchaoken Nov 17, 2022
a452025
fix issue:hdfs inputformat split columns issues and deal with null va…
conghe2402 Nov 18, 2022
3ae4a9f
fix BUG #1398,fix bsh,xml-resolver default version cannot access (#1399)
zhengchaoken Nov 18, 2022
fd449ca
fix BUG #1400,fix multiple SLF4J bindings & no log logged in standalo…
zhengchaoken Nov 18, 2022
703f79c
[bugfix][hbase]fix hbase date type (#1406)
fangxy-7010 Nov 20, 2022
a924b98
[hotfix][hdfs]when writing to hdfs, null value is set to '\N' (#1408)
conghe2402 Nov 22, 2022
41cb73a
[doc-#1415] update doc & starrocks batchsize (#1417)
liumengkai Dec 1, 2022
c664cc2
[Improve][Clinet-#1426] delete tmp flink-distribute-cache-xxx dir aft…
liumengkai Dec 4, 2022
1c9c789
[Improve][Hive] Add Hive table check and correct function (#1425)
conghe2402 Dec 4, 2022
91c3bd4
[Improve][Connector][Hive] add hive table check and correct function…
conghe2402 Dec 5, 2022
0784968
[Improve][Client] Chunjun client support submit task to hadoop with k…
kyo-tom Dec 7, 2022
d5b4643
[Hotfix][CDC] Fix:mysql-cdc can't run in sql mode (#1436)
Bricks-Man Dec 7, 2022
6bb1615
[BugFix-#1334][hdfs-connector] fix orc timestamp/date column can't re…
liumengkai Dec 9, 2022
bc190ce
[hotfix-#1449][ClickHouse] fix ClickHouse source null pointer problem…
ll076110 Dec 20, 2022
d3db08b
[Feature-#1451] add column replace for hbase column (#1452)
liumengkai Dec 21, 2022
3c72eae
[feat-#1455] fix hbase bug & add hbase ttl (#1456)
liumengkai Jan 3, 2023
1d87b29
[BugFix][Postgres][#1463] The cast is bad, only when 'rowConverter' i…
FlechazoW Jan 5, 2023
0db36b8
[BugFix][Jdbc][#1459] Remove the 'checkConnValid', because some conne…
FlechazoW Jan 5, 2023
df98c32
[Bug- #1473 ][chunjun-clients] fix Logic error in confProp parameter …
ChangjunZhang Jan 10, 2023
9d06b7d
[feat-#1470][ftp] improvement ftp read/write performance (#1483)
mggger Jan 11, 2023
8ff95f2
[BugFix][hbase-connector][#1485] hbase ttl millisecond not second (#1…
liumengkai Jan 13, 2023
afc7d51
[feat][jdbc]improvement jdbc read/write performance (#1488)
Paddy0523 Jan 28, 2023
de5b214
[feat-#1487][iceberg]add iceberg writer (#1489)
mggger Jan 29, 2023
58fbb3b
#1494 [feat-1494][http] http support array data (#1495)
yanghuaiGit Feb 6, 2023
d65793b
[hotfix-#1497][chunjun-connector-http]Solve the problem that http-x p…
taoyameng Feb 13, 2023
83c10de
[feat-#1498][main] support run sql job with batch mode when set runMo…
Paddy0523 Feb 16, 2023
8179a6c
[bug][http] commonConf NullPointerException #1510 (#1511)
kinoxyz1 Feb 17, 2023
a26621f
[hotfix-#1512][mongodb] Fix the bug that mongodb supports constants (…
ll076110 Feb 17, 2023
ecd926a
[hotfix-#1501]fix throw NoRestartException can not sotp application (…
zhourui999 Feb 17, 2023
5a516ed
[Feature] Upgrade flink version to 1.16.1 (#1430)
FlechazoW Feb 17, 2023
fbc6d82
[hotfix][http]Solve the separator and cause the dynamic table to fail…
wilson-1024 Feb 18, 2023
0327816
[Readme] Update the supported flink version of master.
FlechazoW Feb 18, 2023
a4973f9
[hotfix-#1518][mongodb] fix mongodb read data not support objectId ty…
ll076110 Feb 22, 2023
6ac872c
[Feature][connector][selectdb] add selectdb cloud connector (#1523)
gnehil Feb 28, 2023
395d33c
[feat-#1525][core] sql mode supports set syntax (#1526)
libailin Feb 28, 2023
082d307
[Improvement][assembly] the chunjun-clients.jar cannot be found after…
alldatafounder Mar 2, 2023
39b207f
[Feature][Connector] Add kafka connector. (#1554)
FlechazoW Mar 18, 2023
5c0fec6
[hotfix-#1553][jdbc]Fixed an issue where EndLocation was not set when…
Paddy0523 Mar 20, 2023
cdedbf1
[hotfix-#1559][jdbc-connector] remove redundant comma of querySplitRa…
lvyanquan Mar 22, 2023
bf52257
[hotfix-#1567][ftp] Fix data missing when synchronizing data from sou…
xiuzhu9527 Mar 24, 2023
37d20b4
#1571 The feNodes parameter cannot be empty. The array is not checked…
yanghuaiGit Mar 24, 2023
efac92a
[hotfix-#1575][sybase] sybase support double precision type (#1576)
liangweixiong Mar 24, 2023
ce5a9fe
[hotfix-#1568][sqlserver] if write column is not have identity column…
fengfangwei Mar 24, 2023
ccc331c
[hotfix-#1577][sqlservercdc]Reacquire a connection when it is not ava…
Paddy0523 Mar 26, 2023
8ffec11
[hotfix-#1579][sybase] fix sybase not support sysname type (#1580)
ll076110 Mar 27, 2023
ce1aca2
[hotfix-#1583][hdfs]Fixed HdfsPathFilter No parameter construction (#…
libailin Mar 28, 2023
d0e2404
[hotfix-1581][jdbc-base] fix the problem that polling sometimes may d…
zoudaokoulife Mar 29, 2023
064032c
[feat-#1586][hdfs]Fixed the problem of escaping the field delimiter (…
libailin Mar 29, 2023
a600467
[hotfix-#1589][doris]Fixed When the written data contains commas, a s…
libailin Mar 29, 2023
7737495
[hotfix-#1564][clickhouse] fix clickhouse not support transaction. (#…
zhiqiang-dev Mar 30, 2023
b045100
[hotfix-#1591][core] Fixed Error ChunJunSqlParseException is reported…
libailin Mar 30, 2023
7e3f64e
[feat-#1594][jdbc]Optimize the acquisition of metadata and index info…
Paddy0523 Apr 2, 2023
adbcc18
[hotfix-#1596][core] Solve the problem that yarn-per-job sql mode doe…
libailin Apr 2, 2023
de6c1ad
[Hotfix][Oceanbase] Fix oceanbase can not read data. (#1599)
FlechazoW Apr 4, 2023
21b7563
[Improve] Add IssueNavigationLink for IDEA (#1600)
lvyanquan Apr 4, 2023
d7a1cc1
[hotfix-#1601][core] Fixed Statistical indicator information is not o…
libailin Apr 5, 2023
74aaf9c
[feat-#1603][jdbc]The sql mode supports filter conditions, custom que…
libailin Apr 6, 2023
54e83be
[hotfix-#1605][core] sql mode supports call initializeGlobal、finalize…
libailin Apr 11, 2023
b7e619b
[hotfix-#1610][core]Fixed the sql parsing error of sink post-sql cont…
libailin Apr 11, 2023
1581168
[github] Add labeler for pull-request (#1621)
lvyanquan Apr 14, 2023
c6f20ac
[feat-#1619][core] Optimize set syntax to not take effect, Optimize t…
libailin Apr 14, 2023
6d61075
[hotfix-#1625][chunjun] compile master branch error: NoSuchMethodErro…
zhengchaoken Apr 15, 2023
33bbb94
[hotfix-#1627][mysql] fixed dependency problem , Upgrade mysql connec…
libailin Apr 17, 2023
6655dc0
[hotfix-#1629][client]fixed NullPointerException in local mode. (#1631)
losesinal Apr 19, 2023
ef5be42
[feat-#1632][jdbc]Solve ClassCastException, optimize the problem of i…
libailin Apr 19, 2023
bac9fca
[hotfix-#1652][core]Fix problems in various operating modes (#1655)
ll076110 May 6, 2023
2a6814a
[feat-#1647][hdfs] Support to generate an empty file with a specified…
libailin May 8, 2023
a49a44c
[feat-#1649][hive] Support jdbc mode to read hive (#1658)
libailin May 11, 2023
a4c473b
[Feature][Connector][Kingbase] Add kingbase connector. (#1663)
FlechazoW May 12, 2023
ff56a5b
[Hotfix-#1662][connector][jdbc] implementation provided for SupportsP…
libailin May 15, 2023
2098130
[Hotfix-#1667][connector][starrocks] fixed get routings null pointer …
libailin May 15, 2023
f47c93f
[Feature-#1670][core] Support yarn log output dirty data details (#1671)
libailin May 16, 2023
5f834fd
[Improve][JDBC]jdbcOutputFormat use statementWrapper (#1676)
Paddy0523 May 18, 2023
e26a186
[hotfix-#1674][connector][hdfs] fixed Unexpected end of input stream
libailin May 18, 2023
f391543
[Hotfix-#1673][Emqx] Fix EmqxRowConverter.toExternal NullPointerExcep…
bianqi520 May 19, 2023
14c2f80
[feature][connector][hudi] add hudi json write function (#1665)
xiaoyuWang312 May 19, 2023
9952690
[Improve][core]support type precision and scale (#1678)
Paddy0523 May 19, 2023
419f9e5
[feature-#1680][connector][kafka]A null pointer exception occurs afte…
kinoxyz1 May 23, 2023
06a4190
[feature][connector][hudi] add hudi json read function and sql read/w…
yc576192 May 23, 2023
2ad9505
[hotfix-#1682][connector][hive] fixed hive jdbc read timed out (#1684)
libailin May 24, 2023
b02e74f
[hotfix][test]Fix test problems caused by type enhancement
Paddy0523 May 25, 2023
46393fd
[feature-#1691][connection][starrocks] A null pointer exception occur…
kinoxyz1 May 31, 2023
ad4d98b
[hotfix-#1697][connector][ftp] fixed unsupported options (#1700)
libailin Jun 1, 2023
3a874cc
[hotfix-#1701][connector][ftp] fixed Read timed out (#1703)
libailin Jun 5, 2023
b230914
[hotfix-#1704][core] Fix json script deserialization error (#1705)
Paddy0523 Jun 5, 2023
af4ee6e
[feature-#1690][connection][arctic] added arctic connector (#1696)
kinoxyz1 Jun 5, 2023
dcb5e1b
[hotfix-#1711][Binlog] Adapt to binlog plugin (#1712)
ll076110 Jun 7, 2023
a1f1207
[hotfix-#1708][MongoDB]Fix the field type null pointer problem of the…
ll076110 Jun 7, 2023
6b79e62
[hotfix-#1706][connector][elasticsearch7] Add write mode, add support…
libailin Jun 7, 2023
2cf657f
[hotfix-#1714][saphana]fix upsert sql equalCondition (#1715)
lvyanquan Jun 7, 2023
cfd8e68
[Feature-#1672][connector][gbase] add gbase connector (#1716)
libailin Jun 9, 2023
569412e
[hotfix-#1724] [connector][hdfs]fix BaseHdfsOutputFormat CannotObtain…
david-gao1 Jun 11, 2023
7d8f265
[hotfix-#1710][connector][dm][elasticsearch7] fixed not found depende…
libailin Jun 11, 2023
9fae82e
[Github-Action] Enable github ci/cd. (#1686)
FlechazoW Jun 19, 2023
7950b2f
[hotfix-#1743][kudu] Solving the problem of ineffective parallelism i…
fengfangwei Jun 27, 2023
d951d21
[hotfix-#1729][connector][jdbc-base] fixed isValid AbstractMethodErro…
libailin Jun 14, 2023
410ba3a
[hotfix-#1748][starrocks]Added configuration for isCacheTableStruct a…
Paddy0523 Jun 28, 2023
fc502b2
[hotfix-#1753][core]Add jobid and taskNumber to the local path of the…
Jun 29, 2023
bca3071
[hotfix-#1756][mysql]Fixed a decimal type precision calculation issue…
liangweixiong Jun 30, 2023
6886e6c
[hotfix][oceanbase] fix value converter and buffer flush (#1747)
whhe Jun 30, 2023
f98ee82
[feature-#1720][connection][mongodb] Support mongodb sql mode (#1732)
david-gao1 Jun 30, 2023
7da0d7a
[hotfix-#1718][core] Dirty data is collected for all slots, not for a…
david-gao1 Jun 30, 2023
efca7d3
[hotfix-#1750][connector][elasticsearch7] fixed Unable to parse respo…
libailin Jul 4, 2023
8f676eb
[hotfix-#1741][connector][jdbc] throw query interrupted exception
libailin Jul 4, 2023
a05900e
[feature][website] migrate documentation projects
Zaoei Jul 11, 2023
264efc2
[hotfix-#1765][chunjun-connector-jdbc-base] failed to consume oracle …
david-gao1 Jul 24, 2023
d1608c4
[hotfix-#1771] [connector][starrocks] The sr table was not partitione…
david-gao1 Jul 27, 2023
df8d8bb
[Feature-#1781][connector] [doris] supports doris pre-sql and post-sq…
david-gao1 Aug 4, 2023
74c1591
[Feature-#1784][connector][starrocks] Support running pre-execution a…
libailin Aug 9, 2023
3d596cd
hotfix-#1795][hdfs] fix sink hdfs bug (#1796)
zhourui999 Aug 24, 2023
b1f79d6
[Feature-#1787]Support hadoop 3 compilation and packaging
libailin Aug 15, 2023
2fb4967
[hotfix-#1799][connector][jdbc] Fix related issues when the write mod…
libailin Sep 13, 2023
45adcc0
[hotfix-#1811][connector][mongodb] Fixed missing dependencies (#1812)
libailin Sep 21, 2023
63297e9
[hotfix-#1814][chunjun-connector-oracle] Consuming oracle data incorr…
david-gao1 Sep 21, 2023
da35245
[hotfix-#1816][connector-oracle] fix NullPointerException when oracle…
tangguol Sep 21, 2023
49c6873
[hotfix-#1823][connector][oracle] oracle Connector incorrectly consum…
david-gao1 Sep 21, 2023
5109c2d
[hotfix-#1827][kudu]Fix flinksql kudu write mode parameter does not t…
ll076110 Sep 25, 2023
8d105fc
[hotfix-#1825][hdfs]Synchronizing text and parquet table data, the sp…
ll076110 Sep 25, 2023
0e6a442
[hotfix-#1829][chunjun] Fixed view checkpoints error report
libailin Sep 28, 2023
d7d2c5c
[fix-#1832][dirty] Fixed Prometheus nErrors failing to synchronize la…
tangguol Oct 13, 2023
e5c0066
[hotfix-#1834][connector][kafka] Fixed missing dependencies (#1835)
libailin Oct 17, 2023
f4402f0
[hotfix-#1745][connector][hdfs][hive] Data loss occurs when multiple …
Nov 1, 2023
2d5f489
[Feature-#1842][ftp] Added compress and write mode when writing, fixe…
libailin Nov 23, 2023
41b96a8
[hotfix-#1849][jdbc] fixed load data using lru method is empty, hide …
libailin Nov 28, 2023
3a72ca9
[bugfix][jdbc] fix uniqueKey NPE
kyo-tom Dec 15, 2023
41989a8
[Feature-#1851][socket] Support reading data from socket connector in…
libailin Dec 11, 2023
9bbdb45
[hotfix-#1853] [connector jdbc] jdbc toInternal methods should proces…
Dec 18, 2023
eabf986
[hotfix-1856] [chunjun-core] Fix the problem that oss's secret shoul…
AliceXiaoLu Dec 14, 2023
786f68a
[Feature-#1862][s3] Added support for reading compressed format files…
libailin Jan 26, 2024
38fed40
[hotfix-#1869] [connector-jdbc-base] Using Collections.singletonList …
Feb 2, 2024
3370267
[hotfix-1881][ddl]resolve maven package failed
Feb 21, 2024
6f890f7
[hotfix-1881][ddl]resolve maven package failed
Feb 21, 2024
56da29c
[chunjun-core] bug fix for local mode.
zoudaokoulife Feb 20, 2024
155466e
[chunjun-core] bug fix for local mode.
zoudaokoulife Feb 20, 2024
8bdbd44
[chunjun-core] bug fix for local mode.
zoudaokoulife Feb 20, 2024
8d80354
[chunjun-test] fix test
zoudaokoulife Feb 21, 2024
03ab05a
[chunjun-server] add session monitor, and auto deploy session,add res…
zoudaokoulife Feb 22, 2024
994c2d1
[Feature-#1877][ftp] Supports reading Chinese paths and optimizing re…
libailin Mar 1, 2024
bf9458e
[Feature-#1889][ftp] read support column index and sheetNO
libailin Mar 13, 2024
3a3f015
[Feature-#1886][hbase] New features in sql mode
libailin Mar 26, 2024
01dac19
[Feature-#1899][connector][mysql] The connector supports MySQL Driver…
Jun 13, 2024
6fdd77a
[Feature-#1897][gbase8s] Added gbase8s connector and gbasehk connector
libailin Jun 6, 2024
a4b34fd
[doc]update dingding.jpg
Jun 25, 2024
90bda68
[doc]update dingding.jpg
Jun 25, 2024
0f27a50
[doc]gbasedbtjdbc_3.5.1.jar deopendency
Jun 25, 2024
b43f897
[doc]update github url
Jun 26, 2024
2dcd8db
[Feature-#1897][gbasehk] annotation gbasehk connector
libailin Jun 26, 2024
1028750
[Feature][chunjun-core] Supports capturing dirty data from the source…
Jun 25, 2024
ec13b28
[hotfix-1906][hbase]#1906 resolve hbase unit test failed
Jul 26, 2024
849a052
[hotfix-#1904][sqlserver] fixed No suitable driver found for jdbc jtds
libailin Jul 1, 2024
e624fb4
[hotfix-1908][chunjun-connector-starrocks]: starrocks data size check
kinoxyz1 Jul 29, 2024
e24b617
[hotfix-1908][chunjun-connector-starrocks]: starrocks data size check
kinoxyz1 Jul 30, 2024
284c84f
[hotfix-#1911][starrocks] fixed stream load failed do not throw excep…
libailin Aug 8, 2024
dfa3f7f
[Improve-#1914][chunjun-connector-clickhouse]Added support for map<st…
Aug 13, 2024
33c14a5
[Bug][chunjun-connectors] jdbc's properties not work where jdbc's rea…
AliceXiaoLu Feb 21, 2024
707e461
[Feature-#1918][s3] Add support for reading all types of documents su…
libailin Sep 20, 2024
5432e78
[Feature-#1920][kingbase] fixed syntax error at or near "t1"
libailin Sep 25, 2024
1d77727
[Feature-#1924][opengauss] Add opengauss connector
libailin Oct 16, 2024
b040670
modified qrcode for community group.
Mar 5, 2025
fec0edf
[Feature-#1933][s3] Support more data type conversions
libailin Nov 29, 2024
b4a9ca4
[Feature-#1925][Module core]Support null serialization of JSON data t…
Oct 9, 2024
09f2316
update org.xerial.snappy:snappy-java 1.1.4 to 1.1.10.1
ChengDaqi2023 Sep 6, 2023
3b3cf33
[Bug][chunjun-connectors] jdbc's properties not work where jdbc's rea…
AliceXiaoLu Nov 4, 2025
47e517f
fix: Fixed conflicts between flink-table-planner-loader and flink-tab…
MYiYang Nov 17, 2025
b24ea69
[hotfix-1786][chunjun-metrics-prometheus] Fix uploading of startLocat…
Icarus-Alpha Nov 17, 2025
77a30fe
Fix JSON parsing stack overflow vulnerabilities (#1939)
scyt01 Nov 17, 2025
eb016bf
Revert "Fix JSON parsing stack overflow vulnerabilities (#1939)" (#1942)
yanghuaiGit Nov 17, 2025
8204be8
[feature-#1926] add paimon dependency (#1943)
lowrockbecomebetter Nov 19, 2025
1791a19
[hotfix-#1821][hdfs]Modify orc file calculation method (#1822)
ll076110 Nov 21, 2025
d39ce22
[Feature-#1946][opengauss] Fix the issue of compilation failure (#1947)
yanghuaiGit Nov 24, 2025
d7570c7
[Feature-#1944][OceanBase]support MysqlMode and Oracle Mode (#1945)
yanghuaiGit Dec 1, 2025
24b9713
[Feature-#1948][doris] performance and resource optimization (#1949)
yanghuaiGit Dec 1, 2025
a3d8d32
[feature-#1926] add paimon dependency (#1943)
Dec 1, 2025
e5ca758
[hotfix-#1952][core|doris] Fix ARRAY and LARGEINT type conversion exc…
zhiqiang-dev Dec 1, 2025
e77873f
[hotfix-#1954][kafka] binlog -> kafka support partition by, add parti…
zhiqiang-dev Dec 1, 2025
c956d25
[feature-#1955]jdbcConf adds default optimization parameters (#1959)
yanghuaiGit Dec 2, 2025
d6dc136
[hotfix-#1954][kafka]remove vcs.xml
Dec 2, 2025
60bc4eb
[hotfix-#1960][kafka] KafkaSyncConverter construct parameter transmis…
zhiqiang-dev Dec 2, 2025
b5d9c0d
[hotfix-#1847][chunjun-connector-kafka] DynamicKafkaSerializationSche…
zhiqiang-dev Dec 2, 2025
cff5fbf
[hotfix-#1960][kafka] KafkaSyncConverter construct parameter transmis…
zhiqiang-dev Dec 2, 2025
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.
154 changes: 154 additions & 0 deletions .github/labeler.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,154 @@
#
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
# Pull Request Labeler Github Action Configuration: https://github.com/marketplace/actions/labeler
INFRA:
- .asf.yaml
- .gitattributes
- .gitignore
- .baseline/**/*
- .github/**/*
- dev/**/*
BUILD:
- build/*
DOCS:
- docs/**/*
- "**/*CHANGELOG.md"
- "**/*README.md"
- "**/*CONTRIBUTING.md"
- chunjun-examples/**/*
ASSEMBLY:
- chunjun-assembly/**/*
CLIENTS:
- chunjun-clients/**/*
CORE:
- chunjun-core/**/*
DDL:
- chunjun-ddl/**/*
DIRTY:
- chunjun-dirty/**/*
DOCKER:
- chunjun-docker/**/*
E2E:
- chunjun-docker/**/*
LOCAL_TEST:
- chunjun-local-test/**/*
METRICS:
- chunjun-metrics/**/*
RESTORE:
- chunjun-restore/**/*
BINLOG:
- chunjun-connectors/chunjun-connector-binlog/**/*
CASSANDRA:
- chunjun-connectors/chunjun-connector-cassandra/**/*
CLICKHOUSE:
- chunjun-connectors/chunjun-connector-clickhouse/**/*
DB2:
- chunjun-connectors/chunjun-connector-db2/**/*
DM:
- chunjun-connectors/chunjun-connector-dm/**/*
DORIS:
- chunjun-connectors/chunjun-connector-doris/**/*
ELASTICSEARCH6:
- chunjun-connectors/chunjun-connector-elasticsearch6/**/*
ELASTICSEARCH7:
- chunjun-connectors/chunjun-connector-elasticsearch7/**/*
ELASTICSEARCH:
- chunjun-connectors/chunjun-connector-elasticsearch-base/**/*
EMQX:
- chunjun-connectors/chunjun-connector-emqx/**/*
FILE:
- chunjun-connectors/chunjun-connector-file/**/*
FTP:
- chunjun-connectors/chunjun-connector-ftp/**/*
GREENPLUM:
- chunjun-connectors/chunjun-connector-greenplum/**/*
HBASE2:
- chunjun-connectors/chunjun-connector-hbase2/**/*
HBASE-1.4:
- chunjun-connectors/chunjun-connector-hbase-1.4/**/*
HBASE:
- chunjun-connectors/chunjun-connector-hbase-base/**/*
HDFS:
- chunjun-connectors/chunjun-connector-hdfs/**/*
HIVE:
- chunjun-connectors/chunjun-connector-hive/**/*
HIVE3:
- chunjun-connectors/chunjun-connector-hive3/**/*
HTTP:
- chunjun-connectors/chunjun-connector-http/**/*
ICEBERG:
- chunjun-connectors/chunjun-connector-iceberg/**/*
INFLUXDB:
- chunjun-connectors/chunjun-connector-influxdb/**/*
JDBC:
- chunjun-connectors/chunjun-connector-jdbc/**/*
KAFKA:
- chunjun-connectors/chunjun-connector-kafka/**/*
KUDU:
- chunjun-connectors/chunjun-connector-kudu/**/*
MONGODB:
- chunjun-connectors/chunjun-connector-mongodb/**/*
MYSQL:
- chunjun-connectors/chunjun-connector-mysql/**/*
MYSQL-CDC:
- chunjun-connectors/chunjun-connector-mysqlcdc/**/*
MYSQLD:
- chunjun-connectors/chunjun-connector-mysqld/**/*
NEBULA:
- chunjun-connectors/chunjun-connector-nebula/**/*
OCEANBASE:
- chunjun-connectors/chunjun-connector-oceanbase/**/*
OCEANBASE-CDC:
- chunjun-connectors/chunjun-connector-oceanbasecdc/**/*
ORACLE:
- chunjun-connectors/chunjun-connector-oracle/**/*
ORACLELOGMINER:
- chunjun-connectors/chunjun-connector-oraclelogminer/**/*
POSTGRESQL:
- chunjun-connectors/chunjun-connector-postgresql/**/*
RABBITMQ:
- chunjun-connectors/chunjun-connector-rabbitmq/**/*
REDIS:
- chunjun-connectors/chunjun-connector-redis/**/*
ROCKETMQ:
- chunjun-connectors/chunjun-connector-rocketmq/**/*
S3:
- chunjun-connectors/chunjun-connector-s3/**/*
SAPHANA:
- chunjun-connectors/chunjun-connector-saphana/**/*
SELECTDB:
- chunjun-connectors/chunjun-connector-selectdb-cloud/**/*
SOCKET:
- chunjun-connectors/chunjun-connector-socket/**/*
SOLR:
- chunjun-connectors/chunjun-connector-solr/**/*
SQLSERVER:
- chunjun-connectors/chunjun-connector-sqlserver/**/*
SQLSERVER-CDC:
- chunjun-connectors/chunjun-connector-sqlservercdc/**/*
STARROCKS:
- chunjun-connectors/chunjun-connector-starrocks/**/*
STREAM:
- chunjun-connectors/chunjun-connector-stream/**/*
SYBASE:
- chunjun-connectors/chunjun-connector-sybase/**/*
VERTICA:
- chunjun-connectors/chunjun-connector-vertica11/**/*


28 changes: 28 additions & 0 deletions .github/workflows/approve-label-trigger.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,28 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#

name: Label-when-reviewed
on: pull_request_review
jobs:

label-when-reviewed:
name: "Label PRs when reviewed"
runs-on: ubuntu-latest
steps:
- name: "Do nothing. Only trigger corresponding workflow_run event"
run: echo
64 changes: 64 additions & 0 deletions .github/workflows/approve-label.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,64 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#

name: "Label when approved workflow run"
on:
workflow_run:
workflows: [Label-when-reviewed]
types: [requested]
permissions:
# All other permissions are set to none
checks: write
contents: read
pull-requests: write
jobs:
label-when-approved:
name: "Label when approved"
runs-on: ubuntu-latest
outputs:
isApprovedByCommitters: ${{ steps.label-when-approved-by-committers.outputs.isApproved }}
isApprovedByAnyone: ${{ steps.label-when-approved-by-anyone.outputs.isApproved }}
steps:
- name: "Checkout ${{ github.ref }} ( ${{ github.sha }} )"
uses: actions/checkout@v2
with:
persist-credentials: false
submodules: recursive
- name: "Get information about the original trigger of the run"
uses: ./.github/actions/get-workflow-origin
id: source-run-info
with:
token: ${{ secrets.GITHUB_TOKEN }}
sourceRunId: ${{ github.event.workflow_run.id }}
- name: Label when approved by committers
uses: ./.github/actions/label-when-approved-action
id: label-when-approved-by-committers
with:
token: ${{ secrets.GITHUB_TOKEN }}
label: 'approved'
require_committers_approval: 'true'
remove_label_when_approval_missing: 'true'
pullRequestNumber: ${{ steps.source-run-info.outputs.pullRequestNumber }}
- name: Label when approved by anyone
uses: ./.github/actions/label-when-approved-action
id: label-when-approved-by-anyone
with:
token: ${{ secrets.GITHUB_TOKEN }}
label: 'reviewed'
pullRequestNumber: ${{ steps.source-run-info.outputs.pullRequestNumber }}
remove_label_when_approval_missing: 'true'
84 changes: 84 additions & 0 deletions .github/workflows/build.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,84 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.

name: Check Code.

on:
push:
branches:
- master
pull_request:
paths-ignore:
- 'chunjun-docker/**/*'
- 'chunjun-examples/**/*'
- 'chunjun-dev/**/*'
- '**/*.md'
- 'docs/**/*'
- 'website/**/*'
- '**/*.ftl'

concurrency:
group: backend-${{ github.event.pull_request.number || github.ref }}
cancel-in-progress: true

jobs:
spotless-check:
if: github.repository =='DTStack/chunjun'
name: Check code style with spotless.
runs-on: ubuntu-latest
timeout-minutes: 10
steps:
- name: Checkout code
uses: actions/checkout@v3
with:
submodules: true
- name: Set up JDK 8
uses: actions/setup-java@v3
with:
java-version: 8
distribution: 'temurin'
cache: 'maven'
- name: Spotless Check
run: |
./mvnw spotless:check

build:
if: github.repository =='DTStack/chunjun'
name: Build the project.
needs: [ spotless-check ]
runs-on: ubuntu-latest
timeout-minutes: 90
steps:
- uses: actions/checkout@v3
- name: Set up JDK 8
uses: actions/setup-java@v3
with:
java-version: 8
distribution: 'temurin'
cache: 'maven'
- name: add dependencies
- name: build project
run: |
./mvnw clean package -Dmaven.test.skip --no-snapshot-updates
- name: unit-test
run: |
./mvnw -T 1C clean compile test -DskipUT=false -DskipITCase=false --no-snapshot-updates
- name: integration-test
run: |
./mvnw -T 1C -B verify -DskipUT=true -DskipIT=false --no-snapshot-updates -pl chunjun-e2e -am
env:
MAVEN_OPTS: -Xmx2048m
46 changes: 46 additions & 0 deletions .github/workflows/docs-deploy.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,46 @@
name: docs deploy.

on:
push:
branches:
- master
paths:
- "website/**/*"
- "docs/**/*"
pull_request:
branches:
- master
paths:
- "website/**/*"
- "docs/**/*"

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

jobs:
build:
if: github.repository =='DTStack/chunjun'
name: Deployment help document.
runs-on: ubuntu-latest
timeout-minutes: 10
steps:
- uses: actions/checkout@v3
- name: Setup node
uses: actions/setup-node@v3
with:
node-version: 16
cache: yarn
cache-dependency-path: website/yarn.lock
- name: build
working-directory: website
run: |
yarn install --frozen-lockfile
yarn build
yarn export
- name: Deploy
uses: JamesIves/github-pages-deploy-action@v4
with:
branch: gh-pages
folder: website/out

Loading