diff --git a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TableInstaller.java b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TableInstaller.java index 5f8d00fb048fb9bbf894dc874338625ce5657e95..ea3d7ead542d8d28b429f49c577b5aad3db3b564 100644 --- a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TableInstaller.java +++ b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TableInstaller.java @@ -19,7 +19,10 @@ package org.apache.skywalking.oap.server.storage.plugin.jdbc.h2.dao; import java.sql.*; + +import org.apache.skywalking.oap.server.core.analysis.manual.segment.SegmentRecord; import org.apache.skywalking.oap.server.core.analysis.metrics.IntKeyLongValueHashMap; +import org.apache.skywalking.oap.server.core.source.DefaultScopeDefine; import org.apache.skywalking.oap.server.core.storage.StorageException; import org.apache.skywalking.oap.server.core.storage.model.*; import org.apache.skywalking.oap.server.library.client.Client; @@ -90,6 +93,11 @@ public class H2TableInstaller extends ModelInstaller { } else if (IntKeyLongValueHashMap.class.equals(type)) { return "VARCHAR(20000)"; } else if (byte[].class.equals(type)) { + if (DefaultScopeDefine.SEGMENT == model.getScopeId()) { + if (name.getName().equals(SegmentRecord.DATA_BINARY)) { + return "MEDIUMTEXT"; + } + } return "VARCHAR(20000)"; } else { throw new IllegalArgumentException("Unsupported data type: " + type.getName()); diff --git a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/mysql/MySQLTableInstaller.java b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/mysql/MySQLTableInstaller.java index 1476d65b8243fee55f9ad506c0742a87b088e158..af409bc131cb008acf0b85258830d2963390f915 100644 --- a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/mysql/MySQLTableInstaller.java +++ b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/mysql/MySQLTableInstaller.java @@ -71,6 +71,9 @@ public class MySQLTableInstaller extends H2TableInstaller { if (DefaultScopeDefine.SEGMENT == model.getScopeId()) { if (name.getName().equals(SegmentRecord.TRACE_ID) || name.getName().equals(SegmentRecord.SEGMENT_ID)) return "VARCHAR(300)"; + if (name.getName().equals(SegmentRecord.DATA_BINARY)) { + return "MEDIUMTEXT"; + } } return "VARCHAR(2000)"; } else if (IntKeyLongValueHashMap.class.equals(type)) {