错误修复核心 [核心] [API] 修复列表的通用类丢失 (#4421) [Starter] 修复 [] 中“，”被分割的问题 (#5401) [核心] [API] 修复 ReadonlyConfig 丢失键的错误 (#5565) [核心] [API] 修复从 LinkHashMap 获取字节 (#5622) [核心] [API] 修复多表接收器关闭时的日志错误 (#5683) [核心] [API] 修复 MultiTableSink 返回提交者但接收器不支持的问题 (#5710) [核心] [API] 修复使用不支持的类型解析架构时的错误消息 (#5790) [核心] [API] 修复不稳定的测试 OptionUtilTest.test (#5894) [核心] [API] 修复 SaveModeHandler 无法关闭的问题 (#5843) [核心] [API]修复 MultiTableSinkWriter 线程索引始终为 1 (#5832) [Core] [API] 修复 SeaTunnelRow::getBytesSize 不支持 map 接口 (#5990) [Core] [Common] 修复 FileUtils::createNewFile 无法创建新文件 (#5943) [Core] [API] 修复 Debezium 格式无法解析日期/时间/时间戳 (#5887) [Starter] 在双引号内时，‘,’ 被视为普通字符而不是分隔符 (#6042 [Core] [Common] 替换 CommonErrorCodeDeprecated.JSON_OPERATION_FAILED (#5978) [Core] [API] 修复 Object.class 选项值无法返回正常值 (#6247) Transformer-V2 [All] 修复 transform 中的 PrimaryKey (#5704) [All] 修复强制转换为时间戳、日期、时间的 bug (#5812) Formats [Text] 允许 map 中的条目为空，允许条目中的 key 为空 (#5277) Connector-V2 [Connector-V2] [Clickhouse] 修复 clickhouse 旧版本兼容性 (#5326) [Connector-V2] [Clickhouse] 修复 http header 覆盖 (#5446) [Connector-V2] [StarRocks] 修复 starrocks template sql parser (#5332) [Connector-V2] [Hive] 修复 HiveConf 中 hive-site.xml 无法注入的 bug (#5261) [Connector-V2] [Clickhouse] 修复 clickhouse sink flush bug (#5448) [Connector-V2] [Hive] 修复读取空目录时出错 (#5427) [Connector-V2] [Hive] 修复读取空目录时出错 (#5427)" (#5487) [Connector-V2] [Oss jindo] 修复 jindo 驱动下载失败的问题。 (#5511) [Connector-V2] [Oss jindo] 移除无用代码 (#5540) [Connector-V2] [File] 修复 WriteStrategy 并行写入线程不安全问题 (#5546) [Connector-V2] [CDC] 修复原表删除字段时 cdc 出现 NPE 的 bug (#5579) [Connector-V2] [Jdbc] oracle catalog 创建表重复，oracle pg 出现 null 点 (#5517) [Connector-V2] [CDC] 修复 cdc 枚举器中线程不安全的集合容器 (#5614) [Connector-V2] [Mongodb] 修复 bsonNull 导致的不支持异常 (#5659) [Connector-V2] [File] 修复文件接收器 isPartitionFieldWriteInFile 在没有给出列时发生异常的问题 (#5508) [Connector-V2] [Doris] 修复 RestService 报 NullPointerException 问题 (#5319) [Connector-V2] [MaxCompute] 修复 MaxCompute 使用不存在的 SCHEMA 选项问题 (#5708) [Connector-V2] [Doris] 使用 try-with-resources 简化代码。 (#4995) [Connector-V2] [Clickhouse] 修复 clickhouse-sink 输出数据字段乱序的 BUG (#5346) [Connector-V2] [Jdbc] 支持 postgresql xml 类型 (#5724) [Connector-V2] [Jdbc] Nullable Column source 有 null 数据可能会产生意想不到的结果。 (#5560) [Connector-V2] [Iceberg] Iceberg 源使用并行选项时丢失数据 (#5732) [Connector-V2] [Jdbc] 修复使用自动创建表时 PG 不会创建索引的问题 #5721 [Connector-V2] [Jdbc] 修复数据库标识符 (#5756) [Connector-V2] [CDC] 修复添加新表时 MultiTableSink 恢复失败的问题 (#5746) [Connector-V2] [Postgres CDC] 修复 Postgres 创建表测试用例失败的问题 (#5778) [Connector-V2] [CDC] 清理未使用的代码 (#5785) [Connector-V2] [CDC] 修复将单表切换到多表时的状态恢复错误 (#5784) [Connector-V2] [ElasticSearch] 修复 elasticsearch 数组格式转换异常的问题 (#5825) [Connector-V2] [Jdbc] 修复从 Oracle Date 类型值读取时丢失时间的问题 (#5814) [Connector-V2] [Pulsar] 修复：更新项目：seatunnel-web 上 pulsar-datasource 的 IDENTIFIER = Pulsar (#5852) [Connector-V2] [Jdbc] 修复 Hive-Jdbc 使用 krb5 覆盖 kerberosKeytabPath 的问题 (#5891) [Connector-V2] [InfluxDB] 解决由直接 QUERY_LIMIT 附加到“tz”函数导致的 initColumnsIndex 方法中的无效 SQL。(#4829) [Connector-V2] [Jdbc] 修复 cdc 更新未过滤相同主键的问题 (#5923) [Connector-V2] [File] Parquet 读取器解析数组类型异常。 (#4457) [Connector-V2] [Http] 修复 http 配置无 schema 选项问题，完善 e2e 测试添加用例 (#5939) [Connector-V2] [Doris] 修复 DorisCatalog 未实现 name 方法问题 (#5988) [Connector-V2] [TDengine] 修复多线程并行度影响驱动加载问题 (#6020) [Connector-V2] [Jdbc] 修复 jdbc setFetchSize 错误问题 (#6005) [Connector-V2] [CDC] 修复 CDC 任务在恢复运行后无法消费增量数据问题 (#625) (#6094) [Connector-V2] [File] 修复从 Excel 文件读取数据异常问题 (#5932) [Connector-V2] [CDC] 修复恢复任务添加表导致的 NPE 问题 (#6145) [Connector-V2] [Jdbc] 修复 dameng 目录查询表 sql (#6141) [Connector-V2] [Jdbc] 更新 pgsql 目录以进行保存模式 (#6080) [Connector-V2] [Jdbc] 修复大量重复数据时的拆分器错误 (#6026) [Connector-V2] [CDC] 修复作业恢复后无法解析添加的列 (#6118) [Connector-V2] [CDC] 修复 CDCRecordEmitDelay 指标中的负值 (#6259) [Connector-V2] [Oracle CDC] 修复无主键时拆分键无效的问题 (#6251) Zeta(ST-Engine) [Zeta] 修复 NotifyTaskRestoreOperation npe (#5362) [Zeta] 修复 Zeta 将关闭两次任务的错误 (#5422) [Zeta] 禁用CheckpointTimeOutTest (#5438) [Zeta] 修复 CDC 任务恢复抛出 NPE 的问题 (#5507) [Zeta] 多个同类型 Sink Action 同名的问题 (#5499) [Zeta] Checkpoint 异常状态消息不包含状态数据 (#5547) [Zeta] 修复 Checkpoint 相关的内存泄漏问题 (#5539) [Zeta] 修复 Checkpoint 阻塞时间过长的问题 (#5695) [Zeta] 修复 Job 状态不稳定的问题 (#5450) [Zeta] 修复提交 Job api (#5702) [Zeta] 将默认 DeployMode 设置为 DeployMode.CLIENT (#5783) [Zeta] rest api 提交中文名称的 Job 返回乱码问题 (#5870) [Zeta] 修复 CheckpointCoordinator 在 ack not exist 挂起 Checkpoint 时报 NPE 的问题(#5909) [Zeta] 修复提交作业有相同作业名称的错误。 (#6041) [Zeta] 修复由于没有状态参数导致返回列表为空的问题 (#6040) [Zeta] 修复 zeta 调度程序错误 (#6050) [Zeta] 修复上次检查点失败时作业无法恢复的问题 (#6193) [Zeta] [Rest-API] 从非活动主节点提交或停止作业 (#6217) E2E [E2E] [Common] 更新 seatunnel 引擎的测试容器版本 (#5323) [E2E] [Jdbc] 修复 jdbc suite 测试完成后不删除 docker 镜像的问题 (#5586) [E2E] [ClickHouse] 增强 ClickHouse E2E 测试以触发多个检查点 (#5476) [E2E] 修复 jdbc suite 测试完成后不删除 docker 镜像的问题 (#5586) [E2E] 修复 ConnectorPackageServiceContainer 未实现 getSavePointCommand/getRestoreCommand (#5780) [E2E] 修复由 JdbcHiveIT 和 SparkSinkTest 导致的构建失败 (#5798) [E2E] 修复提交作业案例错误 (#6059) [E2E] 修复与操作相关的错误 (#6264) [E2E] 将 mysql 容器版本锁定为 8.0 (#6263) CI [CI] 修复 jindo oss 连接器名称 (#5385) [Build] 修复 fork 存储库未更新时出现的错误消息。 (#5497) [CI] 修复 CI 在 fork 存储库中运行时不检查文件更改的问题 (#5515) [CI] 删除 jindo 依赖项 (#5528) [CI] 修复 phoenix ci 错误 (#5530) [Build] 将构建版本更新为 2.3.4-SNAPSHOT (#5619) [Build] 确保 install-plugin.sh 与 Debian 上的 sh 兼容 #5630 (#5631) [CI] [Chore] 删除无用的 sonar 检查脚本 (#5665 [Chore] 删除 DISCLAIMER 文件 (#5673) [CI] 修复 CI 不稳定问题 (#5896) [Build] 修复 config/plugin_config 中的空行导致 BUILD FAILURE (#5921) [CI] 修复 CI 在不更改 api 时不运行 Kudu/AmazonSQS IT 的问题 (#5955) [CI] 将 doris e2e 拆分为独立模块 (#5999) [CI] 修复死链接检查失败 (#6016) [CI] 修复 e2e 错误 (#6018) [Build] 更新 pom.xml (#6113) [Build] 解决示例运行失败问题 (#6173) [Build] 修复构建错误 (#6196) [CI] 修复引擎客户端无法关闭问题 (#6241) 示例 [示例] 修改转换 URL 链接 (#5298) 改进 [改进][CheckStyle] 删除 checkstyle 中无用的“SuppressWarnings”注释。(#5260) [改进][CheckStyle] 调整 spotless 插件的发布阶段。 (#5607) Core [Core] [API] 删除 CatalogTableUtil 中的 CatalogTable 字段 (#5521) [Core] [API] 将获取架构逻辑从 Config 移至 ReadonlyConfig (#5534) [Starter] 当为一个 pluginIdentifier 找到多个连接器 jar 时抛出 IllegalArgumentException (#5551) [Core] [API] 重构 CatalogTable 并添加 SeaTunnelSource::getProducedCatalogTables (#5562) [Core] [API] 支持架构中的配置列/primaryKey/constraintKey (#5564) [Core] [API] 删除无用的 ReadonlyConfig 扁平化功能 (#5612) [Core] [Flink & Spark] 重构 Spark/Flink 执行处理器 (#5595) [Core] [API] 将 SeaTunnelPluginLifeCycle 标记为已弃用(#5625 [Core] [API] 支持配置 schema 的 tableIdentifier (#5628) [Core] [Pom] 将 junit4 添加到根 pom (#5611) [Core] [API] 删除配置文件的 catalog 标签 (#5645) [Core] [API] 删除来自 setTypeInfo 的无用转换代码 (#5647) [Core] [API] 确保 CatalogTable 选项和分区键是可变的 (#5681) [Core] [API] 添加 SeaTunnelSource::getProducedType 的默认实现 (#5670) [Core] [API] 添加 SeaTunnelSink::setTypeInfo 的默认实现 (#5682) [Core] [API] 添加使用 fall back keys 的警告 (#5753) [Core] [API] 调整 flink 和 spark 引擎的睡眠模式与 zeta 一致 (#5698) [核心] [API] 删除 Factory 选项以避免无用信息 (#5754) [核心] [API] 将字段名称添加到 DataTypeConvertor 以改进错误消息 (#5782) [核心] [API] 删除使用 SeaTunnelSink::getConsumedType 方法并将其标记为已弃用 (#5755) [核心] [通用] 删除断言关键字。 (#5915) [核心] [通用] 清理流程控制代码 (#5991) [核心] [通用] 将 FILE_OPERATION_FAILED 调整为 CommonError (#5928) [核心] [API] 将 serialVersionUID 添加到列 [核心] [通用] 将 SupportResourceShare 扩展到 spark/flink (#5847) [核心] [API] 如果检查点已禁用，则删除检查点超时检查 (#6231) 格式 [Json] 使用静态对象映射器，而不是每次都创建它 (#5460) [Json] 删除 assert 关键字。 (#5919) [格式] 替换 CommonErrorCodeDeprecated.JSON_OPERATION_FAILED。 (#5948) [格式] 重构 ignoreParseErrors 的异常捕获。（#6065） [格式] 在 seatunnel-format-compatible-debezium-json 中使用十进制类型的数字格式（#5803） [文本] 添加 dateTimeFormatter 以解析 ISO8601（#5974） [格式] 替换 CommonErrorCodeDeprecated.JSON_OPERATION_FAILED （#5948） Connector-V2 [Connector-V2] [IoTDB] 移除 IoTDB 接收器中的调度程序 (#5270) [Connector-V2] [InfluxDB] 移除 InfluxDB 接收器中的调度程序 (#5271) [Connector-V2] [Dynamodb] 移除 Dynamodb 接收器中的调度程序 (#5248) [Connector-V2] [StarRocks] 移除 StarRocks 接收器中的调度程序 (#5269) [Connector-V2] [CDC] 避免列出不必要的数据库下的表 (#5365) [Connector-V2] [Jdbc] 重构 AbstractJdbcCatalog (#5096) [Connector-V2] [CDC] 支持 flink 运行 cdc 作业 (#4918) [Connector-V2] [Assert] 支持“DECIMAL”类型并修复“Number”类型精度问题(#5479) [Connector-v2] [Redis] Redis 支持 select db (#5570) [Connector-v2] [CDC] 使用 Source 输出 CatalogTable (#5626) [Connector-v2] [SqlServer CDC] 添加 dataType datetimeoffset (#5548) [Connector-v2] [Jdbc] 支持读取多表 (#5581) [Connector-v2] [SqlServer CDC] 统一 sqlserver TypeUtils 类型转换模式 (#5668) [Connector-v2] [Http] 改进 http e2e 测试 (#5655) [Connector-v2] [AmazonDynamicDB] 添加 amazondynamicdb 源拆分 (#5275) [Connector-v2] [File] parquet 使用系统时区 (#5605) [Connector-v2] [Amazonsqs] 将 amazonsqs 更改为 AmazonSqs 作为连接器标识符 (#5742) [Connector-v2] [File] 统一文件源/接收器和更新文档之间的选项 (#5680) [Connector-v2] [AmazonDynamicDB] 清理 AmazonDynamoDB 连接器的代码 (#5791) [Connector-v2] [MongoDB] 实现 TableSourceFactory 以创建 mongodb 源 [Connector-v2] [Jdbc] 优化目录表元数据合并逻辑 (#5828) [Connector-v2] [Jdbc] 重命名 getCountSql 为 getExistDataSql (#5838) [Connector-v2] [ClickHouse] 加快 ClickhouseFile Local 生成 mmap 对象的速度 (#5822) [Connector-v2] [Jdbc] 改进 Jdbc 连接器错误消息不支持数据类型 (#5864) [Connector-v2] [Jdbc] 减少 jdbc 中 getCatalogTable 的时间成本 (#5908) [Connector-v2] [StarRocks] 支持在 StarRocks 中创建 varchar 字段类型 (#5911) [Connector-v2] [StarRocks] 添加 http 套接字超时。 (#5918) [Connector-v2] [File] 清理 JsonWriteStrategy 和 ExcelWriteStrategy 的内存缓冲区 (#5925) [Connector-v2] [StarRocks] StarRocks 支持使用唯一键创建表模板 (#5905) [Connector-v2] [CDC] 在 exactly_once 关闭时禁用内存缓冲 (#6017) [Connector-v2] [Doris] 在 doris sink 中添加批量刷新 (#6024 [Connector-v2] [Paimon] 适配 Paimon 0.6 版本 (#6061) [Connector-v2] [File] 让 Oss 实现源工厂和接收器工厂 (#6062) [Connector-v2] [File] 禁用 HDFSFileSystem 缓存 (#6039) [Connector-v2] [Jdbc] 在 jdbc 中遮盖 hikari连接器 (#6116) [Connector-v2] [Jdbc] 支持 Sqlserver Niche 数据类型 (#6122) [Connector-v2] [Kafka] 删除 kafka 连接器的无用代码 (#6157) [Connector-v2] [Doris] 改进 doris sink 以随机使用 be (#6132) [Connector-v2] [Http] 增加自定义配置超时。 (#6223) [Connector-v2] [Pulsar] 提高 pulsar 吞吐量性能。 (#6234) [Connector-v2] [SqlServer CDC] 在 sql server 中支持 intidentity 类型 (#6186) [Connector-v2] [Doris] Doris 流加载使用 FE 而不是 BE (#6235) [Connector-v2] [Postgres CDC] 修复名称拼写错误(#6248) [Connector-v2] [Tdengine] 支持从 tdengine 读取 bool 列 (#6025) [Connector-v2] [Jdbc] 使用 PreparedStatement 从列中抽样数据 (#6242) CI [CI] 更新 sql-udf 文档 (#5197) [CI][E2E][Zeta] 增加 Zeta 检查点超时以避免 Connector-file-sftp-e2e 频繁失败 (#5339) [CI] 修复 phoenix ci 错误 [Build] 将 seatunnel-hadoop3-3.1.4-uber.jar 放入发布二进制包 (#5743) [Test] 确保 spark 中的值不会被重复使用。 (#5767) [测试] 移动 MaxCompute 测试用例文件 (#5786) [CI] 始终运行所有模块单元测试 (#5800) [测试] 将 System.out.println 更改为日志输出。 (#5912) [测试] 添加一些命令使用的测试用例 [测试] 修复 sql server catalog 测试用例失败 (#6128) [测试] 修复 JobMetricsTest 不稳定 (#6152) [测试] 修复 ConnectorSpecificationCheckTest 不起作用 (#5820 E2E [E2E] 删除不必要的代码以减少磁盘压力 (#5613) [E2E] 为 Oceanbase Mysql 模式启用 IT 案例 (#5697) [E2E] 按需从 url 加载驱动类 (#5712) [E2E] Jdbc 测试检查数据一致性。 (#5734) [E2E] 启用 e2e 日志输出并禁用控制台接收器日志 (#5879) [E2E] 改进所有引擎的 e2e 日志 (#5936) [E2E] 增强 Kudu E2E 的稳定性 (#6258) Zeta(ST-Engine) [Zeta] 优化测试用例 CheckpointTimeOutTest.testJobLevelCheckpointTimeOut (#5403) [Zeta] 改进依赖包 (#5624) [Zeta] 将硬代码配置键更改为引用 (#5618) [Zeta] 更改 RestJobExecutionEnvironment 实现的类名 (#5671) [Zeta] 更改默认的 Zeta 客户端 JVM 堆值 (#5674) [Zeta] 将 generate_client_protocol.sh 移至引擎模块 (#5667) [Zeta]优化 SeaTunnel Zeta 引擎 Jar 包上传逻辑 (#5542) [Zeta] 将 RestJobExecutionEnvironment 移至 rest 包 (#5764) [Zeta] 从操作名称（checkpoint state 键）中删除 result_table_name (#5779) [Zeta] 重构 jar 包服务模块 (#5763) [Zeta] 将客户端 cluster-connect-timeout-millis 暴露给 yaml (#5868) [Zeta] 减少 checkpoint 完成日志 (#5916) [Zeta] 删除 assert 关键字 (#5947) [Zeta] 调整工厂验证实现的日志级别。 (#6153) [Zeta] 忽略无用的错误目标槽错误 (#6135) [Zeta] 添加提交失败时的恢复 (#6101) Transformer-V2 [全部] SeaTunnel 转换的代码清理 (#5810) [全部] 添加转换的常见错误 (#5815) 功能核心 [核心] [API] 添加检查点超时的作业级配置。 (#5222) [核心] [API] Catalog 添加大小写转换定义 (#5328) [核心] [API] 添加 InMemoryCatalog 进行测试并添加新的 getCatalogTableFromConfig 方法 (#5485) [核心] [Flink] 支持可配置精度和小数位数的 Decimal 类型 (#5419) [核心] [API] 在 SinkAggregatedCommitter 中添加 init 和 restoreCommit 方法 (#5598) [核心] [Flink] 支持 Flink 中的流控制 (#5509) [核心] [Spark] 支持 SeaTunnel 时间类型。 (#5188) [核心] [Flink] 删除无用的 stageType。 (#5650) [核心] [API] 支持多表接收器 (#5620) [核心] [Spark] 支持 Spark 中的流控制 (#5510) [核心] [Flink] 添加外部配置参数 (#5480) [核心] [API] 删除所有无用的 prepare 、 getProducedType 方法 (#5741) [核心] [通用] 引入新的错误定义规则 (#5793) [核心] [通用] 删除无用的 DeserializationFormatFactory 及其实现 (#5880) [核心] [API] 在 JdbcRowConverter 中将 SeaTunnelRowType 替换为 TableSchema [核心] [Flink] 升级 flink 源转换 (#5100) [核心] [API] 为所有目录添加不支持的数据类型检查 (#5890) [核心] [Flink] 支持 Flink 引擎中的记录指标 (#6035) Connector-V2 [Connector-V2] [SqlServer CDC] 支持多表读取 (#4377) [Connector-V2] [Jdbc] Jdbc 数据库支持标识符 (#5089) [Connector-V2] [Jdbc] jdbc 连接器支持 Kingbase 数据库 (#4803) [Connector-V2] [Jdbc] 添加 tidb 数据类型转换器 (#5440) [Connector-V2] [Jdbc] 添加 Dameng 目录 (#5451) [Connector-V2] [File] 支持在输出类型为文件 (CSV) 时写入列名 (#5459) [Connector-V2] [File] FILE_FORMAT_TYPE 为 text/csv，添加参数 BaseSinkConfig.ENABLE_HEADER_WRITE: #5566 (#5567) [Connector-V2] [CDC] 支持优先使用数字字段作为拆分键 (#5384) [Connector-V2] [File] 支持读取空目录 (#5591) [Connector-V2] [Fake&Assert] 从 FakeSource/Assert 中添加 table-names 以生成/断言多表 (#5604) [Connector-V2] [Jdbc] 添加 OceanBase 目录 (#5439) [Connector-V2] [File] 支持在文件读取时使用 LZO 压缩 (#5083) [Connector-V2] [MongoDB CDC] 支持在 flink 上运行 MongoDB CDC (#5644) [Connector-V2] [Jdbc] 支持更多配置连接参数的方式。 (#5388) [Connector-V2] [Kafka] KafkaSource 使用 Factory 创建源 (#5635) [Connector-V2] [Jdbc] 添加连接器 amazonsqs (#5367) [Connector-V2] [Jdbc] 支持 MaxCompute Source 中的 catalog (#5283) [Connector-V2] [Kudu] 重构 Kudu 功能，Sink 支持 CDC 数据。 (#5437) [Connector-V2] [Mysql CDC] 优化 mysql server-id 默认值范围，减少冲突。 (#5550) [Connector-V2] [Http] HTTP 支持页面增加 #5477 (#5561) [Connector-V2] [Jdbc] 增加 Save Mode 功能，实现 Connector-JDBC (MySQL) 连接器 (#5663) [Connector-V2] [Jdbc] 支持 XMLTYPE 数据集成 #5716 (#5723) [Connector-V2] [Jdbc] 支持 Hive JDBC Source Connector (#5424) [Connector-V2] [Http] Http 参数支持自定义加密 (#5727) [Connector-V2] [Kudu] 支持 kudu 上的 TableSourceFactory/TableSinkFactory (#5789) [Connector-V2] [File] LocalFileSource 支持多表 [Connector-V2] [Fake] FakeSource 支持为 MultipleTable 生成不同的 CatalogTable (#5766) [Connector-V2] [Kudu] 支持多表源读取 (#5878 [Connector-V2] [Http] 支持 http 上的 TableSourceFactory/TableSinkFactory (#5816) [Connector-V2] [Redis] 支持 redis 上的 TableSourceFactory/TableSinkFactory (#5901) [Connector-V2] [Jdbc] 修复拆分键不支持 BigInteger 类型 [Connector-V2] [File] LocalFile 接收器支持多表 (#5931) [Connector-V2] [Doris] Doris Catalog (#5175) [Connector-V2] [Kudu] 支持 kudu 的多表接收器功能 (#5951) [Connector-V2] [File] 支持使用多个 hadoop 帐户 (#5903) [Connector-V2] [File] 放入多表文件 API 到文件基础模块 (#6033) [Connector-V2] [Paimon] Flink 表存储准备提交失败 (#6057) [Connector-V2] [File] 将多个表文件接收器添加到基础 (#6049) [Connector-V2] [Jdbc] 添加 JDBC 源支持字符串类型作为分区键 (#6079) [Connector-V2] [File] 支持读取 .xls excel 文件 (#6066) [Connector-V2] [CDC] 支持读取无主键表 (#6098) [Connector-V2] [Assert] 支持检查 Decimal 类型的精度和小数位数。 (#6110) [Connector-V2] [Hbase] 支持数组数据。 (#6100) [Connector-V2] [File] FTP 源/接收器添加 ftp 连接模式 (#6077) (#6099) [Connector-V2] [Jdbc] 更新 sqlserver 目录以进行保存模式 (#6086) [Connector-V2] [CDC] 支持自定义表主键 (#6106) [Connector-V2] [Doris] 在 Doris 上支持 SaveMode (#6085) [Connector-V2] [Jdbc] 更新 oracle 目录以进行保存模式 (#6092) [Connector-V2] [ElasticSearch] 添加 elasticsearch save_mode (#6046) (#6092) [Connector-V2] [Jdbc] 改进获取列 sql 兼容性 (#5664) [Connector-V2] [Jdbc] 改进获取列 sql 兼容性 (#5664) [Connector-V2] [Pulsar] 添加 Pulsar Sink 连接器。 (#4382) [Connector-V2] [StarRocks] 添加 starrocks save_mode (#6029) [Connector-V2] [Oracle CDC] 支持 oracle cdc (#5196) [Connector-V2] [Doris] 添加 Doris ConnectorV2 源 (#6161) [Connector-V2] [Jdbc] 在 postgres jdbc 中支持 uuid (#6185) [Connector-V2] [Oracle CDC] 支持读取无主键表 (#6209) [Connector-V2] [Oracle CDC] 修复 jdbc setFetchSize 错误 (#6210) [Connector-V2] [Oracle CDC] 修复将单表切换为多表时的状态恢复错误 (#6211) [Connector-V2] [Oracle CDC] 清理未使用的代码 (#6212) [Connector-V2] [File] 添加 s3file 保存模式功能 (#6131) [Connector-V2] [Oracle CDC] 支持自定义表主键 (#6216) [Connector-V2] [CDC] 添加日期类型和浮点类型列拆分支持 (#6160) [Connector-V2] [Postgres CDC] 支持 Postgres cdc (#5986) [Connector-V2] [Postgres CDC] 更新 jdbc fetchsize (#6245) [Connector-V2] [CDC] 默认禁用 exact_once 以提高稳定性 (#6244) [Connector-V2] [CDC] 在拆分器中支持 Short 和 Byte 类型 (#6027) [Connector-V2] [Jdbc] 改进查询表的近似总行数 (#5972) Zeta(ST-Engine) [Zeta] 添加 UNKNOWABLE 作业状态。(#5303) [Zeta] 支持 zeta 中的流控制 (#5502) [Zeta] [REST-API] 停止正在运行的作业。 (#5512) [Zeta] 在 Kubernetes 上支持 Zeta 引擎 (#5594) [Zeta] 在批处理模式下，可以禁用检查点 (#5914) [Zeta] 将跳过触发检查点日志级别更改为调试 (#5954) [Zeta] 添加新的作业状态 DOING_SAVEPOINT 和 SAVEPOINT_DONE (#5917) [Zeta] 添加 waitForJobCompleteV2 api (#5965) [Zeta] 可以使用 rest api 自动将作业提交到 Zeta 主节点 (#5950) [Zeta] [REST-API] 获取已完成作业的信息 (#5949) [Zeta] 修复转换操作返回相同名称的问题 (#6034) [Zeta] 统一作业环境参数 (#6003) [Zeta] 将 TaskGroupLocation 添加到 TaskExecutionService 的线程名称中(#6095) [Zeta] 在 zeta 中使用 G1 作为默认垃圾收集器 (#6114) [Zeta] 修复从保存点启动时没有检查点文件的错误 (#6215) [Zeta] 支持在通用类型中以 hocon 样式声明行类型 (#6187) CI [Bin] 为所有 shell 脚本添加 .bat 脚本。（#5445） [INFRA] 将 CI 移至 fork 存储库容器上运行（#5495） [Build] 删除 connector/seatunnel 目录（#5489） [INFRA] 更新 PR 模板以添加测试和用户更改问题（#5486） [INFRA] 为 notify_test_workflow.yml 添加日志以跟踪错误原因 [INFRA] 修复 notify_test_workflow.yml 不稳定问题 [Test] 在 jdbc suite 上完成测试后删除 docker 镜像（#5568） [Test] 为 ResourceManager 添加测试以确保任务将部署在不同节点中（#5518） [Chore] 删除无用的 .scalafmt.conf 文件（#5616） [LICENSE] 添加 hadoop 许可证（#6067） [Build] 将 seatunnel-spark-3-starter.jar 添加到发布包中（#6044） [测试] 减少重复目录测试次数 (#6207) [CI] 确保会抛出notify_test_workflow.yml错误 (#6226) 格式 [Ogg] 支持读取 ogg 格式消息 #4201 (#4225) [Json] 删除 assert 关键字。(#5919) [Avro] 支持 avro 格式 (#5084) [格式] 重构 ignoreParseErrors 的异常捕获。 (#6065) [Avro] 改进 avro 格式转换 (#6082) Transformer-V2 [All] 添加 JsonPath 转换 (#5632) [All] 支持 SqlTransform Not Like Expression (#5768) [All] 添加 from_unixtime 函数 (#5462) [All] 支持表达式的大小写 (#6123) 文档 [文档] 使用统一格式飞书重构 Connector-v2 文档 (#5343) [文档] 重构 IoTDB 接收器文档 (#5306) [文档] 更正单词错误 (#5360) [文档] 改进 Iceberg 文档 (#5335) [文档] 使用短网址 https://s.apache.org/seatunnel-slack 替换长网址 (#5363) [文档] 改进 http doc param body des (#5368) [文档] 重构connector-v2文档，使用统一格式Slack (#5344) [文档] 更新sql-udf文档 (#5197) [文档] 重构MySQL-CDC文档 (#5302) [文档] 在FtpFile选项描述中将username替换为user (#5421) [文档] 更新iotdb文档 (#5404) [文档] 增加mysql Connector Document版本标题示例pr (#5249) [文档] 添加Parallel并行性 (#5310) [文档] 源代码中Http source选项键poll_interval_ms不同 (#5430) [文档] 修复kafka sink的错误示例 (#5527) [文档] 改进Console Sink文档 (#5230) [文档] 添加如何更改 e2e 测试的日志配置 (#5589) [文档] 添加 RocketMq 连接器 (#5361) [文档] 修复 README.md 中的构建状态未更新 (#5574) [文档] hdfsFile file_format 更改为 file_format_type (#5653) [文档] 改进 README.md (#5662) [文档] 添加 FakeSource 连接器文档 (#5255) [文档] 在 README.md 中引入 SeaTunnel web 项目 (#5634) [文档] 在 README 中添加目录和常见问题解答 (#5693) [文档] 更新 quick-start-spark.md (#5795) [文档] 添加套接字连接器文档 #5255 (#5287) [文档] 改进文件接收器文档（#5799） [文档] 添加 SqlServer 连接器文档（#5498） [文档] 更新（#5808） [文档] 添加 hive jdbc 引用值（#5882） [文档] Checkpoint-Storage 描述不正确。 (#5883) [文档] 重构 OssFile 连接器文档 (#5233) [文档] 修复 oss 连接器无法运行的 bug (#6010) [文档] 更新 jdbc-connector 文档 (#5765) [文档] 添加 V2 连接器 jdbc 文档参数可加快数据导入 PR (#6176) [文档] 修改部分文档标题规范 (#6237) [文档] 重构 Socket Source 和 SftpFile 连接器文档 (#5386) [文档] 完善驱动程序 put 路径文档 [文档] 修正数组元素类型和映射键类型的引入 (#6261)

Apache SeaTunnel 2.3.4 发布

qianmoQ

错误修复

核心

[核心] [API] 修复列表的通用类丢失 (#4421)
[Starter] 修复 [] 中“，”被分割的问题 (#5401)
[核心] [API] 修复 ReadonlyConfig 丢失键的错误 (#5565)
[核心] [API] 修复从 LinkHashMap 获取字节 (#5622)
[核心] [API] 修复多表接收器关闭时的日志错误 (#5683)
[核心] [API] 修复 MultiTableSink 返回提交者但接收器不支持的问题 (#5710)
[核心] [API] 修复使用不支持的类型解析架构时的错误消息 (#5790)
[核心] [API] 修复不稳定的测试 OptionUtilTest.test (#5894)
[核心] [API] 修复 SaveModeHandler 无法关闭的问题 (#5843)
[核心] [API]修复 MultiTableSinkWriter 线程索引始终为 1 (#5832)
[Core] [API] 修复 SeaTunnelRow::getBytesSize 不支持 map 接口 (#5990)
[Core] [Common] 修复 FileUtils::createNewFile 无法创建新文件 (#5943)
[Core] [API] 修复 Debezium 格式无法解析日期/时间/时间戳 (#5887)
[Starter] 在双引号内时，‘,’ 被视为普通字符而不是分隔符 (#6042
[Core] [Common] 替换 CommonErrorCodeDeprecated.JSON_OPERATION_FAILED (#5978)
[Core] [API] 修复 Object.class 选项值无法返回正常值 (#6247)

Transformer-V2

[All] 修复 transform 中的 PrimaryKey (#5704)
[All] 修复强制转换为时间戳、日期、时间的 bug (#5812)

Formats

[Text] 允许 map 中的条目为空，允许条目中的 key 为空 (#5277)

Connector-V2

[Connector-V2] [Clickhouse] 修复 clickhouse 旧版本兼容性 (#5326)
[Connector-V2] [Clickhouse] 修复 http header 覆盖 (#5446)
[Connector-V2] [StarRocks] 修复 starrocks template sql parser (#5332)
[Connector-V2] [Hive] 修复 HiveConf 中 hive-site.xml 无法注入的 bug (#5261)
[Connector-V2] [Clickhouse] 修复 clickhouse sink flush bug (#5448)
[Connector-V2] [Hive] 修复读取空目录时出错 (#5427)
[Connector-V2] [Hive] 修复读取空目录时出错 (#5427)" (#5487)
[Connector-V2] [Oss jindo] 修复 jindo 驱动下载失败的问题。 (#5511)
[Connector-V2] [Oss jindo] 移除无用代码 (#5540)
[Connector-V2] [File] 修复 WriteStrategy 并行写入线程不安全问题 (#5546)
[Connector-V2] [CDC] 修复原表删除字段时 cdc 出现 NPE 的 bug (#5579)
[Connector-V2] [Jdbc] oracle catalog 创建表重复，oracle pg 出现 null 点 (#5517)
[Connector-V2] [CDC] 修复 cdc 枚举器中线程不安全的集合容器 (#5614)
[Connector-V2] [Mongodb] 修复 bsonNull 导致的不支持异常 (#5659)
[Connector-V2] [File] 修复文件接收器 isPartitionFieldWriteInFile 在没有给出列时发生异常的问题 (#5508)
[Connector-V2] [Doris] 修复 RestService 报 NullPointerException 问题 (#5319)
[Connector-V2] [MaxCompute] 修复 MaxCompute 使用不存在的 SCHEMA 选项问题 (#5708)
[Connector-V2] [Doris] 使用 try-with-resources 简化代码。 (#4995)
[Connector-V2] [Clickhouse] 修复 clickhouse-sink 输出数据字段乱序的 BUG (#5346)
[Connector-V2] [Jdbc] 支持 postgresql xml 类型 (#5724)
[Connector-V2] [Jdbc] Nullable Column source 有 null 数据可能会产生意想不到的结果。 (#5560)
[Connector-V2] [Iceberg] Iceberg 源使用并行选项时丢失数据 (#5732)
[Connector-V2] [Jdbc] 修复使用自动创建表时 PG 不会创建索引的问题 #5721
[Connector-V2] [Jdbc] 修复数据库标识符 (#5756)
[Connector-V2] [CDC] 修复添加新表时 MultiTableSink 恢复失败的问题 (#5746)
[Connector-V2] [Postgres CDC] 修复 Postgres 创建表测试用例失败的问题 (#5778)
[Connector-V2] [CDC] 清理未使用的代码 (#5785)
[Connector-V2] [CDC] 修复将单表切换到多表时的状态恢复错误 (#5784)
[Connector-V2] [ElasticSearch] 修复 elasticsearch 数组格式转换异常的问题 (#5825)
[Connector-V2] [Jdbc] 修复从 Oracle Date 类型值读取时丢失时间的问题 (#5814)
[Connector-V2] [Pulsar] 修复：更新项目：seatunnel-web 上 pulsar-datasource 的 IDENTIFIER = Pulsar (#5852)
[Connector-V2] [Jdbc] 修复 Hive-Jdbc 使用 krb5 覆盖 kerberosKeytabPath 的问题 (#5891)
[Connector-V2] [InfluxDB] 解决由直接 QUERY_LIMIT 附加到“tz”函数导致的 initColumnsIndex 方法中的无效 SQL。(#4829)
[Connector-V2] [Jdbc] 修复 cdc 更新未过滤相同主键的问题 (#5923)
[Connector-V2] [File] Parquet 读取器解析数组类型异常。 (#4457)
[Connector-V2] [Http] 修复 http 配置无 schema 选项问题，完善 e2e 测试添加用例 (#5939)
[Connector-V2] [Doris] 修复 DorisCatalog 未实现 name 方法问题 (#5988)
[Connector-V2] [TDengine] 修复多线程并行度影响驱动加载问题 (#6020)
[Connector-V2] [Jdbc] 修复 jdbc setFetchSize 错误问题 (#6005)
[Connector-V2] [CDC] 修复 CDC 任务在恢复运行后无法消费增量数据问题 (#625) (#6094)
[Connector-V2] [File] 修复从 Excel 文件读取数据异常问题 (#5932)
[Connector-V2] [CDC] 修复恢复任务添加表导致的 NPE 问题 (#6145)
[Connector-V2] [Jdbc] 修复 dameng 目录查询表 sql (#6141)
[Connector-V2] [Jdbc] 更新 pgsql 目录以进行保存模式 (#6080)
[Connector-V2] [Jdbc] 修复大量重复数据时的拆分器错误 (#6026)
[Connector-V2] [CDC] 修复作业恢复后无法解析添加的列 (#6118)
[Connector-V2] [CDC] 修复 CDCRecordEmitDelay 指标中的负值 (#6259)
[Connector-V2] [Oracle CDC] 修复无主键时拆分键无效的问题 (#6251)

Zeta(ST-Engine)

[Zeta] 修复 NotifyTaskRestoreOperation npe (#5362)
[Zeta] 修复 Zeta 将关闭两次任务的错误 (#5422)
[Zeta] 禁用CheckpointTimeOutTest (#5438)
[Zeta] 修复 CDC 任务恢复抛出 NPE 的问题 (#5507)
[Zeta] 多个同类型 Sink Action 同名的问题 (#5499)
[Zeta] Checkpoint 异常状态消息不包含状态数据 (#5547)
[Zeta] 修复 Checkpoint 相关的内存泄漏问题 (#5539)
[Zeta] 修复 Checkpoint 阻塞时间过长的问题 (#5695)
[Zeta] 修复 Job 状态不稳定的问题 (#5450)
[Zeta] 修复提交 Job api (#5702)
[Zeta] 将默认 DeployMode 设置为 DeployMode.CLIENT (#5783)
[Zeta] rest api 提交中文名称的 Job 返回乱码问题 (#5870)
[Zeta] 修复 CheckpointCoordinator 在 ack not exist 挂起 Checkpoint 时报 NPE 的问题(#5909)
[Zeta] 修复提交作业有相同作业名称的错误。 (#6041)
[Zeta] 修复由于没有状态参数导致返回列表为空的问题 (#6040)
[Zeta] 修复 zeta 调度程序错误 (#6050)
[Zeta] 修复上次检查点失败时作业无法恢复的问题 (#6193)
[Zeta] [Rest-API] 从非活动主节点提交或停止作业 (#6217)

E2E

[E2E] [Common] 更新 seatunnel 引擎的测试容器版本 (#5323)
[E2E] [Jdbc] 修复 jdbc suite 测试完成后不删除 docker 镜像的问题 (#5586)
[E2E] [ClickHouse] 增强 ClickHouse E2E 测试以触发多个检查点 (#5476)
[E2E] 修复 jdbc suite 测试完成后不删除 docker 镜像的问题 (#5586)
[E2E] 修复ConnectorPackageServiceContainer 未实现 getSavePointCommand/getRestoreCommand (#5780)
[E2E] 修复由 JdbcHiveIT 和 SparkSinkTest 导致的构建失败 (#5798)
[E2E] 修复提交作业案例错误 (#6059)
[E2E] 修复与操作相关的错误 (#6264)
[E2E] 将 mysql 容器版本锁定为 8.0 (#6263)

CI

[CI] 修复 jindo oss 连接器名称 (#5385)
[Build] 修复 fork 存储库未更新时出现的错误消息。 (#5497)
[CI] 修复 CI 在 fork 存储库中运行时不检查文件更改的问题 (#5515)
[CI] 删除 jindo 依赖项 (#5528)
[CI] 修复 phoenix ci 错误 (#5530)
[Build] 将构建版本更新为 2.3.4-SNAPSHOT (#5619)
[Build] 确保 install-plugin.sh 与 Debian 上的 sh 兼容 #5630 (#5631)
[CI] [Chore] 删除无用的 sonar 检查脚本 (#5665
[Chore] 删除 DISCLAIMER 文件 (#5673)
[CI] 修复 CI 不稳定问题 (#5896)
[Build] 修复 config/plugin_config 中的空行导致 BUILD FAILURE (#5921)
[CI] 修复 CI 在不更改 api 时不运行 Kudu/AmazonSQS IT 的问题 (#5955)
[CI] 将 doris e2e 拆分为独立模块 (#5999)
[CI] 修复死链接检查失败 (#6016)
[CI] 修复 e2e 错误 (#6018)
[Build] 更新 pom.xml (#6113)
[Build] 解决示例运行失败问题 (#6173)
[Build] 修复构建错误 (#6196)
[CI] 修复引擎客户端无法关闭问题 (#6241)

示例

[示例] 修改转换 URL 链接 (#5298)

改进

[改进][CheckStyle] 删除 checkstyle 中无用的“SuppressWarnings”注释。(#5260)
[改进][CheckStyle] 调整 spotless 插件的发布阶段。 (#5607)

Core

[Core] [API] 删除 CatalogTableUtil 中的 CatalogTable 字段 (#5521)
[Core] [API] 将获取架构逻辑从 Config 移至 ReadonlyConfig (#5534)
[Starter] 当为一个 pluginIdentifier 找到多个连接器 jar 时抛出 IllegalArgumentException (#5551)
[Core] [API] 重构 CatalogTable 并添加 SeaTunnelSource::getProducedCatalogTables (#5562)
[Core] [API] 支持架构中的配置列/primaryKey/constraintKey (#5564)
[Core] [API] 删除无用的 ReadonlyConfig 扁平化功能 (#5612)
[Core] [Flink & Spark] 重构 Spark/Flink 执行处理器 (#5595)
[Core] [API] 将 SeaTunnelPluginLifeCycle 标记为已弃用(#5625
[Core] [API] 支持配置 schema 的 tableIdentifier (#5628)
[Core] [Pom] 将 junit4 添加到根 pom (#5611)
[Core] [API] 删除配置文件的 catalog 标签 (#5645)
[Core] [API] 删除来自 setTypeInfo 的无用转换代码 (#5647)
[Core] [API] 确保 CatalogTable 选项和分区键是可变的 (#5681)
[Core] [API] 添加 SeaTunnelSource::getProducedType 的默认实现 (#5670)
[Core] [API] 添加 SeaTunnelSink::setTypeInfo 的默认实现 (#5682)
[Core] [API] 添加使用 fall back keys 的警告 (#5753)
[Core] [API] 调整 flink 和 spark 引擎的睡眠模式与 zeta 一致 (#5698)
[核心] [API] 删除 Factory 选项以避免无用信息 (#5754)
[核心] [API] 将字段名称添加到 DataTypeConvertor 以改进错误消息 (#5782)
[核心] [API] 删除使用 SeaTunnelSink::getConsumedType 方法并将其标记为已弃用 (#5755)
[核心] [通用] 删除断言关键字。 (#5915)
[核心] [通用] 清理流程控制代码 (#5991)
[核心] [通用] 将 FILE_OPERATION_FAILED 调整为 CommonError (#5928)
[核心] [API] 将 serialVersionUID 添加到列
[核心] [通用] 将 SupportResourceShare 扩展到 spark/flink (#5847)
[核心] [API] 如果检查点已禁用，则删除检查点超时检查 (#6231)

格式

[Json] 使用静态对象映射器，而不是每次都创建它 (#5460)
[Json] 删除 assert 关键字。 (#5919)
[格式] 替换 CommonErrorCodeDeprecated.JSON_OPERATION_FAILED。 (#5948)
[格式] 重构 ignoreParseErrors 的异常捕获。（#6065）
[格式] 在 seatunnel-format-compatible-debezium-json 中使用十进制类型的数字格式（#5803）
[文本] 添加 dateTimeFormatter 以解析 ISO8601（#5974）
[格式] 替换 CommonErrorCodeDeprecated.JSON_OPERATION_FAILED（#5948）

Connector-V2

[Connector-V2] [IoTDB] 移除 IoTDB 接收器中的调度程序 (#5270)
[Connector-V2] [InfluxDB] 移除 InfluxDB 接收器中的调度程序 (#5271)
[Connector-V2] [Dynamodb] 移除 Dynamodb 接收器中的调度程序 (#5248)
[Connector-V2] [StarRocks] 移除 StarRocks 接收器中的调度程序 (#5269)
[Connector-V2] [CDC] 避免列出不必要的数据库下的表 (#5365)
[Connector-V2] [Jdbc] 重构 AbstractJdbcCatalog (#5096)
[Connector-V2] [CDC] 支持 flink 运行 cdc 作业 (#4918)
[Connector-V2] [Assert] 支持“DECIMAL”类型并修复“Number”类型精度问题(#5479)
[Connector-v2] [Redis] Redis 支持 select db (#5570)
[Connector-v2] [CDC] 使用 Source 输出 CatalogTable (#5626)
[Connector-v2] [SqlServer CDC] 添加 dataType datetimeoffset (#5548)
[Connector-v2] [Jdbc] 支持读取多表 (#5581)
[Connector-v2] [SqlServer CDC] 统一 sqlserver TypeUtils 类型转换模式 (#5668)
[Connector-v2] [Http] 改进 http e2e 测试 (#5655)
[Connector-v2] [AmazonDynamicDB] 添加 amazondynamicdb 源拆分 (#5275)
[Connector-v2] [File] parquet 使用系统时区 (#5605)
[Connector-v2] [Amazonsqs] 将 amazonsqs 更改为 AmazonSqs 作为连接器标识符 (#5742)
[Connector-v2] [File] 统一文件源/接收器和更新文档之间的选项 (#5680)
[Connector-v2] [AmazonDynamicDB] 清理 AmazonDynamoDB 连接器的代码 (#5791)
[Connector-v2] [MongoDB] 实现 TableSourceFactory 以创建 mongodb 源
[Connector-v2] [Jdbc] 优化目录表元数据合并逻辑 (#5828)
[Connector-v2] [Jdbc] 重命名 getCountSql 为 getExistDataSql (#5838)
[Connector-v2] [ClickHouse] 加快 ClickhouseFile Local 生成 mmap 对象的速度 (#5822)
[Connector-v2] [Jdbc] 改进 Jdbc 连接器错误消息不支持数据类型 (#5864)
[Connector-v2] [Jdbc] 减少 jdbc 中 getCatalogTable 的时间成本 (#5908)
[Connector-v2] [StarRocks] 支持在 StarRocks 中创建 varchar 字段类型 (#5911)
[Connector-v2] [StarRocks] 添加 http 套接字超时。 (#5918)
[Connector-v2] [File] 清理 JsonWriteStrategy 和 ExcelWriteStrategy 的内存缓冲区 (#5925)
[Connector-v2] [StarRocks] StarRocks 支持使用唯一键创建表模板 (#5905)
[Connector-v2] [CDC] 在 exactly_once 关闭时禁用内存缓冲 (#6017)
[Connector-v2] [Doris] 在 doris sink 中添加批量刷新 (#6024
[Connector-v2] [Paimon] 适配 Paimon 0.6 版本 (#6061)
[Connector-v2] [File] 让 Oss 实现源工厂和接收器工厂 (#6062)
[Connector-v2] [File] 禁用 HDFSFileSystem 缓存 (#6039)
[Connector-v2] [Jdbc] 在 jdbc 中遮盖 hikari连接器 (#6116)
[Connector-v2] [Jdbc] 支持 Sqlserver Niche 数据类型 (#6122)
[Connector-v2] [Kafka] 删除 kafka 连接器的无用代码 (#6157)
[Connector-v2] [Doris] 改进 doris sink 以随机使用 be (#6132)
[Connector-v2] [Http] 增加自定义配置超时。 (#6223)
[Connector-v2] [Pulsar] 提高 pulsar 吞吐量性能。 (#6234)
[Connector-v2] [SqlServer CDC] 在 sql server 中支持 intidentity 类型 (#6186)
[Connector-v2] [Doris] Doris 流加载使用 FE 而不是 BE (#6235)
[Connector-v2] [Postgres CDC] 修复名称拼写错误(#6248)
[Connector-v2] [Tdengine] 支持从 tdengine 读取 bool 列 (#6025)
[Connector-v2] [Jdbc] 使用 PreparedStatement 从列中抽样数据 (#6242)

CI

[CI] 更新 sql-udf 文档 (#5197)
[CI][E2E][Zeta] 增加 Zeta 检查点超时以避免 Connector-file-sftp-e2e 频繁失败 (#5339)
[CI] 修复 phoenix ci 错误
[Build] 将 seatunnel-hadoop3-3.1.4-uber.jar 放入发布二进制包 (#5743)
[Test] 确保 spark 中的值不会被重复使用。 (#5767)
[测试] 移动 MaxCompute 测试用例文件 (#5786)
[CI] 始终运行所有模块单元测试 (#5800)
[测试] 将 System.out.println 更改为日志输出。 (#5912)
[测试] 添加一些命令使用的测试用例
[测试] 修复 sql server catalog 测试用例失败 (#6128)
[测试] 修复 JobMetricsTest 不稳定 (#6152)
[测试] 修复 ConnectorSpecificationCheckTest 不起作用 (#5820

E2E

[E2E] 删除不必要的代码以减少磁盘压力 (#5613)
[E2E] 为 Oceanbase Mysql 模式启用 IT 案例 (#5697)
[E2E] 按需从 url 加载驱动类 (#5712)
[E2E] Jdbc 测试检查数据一致性。 (#5734)
[E2E] 启用 e2e 日志输出并禁用控制台接收器日志 (#5879)
[E2E] 改进所有引擎的 e2e 日志 (#5936)
[E2E] 增强 Kudu E2E 的稳定性 (#6258)

Zeta(ST-Engine)

[Zeta] 优化测试用例 CheckpointTimeOutTest.testJobLevelCheckpointTimeOut (#5403)
[Zeta] 改进依赖包 (#5624)
[Zeta] 将硬代码配置键更改为引用 (#5618)
[Zeta] 更改 RestJobExecutionEnvironment 实现的类名 (#5671)
[Zeta] 更改默认的 Zeta 客户端 JVM 堆值 (#5674)
[Zeta] 将 generate_client_protocol.sh 移至引擎模块 (#5667)
[Zeta]优化 SeaTunnel Zeta 引擎 Jar 包上传逻辑 (#5542)
[Zeta] 将 RestJobExecutionEnvironment 移至 rest 包 (#5764)
[Zeta] 从操作名称（checkpoint state 键）中删除 result_table_name (#5779)
[Zeta] 重构 jar 包服务模块 (#5763)
[Zeta] 将客户端 cluster-connect-timeout-millis 暴露给 yaml (#5868)
[Zeta] 减少 checkpoint 完成日志 (#5916)
[Zeta] 删除 assert 关键字 (#5947)
[Zeta] 调整工厂验证实现的日志级别。 (#6153)
[Zeta] 忽略无用的错误目标槽错误 (#6135)
[Zeta] 添加提交失败时的恢复 (#6101)

Transformer-V2

[全部] SeaTunnel 转换的代码清理 (#5810)
[全部] 添加转换的常见错误 (#5815)

功能

核心

[核心] [API] 添加检查点超时的作业级配置。 (#5222)
[核心] [API] Catalog 添加大小写转换定义 (#5328)
[核心] [API] 添加 InMemoryCatalog 进行测试并添加新的 getCatalogTableFromConfig 方法 (#5485)
[核心] [Flink] 支持可配置精度和小数位数的 Decimal 类型 (#5419)
[核心] [API] 在 SinkAggregatedCommitter 中添加 init 和 restoreCommit 方法 (#5598)
[核心] [Flink] 支持 Flink 中的流控制 (#5509)
[核心] [Spark] 支持 SeaTunnel 时间类型。 (#5188)
[核心] [Flink] 删除无用的 stageType。 (#5650)
[核心] [API] 支持多表接收器 (#5620)
[核心] [Spark] 支持 Spark 中的流控制 (#5510)
[核心] [Flink] 添加外部配置参数 (#5480)
[核心] [API] 删除所有无用的 prepare、getProducedType 方法 (#5741)
[核心] [通用] 引入新的错误定义规则 (#5793)
[核心] [通用] 删除无用的 DeserializationFormatFactory 及其实现 (#5880)
[核心] [API] 在 JdbcRowConverter 中将 SeaTunnelRowType 替换为 TableSchema
[核心] [Flink] 升级 flink 源转换 (#5100)
[核心] [API] 为所有目录添加不支持的数据类型检查 (#5890)
[核心] [Flink] 支持 Flink 引擎中的记录指标 (#6035)

Connector-V2

[Connector-V2] [SqlServer CDC] 支持多表读取 (#4377)
[Connector-V2] [Jdbc] Jdbc 数据库支持标识符 (#5089)
[Connector-V2] [Jdbc] jdbc 连接器支持 Kingbase 数据库 (#4803)
[Connector-V2] [Jdbc] 添加 tidb 数据类型转换器 (#5440)
[Connector-V2] [Jdbc] 添加 Dameng 目录 (#5451)
[Connector-V2] [File] 支持在输出类型为文件 (CSV) 时写入列名 (#5459)
[Connector-V2] [File] FILE_FORMAT_TYPE 为 text/csv，添加参数 BaseSinkConfig.ENABLE_HEADER_WRITE: #5566 (#5567)
[Connector-V2] [CDC] 支持优先使用数字字段作为拆分键 (#5384)
[Connector-V2] [File] 支持读取空目录 (#5591)
[Connector-V2] [Fake&Assert] 从 FakeSource/Assert 中添加 table-names 以生成/断言多表 (#5604)
[Connector-V2] [Jdbc] 添加 OceanBase 目录 (#5439)
[Connector-V2] [File] 支持在文件读取时使用 LZO 压缩 (#5083)
[Connector-V2] [MongoDB CDC] 支持在 flink 上运行 MongoDB CDC (#5644)
[Connector-V2] [Jdbc] 支持更多配置连接参数的方式。 (#5388)
[Connector-V2] [Kafka] KafkaSource 使用 Factory 创建源 (#5635)
[Connector-V2] [Jdbc] 添加连接器 amazonsqs (#5367)
[Connector-V2] [Jdbc] 支持 MaxCompute Source 中的 catalog (#5283)
[Connector-V2] [Kudu] 重构 Kudu 功能，Sink 支持 CDC 数据。 (#5437)
[Connector-V2] [Mysql CDC] 优化 mysql server-id 默认值范围，减少冲突。 (#5550)
[Connector-V2] [Http] HTTP 支持页面增加 #5477 (#5561)
[Connector-V2] [Jdbc] 增加 Save Mode 功能，实现 Connector-JDBC (MySQL) 连接器 (#5663)
[Connector-V2] [Jdbc] 支持 XMLTYPE 数据集成 #5716 (#5723)
[Connector-V2] [Jdbc] 支持 Hive JDBC Source Connector (#5424)
[Connector-V2] [Http] Http 参数支持自定义加密 (#5727)
[Connector-V2] [Kudu] 支持 kudu 上的 TableSourceFactory/TableSinkFactory (#5789)
[Connector-V2] [File] LocalFileSource 支持多表
[Connector-V2] [Fake] FakeSource 支持为 MultipleTable 生成不同的 CatalogTable (#5766)
[Connector-V2] [Kudu] 支持多表源读取 (#5878
[Connector-V2] [Http] 支持 http 上的 TableSourceFactory/TableSinkFactory (#5816)
[Connector-V2] [Redis] 支持 redis 上的 TableSourceFactory/TableSinkFactory (#5901)
[Connector-V2] [Jdbc] 修复拆分键不支持 BigInteger 类型
[Connector-V2] [File] LocalFile 接收器支持多表 (#5931)
[Connector-V2] [Doris] Doris Catalog (#5175)
[Connector-V2] [Kudu] 支持 kudu 的多表接收器功能 (#5951)
[Connector-V2] [File] 支持使用多个 hadoop 帐户 (#5903)
[Connector-V2] [File] 放入多表文件 API 到文件基础模块 (#6033)
[Connector-V2] [Paimon] Flink 表存储准备提交失败 (#6057)
[Connector-V2] [File] 将多个表文件接收器添加到基础 (#6049)
[Connector-V2] [Jdbc] 添加 JDBC 源支持字符串类型作为分区键 (#6079)
[Connector-V2] [File] 支持读取 .xls excel 文件 (#6066)
[Connector-V2] [CDC] 支持读取无主键表 (#6098)
[Connector-V2] [Assert] 支持检查 Decimal 类型的精度和小数位数。 (#6110)
[Connector-V2] [Hbase] 支持数组数据。 (#6100)
[Connector-V2] [File] FTP 源/接收器添加 ftp 连接模式 (#6077) (#6099)
[Connector-V2] [Jdbc] 更新 sqlserver 目录以进行保存模式 (#6086)
[Connector-V2] [CDC] 支持自定义表主键 (#6106)
[Connector-V2] [Doris] 在 Doris 上支持 SaveMode (#6085)
[Connector-V2] [Jdbc] 更新 oracle 目录以进行保存模式 (#6092)
[Connector-V2] [ElasticSearch] 添加 elasticsearch save_mode (#6046) (#6092)
[Connector-V2] [Jdbc] 改进获取列 sql 兼容性 (#5664)
[Connector-V2] [Jdbc] 改进获取列 sql 兼容性 (#5664)
[Connector-V2] [Pulsar] 添加 Pulsar Sink 连接器。 (#4382)
[Connector-V2] [StarRocks] 添加 starrocks save_mode (#6029)
[Connector-V2] [Oracle CDC] 支持 oracle cdc (#5196)
[Connector-V2] [Doris] 添加 Doris ConnectorV2 源 (#6161)
[Connector-V2] [Jdbc] 在 postgres jdbc 中支持 uuid (#6185)
[Connector-V2] [Oracle CDC] 支持读取无主键表 (#6209)
[Connector-V2] [Oracle CDC] 修复 jdbc setFetchSize 错误 (#6210)
[Connector-V2] [Oracle CDC] 修复将单表切换为多表时的状态恢复错误 (#6211)
[Connector-V2] [Oracle CDC] 清理未使用的代码 (#6212)
[Connector-V2] [File] 添加 s3file 保存模式功能 (#6131)
[Connector-V2] [Oracle CDC] 支持自定义表主键 (#6216)
[Connector-V2] [CDC] 添加日期类型和浮点类型列拆分支持 (#6160)
[Connector-V2] [Postgres CDC] 支持 Postgres cdc (#5986)
[Connector-V2] [Postgres CDC] 更新 jdbc fetchsize (#6245)
[Connector-V2] [CDC] 默认禁用 exact_once 以提高稳定性 (#6244)
[Connector-V2] [CDC] 在拆分器中支持 Short 和 Byte 类型 (#6027)
[Connector-V2] [Jdbc] 改进查询表的近似总行数 (#5972)

Zeta(ST-Engine)

[Zeta] 添加 UNKNOWABLE 作业状态。(#5303)
[Zeta] 支持 zeta 中的流控制 (#5502)
[Zeta] [REST-API] 停止正在运行的作业。 (#5512)
[Zeta] 在 Kubernetes 上支持 Zeta 引擎 (#5594)
[Zeta] 在批处理模式下，可以禁用检查点 (#5914)
[Zeta] 将跳过触发检查点日志级别更改为调试 (#5954)
[Zeta] 添加新的作业状态 DOING_SAVEPOINT 和 SAVEPOINT_DONE (#5917)
[Zeta] 添加 waitForJobCompleteV2 api (#5965)
[Zeta] 可以使用 rest api 自动将作业提交到 Zeta 主节点 (#5950)
[Zeta] [REST-API] 获取已完成作业的信息 (#5949)
[Zeta] 修复转换操作返回相同名称的问题 (#6034)
[Zeta] 统一作业环境参数 (#6003)
[Zeta] 将 TaskGroupLocation 添加到 TaskExecutionService 的线程名称中(#6095)
[Zeta] 在 zeta 中使用 G1 作为默认垃圾收集器 (#6114)
[Zeta] 修复从保存点启动时没有检查点文件的错误 (#6215)
[Zeta] 支持在通用类型中以 hocon 样式声明行类型 (#6187)

CI

[Bin] 为所有 shell 脚本添加 .bat 脚本。（#5445）
[INFRA] 将 CI 移至 fork 存储库容器上运行（#5495）
[Build] 删除 connector/seatunnel 目录（#5489）
[INFRA] 更新 PR 模板以添加测试和用户更改问题（#5486）
[INFRA] 为 notify_test_workflow.yml 添加日志以跟踪错误原因
[INFRA] 修复 notify_test_workflow.yml 不稳定问题
[Test] 在 jdbc suite 上完成测试后删除 docker 镜像（#5568）
[Test] 为 ResourceManager 添加测试以确保任务将部署在不同节点中（#5518）
[Chore] 删除无用的 .scalafmt.conf 文件（#5616）
[LICENSE] 添加 hadoop 许可证（#6067）
[Build] 将 seatunnel-spark-3-starter.jar 添加到发布包中（#6044）
[测试] 减少重复目录测试次数 (#6207)
[CI] 确保会抛出notify_test_workflow.yml错误 (#6226)

格式

[Ogg] 支持读取 ogg 格式消息 #4201 (#4225)
[Json] 删除 assert 关键字。(#5919)
[Avro] 支持 avro 格式 (#5084)
[格式] 重构 ignoreParseErrors 的异常捕获。 (#6065)
[Avro] 改进 avro 格式转换 (#6082)

Transformer-V2

[All] 添加 JsonPath 转换 (#5632)
[All] 支持 SqlTransform Not Like Expression (#5768)
[All] 添加 from_unixtime 函数 (#5462)
[All] 支持表达式的大小写 (#6123)

文档

[文档] 使用统一格式飞书重构 Connector-v2 文档 (#5343)
[文档] 重构 IoTDB 接收器文档 (#5306)
[文档] 更正单词错误 (#5360)
[文档] 改进 Iceberg 文档 (#5335)
[文档] 使用短网址 https://s.apache.org/seatunnel-slack 替换长网址 (#5363)
[文档] 改进 http doc param body des (#5368)
[文档] 重构connector-v2文档，使用统一格式Slack (#5344)
[文档] 更新sql-udf文档 (#5197)
[文档] 重构MySQL-CDC文档 (#5302)
[文档] 在FtpFile选项描述中将username替换为user (#5421)
[文档] 更新iotdb文档 (#5404)
[文档] 增加mysql Connector Document版本标题示例pr (#5249)
[文档] 添加Parallel并行性 (#5310)
[文档] 源代码中Http source选项键poll_interval_ms不同 (#5430)
[文档] 修复kafka sink的错误示例 (#5527)
[文档] 改进Console Sink文档 (#5230)
[文档] 添加如何更改 e2e 测试的日志配置 (#5589)
[文档] 添加 RocketMq 连接器 (#5361)
[文档] 修复 README.md 中的构建状态未更新 (#5574)
[文档] hdfsFile file_format 更改为 file_format_type (#5653)
[文档] 改进 README.md (#5662)
[文档] 添加 FakeSource 连接器文档 (#5255)
[文档] 在 README.md 中引入 SeaTunnel web 项目 (#5634)
[文档] 在 README 中添加目录和常见问题解答 (#5693)
[文档] 更新 quick-start-spark.md (#5795)
[文档] 添加套接字连接器文档 #5255 (#5287)
[文档] 改进文件接收器文档（#5799）
[文档] 添加 SqlServer 连接器文档（#5498）
[文档] 更新（#5808）
[文档] 添加 hive jdbc 引用值（#5882）
[文档] Checkpoint-Storage 描述不正确。 (#5883)
[文档] 重构 OssFile 连接器文档 (#5233)
[文档] 修复 oss 连接器无法运行的 bug (#6010)
[文档] 更新 jdbc-connector 文档 (#5765)
[文档] 添加 V2 连接器 jdbc 文档参数可加快数据导入 PR (#6176)
[文档] 修改部分文档标题规范 (#6237)
[文档] 重构 Socket Source 和 SftpFile 连接器文档 (#5386)
[文档] 完善驱动程序 put 路径文档
[文档] 修正数组元素类型和映射键类型的引入 (#6261)