Skip to content

Commit 2e1bb57

Browse files
committed
fix test_reads
1 parent b63ecf2 commit 2e1bb57

2 files changed

Lines changed: 5 additions & 4 deletions

File tree

dev/hive/Dockerfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ ENV AWS_SDK_BUNDLE=1.12.753
2323
RUN curl https://repo1.maven.org/maven2/org/apache/hadoop/hadoop-aws/${HADOOP_VERSION}/hadoop-aws-${HADOOP_VERSION}.jar -Lo /tmp/hadoop-aws-${HADOOP_VERSION}.jar
2424
RUN curl https://repo1.maven.org/maven2/com/amazonaws/aws-java-sdk-bundle/${AWS_SDK_BUNDLE}/aws-java-sdk-bundle-${AWS_SDK_BUNDLE}.jar -Lo /tmp/aws-java-sdk-bundle-${AWS_SDK_BUNDLE}.jar
2525

26-
FROM apache/hive:3.1.3
26+
FROM apache/hive:4.0.0
2727

2828
ENV HADOOP_VERSION=3.3.6
2929
ENV AWS_SDK_BUNDLE=1.12.753

tests/integration/test_reads.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -115,14 +115,14 @@ def test_table_properties(catalog: Catalog) -> None:
115115

116116
@pytest.mark.integration
117117
@pytest.mark.parametrize("catalog", [pytest.lazy_fixture("session_catalog_hive")])
118-
def test_hive_properties(catalog: Catalog) -> None:
118+
def test_hive_properties(catalog: HiveCatalog) -> None:
119119
table = create_table(catalog)
120120
table.transaction().set_properties({"abc": "def", "p1": "123"}).commit_transaction()
121-
121+
pTABLE_NAME = ("default", "t1")
122122
hive_client: _HiveClient = _HiveClient(catalog.properties["uri"])
123123

124124
with hive_client as open_client:
125-
hive_table = open_client.get_table(*TABLE_NAME)
125+
catalog._get_hive_table(open_client, dbname="default", tbl_name="t1")
126126
assert hive_table.parameters.get("abc") == "def"
127127
assert hive_table.parameters.get("p1") == "123"
128128
assert hive_table.parameters.get("not_exist_parameter") is None
@@ -131,6 +131,7 @@ def test_hive_properties(catalog: Catalog) -> None:
131131

132132
with hive_client as open_client:
133133
hive_table = open_client.get_table(*TABLE_NAME)
134+
catalog._get_hive_table(open_client, dbname="default", tbl_name="t1")
134135
assert hive_table.parameters.get("abc") is None
135136

136137

0 commit comments

Comments
 (0)