Skip to main content
Version: Next

JDBC

Description

The JDBC Source connector reads tables or custom query results from databases through a JDBC driver. It supports column projection, row filtering, parallel snapshot reads, and reading multiple tables in one source configuration.

JDBC Source is a bounded source: it reads the rows visible to the database query and then finishes. Use a CDC connector instead when the job must continue capturing later inserts, updates, and deletes.

If this is your first JDBC Source job, start with Choose a read mode and the Quick start. The complete option reference follows those sections.

Using Dependency

Install the connector-jdbc plugin first:

--seatunnel-connectors--
connector-jdbc
--end--
cd "${SEATUNNEL_HOME}"
sh bin/install-plugin.sh

JDBC driver licenses and redistribution terms vary by database vendor, and the driver version must be compatible with both the database and the Java runtime. SeaTunnel therefore does not bundle every JDBC driver. Download the appropriate driver yourself and place its JAR in the engine-specific directory below before starting the job.

Place the JDBC driver in ${SEATUNNEL_HOME}/plugins/Jdbc/lib/ on every node that runs SeaTunnel.

Zeta engine

Place the JDBC driver in ${SEATUNNEL_HOME}/lib/ on every SeaTunnel node, then restart the affected SeaTunnel processes so the driver is loaded.

See the driver reference for common driver class names and download locations.

Choose a read mode

Choose a single-table or multi-table layout before configuring parallelism. In the single-table layout, table_path and query can be used separately or together. The multi-table table_list layout is mutually exclusive with top-level table_path and query.

Use caseConfigurationBehavior
Read one table with automatic schema discovery and dynamic splittingtable_pathRecommended for a full-table snapshot. SeaTunnel reads table metadata and uses split.size when the table has a usable split key.
Control selected columns, joins, or database-side expressionsquery, optionally with table_pathSeaTunnel executes the SQL you provide. Add table_path when explicit table identity and metadata are also needed. Query key inference is unsafe for some joins; see Query and primary-key caution.
Read multiple tables or table-name patternstable_listEach entry can define table_path, an optional query, and split settings. Top-level table_path and query cannot be used together with table_list.

Use where_condition only for a common filter that should be added to every selected table or query. Its value must start with where, for example where updated_at >= '2026-01-01'.

Quick start: PostgreSQL

This example reads three rows from PostgreSQL and prints them to the SeaTunnel log.

  1. Put a compatible PostgreSQL JDBC driver in the directory described in Using Dependency.

  2. As a PostgreSQL administrator, connect to an existing sales database, create a dedicated tutorial table, and grant a read-only account access. If seatunnel_reader already exists, omit the CREATE ROLE statement and reuse the account:

CREATE ROLE seatunnel_reader WITH LOGIN PASSWORD 'change_me';

DROP TABLE IF EXISTS public.seatunnel_jdbc_source_quick_start;

CREATE TABLE public.seatunnel_jdbc_source_quick_start (
id BIGINT PRIMARY KEY,
customer_name VARCHAR(100) NOT NULL,
amount DECIMAL(10, 2) NOT NULL
);

INSERT INTO public.seatunnel_jdbc_source_quick_start VALUES
(1, 'Alice', 120.50),
(2, 'Bob', 80.00),
(3, 'Carol', 42.00);

GRANT CONNECT ON DATABASE sales TO seatunnel_reader;
GRANT USAGE ON SCHEMA public TO seatunnel_reader;
GRANT SELECT ON TABLE public.seatunnel_jdbc_source_quick_start TO seatunnel_reader;

The DROP TABLE makes the tutorial data repeatable. Do not use that statement with a business table.

  1. Save the following job as ${SEATUNNEL_HOME}/config/jdbc-source-quick-start.conf. Replace the host, credentials, and database name for your environment.
env {
parallelism = 1
job.mode = "BATCH"
}

source {
Jdbc {
url = "jdbc:postgresql://postgresql.example.com:5432/sales"
driver = "org.postgresql.Driver"
username = "seatunnel_reader"
password = "change_me"
query = "SELECT id, customer_name, amount FROM public.seatunnel_jdbc_source_quick_start ORDER BY id"
}
}

sink {
Console {}
}
  1. Run the job:
cd "${SEATUNNEL_HOME}"
./bin/seatunnel.sh --config ./config/jdbc-source-quick-start.conf -m local
  1. Confirm that the Console sink prints rows with the following values:
idcustomer_nameamount
1Alice120.50
2Bob80.00
3Carol42.00

If the job fails before reading rows, check Troubleshooting first.

Key features

Use query to select only the required columns.

Options

url and driver are always required. Authentication is optional because some databases allow unauthenticated connections. Use either the top-level single-table layout or table_list; top-level table_path and query may be combined. username is the preferred account key, while legacy configurations using user remain supported as a fallback.

nametyperequireddefault valuedescription
urlStringYes-The URL of the JDBC connection. Refer to a case: jdbc:postgresql://localhost/test
driverStringYes-The jdbc class name used to connect to the remote data source, if you use MySQL the value is com.mysql.cj.jdbc.Driver.
usernameStringNo-Database account name. The legacy key user is still accepted as a fallback.
passwordStringNo-Password for the database account.
queryStringNo-SQL query to execute. It can be combined with table_path when explicit table identity and metadata are also needed.
compatible_modeStringNo-The compatible mode of database, required when the database supports multiple compatible modes.
For example, when using OceanBase database, you need to set it to 'mysql' or 'oracle'.
when using starrocks, you need set it to starrocks
dialectStringNo-The appointed dialect, if it does not exist, is still obtained according to the url, and the priority is higher than the url.
For example,when using starrocks, you need set it to starrocks
connection_check_timeout_secIntNo30The time in seconds to wait for the database operation used to validate the connection to complete.
connect_timeout_msIntNo86400000Connection timeout in milliseconds when establishing the JDBC connection. 0 means no timeout.
socket_timeout_msIntNo86400000Socket read timeout in milliseconds after the JDBC connection is established. 0 means no timeout.
partition_columnStringNo-The column name for split data.
partition_upper_boundStringNo-Inclusive upper value used for query-based partitioning. When omitted, SeaTunnel queries the source for the maximum value.
partition_lower_boundStringNo-Inclusive lower value used for query-based partitioning. When omitted, SeaTunnel queries the source for the minimum value.
partition_numIntNo10Number of splits when top-level query and partition_column select the fixed splitter, whether or not table_path is also present. Dynamic table_path and table_list layouts use split.size instead.
decimal_type_narrowingBooleanNotrueDecimal type narrowing, if true, the decimal type will be narrowed to the int or long type if without loss of precision. Only support for Oracle at now. Please refer to decimal_type_narrowing below
int_type_narrowingBooleanNotrueInt type narrowing, if true, the tinyint(1) type will be narrowed to the boolean type if without loss of precision. Support for MySQL at now. Please refer to int_type_narrowing below
handle_blob_as_stringBooleanNofalseIf true, BLOB type will be converted to STRING type. Only supported for Oracle database. This is useful for handling large BLOB fields in Oracle that exceed the default size limit. When transmitting Oracle's BLOB fields to systems like Doris, setting this to true can make the data transfer more efficient.
use_kerberosBooleanNofalseWhether to enable Kerberos authentication for JDBC connections.
kerberos_principalStringNo-Kerberos principal used when use_kerberos = true.
kerberos_keytab_pathStringNo-Path of the Kerberos keytab file used when use_kerberos = true.
krb5_pathStringNo/etc/krb5.confPath of the Kerberos krb5 configuration file.
use_select_countBooleanNofalseUse select count for table count rather then other methods in dynamic chunk split stage. This is currently only available for jdbc-oracle.In this scenario, select count directly is used when it is faster to update statistics using sql from analysis table
skip_analyzeBooleanNofalseSkip the analysis of table count in dynamic chunk split stage. This is currently only available for jdbc-oracle.In this scenario, you schedule analysis table sql to update related table statistics periodically or your table data does not change frequently
use_regexBooleanNofalseControl regular expression matching for table_path. When set to true, the table_path will be treated as a regular expression pattern. When set to false or not specified, the table_path will be treated as an exact path (no regex matching).
fetch_sizeIntNo0For queries that return a large number of objects, you can configure the row fetch size used in the query to improve performance by reducing the number database hits required to satisfy the selection criteria. Zero means use jdbc default value.
propertiesMapNo-Additional connection configuration parameters,when properties and URL have the same parameters, the priority is determined by the
specific implementation of the driver. For example, in MySQL, properties take precedence over the URL.
table_pathStringNo-Full table path. It can be used alone or together with query in the single-table layout.
Examples:
- mysql: "testdb.table1"
- oracle: "test_schema.table1"
- sqlserver: "testdb.test_schema.table1"
- postgresql: "testdb.test_schema.table1"
- iris: "test_schema.table1"
table_listArrayNo-The list of tables to be read, you can use this configuration instead of table_path
where_conditionStringNo-Common row filter conditions for all tables/queries, must start with where. for example where id > 100
split.sizeIntNo8096Target rows per split when the dynamic splitter is used, including table_path and table_list layouts. It does not control the top-level fixed query plus partition_column mode.
split.even-distribution.factor.lower-boundDoubleNo0.05Not recommended for use.
The lower bound of the chunk key distribution factor. This factor is used to determine whether the table data is evenly distributed. If the distribution factor is calculated to be greater than or equal to this lower bound (i.e., (MAX(id) - MIN(id) + 1) / row count), the table chunks would be optimized for even distribution. Otherwise, if the distribution factor is less, the table will be considered as unevenly distributed and the sampling-based sharding strategy will be used if the estimated shard count exceeds the value specified by sample-sharding.threshold. The default value is 0.05.
split.even-distribution.factor.upper-boundDoubleNo100Not recommended for use.
The upper bound of the chunk key distribution factor. This factor is used to determine whether the table data is evenly distributed. If the distribution factor is calculated to be less than or equal to this upper bound (i.e., (MAX(id) - MIN(id) + 1) / row count), the table chunks would be optimized for even distribution. Otherwise, if the distribution factor is greater, the table will be considered as unevenly distributed and the sampling-based sharding strategy will be used if the estimated shard count exceeds the value specified by sample-sharding.threshold. The default value is 100.0.
split.sample-sharding.thresholdIntNo1000This configuration specifies the threshold of estimated shard count to trigger the sample sharding strategy. When the distribution factor is outside the bounds specified by chunk-key.even-distribution.factor.upper-bound and chunk-key.even-distribution.factor.lower-bound, and the estimated shard count (calculated as approximate row count / chunk size) exceeds this threshold, the sample sharding strategy will be used. This can help to handle large datasets more efficiently. The default value is 1000 shards.
split.inverse-sampling.rateIntNo1000The inverse of the sampling rate used in the sample sharding strategy. For example, if this value is set to 1000, it means a 1/1000 sampling rate is applied during the sampling process. This option provides flexibility in controlling the granularity of the sampling, thus affecting the final number of shards. It's especially useful when dealing with very large datasets where a lower sampling rate is preferred. The default value is 1000.
split.allow-samplingBooleanNotrueWhether to allow sampling-based sharding strategy. When set to false, the system will fall back to unevenly-sized chunk splitting (iterative query approach) regardless of the shard count.
common-optionsNo-Source plugin common parameters, please refer to Source Common Options for details.
split.string_split_modeStringNosampleSupports different string splitting algorithms. By default, sample is used to determine the split by sampling the string value. You can switch to charset_based to enable charset-based string splitting algorithm. When set to charset_based, the algorithm assumes characters of partition_column are within ASCII range 32-126, which covers most character-based splitting scenarios.
split.string-strategyStringNo-Controls how String partition columns are split. Available values are none, hash, range, and auto. range and auto currently require MySQL binary collation and fixed-length printable ASCII key values. Other JDBC dialects reject range and auto until their range split support is explicitly validated. auto tries range splitting first and falls back to hash splitting when range splitting is unsafe. When this option is not set, SeaTunnel keeps the existing split.string_split_mode behavior.
split.string_split_mode_collateStringNo-Specifies the collation to use when string_split_mode is set to charset_based and the table has a special collation. If not specified, the database's default collation will be used.

