Skip to content

Commit

Permalink
[bugfix] Fix the bug that flink decimal cannot be converted to the st…
Browse files Browse the repository at this point in the history
…arRocks bigint unsigned data type.

Signed-off-by: danzhewuju <danyuhao@qq.com>
  • Loading branch information
danzhewuju committed Aug 23, 2024
1 parent 98226dd commit 8db36fe
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -228,6 +228,7 @@ public StarRocksSinkTable build() {
typesMap.put("smallint", Arrays.asList(LogicalTypeRoot.SMALLINT, LogicalTypeRoot.INTEGER, LogicalTypeRoot.BINARY));
typesMap.put("varchar", Arrays.asList(LogicalTypeRoot.VARCHAR, LogicalTypeRoot.ARRAY, LogicalTypeRoot.MAP, LogicalTypeRoot.ROW));
typesMap.put("string", Arrays.asList(LogicalTypeRoot.CHAR, LogicalTypeRoot.VARCHAR, LogicalTypeRoot.ARRAY, LogicalTypeRoot.MAP, LogicalTypeRoot.ROW));
typesMap.put("bigint unsigned", Arrays.asList(LogicalTypeRoot.DECIMAL));
}

}

0 comments on commit 8db36fe

Please sign in to comment.