This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 8ae05e5 [improve]Optimize the code for creating ObjectMapper in
GeoUtils (#50)
8ae05e5 is described below
commit 8ae05e5a1c7e7d852e1a22e66a703408de4fa60f
Author: wudongliang <[email protected]>
AuthorDate: Thu Nov 21 10:53:04 2024 +0800
[improve]Optimize the code for creating ObjectMapper in GeoUtils (#50)
---
.../org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java
b/src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java
index 9c0fc65..dec8439 100644
---
a/src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java
+++
b/src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java
@@ -32,13 +32,13 @@ import org.slf4j.LoggerFactory;
public class GeoUtils {
private static final Logger LOGGER =
LoggerFactory.getLogger(GeoUtils.class);
+ private static final ObjectMapper objectMapper = new ObjectMapper();
private GeoUtils() {}
public static Object handleGeoStructData(Object sourceValue) {
// the Geometry datatype in MySQL will be converted to
// a String with Json format
- final ObjectMapper objectMapper = new ObjectMapper();
Struct geometryStruct = (Struct) sourceValue;
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