Table Matching

Use the full table path expected by the database dialect:

Database familyExample
MySQLsales.orders
PostgreSQL and SQL Serversales.public.orders
OracleSALES.ORDERS

use_regex = false performs exact matching and is the safest default. Set use_regex = true only when the table part of table_path is intentionally a regular expression:

table_path = "sales.orders_\\d+"
use_regex = true

In HOCON strings, a regular-expression backslash must be escaped, so \d+ is written as \\d+ in the file. The final unescaped dot separates the database/schema path from the table pattern.

Many JDBC drivers treat schema and table arguments passed to DatabaseMetaData as SQL LIKE patterns. SeaTunnel performs an exact identifier check after metadata discovery, but you should still use the exact case for case-sensitive database identifiers.

decimal_type_narrowing

Decimal type narrowing, if true, the decimal type will be narrowed to the int or long type if without loss of precision. Only support for Oracle at now.

eg:

decimal_type_narrowing = true

OracleSeaTunnel
NUMBER(1, 0)Boolean
NUMBER(6, 0)INT
NUMBER(10, 0)BIGINT

decimal_type_narrowing = false

OracleSeaTunnel
NUMBER(1, 0)Decimal(1, 0)
NUMBER(6, 0)Decimal(6, 0)
NUMBER(10, 0)Decimal(10, 0)

int_type_narrowing

Int type narrowing, if true, the tinyint(1) type will be narrowed to the boolean type if without loss of precision. Support for MySQL at now.

eg:

int_type_narrowing = true

MySQLSeaTunnel
TINYINT(1)Boolean

int_type_narrowing = false

MySQLSeaTunnel
TINYINT(1)TINYINT

dialect [string]

The appointed dialect, if it does not exist, is still obtained according to the url, and the priority is higher than the url. For example,when using starrocks, you need set it to starrocks. Similarly, when using mysql, you need to set its value to mysql.

If one dialect not supported by SeaTunnel, it will use the default dialect GenericDialect. Just make sure the driver you provided support the database you want to connect.

dialect list

Dialect Name
GreenplumDB2Dameng
Gbase8aHIVEKingBase
MySQLStarRocksOracle
PhoenixPostgresRedshift
SapHanaSnowflakeSqlite
SqlServerTablestoreTeradata
VerticaOceanBaseXUGU
IRISInceptorHighgo
YashanDB

Parallel Reader

Parallelism determines how many readers can run at the same time; the split configuration determines how many independent splits are available.

For a full-table snapshot, configure table_path and normally leave split-key discovery to SeaTunnel. The connector uses partition_column when provided. Otherwise it searches the primary key and then unique indexes for the first supported column. String, numeric, and date columns are supported split-key types.

split.size is the target row count per split. It is not a hard row limit: actual split sizes depend on key distribution and database statistics. If no supported primary key, unique index, or explicit partition_column exists, the table is read by one split even when job parallelism is greater than one.

Top-level query with fixed partitions

Only the top-level combination of query and partition_column selects the legacy fixed splitter; partition_num then controls the number of splits. The partition column must be present in the query result. Optional lower and upper bounds avoid extra MIN/MAX queries, but incorrect bounds can omit source rows, so use them only when the full data range is known.

Entries inside table_list continue to use dynamic splitting even when they include query or partition settings. Do not expect split.size to affect the top-level fixed partition mode.

Query and primary-key caution

When SeaTunnel infers a key for query, it inherits metadata from the underlying table of the first result column. For joins or multi-table queries, that key is not guaranteed to be unique across the complete result set. Prefer a single-reader query or explicitly choose a partition column whose values divide the result safely.

Driver reference

The following values are starting points. Confirm the driver artifact, license, database compatibility, and Java compatibility with the database vendor before deployment.

datasourcedriverurlmaven
mysqlcom.mysql.cj.jdbc.Driverjdbc:mysql://localhost:3306/testhttps://mvnrepository.com/artifact/mysql/mysql-connector-java
postgresqlorg.postgresql.Driverjdbc:postgresql://localhost:5432/postgreshttps://mvnrepository.com/artifact/org.postgresql/postgresql
dmdm.jdbc.driver.DmDriverjdbc:dm://localhost:5236https://mvnrepository.com/artifact/com.dameng/DmJdbcDriver18
phoenixorg.apache.phoenix.queryserver.client.Driverjdbc:phoenix:thin:url=http://localhost:8765;serialization=PROTOBUFhttps://mvnrepository.com/artifact/com.aliyun.phoenix/ali-phoenix-shaded-thin-client
sqlservercom.microsoft.sqlserver.jdbc.SQLServerDriverjdbc:sqlserver://localhost:1433https://mvnrepository.com/artifact/com.microsoft.sqlserver/mssql-jdbc
oracleoracle.jdbc.OracleDriverjdbc:oracle:thin:@localhost:1521/xepdb1https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8
sqliteorg.sqlite.JDBCjdbc:sqlite:test.dbhttps://mvnrepository.com/artifact/org.xerial/sqlite-jdbc
gbase8acom.gbase.jdbc.Driverjdbc:gbase://localhost:5258/testhttps://cdn.gbase.cn/products/30/p5CiVwXBKQYIUGN8ecHvk/gbase-connector-java-9.5.0.7-build1-bin.jar
starrockscom.mysql.cj.jdbc.Driverjdbc:mysql://localhost:3306/testhttps://mvnrepository.com/artifact/mysql/mysql-connector-java
db2com.ibm.db2.jcc.DB2Driverjdbc:db2://localhost:50000/testdbhttps://mvnrepository.com/artifact/com.ibm.db2.jcc/db2jcc/db2jcc4
tablestorecom.alicloud.openservices.tablestore.jdbc.OTSDriverjdbc:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstancehttps://mvnrepository.com/artifact/com.aliyun.openservices/tablestore-jdbc
saphanacom.sap.db.jdbc.Driverjdbc:sap://localhost:39015https://mvnrepository.com/artifact/com.sap.cloud.db.jdbc/ngdbc
doriscom.mysql.cj.jdbc.Driverjdbc:mysql://localhost:3306/testhttps://mvnrepository.com/artifact/mysql/mysql-connector-java
teradatacom.teradata.jdbc.TeraDriverjdbc:teradata://localhost/DBS_PORT=1025,DATABASE=testhttps://mvnrepository.com/artifact/com.teradata.jdbc/terajdbc
Snowflakenet.snowflake.client.jdbc.SnowflakeDriverjdbc:snowflake://<account_name>.snowflakecomputing.comhttps://mvnrepository.com/artifact/net.snowflake/snowflake-jdbc
Redshiftcom.amazon.redshift.jdbc42.Driverjdbc:redshift://localhost:5439/testdb?defaultRowFetchSize=1000https://mvnrepository.com/artifact/com.amazon.redshift/redshift-jdbc42
Verticacom.vertica.jdbc.Driverjdbc:vertica://localhost:5433https://repo1.maven.org/maven2/com/vertica/jdbc/vertica-jdbc/12.0.3-0/vertica-jdbc-12.0.3-0.jar
Kingbasecom.kingbase8.Driverjdbc:kingbase8://localhost:54321/db_testhttps://repo1.maven.org/maven2/cn/com/kingbase/kingbase8/8.6.0/kingbase8-8.6.0.jar
OceanBasecom.oceanbase.jdbc.Driverjdbc:oceanbase://localhost:2881https://repo1.maven.org/maven2/com/oceanbase/oceanbase-client/2.4.12/oceanbase-client-2.4.12.jar
Hiveorg.apache.hive.jdbc.HiveDriverjdbc:hive2://localhost:10000https://repo1.maven.org/maven2/org/apache/hive/hive-jdbc/3.1.3/hive-jdbc-3.1.3-standalone.jar
xugucom.xugu.cloudjdbc.Driverjdbc:xugu://localhost:5138https://repo1.maven.org/maven2/com/xugudb/xugu-jdbc/12.2.0/xugu-jdbc-12.2.0.jar
InterSystems IRIScom.intersystems.jdbc.IRISDriverjdbc:IRIS://localhost:1972/%SYShttps://raw.githubusercontent.com/intersystems-community/iris-driver-distribution/main/JDBC/JDK18/intersystems-jdbc-3.8.4.jar
opengaussorg.opengauss.Driverjdbc:opengauss://localhost:5432/postgreshttps://repo1.maven.org/maven2/org/opengauss/opengauss-jdbc/5.1.0-og/opengauss-jdbc-5.1.0-og.jar
Highgocom.highgo.jdbc.Driverjdbc:highgo://localhost:5866/highgohttps://repo1.maven.org/maven2/com/highgo/HgdbJdbc/6.2.3/HgdbJdbc-6.2.3.jar
Prestocom.facebook.presto.jdbc.PrestoDriverjdbc:presto://localhost:8080/prestohttps://repo1.maven.org/maven2/com/facebook/presto/presto-jdbc/0.279/presto-jdbc-0.279.jar
Trinoio.trino.jdbc.TrinoDriverjdbc:trino://localhost:8080/trinohttps://repo1.maven.org/maven2/io/trino/trino-jdbc/460/trino-jdbc-460.jar
YashanDBcom.yashandb.jdbc.Driverjdbc:yasdb://localhost:1688/SYShttps://mvnrepository.com/artifact/com.yashandb/yashandb-jdbc

