Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion test_container/tests/test/java/external_jar_files.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ def build_java_udf(self) -> Path:
def upload_to_bucketfs(self, src_path: Path, expected_jar_in_script_option: str, target_filename: str) -> str:
env_info = obj_from_json_file("/environment_info.json")
docker_db_ip = env_info.database_info.container_info.ip_address
bucketfs_port = env_info.database_info.ports.bucketfs
bucketfs_port = env_info.database_info.ports._bucketfs_http
with tempfile.TemporaryDirectory() as tmp_dir:
local_target_file_path = Path(tmp_dir) / target_filename
shutil.copy(src_path, local_target_file_path)
Expand Down
2 changes: 1 addition & 1 deletion test_container/tests/test/java/java_modules.py
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ def test_udf_jar_is_module_java17(self):
def upload_to_bucketfs(self, path: Path) -> str:
env_info = obj_from_json_file("/environment_info.json")
docker_db_ip = env_info.database_info.container_info.ip_address
bucketfs_port = env_info.database_info.ports.bucketfs
bucketfs_port = env_info.database_info.ports._bucketfs_http
upload_url = f"http://{docker_db_ip}:{bucketfs_port}/myudfs/{path.name}"
username = "w"
password = "write"
Expand Down
2 changes: 1 addition & 1 deletion test_container/tests/test/java/test_hadoop_etl_udfs.py
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ def add_containers_to_hosts_file_in_docker_db(self, env):
def upload_hadoop_etl_udf_jar_to_bucket_fs(self, env):
env_info = obj_from_json_file("/environment_info.json")
docker_db_ip = env_info.database_info.container_info.ip_address
bucketfs_port = env_info.database_info.ports.bucketfs
bucketfs_port = env_info.database_info.ports._bucketfs_http
upload_url = f"http://{docker_db_ip}:{bucketfs_port}/myudfs/hadoop-etl-udfs-v0.0.1-apache-2.8.5-3.0.0.jar".format(
docker_db_ip=docker_db_ip)
username = "w"
Expand Down
Loading