Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
suxiaogang223 committed Aug 12, 2024
1 parent a1a2317 commit 321ec9b
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -560,7 +560,7 @@ CREATE TABLE `all_types_text`(
`t_array_string_all_nulls` array<string>,
`dt` int)
stored as textfile
TBLPROPERTIES("line.delim"="\n", "field.delim"=",");
TBLPROPERTIES("line.delim"="\n", "field.delim"="\1");

CREATE TABLE all_types_par_text(
`boolean_col` boolean,
Expand Down Expand Up @@ -628,4 +628,4 @@ CREATE TABLE all_types_par_text(
PARTITIONED BY (
`dt` int)
stored as textfile
TBLPROPERTIES("line.delim"="\n", "field.delim"=",");
TBLPROPERTIES("line.delim"="\n", "field.delim"="\1");
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
// specific language governing permissions and limitations
// under the License.

suite("test_hive_write_insert", "p0,external,hive,external_docker,external_docker_hive") {
suite("test_hive_text_write_insert", "p0,external,hive,external_docker,external_docker_hive") {
def format_compressions = ["gzip", "zlib", "deflate", "bzip2", "snappy", "lz4", "zstd"]

def q01 = { String format_compression, String catalog_name ->
Expand Down Expand Up @@ -833,7 +833,7 @@ INSERT INTO all_types_par_text
try {
String hms_port = context.config.otherConfigs.get(hivePrefix + "HmsPort")
String hdfs_port = context.config.otherConfigs.get(hivePrefix + "HdfsPort")
String catalog_name = "test_${hivePrefix}_write_insert"
String catalog_name = "test_${hivePrefix}_text_write_insert"
String externalEnvIp = context.config.otherConfigs.get("externalEnvIp")

sql """drop catalog if exists ${catalog_name}"""
Expand Down

0 comments on commit 321ec9b

Please sign in to comment.