Skip to content

Release v1.16.1

Latest

Choose a tag to compare

@yanghuaiGit yanghuaiGit released this 02 Dec 13:23
cff5fbf

What's Changed

  • [feat][s3-connector] support more DataType. by @libailin in #1933
  • [feat][core] Support null serialization of JSON data to prevent the loss of data columns. by @david-gao1 in #1925
  • [feat][core] Supports capturing dirty data from the source and when the source sends it downstream. by @david-gao1 in #1902
  • [bugfix][jdbc-connector] jdbc's properties not work where jdbc's reader has set properties. by @AliceXiaoLu in #1874
  • [bugfix][metrics]Invalid metric name: org/apache/flink_taskmanager_job_task_operator_chunjun_startLocation. by @Icarus-Alpha in #1894
  • [bugfix][hdfs-connector]orc file size calculation method is wrong. by @Icarus-Alpha in #1822
  • [feat][doris-connector]Performance and resource optimization. by @yanghuaiGit in #1949
  • [feat][openguasdb-connector]support oracle mode and mysql mode. by @yanghuaiGit in #1945
  • [bugfix][kafka-connector] KafkaSyncConverter construct parameter transmission error. by @zhiqiang-dev in #1966
  • [feat][jdbc-connector] jdbcConf adds default optimization parameters. by @yanghuaiGit in #1959
  • [feat][jdbc-connector] kafka support partition by, add partitionStrategy parameter, optional value all-to-zero or hash-by-key, default value all-to-zero. by @zhiqiang-dev in #1957
  • [feat][kafka-connector] DynamicKafkaSerializationSchema durationCounter have two different type. by @zhiqiang-dev in #1962
  • [feat][doris-connector] Fix time-related type conversion exceptions . by @zhiqiang-dev in #1956