Skip to content

Commit

Permalink
1
Browse files Browse the repository at this point in the history
  • Loading branch information
gdliu3 committed Dec 26, 2023
1 parent 5ff4395 commit 628aa70
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@ public void testUserDefinedParamsCommand() throws URISyntaxException {
String fakeSourceTable = "fake";
String fakeSinkTable = "sink";
String list = "[par1=20230829,par2=20230829]";
String blankSpace = "2023-12-26 11:30:00";
String[] args = {
"-c",
"/args/user_defined_params.conf",
Expand All @@ -57,6 +58,8 @@ public void testUserDefinedParamsCommand() throws URISyntaxException {
"-i",
"username=" + username,
"-i",
"blankSpace=" + blankSpace,
"-i",
"list=" + list,
"-i",
"sql=" + "\"select a , b from fake_source_table\""
Expand Down Expand Up @@ -98,6 +101,7 @@ public void testUserDefinedParamsCommand() throws URISyntaxException {
Assertions.assertEquals(list1.get(1), "par2=20230829");
String sql = sinkConfig.getString("sql");
Assertions.assertEquals(sql, "\"select a , b from fake_source_table\"");
Assertions.assertEquals(sinkConfig.getString("blankSpace"), blankSpace);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ sink {
result_table_name = ${fake_sink_table}
username = ${username}
password = ${password}
blankSpace = ${blankSpace}
list = ${list}
sql = ${sql}
}
Expand Down

0 comments on commit 628aa70

Please sign in to comment.