Common patterns

Custom query

env {
parallelism = 1
job.mode = "BATCH"
}

source {
Jdbc {
url = "jdbc:mysql://mysql.example.com:3306/sales"
driver = "com.mysql.cj.jdbc.Driver"
username = "seatunnel_reader"
password = "change_me"
query = "SELECT id, customer_name, amount FROM orders WHERE status = 'PAID'"
}
}

sink {
Console {}
}

Oracle BLOB as STRING

Set handle_blob_as_string = true when Oracle BLOB values should be exposed as SeaTunnel STRING values, for example before writing them to Doris.

env {
parallelism = 1
job.mode = "BATCH"
}

source {
Jdbc {
driver = oracle.jdbc.driver.OracleDriver
url = "jdbc:oracle:thin:@oracle.example.com:1521/SERVICE_NAME"
username = "seatunnel_reader"
password = "change_me"
query = "SELECT ID, NAME, CONTENT_BLOB FROM MY_TABLE"
handle_blob_as_string = true # Enable BLOB to String conversion for Oracle
}
}

sink {
Console {}
}

Custom query partitioned by a column

env {
parallelism = 10
job.mode = "BATCH"
}
source {
Jdbc {
url = "jdbc:mysql://mysql.example.com:3306/sales?serverTimezone=UTC"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
username = "seatunnel_reader"
password = "change_me"
query = "SELECT id, customer_name, amount FROM orders"
partition_column = "id"
partition_num = 10
}
}

sink {
Console {}
}

Explicit partition boundaries

Specify bounds only when they cover the complete source range. SeaTunnel does not read values outside the configured interval.

env {
parallelism = 10
job.mode = "BATCH"
}

source {
Jdbc {
url = "jdbc:mysql://mysql.example.com:3306/sales?serverTimezone=UTC"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
username = "seatunnel_reader"
password = "change_me"
query = "SELECT id, customer_name, amount FROM orders"
partition_column = "id"
partition_lower_bound = 1
partition_upper_bound = 500
partition_num = 10
}
}

sink {
Console {}
}

Dynamic splitting by primary key or unique index

This example uses table_path without the top-level query plus partition_column combination, so it uses dynamic splitting. Start with the default split settings, then tune split.size only after measuring the source database load and job throughput.

env {
parallelism = 10
job.mode = "BATCH"
}
source {
Jdbc {
url = "jdbc:mysql://mysql.example.com:3306/sales?serverTimezone=UTC"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
username = "seatunnel_reader"
password = "change_me"
table_path = "sales.orders"
split.size = 10000
}
}

sink {
Console {}
}

Multiple tables

Use table_list when different tables need different queries or matching rules.

env {
parallelism = 4
job.mode = "BATCH"
}

source {
Jdbc {
url = "jdbc:mysql://mysql.example.com:3306/sales?serverTimezone=UTC"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
username = "seatunnel_reader"
password = "change_me"

table_list = [
{
table_path = "sales.orders"
},
{
table_path = "sales.customers"
query = "SELECT id, name FROM customers WHERE id > 100"
},
{
table_path = "sales.archive_\\d+"
use_regex = true
}
]
}
}

sink {
Console {}
}

Troubleshooting

JDBC driver class cannot be found

Confirm that the driver JAR is in the engine-specific directory on every execution node, that the configured driver class exists in that JAR, and that the affected process was restarted after the JAR was added.

Connection succeeds in a SQL client but fails in SeaTunnel

The hostname must be reachable from the SeaTunnel process, not only from your laptop. Check network routing, firewall rules, TLS settings, credentials, database name, and connection_check_timeout_sec. Do not copy an example hostname without replacing it.

Table or columns cannot be discovered

Check the database-specific table_path format, identifier case, and the account's metadata and SELECT privileges. For a custom query, first execute the exact SQL with the same account in a database client.

Parallelism does not increase the number of readers

For dynamic splitting, verify that the table has a supported primary key or unique index, or configure partition_column. To select the legacy fixed splitter for a top-level query, configure both partition_column and a suitable partition_num. A table without a safe split key is intentionally read by one split.

Rows are missing after setting partition bounds

partition_lower_bound and partition_upper_bound define the range SeaTunnel reads; they are not only performance hints. Remove them to let SeaTunnel discover the bounds, or correct them so they include every required row.

Changelog

