Skip to content

Commit 9a52ddc

Browse files
authored
[Fix-4337] Fix Paimon tinyint data can not preview in data source center (#4440)
1 parent 4975056 commit 9a52ddc

2 files changed

Lines changed: 10 additions & 1 deletion

File tree

dinky-flink/dinky-flink-1.20/pom.xml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -198,5 +198,10 @@
198198
<artifactId>flink-sql-client</artifactId>
199199
<version>${flink.version}</version>
200200
</dependency>
201+
<dependency>
202+
<groupId>org.apache.paimon</groupId>
203+
<artifactId>paimon-flink-1.20</artifactId>
204+
<version>1.0.0</version>
205+
</dependency>
201206
</dependencies>
202207
</project>

dinky-metadata/dinky-metadata-paimon/src/main/java/org/dinky/metadata/convert/PaimonTypeConvert.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,11 @@ public static Object getRowDataSafe(DataField fieldType, InternalRow row, int or
8888
.toString();
8989
case TINYINT:
9090
case SMALLINT:
91-
return row.getShort(ordinal);
91+
try {
92+
return row.getShort(ordinal);
93+
} catch (Exception e) {
94+
return row.getByte(ordinal);
95+
}
9296
case INTEGER:
9397
return row.getInt(ordinal);
9498
case BIGINT:

0 commit comments

Comments
 (0)