This is an automated email from the ASF dual-hosted git repository.

michaelsmith pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git

commit 2de7b8287d44aa4e31ceeb51c0a3921670fd7308
Author: Mihaly Szjatinya <msz...@pm.me>
AuthorDate: Tue Jun 10 16:19:03 2025 +0200

    IMPALA-14136: test_charcodec fails with Ozone
    
    A regression for IMPALA-10319 for Ozone environment. A hardcoded
    '/test-warehouse' in the path was causing some of the 'test_charcodec'
    tests to fail. Turns out the 'makedir' part is not necessary.
    
    Change-Id: If1f74b1ddc481a996d82843041f0f031580f14e5
    Reviewed-on: http://gerrit.cloudera.org:8080/23004
    Reviewed-by: Impala Public Jenkins <impala-public-jenk...@cloudera.com>
    Tested-by: Impala Public Jenkins <impala-public-jenk...@cloudera.com>
---
 tests/query_test/test_charcodec.py | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git a/tests/query_test/test_charcodec.py 
b/tests/query_test/test_charcodec.py
index 90b4a5df7..aa6ef1561 100644
--- a/tests/query_test/test_charcodec.py
+++ b/tests/query_test/test_charcodec.py
@@ -223,9 +223,7 @@ class TestCharCodecGen(ImpalaTestSuite):
       part_url = os.path.join(
           self._get_table_location("{0}.{1}".format(db, tbl_name), vector),
           "part={}".format(i))
-      part_dir = part_url[part_url.index("/test-warehouse"):]
-      self.filesystem_client.make_dir(part_dir)
-      self.filesystem_client.copy_from_local(file_paths[i], part_dir)
+      self.filesystem_client.copy_from_local(file_paths[i], part_url)
     self.execute_query("""REFRESH {}.{}""".format(db, tbl_name))
     return tbl_name
 
@@ -309,9 +307,7 @@ class TestCharCodecGenMixed(ImpalaTestSuite):
       part_url = os.path.join(
           self._get_table_location("{0}.{1}".format(db, tbl_name), vector),
           "part={}".format(i))
-      part_dir = part_url[part_url.index("/test-warehouse"):]
-      self.filesystem_client.make_dir(part_dir)
-      self.filesystem_client.copy_from_local(file_paths[i], part_dir)
+      self.filesystem_client.copy_from_local(file_paths[i], part_url)
     self.execute_query("""REFRESH {}.{}""".format(db, tbl_name))
     return tbl_name
 

Reply via email to