Change Log
ChangeCommitVersion
[Fix][Connector-xugu] Fix several bugs in the xugu connector (#9820)https://github.com/apache/seatunnel/commit/75c9adb280dev
[Feature][Transform-V2] Support AT TIME ZONE statement for sql transform (#9784)https://github.com/apache/seatunnel/commit/ad5278c5bbdev
[Feature][Transform-V2] Support vector series sql function (#9765)https://github.com/apache/seatunnel/commit/a40114cf7a2.3.12
[Chore] fix typos filed -> field (#9757)https://github.com/apache/seatunnel/commit/e3e1c67d292.3.12
[Feature][Core] Add plugin directory support for each connector (#9650)https://github.com/apache/seatunnel/commit/4beb2b93362.3.12
[Improve][Core] Update apache common to apache common lang3 (#9694)https://github.com/apache/seatunnel/commit/6e5737c1ec2.3.12
[Improve][API] Optimize the enumerator API semantics and reduce lock calls at the connector level (#9671)https://github.com/apache/seatunnel/commit/9212a771402.3.12
[Fix][connector-jdbc] prevent precision loss in Float to BigDecimal conversion (#9670)https://github.com/apache/seatunnel/commit/6e11285bf62.3.12
[Fix][Connector-Jdbc] Supports reading and writing Postgres network dress types (#9618)https://github.com/apache/seatunnel/commit/3dc79c1ddf2.3.12
[improve] jdbc options (#9541)https://github.com/apache/seatunnel/commit/d041e5fb322.3.12
[Fix][Connector-Jdbc]Fixed Vertica data source cannot upsert data. (#9607)https://github.com/apache/seatunnel/commit/7b4d05171b2.3.12
[Fix][Connectors-Jdbc] Postgres supports streaming and batch reading and writing of the interval data type (#9590)https://github.com/apache/seatunnel/commit/58ab9170242.3.12
[Feature][Connectors-v2] Optimize the size of CDC JAR Files (#9546)https://github.com/apache/seatunnel/commit/1dd19c68232.3.12
[improve][Connector-jdbc] add comments when schema not include all columns (#9559)https://github.com/apache/seatunnel/commit/02d2b69d852.3.12
[Hotfix][Connector-Jdbc] Write MySQL to support set collection data type (#9553)https://github.com/apache/seatunnel/commit/3836c97a622.3.12
[Feature][Jdbc] Support read multiple tables by regular expressions (#9380)https://github.com/apache/seatunnel/commit/670a52a9182.3.12
[bugfix][Connector-V2] Fixed the load driver inaccurate situation (#9468)https://github.com/apache/seatunnel/commit/c6639e81fe2.3.12
[Fix][Connector-V2] Fix OceanBase Oracle create unsupported data type (#9383)https://github.com/apache/seatunnel/commit/f4178c72f12.3.12
[improve][Connector-V2] delete jdbc param support_upsert_by_query_primary_key_exist (#9408)https://github.com/apache/seatunnel/commit/d247fe1d8d2.3.12
[Feature][Connector-V2] Jdbc mysql support read tinyint(1) to byte(tinyint) (#9373)https://github.com/apache/seatunnel/commit/7b87aa6f122.3.12
[Improve] JdbcInputFormat nextRecord Exception throw TableId (#9374)https://github.com/apache/seatunnel/commit/484aef593d2.3.12
[Feature][Connector-V2][JDBC] Add presto/trino dialect (#9388)https://github.com/apache/seatunnel/commit/3cac2bd1262.3.12
[Feature][Connector-JDBC] Supprot read Oracle BLOB data as string instead of bytes (#9305)https://github.com/apache/seatunnel/commit/454a88f81a2.3.11
[Fix][Connector-jdbc] Fix postgresql sink trying to update unique key (#9293) (#9298)https://github.com/apache/seatunnel/commit/d0c1de83572.3.11
[Fix][Connector-V2] Fix oceanbase mysql jdbc sink create statement error (#9267)https://github.com/apache/seatunnel/commit/79f8125ea62.3.11
[Feature][Transform] Support define sink column type (#9114)https://github.com/apache/seatunnel/commit/ab7119e5072.3.11
[Feature][Checkpoint] Add check script for source/sink state class serialVersionUID missing (#9118)https://github.com/apache/seatunnel/commit/4f5adeb1c72.3.11
[Fix][API] Fixed not invoke the SinkAggregatedCommitter's init method (#9070)https://github.com/apache/seatunnel/commit/df0d11d6322.3.11
[Fix][Connector-V2] Fix SqlServer create table when database with dot (#9007)https://github.com/apache/seatunnel/commit/e09445c7892.3.11
[Fix][Connector-V2][OceanBase] oceanbase vector support simple vector index (#9072)https://github.com/apache/seatunnel/commit/4140cd1d8f2.3.11
[Improve][Connector-V2] Optimize dialect selection in jdbc (#8820)https://github.com/apache/seatunnel/commit/92c62c5e632.3.11
[Fix][JDBC] fix jdbc default connection parameter invalid (#8185)https://github.com/apache/seatunnel/commit/f85eb78b372.3.11
[Hotfix][Jdbc] Fix mysql tinyint(1) type mapping for TypeMapper (#9012)https://github.com/apache/seatunnel/commit/5f85d7668a2.3.11
[Feature][Jdbc] Add String type column split Support by charset-based splitting algorithm (#9002)https://github.com/apache/seatunnel/commit/dbe41e74cd2.3.11
[Fix][Paimon] nullable and comment attribute was lost during automatic table creation (#9020)https://github.com/apache/seatunnel/commit/eb54fdd52c2.3.11
[Fix][Connector-JDBC] Fix JDBC driver selection for data source connections (#8986)https://github.com/apache/seatunnel/commit/a5aafa73012.3.11
[Improve][Jdbc] Upgrade sap-hana driver from 2.14.7 to 2.23.10 (#9013)https://github.com/apache/seatunnel/commit/9ba9f169be2.3.11
[Feature][Jdbc] Support sink ddl for sqlserver #8114 (#8936)https://github.com/apache/seatunnel/commit/30aa485b382.3.10
[Fix][Connector-V2] Fix parse SqlServer JDBC Url error (#8784)https://github.com/apache/seatunnel/commit/373d2162d32.3.10
[Improve][Jdbc] Support upsert for opengauss (#8627)https://github.com/apache/seatunnel/commit/56110bf3922.3.10
[Improve][Jdbc] Remove useless utils. (#8793)https://github.com/apache/seatunnel/commit/36a7533e852.3.10
[Improve][Jdbc] Improve catalog connection cache (#8626)https://github.com/apache/seatunnel/commit/6205065b252.3.10
[Fix][Connector-V2] Fix jdbc sink statement buffer wrong time to clear (#8653)https://github.com/apache/seatunnel/commit/cf35eecdfc2.3.10
[Feature][Jdbc] Support sink ddl for dameng (#8380)https://github.com/apache/seatunnel/commit/5ff34274282.3.10
[Improve] restruct connector common options (#8634)https://github.com/apache/seatunnel/commit/f3499a6eeb2.3.10
[Improve][Jdbc] Remove oracle 'v$database' query (#8571)https://github.com/apache/seatunnel/commit/3cf09f61ca2.3.10
[Fix][Connector-V2] Postgres support for multiple primary keys (#8526)https://github.com/apache/seatunnel/commit/04db40d9732.3.10
[Feature][JDBC source] pg support char types (#8420)https://github.com/apache/seatunnel/commit/776ac944782.3.9
[Feature][Jdbc] Support sink ddl for postgresql (#8276)https://github.com/apache/seatunnel/commit/353bbd21a12.3.9
[Feature][Connector-V2] Support the jdbc connector for highgo db (#8282)https://github.com/apache/seatunnel/commit/aa381cbfb42.3.9
[Improve][Jdbc] Support nvarchar in dm (#8270)https://github.com/apache/seatunnel/commit/2f1c54ee2e2.3.9
[Improve][Connector-v2] Use regex to match filedName placeholders in jdbc sink (#8222)https://github.com/apache/seatunnel/commit/c02d4fed362.3.9
[Improve][Connector-V2] Support read comment when jdbc dialect without catalog (#8196)https://github.com/apache/seatunnel/commit/567cd54de52.3.9
[Improve][Connector-V2] The interface supports jdbc respects the target database field type (#8031)https://github.com/apache/seatunnel/commit/1de056a9a42.3.9
[Improve][dist]add shade check rule (#8136)https://github.com/apache/seatunnel/commit/51ef8000162.3.9
[Improve][Jdbc] Improve ddl write validate (#8158)https://github.com/apache/seatunnel/commit/9cdaacddd92.3.9
[Feature][Jdbc] Add Jdbc default dialect for all jdbc series database without dialect (#8132)https://github.com/apache/seatunnel/commit/399eabcd3f2.3.9
[Improve][Jdbc] Refactor ddl change (#8134)https://github.com/apache/seatunnel/commit/e1f0a238f72.3.9
[Feature][Core] Rename result_table_name/source_table_name to plugin_input/plugin_output (#8072)https://github.com/apache/seatunnel/commit/c7bbd322db2.3.9
[Improve][Connector-V2] Improve schema evolution on column insert after for mysql-jdbc (#8017)https://github.com/apache/seatunnel/commit/3fb05da3652.3.9
[Feature][Core] Support cdc task ddl restore for zeta (#7463)https://github.com/apache/seatunnel/commit/8e322281ed2.3.9
[Feature][transform] transform support explode (#7928)https://github.com/apache/seatunnel/commit/132278c06a2.3.9
[Feature][Connector-v2] Support schema evolution for Oracle connector (#7908)https://github.com/apache/seatunnel/commit/79406bcc2f2.3.9
[Improve][Connector-V2] Improve jdbc merge table from path and query when type is decimal (#7917)https://github.com/apache/seatunnel/commit/8baa012ced2.3.9
[Fix][Connector-V2] Fix hana type loss of precision (#7912)https://github.com/apache/seatunnel/commit/18dcca36cd2.3.9
[Feature][Connector-V2] Jdbc DB2 support upsert SQL (#7879)https://github.com/apache/seatunnel/commit/139919334d2.3.9
[Improve][Jdbc] Optimize index name conflicts when create table for postgresql (#7875)https://github.com/apache/seatunnel/commit/312ee866fb2.3.9
[Improve][Jdbc] Support postgresql inet type. (#7820)https://github.com/apache/seatunnel/commit/25b68b36232.3.9
[Fix][Connector-V2]Oceanbase vector database is added as the source server (#7832)https://github.com/apache/seatunnel/commit/258f9317652.3.9
[Feature][connector-v2]Support opengauss jdbc connnector using opengauss driver. (#7622)https://github.com/apache/seatunnel/commit/bbf643772e2.3.9
[Improve][Jdbc] Support save mode for the sink of jdbc-dm (#7814)https://github.com/apache/seatunnel/commit/b87d732c812.3.9
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d03c2.3.9
[Feature][Connector-V2] SqlServer support user-defined type (#7706)https://github.com/apache/seatunnel/commit/fb890332732.3.8
[Hotfix][CDC] Fix ddl duplicate execution error when config multi_table_sink_replica (#7634)https://github.com/apache/seatunnel/commit/23ab3edbbb2.3.8
[Feature][Connector-Paimon] Support dynamic bucket splitting improves Paimon writing efficiency (#7335)https://github.com/apache/seatunnel/commit/bc0326cba82.3.8
[Fix][Connector-V2] Fix jdbc test case failed (#7690)https://github.com/apache/seatunnel/commit/4f5d27f6252.3.8
[Improve][Jdbc] Jdbc truncate table should check table not database (#7654)https://github.com/apache/seatunnel/commit/0c0eb7e41b2.3.8
[Feature][Connector-V2] jdbc saphana source tablepath support view and synonym (#7670)https://github.com/apache/seatunnel/commit/7e0c20a4882.3.8
[Fix][Connector-v2] Throw Exception in sql query for JdbcCatalog in table or db exists query (#7651)https://github.com/apache/seatunnel/commit/70ec59ce0e2.3.8
[Fix][JDBC] Fix starrocks jdbc dialect catalog conflict with starrocks connector (#7578)https://github.com/apache/seatunnel/commit/020aab422e2.3.8
[Feature] Support tidb cdc connector source #7199 (#7477)https://github.com/apache/seatunnel/commit/87ec786bd62.3.8
[bugfix] fix oracle query table length (#7627)https://github.com/apache/seatunnel/commit/2e002ce09b2.3.8
[Hotfix][Connector-v2] Fix the NullPointerException for jdbc oracle which used the table_list (#7544)https://github.com/apache/seatunnel/commit/555028217a2.3.8
[Improve][Connector-v2] Support mysql 8.1/8.2/8.3 for jdbc (#7530)https://github.com/apache/seatunnel/commit/657fe69b262.3.8
[Improve][Connector-v2] Release resource in closeStatements even exception occurred in executeBatch (#7533)https://github.com/apache/seatunnel/commit/590f7d110d2.3.8
[Fix][Connector-V2] Fix jdbc query sql can not get table path (#7484)https://github.com/apache/seatunnel/commit/8e0ca8f7252.3.8
[Feature][Connector-V2] Add decimal_type_narrowing option in jdbc (#7461)https://github.com/apache/seatunnel/commit/696f2948fa2.3.8
[Improve][Connector-V2] update vectorType (#7446)https://github.com/apache/seatunnel/commit/1bba72385b2.3.8
[Improve][API] Move catalog open to SaveModeHandler (#7439)https://github.com/apache/seatunnel/commit/8c2c5c79a12.3.8
[FIX][E2E]Modify the OceanBase test case to the latest imageChange image (#7452)https://github.com/apache/seatunnel/commit/6abb83deab2.3.8
[Feature][Connector-V2][OceanBase] Support vector types on OceanBase (#7375)https://github.com/apache/seatunnel/commit/a6b188d5522.3.8
[Improve][Connector-V2] Remove system table limit (#7391)https://github.com/apache/seatunnel/commit/adf888e0082.3.8
[Fix] Fix oracle sample data from column error (#7340)https://github.com/apache/seatunnel/commit/2130e0d5ad2.3.8
[Improve][Connector-V2] Close all ResultSet after used (#7389)https://github.com/apache/seatunnel/commit/853e9732122.3.8
[Hotifx][Jdbc] Fix MySQL unsupport 'ZEROFILL' column type (#7407)https://github.com/apache/seatunnel/commit/71303821232.3.8
[Improvement] add starrocks jdbc dialect (#7294)https://github.com/apache/seatunnel/commit/b5140f598e2.3.8
[Hotfix][Connector] Fix jdbc compile error (#7359)https://github.com/apache/seatunnel/commit/2769ed50292.3.7
[Fix][Connector-V2][OceanBase] Remove OceanBase catalog's dependency on mysql driver (#7311)https://github.com/apache/seatunnel/commit/3130ae089e2.3.7
[Improve][Jdbc] Skip all index when auto create table to improve performance of write (#7288)https://github.com/apache/seatunnel/commit/dc3c23981b2.3.7
[Improve][Jdbc] Remove MysqlType references in JdbcDialect (#7333)https://github.com/apache/seatunnel/commit/16eeb1c1232.3.7
[Improve][Jdbc] Merge user config primary key when create table (#7313)https://github.com/apache/seatunnel/commit/819c6856512.3.7
[Improve][Connector-v2] Optimize the way of databases and tables are checked for existence (#7261)https://github.com/apache/seatunnel/commit/f012b2a6f02.3.7
[Feature][Jdbc] Support hive compatibleMode add inceptor dialect (#7262)https://github.com/apache/seatunnel/commit/31e59cdf822.3.6
[Improve][Connector-v2] Optimize the count table rows for jdbc-oracle and oracle-cdc (#7248)https://github.com/apache/seatunnel/commit/0d08b200612.3.6
[Feature][Core] Support using upstream table placeholders in sink options and auto replacement (#7131)https://github.com/apache/seatunnel/commit/c4ca74122c2.3.6
[Fix] Fix Hana type converter decimal scale is 0 convert to int error (#7167)https://github.com/apache/seatunnel/commit/6e33a97c862.3.6
[Improve][Jdbc] Support write unicode text into sqlserver (#7159)https://github.com/apache/seatunnel/commit/e44e8b93bc2.3.6
[Improve][Jdbc] Remove user info in catalog-table options (#7178)https://github.com/apache/seatunnel/commit/4e001be25c2.3.6
[Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4 (#7151)https://github.com/apache/seatunnel/commit/dbdbdf015b2.3.6
[Feature][Connector-V2] Support jdbc hana catalog and type convertor (#6950)https://github.com/apache/seatunnel/commit/d6633987392.3.6
[Improve] Change catalog table log to debug level (#7136)https://github.com/apache/seatunnel/commit/b111d2f8432.3.6
[Improve][Connector-V2] Support schema evolution for mysql-cdc and mysql-jdbc (#6929)https://github.com/apache/seatunnel/commit/cf91e51fc72.3.6
[connector-jdbc][bugfix] fix sqlServer create table comment special string bug (#7024)https://github.com/apache/seatunnel/commit/403564db132.3.6
[bugfix] fix pgsql create table comment special string bug (#7022)https://github.com/apache/seatunnel/commit/9fe844f62a2.3.6
[connector-jdbc][bugfix] fix oracle create table comment special string bug (#7012)https://github.com/apache/seatunnel/commit/a9e0f678732.3.6
[bugfix] fix mysql create table comment special string bug (#6998)https://github.com/apache/seatunnel/commit/904e9cf7852.3.6
[Improve][Jdbc]sink sql support custom field.(#6515) (#6525)https://github.com/apache/seatunnel/commit/ef3e61dbc42.3.6
[Feature][Jdbc] Support redshift catalog (#6992)https://github.com/apache/seatunnel/commit/8d5cbcee742.3.6
[Improve][Connector-V2] Clean key name in catalog table (#6942)https://github.com/apache/seatunnel/commit/a399ef48c62.3.6
[Improve][Zeta] Move SaveMode behavior to master (#6843)https://github.com/apache/seatunnel/commit/80cf91318d2.3.6
[Improve][Jdbc] Quotes the identifier for table path (#6951)https://github.com/apache/seatunnel/commit/d70ec61f352.3.6
[Hotfix][Jdbc] Fix oracle savemode create table (#6651)https://github.com/apache/seatunnel/commit/4b6c13e8fc2.3.6
[Improve][JDBC Source] Fix Split can not be cancel (#6825)https://github.com/apache/seatunnel/commit/ee3b7c37232.3.6
[Feature][Doris] Add Doris type converter (#6354)https://github.com/apache/seatunnel/commit/51899918432.3.6
[Hotfix][Jdbc/CDC] Fix postgresql uuid type in jdbc read (#6684)https://github.com/apache/seatunnel/commit/868ba4d7c72.3.6
[Improve][Connector] Add some sqlserver IDENTITY type for catalog (#6822)https://github.com/apache/seatunnel/commit/f6983965552.3.6
[Feature][Jdbc] Support the jdbc connector for InterSystems IRIS (#6797)https://github.com/apache/seatunnel/commit/46600969bb2.3.6
[Fix][MySQL]: Fix MySqlTypeConverter could not be instantiated (#6781)https://github.com/apache/seatunnel/commit/a5609d600e2.3.6
[Hotfix][Jdbc] Fix table/query columns order merge for jdbc catalog (#6771)https://github.com/apache/seatunnel/commit/df1954d5202.3.6
[Fix] Fix Oracle type converter handle negative scale in number type (#6758)https://github.com/apache/seatunnel/commit/6d710690c52.3.6
[Improve][mysql-cdc] Support mysql 5.5 versions (#6710)https://github.com/apache/seatunnel/commit/058f5594a32.3.6
[Improve][Jdbc] Add quote identifier for sql (#6669)https://github.com/apache/seatunnel/commit/849d748d3d2.3.5
[Improve][Jdbc] Increase tyepe converter when auto creating tables (#6617)https://github.com/apache/seatunnel/commit/cc660206d82.3.5
[feature][connector-v2] add xugudb connector (#6561)https://github.com/apache/seatunnel/commit/80f392afbb2.3.5
[Hotfix] Fix DEFAULT TABLE problem (#6352)https://github.com/apache/seatunnel/commit/cdb1856e842.3.5
[Improve] Improve MultiTableSinkWriter prepare commit performance (#6495)https://github.com/apache/seatunnel/commit/2086b0e8a62.3.5
[Improve][JDBC] Optimized code style for getting jdbc field types (#6583)https://github.com/apache/seatunnel/commit/ddca95f32c2.3.5
[Improve] Add SaveMode log of process detail (#6375)https://github.com/apache/seatunnel/commit/b0d70ce2242.3.5
[Improve][Jdbc] Support custom case-sensitive config for dameng (#6510)https://github.com/apache/seatunnel/commit/d6dcb03bf32.3.5
feat: jdbc support copy in statement. (#6443)https://github.com/apache/seatunnel/commit/ca4a65fc002.3.5
[Improve][Jdbc] Using varchar2 datatype store string in oracle (#6392)https://github.com/apache/seatunnel/commit/14405fa8d42.3.5
[Improve][API] Unify type system api(data & type) (#5872)https://github.com/apache/seatunnel/commit/b38c7edcc92.3.5
Fix Jdbc sink target table name error (#6269)https://github.com/apache/seatunnel/commit/2f62235e382.3.4
[Improve][JDBC] Use PreparedStatement to sample data from column (#6242)https://github.com/apache/seatunnel/commit/bd0e66d5332.3.4
[Improve][JDBC-sink] Improve query Approximate Total Row Count of a Table (#5972)https://github.com/apache/seatunnel/commit/8156036a2f2.3.4
[Feature][JDBC、CDC] Support Short and Byte Type in spliter (#6027)https://github.com/apache/seatunnel/commit/6f8d0a50402.3.4
[Improve] Support int identity type in sql server (#6186)https://github.com/apache/seatunnel/commit/1a8da1c8432.3.4
[Bugfix][JDBC、CDC] Fix Spliter Error in Case of Extensive Duplicate Data (#6026)https://github.com/apache/seatunnel/commit/635c24e8b22.3.4
[Feature][Connector-V2][Postgres-cdc]Support for Postgres cdc (#5986)https://github.com/apache/seatunnel/commit/97438b94022.3.4
Add date type and float type column split support (#6160)https://github.com/apache/seatunnel/commit/b9a62e5c3f2.3.4
[Improve] Extend SupportResourceShare to spark/flink (#5847)https://github.com/apache/seatunnel/commit/c69da93b872.3.4
[Feature] Support uuid in postgres jdbc (#6185)https://github.com/apache/seatunnel/commit/f56855098b2.3.4
[Feature][Connector-V2][Oracle-cdc]Support for oracle cdc (#5196)https://github.com/apache/seatunnel/commit/aaef22b31b2.3.4
[Feature][Connector] update pgsql catalog for save mode (#6080)https://github.com/apache/seatunnel/commit/84ce5169292.3.4
[Hotfix][Jdbc] Fix dameng catalog query table sql (#6141)https://github.com/apache/seatunnel/commit/413fa745002.3.4
[improve][catalog-postgres] Improve get column sql compatibility (#5664)https://github.com/apache/seatunnel/commit/23ce592ad22.3.4
[Feature][Connector] update oracle catalog for save mode (#6092)https://github.com/apache/seatunnel/commit/dfbf92769c2.3.4
[Feature][Connectors-V2][Jdbc] Supports Sqlserver Niche Data Types (#6122)https://github.com/apache/seatunnel/commit/6673f6f7712.3.4
[Improve][Connector-V2][Jdbc] Shade hikari in jdbc connector (#6116)https://github.com/apache/seatunnel/commit/dd698c95bf2.3.4
[Feature][Connector] update sqlserver catalog for save mode (#6086)https://github.com/apache/seatunnel/commit/edcaacecb12.3.4
[Feature][Connector-V2][PostgresSql] add JDBC source support string type as partition key (#6079)https://github.com/apache/seatunnel/commit/3522eb157c2.3.4
[Hotfix][Jdbc] Fix jdbc setFetchSize error (#6005)https://github.com/apache/seatunnel/commit/d41af8a6ed2.3.4
Support using multiple hadoop account (#5903)https://github.com/apache/seatunnel/commit/d69d88d1aa2.3.4
[Feature] Add unsupported datatype check for all catalog (#5890)https://github.com/apache/seatunnel/commit/b9791285a02.3.4
[Hotfix][Split] Fix split key not support BigInteger typehttps://github.com/apache/seatunnel/commit/5adf5d2b9a2.3.4
[Improve] Replace SeaTunnelRowType with TableSchema in the JdbcRowConverterhttps://github.com/apache/seatunnel/commit/1cc1b1b8cd2.3.4
[Hotfix][Jdbc] Fix cdc updates were not filtering same primary key (#5923)https://github.com/apache/seatunnel/commit/38d3b858142.3.4
[Improve]Change System.out.println to log output. (#5912)https://github.com/apache/seatunnel/commit/bbedb07a9c2.3.4
[Bug] Fix Hive-Jdbc use krb5 overwrite kerberosKeytabPath (#5891)https://github.com/apache/seatunnel/commit/f0b6092c152.3.4
Reduce the time cost of getCatalogTable in jdbc (#5908)https://github.com/apache/seatunnel/commit/51a37375782.3.4
[Improve] Improve Jdbc connector error message when datatype unsupported (#5864)https://github.com/apache/seatunnel/commit/69f79af3a42.3.4
[Improve] Rename getCountSql to getExistDataSql (#5838)https://github.com/apache/seatunnel/commit/2233b3a3812.3.4
[Fix] Fix read from Oracle Date type value lose time (#5814)https://github.com/apache/seatunnel/commit/2d704e36bd2.3.4
[Improve][JdbcSource] Optimize catalog-table metadata merge logic (#5828)https://github.com/apache/seatunnel/commit/7d8028a60b2.3.4
[Improve][Common] Introduce new error define rule (#5793)https://github.com/apache/seatunnel/commit/9d1b2582b22.3.4
[Feature][Hive JDBC Source] Support Hive JDBC Source Connector (#5424)https://github.com/apache/seatunnel/commit/a64e177d062.3.4
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)https://github.com/apache/seatunnel/commit/8de74081002.3.4
[Improve][Connector] Add field name to DataTypeConvertor to improve error message (#5782)https://github.com/apache/seatunnel/commit/ab60790f0d2.3.4
[Feature][Oracle] Support XMLTYPE data integration #5716 (#5723)https://github.com/apache/seatunnel/commit/620f081adb2.3.4
[Fix] Fix Postgres create table test case failed (#5778)https://github.com/apache/seatunnel/commit/b98b6bcee32.3.4
[Improve][Jdbc] Fix database identifier (#5756)https://github.com/apache/seatunnel/commit/dbfc8a670a2.3.4
[Fix] Fix PG will not create index when using auto create table #5721https://github.com/apache/seatunnel/commit/e5fd88dbe72.3.4
[Improve] Remove all useless prepare, getProducedType method (#5741)https://github.com/apache/seatunnel/commit/ed94fffbb92.3.4
[feature][connector-jdbc]Add Save Mode function and Connector-JDBC (MySQL) connector has been realized (#5663)https://github.com/apache/seatunnel/commit/eff17ccbe52.3.4
[Bug][connector-jdbc] Nullable Column source have null data could be unexpected results. (#5560)https://github.com/apache/seatunnel/commit/3f429e1f0a2.3.4
[Improve] Add default implement for SeaTunnelSink::setTypeInfo (#5682)https://github.com/apache/seatunnel/commit/86cba874502.3.4
[BUG][Connector-V2][Jdbc] support postgresql xml type (#5724)https://github.com/apache/seatunnel/commit/5f5d4da13f2.3.4
[Improve][E2E][Jdbc] Enable IT case for Oceanbase Mysql mode (#5697)https://github.com/apache/seatunnel/commit/879c2aa07c2.3.4
[Feature][Jdbc] Support read multiple tables (#5581)https://github.com/apache/seatunnel/commit/33fa8ff2482.3.4
[Feature] Support multi-table sink (#5620)https://github.com/apache/seatunnel/commit/81ac1731892.3.4
[Improve] Remove catalog tag for config file (#5645)https://github.com/apache/seatunnel/commit/dc509aa0802.3.4
[Feature][Jdbc] Supporting more ways to configure connection parameters. (#5388)https://github.com/apache/seatunnel/commit/d31e9478f72.3.4
[Feature][Connector-V2][Jdbc] Add OceanBase catalog (#5439)https://github.com/apache/seatunnel/commit/cd4b7ff7d22.3.4
[BUGFIX][Catalog] oracle catalog create table repeat and oracle pg null point (#5517)https://github.com/apache/seatunnel/commit/103da931f32.3.4
Support config column/primaryKey/constraintKey in schema (#5564)https://github.com/apache/seatunnel/commit/eac76b4e502.3.4
[Improve] Refactor CatalogTable and add SeaTunnelSource::getProducedCatalogTables (#5562)https://github.com/apache/seatunnel/commit/41173357f82.3.4
[Feature][Jdbc] Add Dameng catalog (#5451)https://github.com/apache/seatunnel/commit/c23070919c2.3.4
[Feature] Add tidb datatype convertor (#5440)https://github.com/apache/seatunnel/commit/61391bda9f2.3.4
[Feature][Connector-V2] jdbc connector supports Kingbase database (#4803)https://github.com/apache/seatunnel/commit/95385671592.3.4
[Feature][Catalog] Catalog add Case Conversion Definition (#5328)https://github.com/apache/seatunnel/commit/7b5b28bdbe2.3.4
[Feature][Jdbc] Jdbc database support identifier (#5089)https://github.com/apache/seatunnel/commit/38b6d6e4bb2.3.4
[Improve][Connector-v2][Jdbc] Refactor AbstractJdbcCatalog (#5096)https://github.com/apache/seatunnel/commit/dde3104f762.3.4
[Improve][CheckStyle] Remove useless 'SuppressWarnings' annotation of checkstyle. (#5260)https://github.com/apache/seatunnel/commit/51c0d709ba2.3.4
[Hotfix] Fix com.google.common.base.Preconditions to seatunnel shade one (#5284)https://github.com/apache/seatunnel/commit/ed5eadcf732.3.3
[bug][jdbc][oracle]Fix the Oracle number type mapping problem (#5209)https://github.com/apache/seatunnel/commit/9d3c3de90d2.3.3
[BUG][Connector-V2][Jdbc] support postgresql json type (#5194)https://github.com/apache/seatunnel/commit/7a862d14b72.3.3
[Improve][Connector-V2] Remove scheduler in JDBC sink #4736 (#5168)https://github.com/apache/seatunnel/commit/3b0a3931452.3.3
[CI] Split updated modules integration test for part 5 (#5208)https://github.com/apache/seatunnel/commit/18f14d60872.3.3
[Bug][connector-v2] PostgreSQL versions below 9.5 are compatible use cdc sync problem (#5120)https://github.com/apache/seatunnel/commit/9af696a1dd2.3.3
[Improve][Connector-v2][Jdbc] check url not null throw friendly message (#5097)https://github.com/apache/seatunnel/commit/b0815f2a952.3.3
[Feature][Catalog] Add JDBC Catalog auto create table (#4917)https://github.com/apache/seatunnel/commit/63eb1376712.3.3
[Feature][CDC] Support tables without primary keys (with unique keys) (#163) (#5150)https://github.com/apache/seatunnel/commit/32b7f2b6902.3.3
[Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database connection leak (#4802)https://github.com/apache/seatunnel/commit/4cc10e83e72.3.3
[Feature][JDBC Sink] Add DM upsert support (#5073)https://github.com/apache/seatunnel/commit/5e8d982e252.3.3
[Improve] Improve savemode api (#4767)https://github.com/apache/seatunnel/commit/4acd370d482.3.3
[Feature][Connector-V2] JDBC source support string type as partition key (#4947)https://github.com/apache/seatunnel/commit/d1d26776582.3.3
[Feature][Connector-V2][Jdbc] Add oceanbase dialect factory (#4989)https://github.com/apache/seatunnel/commit/7ba11cecdf2.3.3
Fix XA Transaction bug (#5020)https://github.com/apache/seatunnel/commit/852fe104bc2.3.3
[Improve][CDC]Remove driver for cdc connector (#4952)https://github.com/apache/seatunnel/commit/b65f40c3c92.3.3
[Improve] Documentation and partial word optimization. (#4936)https://github.com/apache/seatunnel/commit/6e8de0e2a62.3.3
[Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict keys (#4634)https://github.com/apache/seatunnel/commit/d56bb1ba1c2.3.3
[Bugfix][zeta] Fix the deadlock issue with JDBC driver loading (#4878)https://github.com/apache/seatunnel/commit/c30a2a1b1c2.3.2
[Hotfix][Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) (#4866)https://github.com/apache/seatunnel/commit/bde19b63772.3.2
[Feature][Connector-v2] Add Snowflake Source&Sink connector (#4470)https://github.com/apache/seatunnel/commit/06c59a25f32.3.2
[Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column in sink (#4815)https://github.com/apache/seatunnel/commit/0eff3aeed02.3.2
[Hotfix][Connector][Jdbc] Fix reconnect throw close statement exception (#4801)https://github.com/apache/seatunnel/commit/ea3bc1a6732.3.2
[Hotfix][Connector][Jdbc] Fix sqlserver system table case sensitivity (#4806)https://github.com/apache/seatunnel/commit/2ca7426d222.3.2
[Hotfix][Jdbc][Oracle] Fix oracle sql table identifier (#4754)https://github.com/apache/seatunnel/commit/84cb51ff832.3.2
[Improve][Jdbc] Populate primary key when jdbc sink is created using CatalogTable (#4755)https://github.com/apache/seatunnel/commit/4af3bf90152.3.2
[Feature][PostgreSQL-jdbc] Supports GEOMETRY data type for PostgreSQL… (#4673)https://github.com/apache/seatunnel/commit/a5af4d9b6e2.3.2
[Improve][Core] Add check of sink and source config to avoid null pointer exception. (#4734)https://github.com/apache/seatunnel/commit/8f66ce96cb2.3.2
[Hotfix][JDBC-SINK] Fix TiDBCatalog without open (#4718)https://github.com/apache/seatunnel/commit/34a7f3eaa42.3.2
[Feature][E2E] Add mysql-cdc e2e testcase (#4639)https://github.com/apache/seatunnel/commit/87001dfd162.3.2
[Hotfix][JDBC Sink] Fix JDBC Sink oom bug (#4690)https://github.com/apache/seatunnel/commit/08b6f992aa2.3.2
Improve the option rule for jdbc sink (#4694)https://github.com/apache/seatunnel/commit/a6b37044142.3.2
[feature][catalog] Support for multiplexing connections (#4550)https://github.com/apache/seatunnel/commit/41277d7f782.3.2
[Bugfix][Jdbc-Mysql Mysql-CDC] Fix MySQL BIT type incorrectly converted to Boolean type (#4671)https://github.com/apache/seatunnel/commit/89b0099ff42.3.2
[Hotfix]Jdbc[SqlServer] Fix sqlserver jdbc url parse (#4697)https://github.com/apache/seatunnel/commit/b24c3226ec2.3.2
Revert "[Improve][Catalog] refactor catalog (#4540)" (#4628)https://github.com/apache/seatunnel/commit/2d1933195d2.3.2
[Feature][Connector][Jdbc] Add DataTypeConvertor for JDBC-Postgres (#4575)https://github.com/apache/seatunnel/commit/91f51259762.3.2
[Improve][Catalog] refactor catalog (#4540)https://github.com/apache/seatunnel/commit/b0a701cb832.3.2
[Bug][JDBC Source] fix split exception when source table is empty (#4570)https://github.com/apache/seatunnel/commit/c73b9331ce2.3.2
[Feature][Connector][Jdbc] Add vertica connector. (#4303)https://github.com/apache/seatunnel/commit/e6b4f987212.3.2
[Hotfix][Catalog] Filter out unavailable constrain keys (#4557)https://github.com/apache/seatunnel/commit/5e5859546a2.3.2
[Hotfix][Connector-V2][Jdbc] Simple sql has the highest priority (#4548)https://github.com/apache/seatunnel/commit/74d4d248582.3.2
[Improve][Connector-V2][Jdbc] Jdbc source supports factory SPI (#4264)https://github.com/apache/seatunnel/commit/a97f33797d2.3.2
[Jdbc][Chore] improve the exception message when primary key not found in row (#4474)https://github.com/apache/seatunnel/commit/06fa850da92.3.2
[hotfix][JDBC] Fix the table name is not automatically obtained when multiple tables (#4514)https://github.com/apache/seatunnel/commit/c84d6f8d112.3.2
[Chore][Jdbc] add the log for sql and update some style (#4475)https://github.com/apache/seatunnel/commit/a9e65030452.3.2
[Hotfix][Connector-V2][Jdbc] Set default value to false of JdbcOption: generate_sink_sql (#4471)https://github.com/apache/seatunnel/commit/7da11c2f442.3.2
[feature][jdbc][TiDB] add TiDB catalog (#4438)https://github.com/apache/seatunnel/commit/9a32db6fc02.3.2
[Hotfix][Connector] Fix sqlserver catalog (#4441)https://github.com/apache/seatunnel/commit/8540c7f9f32.3.2
[Feature][CDC][SqlServer] Support multi-table read (#4377)https://github.com/apache/seatunnel/commit/c4e3f2dc032.3.2
[Improve][JdbcSink]Fix connection failure caused by connection timeout. (#4322)https://github.com/apache/seatunnel/commit/e1f6d3b3fd2.3.2
[Hotfix][Connector-V2][Jdbc] Field aliases are not supported in the query of jdbc source. (#4158) (#4210)https://github.com/apache/seatunnel/commit/3d7ff831f92.3.1
Change file type to file_format_type in file source/sink (#4249)https://github.com/apache/seatunnel/commit/973a2fae3c2.3.1
Change redshift type to lowercase (#4248)https://github.com/apache/seatunnel/commit/10447ae1032.3.1
Add redshift datatype convertor (#4245)https://github.com/apache/seatunnel/commit/b19011517f2.3.1
[improve][zeta] fix zeta bugshttps://github.com/apache/seatunnel/commit/3a82e8b39f2.3.1
[Improve] Support MySqlCatalog Use JDBC URL With Custom Suffixhttps://github.com/apache/seatunnel/commit/210d0ff1f82.3.1
[hotfix] fixed jdbc IT errorhttps://github.com/apache/seatunnel/commit/dd20af0a9e2.3.1
Merge branch 'dev' into merge/cdchttps://github.com/apache/seatunnel/commit/4324ee19122.3.1
[Improve][Project] Code format with spotless plugin.https://github.com/apache/seatunnel/commit/423b5830382.3.1
[improve][jdbc] use ReadonlyConfig instead of Config (#4236)https://github.com/apache/seatunnel/commit/c90c58e2432.3.1
[Improve][Jdbc-sink] add database field to sink config (#4199)https://github.com/apache/seatunnel/commit/ec368902f42.3.1
[improve][jdbc] Reduce jdbc options configuration (#4218)https://github.com/apache/seatunnel/commit/ddd8f808b52.3.1
Fix mysql get default value (#4204)https://github.com/apache/seatunnel/commit/6848434f2d2.3.1
[hotfix][zeta] fix zeta multi-table parser error (#4193)https://github.com/apache/seatunnel/commit/98f2ad0c192.3.1
[Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule (#4194)https://github.com/apache/seatunnel/commit/9d088017a32.3.1
[Improve][Connector-V2] [StarRocks] Starrocks Support Auto Create Table (#4177)https://github.com/apache/seatunnel/commit/7e0008e6fb2.3.1
[improve][catalog][jdbc] Add MySQL catalog factory (#4168)https://github.com/apache/seatunnel/commit/95e3cbf8752.3.1
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd6010512.3.1
Add convertor factory (#4119)https://github.com/apache/seatunnel/commit/cbdea45d952.3.1
Add ElasticSearch catalog (#4108)https://github.com/apache/seatunnel/commit/9ee4d8394c2.3.1
Add Kafka catalog (#4106)https://github.com/apache/seatunnel/commit/34f1f21e482.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab1665612.3.1
Add DataTypeConvertor in Catalog (#4094)https://github.com/apache/seatunnel/commit/840c3e5eb42.3.1
[Feature][Catalog] Support create/drop table, create/drop database in catalog (#4075)https://github.com/apache/seatunnel/commit/d8a0be84ca2.3.1
[Bug][Connector-V2][Jdbc] Fixed no exception throwing problem (#3957)https://github.com/apache/seatunnel/commit/6ab266e5942.3.1
[Bug][CDC] Fix jdbc sink generate update sql (#3940)https://github.com/apache/seatunnel/commit/233465d4e42.3.1
[Improve][JDBC] improve jdbc sink option (#3864)https://github.com/apache/seatunnel/commit/768a9300e82.3.1
Fix Source Class Support Parallelism judge & Add UT for it (#3878)https://github.com/apache/seatunnel/commit/ce85a8c68b2.3.1
[Feature][Connector] add get source method to all source connector (#3846)https://github.com/apache/seatunnel/commit/417178fb842.3.1
[Feature][Connector-V2] Jdbc connector support SAP HANA. (#3017)https://github.com/apache/seatunnel/commit/fe0180fab22.3.1
[Feature][API &amp; Connector &amp; Doc] add parallelism and column projection interface (#3829)https://github.com/apache/seatunnel/commit/b9164b8ba12.3.1
[Improve][JDBC Connector]improve option rule (#3802)https://github.com/apache/seatunnel/commit/139256741a2.3.1
[Hotfix][Jdbc Sink] fix xa transaction commit failure on pipeline restore (#3809)https://github.com/apache/seatunnel/commit/39dae4cfd92.3.1
[Improve][Connector-V2][JDBC] Add exactly-once for JDBC source connector (#3750)https://github.com/apache/seatunnel/commit/5328e9d8472.3.1
[Improve][Connector-v2] Remove unused options for jdbc source factory (#3794)https://github.com/apache/seatunnel/commit/861004d3092.3.1
[Feature][Connector-jdbc] Fix JDBC Connector Throw Exception Error. (#3796)https://github.com/apache/seatunnel/commit/38646b11b82.3.1
[hotfix][ST-Engine] fix jdbc connector exactly-once null pointer (#3730)https://github.com/apache/seatunnel/commit/0c5986fbec2.3.0
[Improve][connector-jdbc] Add config item enable upsert by query (#3708)https://github.com/apache/seatunnel/commit/e1f951f7822.3.0
[Hotfix][connector-v2] fix SemanticXidGenerator#generateXid indexOutOfBounds #3701 (#3705)https://github.com/apache/seatunnel/commit/f351ceaf4b2.3.0
[Hotfix][Connector-V2][jdbc] fix jdbc connection reset bug (#3670)https://github.com/apache/seatunnel/commit/6fe0e6aece2.3.0
[Improve][Connector-V2][JDBC] Unified exception for JDBC source & sink (#3598)https://github.com/apache/seatunnel/commit/865ca2bba92.3.0
[Connector][JDBC]Support Redshift sink and source (#3615)https://github.com/apache/seatunnel/commit/8d9d8638d22.3.0
[Improve][Connectors-V2][jdbc] Adapts to multiple versions of Flink #3589https://github.com/apache/seatunnel/commit/e77fdbbef72.3.0
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a1192.3.0
[Feature][Connector-V2][Doris]Add Doris Source & Sink connector (#3586)https://github.com/apache/seatunnel/commit/3d46b796142.3.0
[Feature][Connector-V2][Teradata] Add Teradata Source And Sink Connectorhttps://github.com/apache/seatunnel/commit/3a095d30fd2.3.0
[Feature][Connector-V2][JDBC] support sqlite Source & Sink (#3089)https://github.com/apache/seatunnel/commit/a73bb3e7142.3.0
Bump postgresql in /seatunnel-connectors-v2/connector-jdbc (#3559)https://github.com/apache/seatunnel/commit/c8dfdf3e462.3.0
[feature][connector][cdc] add SeaTunnelRowDebeziumDeserializeSchema (#3499)https://github.com/apache/seatunnel/commit/ff44db116e2.3.0
[JDBC][ORACLE] Improve Oracle Type to SeaTunnel Type Mapping (#3486)https://github.com/apache/seatunnel/commit/8fe0dda6e22.3.0
[JDBC][Config] Add JDBC Fetch Size Config And Custom Postgres PrepareStatement (#3478)https://github.com/apache/seatunnel/commit/d60a705f5d2.3.0
[feature][connector][jdbc] expose configurable options in JDBC (#3410)https://github.com/apache/seatunnel/commit/72b8a73cab2.3.0
[feature][connector][jdbc] Support write cdc changelog event in jdbc sink (#3444)https://github.com/apache/seatunnel/commit/b12a908f012.3.0
[Improve][Connector-v2][Jdbc] Add AutoCommit to jdbcConfig (#3453)https://github.com/apache/seatunnel/commit/cfb1e978532.3.0
[Improve][Connector-v2] Unset AutoCommit default to true (#3451)https://github.com/apache/seatunnel/commit/439f686d922.3.0
[Feature][connector-v2] add tablestore source and sink (#3309)https://github.com/apache/seatunnel/commit/ebebf0b6332.3.0
Close jdbc connection after use. (#3358)https://github.com/apache/seatunnel/commit/219fea517c2.3.0
[Improve][Engine] Improve Engine performance. (#3216)https://github.com/apache/seatunnel/commit/7393c473272.3.0
[Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)https://github.com/apache/seatunnel/commit/40d67ab9022.3.0
[Feature][Connector-V2][JDBC] Support DB2 Source & Sink (#2410)https://github.com/apache/seatunnel/commit/bf1ef69e842.3.0
update org.postgresql:postgresql 42.3.3 to 42.4.1 (#3097)https://github.com/apache/seatunnel/commit/28525164902.3.0
[Feature][Connector-V2][Jdbc] support gbase 8a (#3026)https://github.com/apache/seatunnel/commit/dc6e85d06f2.3.0-beta
[Bug][sqlserver] timestamp convert exception (#3024)https://github.com/apache/seatunnel/commit/99ac1a655e2.3.0-beta
[Feature][Connector-V2] oracle connector (#2550)https://github.com/apache/seatunnel/commit/384ece19132.3.0-beta
[Improve][Connector-v2][jdbc] Support for specify number of partitions when parallel reading (#2950)https://github.com/apache/seatunnel/commit/fc284ac32e2.3.0-beta
[Feature][Connector-V2] add sqlserver connector (#2646)https://github.com/apache/seatunnel/commit/05d105dea32.3.0-beta
[Improve][e2e] Unified e2e IT for DaMengDB (#2946)https://github.com/apache/seatunnel/commit/15636bdea12.3.0-beta
[Improve][e2e] modify DM-driver by downLoad and add the value comparison of all columns (#2772)https://github.com/apache/seatunnel/commit/f3ff39bdfe2.3.0-beta
[Improve][e2e] Improve jdbc driver management (#2770)https://github.com/apache/seatunnel/commit/f907927a352.3.0-beta
[hotfix][connector][jdbc] fix JDBC split exception (#2904)https://github.com/apache/seatunnel/commit/57342c65452.3.0-beta
[Improve][connector-jdbc] Calculate splits only once in JdbcSourceSplitEnumerator (#2900)https://github.com/apache/seatunnel/commit/7622f289992.3.0-beta
[Feature][Connector-V2 E2E] Add mysql and postgres e2e test and bug fix (#2838)https://github.com/apache/seatunnel/commit/db434adc152.2.0-beta
fix XAConnection being wrongly submitted (#2805)https://github.com/apache/seatunnel/commit/d9a6039fd32.2.0-beta
fix spark execute exception is not thrown (#2791)https://github.com/apache/seatunnel/commit/b1711c984e2.2.0-beta
[Improve][e2e] Add driver-jar to lib (#2719)https://github.com/apache/seatunnel/commit/d64d452c862.2.0-beta
[DEV][Api] Replace SeaTunnelContext with JobContext and remove singleton pattern (#2706)https://github.com/apache/seatunnel/commit/cbf82f755c2.2.0-beta
[Connector-V2][JDBC-connector] support Jdbc dm (#2377)https://github.com/apache/seatunnel/commit/7278209ca22.2.0-beta
[#2606]Dependency management split (#2630)https://github.com/apache/seatunnel/commit/fc047be69b2.2.0-beta
[Bug][connector-jdbc-v2] Fix transaction force commit when autoCommit is enabled (#2636)https://github.com/apache/seatunnel/commit/8cd8cf7aa22.2.0-beta
[Feature][Connector-V2] Add phoenix connector sink (#2499)https://github.com/apache/seatunnel/commit/05ccf9d68c2.2.0-beta
[Connector-V2][JDBC] Support database: greenplum (#2429)https://github.com/apache/seatunnel/commit/3561d3878f2.2.0-beta
Add jdbc connector e2e test (#2321)https://github.com/apache/seatunnel/commit/5fbcb811c62.2.0-beta
StateT of SeaTunnelSource should extend Serializable (#2214)https://github.com/apache/seatunnel/commit/8c426ef8502.2.0-beta
update the condition to 1 = 0 about get table operation (#2186)https://github.com/apache/seatunnel/commit/7c56d7143b2.2.0-beta
[SeaTunnel API][Sink] remove useless context field (#2124)https://github.com/apache/seatunnel/commit/a31fdeedcc2.2.0-beta
[bugfix] Check isOpen before closing (#2107)https://github.com/apache/seatunnel/commit/7ec0ada2b92.2.0-beta
[API-DRAFT][MERGE] fix merge errorhttps://github.com/apache/seatunnel/commit/3c0e9846482.2.0-beta
merge dev to api-drafthttps://github.com/apache/seatunnel/commit/d265597c642.2.0-beta
[api-draft][Optimize] Optimize module name (#2062)https://github.com/apache/seatunnel/commit/f79e3112b12.2.0-beta