database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](Routineload)routine load does not support lowercase data source names (#21005)

Browse Source
This commit is contained in:
Calvin Kirs
2023-06-20 11:44:02 +08:00
committed by GitHub
parent 923f7edad0
commit 1eb4e5bd06
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadDataSourcePropertyFactory.java
View File

@ -35,14 +35,14 @@ public class RoutineLoadDataSourcePropertyFactory {
public static AbstractDataSourceProperties createDataSource(String type, Map<String, String> parameters,
boolean multiLoad) {
if (type.equals(LoadDataSourceType.KAFKA.name())) {
if (type.equalsIgnoreCase(LoadDataSourceType.KAFKA.name())) {
return new KafkaDataSourceProperties(parameters, multiLoad);
}
throw new IllegalArgumentException("Unknown routine load data source type: " + type);
}
public static AbstractDataSourceProperties createDataSource(String type, Map<String, String> parameters) {
if (type.equals(LoadDataSourceType.KAFKA.name())) {
if (type.equalsIgnoreCase(LoadDataSourceType.KAFKA.name())) {
return new KafkaDataSourceProperties(parameters);
}
throw new IllegalArgumentException("Unknown routine load data source type: " + type);