File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed
impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -77,7 +77,7 @@ public class ImpalaOutputFormat extends AbstractDtRichOutputFormat<Tuple2<Boolea
7777 // cast(value as string) -> cast('value' as string) cast(value as timestamp) -> cast('value' as timestamp)
7878 private static final Pattern TYPE_PATTERN = Pattern .compile ("cast\\ ((.*) as (.*)\\ )" );
7979 //specific type which values need to be quoted
80- private static final String [] NEED_QUOTE_TYPE = {"timestamp" , "varchar" };
80+ private static final String [] NEED_QUOTE_TYPE = {"string" , " timestamp" , "varchar" };
8181
8282 private static final Integer DEFAULT_CONN_TIME_OUT = 60 ;
8383 private static final int RECEIVE_DATA_PRINT_FREQUENCY = 1000 ;
@@ -761,7 +761,5 @@ public ImpalaOutputFormat build() {
761761
762762 return format ;
763763 }
764-
765764 }
766-
767765}
You can’t perform that action at this time.
0 commit comments