refs/heads/connector_repo - doris-spark-connector

commit	415e06c098f0d2f8dec5212247f68fb64f787d3a	[log] [tgz]
author	jiafeng.zhang <zhangjf1@gmail.com>	Mon Jan 31 22:12:34 2022 +0800
committer	GitHub <noreply@github.com>	Mon Jan 31 22:12:34 2022 +0800
tree	dcefa54a04e547275c4ad819f41cd7d544af38bf
parent	af21ca25232310919f950c1a58b73096e2dd1a32 [diff]

[fix](httpv2) make http v2 and v1 interface compatible (#7848)

http v2 TableSchemaAction adds the return value of aggregation_type,
and modifies the corresponding code of Flink/Spark Connector

flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java[diff]
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java[diff]
flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java[diff]
flink-doris-connector/src/test/java/org/apache/doris/flink/serialization/TestRowBatch.java[diff]
spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Field.java[diff]
spark-doris-connector/src/main/java/org/apache/doris/spark/rest/models/Schema.java[diff]
spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/SchemaUtils.scala[diff]
spark-doris-connector/src/test/java/org/apache/doris/spark/rest/TestRestService.java[diff]
spark-doris-connector/src/test/java/org/apache/doris/spark/serialization/TestRowBatch.java[diff]
spark-doris-connector/src/test/scala/org/apache/doris/spark/sql/TestSchemaUtils.scala[diff]

10 files changed

tree: dcefa54a04e547275c4ad819f41cd7d544af38bf

DataX/
flink-doris-connector/
logstash/
spark-doris-connector/