Skip to content

Commit

Permalink
[fix](regression-test) fix test_trino_kafka_base case (apache#46313)
Browse files Browse the repository at this point in the history
### What problem does this PR solve?

When there are multiple nodes, the table description file needs to be
distributed to all nodes.
  • Loading branch information
zgxme authored Jan 3, 2025
1 parent 94d98c4 commit 530a00b
Showing 1 changed file with 6 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,11 @@ suite("test_trino_kafka_base", "external,kafka,external_docker,external_docker_k
producer.send(record)
}
}

def tblDescFile = "${context.file.parent}/table_desc"
def tblDescFileTemp = "/tmp/"
for (def ip in host_ips) {
scpFiles("root", ip, tblDescFile, tblDescFileTemp, false)
}

// create trino-connector catalog
String catalog_name = "test_trino_kafka_base_catalog"
Expand All @@ -82,7 +86,7 @@ suite("test_trino_kafka_base", "external,kafka,external_docker,external_docker_k
"trino.connector.name"="kafka",
"trino.kafka.table-names"="${db_name}.${basic_data_table}",
"trino.kafka.nodes"="${externalEnvIp}:${kafka_port}",
"trino.kafka.table-description-dir" = "${context.file.parent}/table_desc"
"trino.kafka.table-description-dir" = "/tmp/table_desc"
);
"""
sql """use `${catalog_name}`.`${db_name}`"""
Expand Down

0 comments on commit 530a00b

Please sign in to comment.