Skip to content

Latest commit

 

History

History
232 lines (202 loc) · 12.7 KB

release-note.md

File metadata and controls

232 lines (202 loc) · 12.7 KB
Raw

next-release

Bug fix

Core

  • [Core] [API] Fixed generic class loss for lists (#4421)
  • [Core] [API] Fix parse nested row data type key changed upper (#4459)
  • [Starter][Flink]Support transform-v2 for flink #3396
  • [Flink] Support flink 1.14.x #3963
  • [Core][Translation][Spark] Fix SeaTunnelRowConvertor fail to convert when schema contains row type (#5170)

Transformer

  • [Spark] Support transform-v2 for spark (#3409)
  • [ALL]Add FieldMapper Transform #3781
  • [All]Add JsonPath Transform #5633

Connectors

  • [Elasticsearch] Support https protocol & compatible with opensearch
  • [Hbase] Add hbase sink connector #4049
  • [Clickhouse] Fix clickhouse old version compatibility #5326
  • [Easysearch] Support INFINI Easysearch #5933
  • [Web3j] add Web3j source connector #6598

Formats

  • [Canal]Support read canal format message #3950
  • [Debezium]Support debezium canal format message #3981

Connector-V2

  • [Json-format] [Canal-Json] Fix json deserialize NPE (#4195)
  • [Connector-V2] [Jdbc] Field aliases are not supported in the query of jdbc source. (#4210)
  • [Connector-V2] [Jdbc] Fix connection failure caused by connection timeout. (#4322)
  • [Connector-V2] [Jdbc] Set default value to false of JdbcOption: generate_sink_sql (#4471)
  • [Connector-V2] [JDBC] Fix TiDBCatalog without open (#4718)
  • [Connector-V2] [Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) (#4866)
  • [Connector-V2] [Pulsar] Fix the bug that can't consume messages all the time. (#4125)
  • [Connector-V2] [Eleasticsearch] Document description error (#4390)
  • [Connector-V2] [Eleasticsearch] Source deserializer error and inappropriate (#4233)
  • [Connector-V2] [Kafka] Fix KafkaProducer resources have never been released. (#4302)
  • [Connector-V2] [Kafka] Fix the permission problem caused by client.id. (#4246)
  • [Connector-V2] [Kafka] Fix KafkaConsumerThread exit caused by commit offset error. (#4379)
  • [Connector-V2] [Mongodb] Mongodb support cdc sink. (#4833)
  • [Connector-V2] [kafka] Fix the problem that the partition information can not be obtained when kafka is restored (#4764)
  • [Connector-V2] [SFTP] Fix incorrect exception handling logic (#4720)
  • [Connector-V2] [File] Fix read temp file (#4876)
  • [Connector-V2] [CDC Base] Solving the ConcurrentModificationException caused by snapshotState being modified concurrently. (#4877)
  • [Connector-V2] [Doris] update last checkpoint id when doing snapshot (#4881)
  • [Connector-v2] [kafka] Fix the short interval of pull data settings and revise the format (#4875)
  • [Connector-v2] [RabbitMQ] Fix reduplicate ack msg bug and code style (#4842)
  • [Connector-V2] [Jdbc] Fix the error of extracting primary key column in sink (#4815)
  • [Connector-V2] [Jdbc] Fix reconnect throw close statement exception (#4801)
  • [Connector-V2] [Jdbc] Fix sqlserver system table case sensitivity (#4806)
  • [Connector-v2] [File] Fix configuration file format and error comments (#4762)
  • [Connector-v2] [Jdbc] Fix oracle sql table identifier (#4754)
  • [Connector-v2] [Clickhouse] fix get clickhouse local table name with closing bracket from distributed table engineFull (#4710)
  • [Connector-v2] [CDC] Fix jdbc connection leak for mysql (#5037)
  • [Connector-v2] [File] Fix WriteStrategy parallel writing thread unsafe issue #5546
  • [Connector-v2] [File] Inject FileSystem to OrcWriteStrategy
  • [Connector-v2] [File] Support assign encoding for file source/sink (#5973)
  • [Connector-v2] [Mongodb] Support to convert to double from numeric type that mongodb saved it as numeric internally (#6997)
  • [Connector-v2] [Redis] Using scan replace keys operation command,support batchWrite in single mode(#7030,#7085)

Zeta(ST-Engine)

  • [Zeta] Fix LogicalDagGeneratorTest testcase (#4401)
  • [Zeta] Fix MultipleTableJobConfigParser parse only one transform (#4412)
  • [Zeta] Fix missing common plugin jars (#4448)
  • [Zeta] Fix handleCheckpointError be called while checkpoint already complete (#4442)
  • [Zeta] Fix job error message is not right bug (#4463)
  • [Zeta] Fix finding TaskGroup deployment node bug (#4449)
  • [Zeta] Fix the bug of conf (#4488)
  • [Zeta] Fix Connector load logic from zeta (#4510)
  • [Zeta] Fix conflict dependency of hadoop-hdfs (#4509)
  • [Zeta] Fix TaskExecutionService synchronized lock will not release (#4886)
  • [Zeta] Fix TaskExecutionService will return not active ExecutionContext (#4869)
  • [Zeta] Fix deploy operation timeout but task already finished bug (#4867)
  • [Zeta] Fix restoreComplete Future can't be completed when cancel task (#4863)
  • [Zeta] Fix IMap operation timeout bug (#4859)
  • [Zeta] fix pipeline state not right bug (#4823)
  • [Zeta] Fix the incorrect setting of transform parallelism (#4814)
  • [Zeta] Fix master active bug (#4855)
  • [Zeta] Fix completePendingCheckpoint concurrent action (#4854)
  • [Zeta] Fix engine runtime error (#4850)
  • [Zeta] Fix TaskGroupContext always hold classloader so classloader can't recycle (#4849)
  • [Zeta] Fix task notifyTaskStatusToMaster failed when job not running or failed before run (#4847)
  • [Zeta] Fix cpu load problem (#4828)
  • [zeta] Fix the deadlock issue with JDBC driver loading (#4878)
  • [zeta] dynamically replace the value of the variable at runtime (#4950)
  • [Zeta] Add from_unixtime function (#5462)
  • [zeta] Fix CDC task restore throw NPE (#5507)

E2E

  • [E2E] [Kafka] Fix kafka e2e testcase (#4520)
  • [Container Version] Fix risk of unreproducible test cases #4591
  • [E2e] [Mysql-cdc] Removing the excess MySqlIncrementalSourceIT e2e reduces the CI time (#4738)
  • [E2E] [Common] Update test container version of seatunnel engine (#5323)
  • [E2E] [Jdbc] Fix not remove docker image after test finish on jdbc suite (#5586)

Improve

  • [Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict keys (#4634)

Core

  • [Core] [Spark] Push transform operation from Spark Driver to Executors (#4503)
  • [Core] [Starter] Optimize code structure & remove redundant code (#4525)
  • [Core] [Translation] [Flink] Optimize code structure & remove redundant code (#4527)
  • [Core] [Starter] Add check of sink and source config to avoid null pointer exception. (#4734)
  • [Core] [Flink] Remove useless stage type related codes. (#5650)

Formats

  • [Json] Remove assert key word. (#5919)
  • [Formats] Replace CommonErrorCodeDeprecated.JSON_OPERATION_FAILED. (#5948)
  • [Formats] Refactor exception catch for ignoreParseErrors. (#6065)

Connector-V2

  • [Connector-V2] [CDC] Improve startup.mode/stop.mode options (#4360)
  • [Connector-V2] [CDC] Optimize jdbc fetch-size options (#4352)
  • [Connector-V2] [CDC] Fix chunk start/end parameter type error (#4777)
  • [Connector-V2] [SQLServer] Fix sqlserver catalog (#4441)
  • [Connector-V2] [StarRocks] Improve StarRocks Serialize Error Message (#4458)
  • [Connector-V2] [Jdbc] add the log for sql and update some style (#4475)
  • [Connector-V2] [Jdbc] Fix the table name is not automatically obtained when multiple tables (#4514)
  • [Connector-V2] [S3 & Kafka] Delete unavailable S3 & Kafka Catalogs (#4477)
  • [Connector-V2] [Pulsar] Support Canal Format
  • [Connector-V2] [CDC base] Implement Sample-based Sharding Strategy with Configurable Sampling Rate (#4856)
  • [Connector-V2] [SelectDB] Add a jobId to the selectDB label to distinguish between tasks (#4864)
  • [Connector-V2] [Doris] Add a jobId to the doris label to distinguish between tasks (#4839) (#4853)
  • [Connector-v2] [Mongodb]Refactor mongodb connector (#4620)
  • [Connector-v2] [Jdbc] Populate primary key when jdbc sink is created using CatalogTable (#4755)
  • [Connector-v2] [Neo4j] Supports neo4j sink batch write mode (#4835)
  • [Transform-V2] Optimize SQL Transform package and Fix Spark type conversion bug of transform (#4490)
  • [Connector-V2] [Common] Remove assert key word (#5915)
  • [Connector-V2] Replace CommonErrorCodeDeprecated.JSON_OPERATION_FAILED. (#5978)

CI

  • [CI] Fix error repository name in ci config files (#4795)
  • [CI][E2E][Zeta] Increase Zeta checkpoint timeout to avoid connector-file-sftp-e2e failed frequently (#5339)

Zeta(ST-Engine)

  • [Zeta] Support run the server through daemon mode (#4161)
  • [Zeta] Change ClassLoader To Improve the SDK compatibility of the client (#4447)
  • [Zeta] Client Support Async Submit Job (#4456)
  • [Zeta] Add more detailed log output. (#4446)
  • [Zeta] Improve seatunnel-cluster.sh (#4435)
  • [Zeta] Reduce CPU Cost When Task Not Ready (#4479)
  • [Zeta] Add parser log (#4485)
  • [Zeta] Remove redundant code (#4489)
  • [Zeta] Remove redundancy code in validateSQL (#4506)
  • [Zeta] Improve JobMetrics fetch performance (#4467)
  • [Zeta] Reduce the operation count of imap_running_job_metrics (#4861)
  • [Zeta] Speed up listAllJob function (#4852)
  • [Zeta] async execute checkpoint trigger and other block method (#4846)
  • [Zeta] Reduce the number of IMAPs used by checkpointIdCounter (#4832)
  • [Zeta] Cancel pipeline add retry to avoid cancel failed. (#4792)
  • [Zeta] Improve Zeta operation max count and ignore NPE (#4787)
  • [Zeta] Remove serialize(deserialize) cost when use shuffle action (#4722)
  • [zeta] Checkpoint exception status messages exclude state data (#5547)
  • [Zeta] Remove assert key words (#5947)

Feature

Core

  • [Core] [API] Support convert strings as List option (#4362)
  • [Core] [API] Add copy method to Catalog codes (#4414)
  • [Core] [API] Add options check before create source and sink and transform in FactoryUtil (#4424)
  • [Core] [Shade] Add guava shade module (#4358)
  • [Core] [Spark] Support SeaTunnel Time Type (#5188)
  • [Core] [Flink] Support Decimal Type with configurable precision and scale (#5419)
  • [Core] [API] Support hocon style declare row type in generic type (#6187)

Connector-V2

  • [Connector-V2] [CDC] [SQLServer] Support multi-table read (#4377)
  • [Connector-V2] [Kafka] Kafka source supports data deserialization failure skipping (#4364)
  • [Connector-V2] [Jdbc] [TiDB] Add TiDB catalog (#4438)
  • [Connector-V2] [File] Add file excel sink and source (#4164)
  • [Connector-V2] [FILE-OBS] Add Huawei Cloud OBS connector (#4577)
  • [Connector-v2] [Snowflake] Add Snowflake Source&Sink connector (#4470)
  • [Connector-V2] [Pular] support read format for pulsar (#4111)
  • [Connector-V2] [Paimon] Introduce paimon connector (#4178)
  • [Connector V2] [Cassandra] Expose configurable options in Cassandra (#3681)
  • [Connector V2] [Jdbc] Supports GEOMETRY data type for PostgreSQL (#4673)
  • [Connector V2] [Jdbc] Supports Kingbase database (#4803)
  • [Transform-V2] Add UDF SPI and an example implement for SQL Transform plugin (#4392)
  • [Transform-V2] Support copy field list (#4404)
  • [Transform-V2] Add support CatalogTable for FieldMapperTransform (#4423)
  • [Transform-V2] Add CatalogTable support for ReplaceTransform (#4411)
  • [Transform-V2] Add Catalog support for FilterRowKindTransform (#4420)
  • [Transform-V2] Add support CatalogTable for FilterFieldTransform (#4422)
  • [Transform-V2] Add catalog support for SQL Transform plugin (#4819)
  • [Connector-V2] [Assert] Support check the precision and scale of Decimal type (#6110)
  • [Connector-V2] [Assert] Support field type assert and field value equality assert for full data types (#6275)
  • [Connector-V2] [Iceberg] Support iceberg sink #6198
  • [Connector-V2] [FILE-OBS] Add Huawei Cloud OBS connector #4578

Zeta(ST-Engine)

  • [Zeta] Support for mixing Factory and Plugin SPI (#4359)
  • [Zeta] Add get running job info by jobId rest api (#4140)
  • [Zeta] Add REST API To Get System Monitoring Information (#4315)
  • [Transform V2 & Zeta] Make SplitTransform Support CatalogTable And CatalogTable Evolution (#4396)
  • [Zeta] Move driver into lib directory and change operation count (#4845)
  • [Zeta] Add Metaspace size default value to config file (#4848)
  • [Zeta] Reduce the frequency of fetching data from imap (#4851)
  • [Zeta] Add OSS support for Imap storage to cluster-mode type (#4683)
  • [Zeta] Improve local mode startup request ports (#4660)

Docs

  • [Docs] Optimizes part of the Doris and SelectDB connector documentation (#4365)
  • [Docs] Fix docs code style (#4368)
  • [Docs] Update jdbc doc and kafka doc (#4380)
  • [Docs] Fix max_retries default value is 0. (#4383)
  • [Docs] Fix markdown syntax (#4426)
  • [Docs] Fix Kafka Doc Error Config Key "kafka." (#4427)
  • [Docs] Add Transform to Quick Start v2 (#4436)
  • [Docs] Fix Dockerfile and seatunnel-flink.yaml in Set Up with Kubernetes (#4788)
  • [Docs] Fix Mysql sink format doc (#4800)
  • [Docs] Add the generate sink sql parameter for the jdbc sink document (#4797)
  • [Docs] Add the generate sink sql parameter And example (#4769)
  • [Docs] Redshift add defaultRowFetchSize (#4616)
  • [Docs] Refactor connector-v2 docs using unified format Mysql (#4590)
  • [Docs] Add Value types in Java to Schema features (#5087)
  • [Docs] Replace username by user in the options of FtpFile (#5421)
  • [Docs] Add how to configure logging related parameters of SeaTunnel-E2E Test (#5589)
  • [Docs] Remove redundant double quotation mark from an example code (#5845)
  • [Docs] Add Hive JDBC reference value (#5882)