This is an automated email from the ASF dual-hosted git repository.
pvary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new 8c938724d1 Core: Minor renaming to avoid engine specific naming in
core (#6496)
8c938724d1 is described below
commit 8c938724d16fc2f36099cec3063465634d3ab186
Author: Ajantha Bhat <[email protected]>
AuthorDate: Tue Jan 10 11:37:51 2023 +0530
Core: Minor renaming to avoid engine specific naming in core (#6496)
---
core/src/test/java/org/apache/iceberg/TestCatalogUtil.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/core/src/test/java/org/apache/iceberg/TestCatalogUtil.java
b/core/src/test/java/org/apache/iceberg/TestCatalogUtil.java
index 86e4a2c837..2c139adcf4 100644
--- a/core/src/test/java/org/apache/iceberg/TestCatalogUtil.java
+++ b/core/src/test/java/org/apache/iceberg/TestCatalogUtil.java
@@ -48,7 +48,7 @@ public class TestCatalogUtil {
CatalogUtil.loadCatalog(TestCatalog.class.getName(), name, options,
hadoopConf);
Assertions.assertThat(catalog).isInstanceOf(TestCatalog.class);
Assert.assertEquals(name, ((TestCatalog) catalog).catalogName);
- Assert.assertEquals(options, ((TestCatalog) catalog).flinkOptions);
+ Assert.assertEquals(options, ((TestCatalog) catalog).catalogProperties);
}
@Test
@@ -62,7 +62,7 @@ public class TestCatalogUtil {
CatalogUtil.loadCatalog(TestCatalogConfigurable.class.getName(), name,
options, hadoopConf);
Assertions.assertThat(catalog).isInstanceOf(TestCatalogConfigurable.class);
Assert.assertEquals(name, ((TestCatalogConfigurable) catalog).catalogName);
- Assert.assertEquals(options, ((TestCatalogConfigurable)
catalog).flinkOptions);
+ Assert.assertEquals(options, ((TestCatalogConfigurable)
catalog).catalogProperties);
Assert.assertEquals(hadoopConf, ((TestCatalogConfigurable)
catalog).configuration);
}
@@ -218,14 +218,14 @@ public class TestCatalogUtil {
public static class TestCatalog extends BaseMetastoreCatalog {
private String catalogName;
- private Map<String, String> flinkOptions;
+ private Map<String, String> catalogProperties;
public TestCatalog() {}
@Override
public void initialize(String name, Map<String, String> properties) {
this.catalogName = name;
- this.flinkOptions = properties;
+ this.catalogProperties = properties;
}
@Override
@@ -255,7 +255,7 @@ public class TestCatalogUtil {
public static class TestCatalogConfigurable extends BaseMetastoreCatalog
implements Configurable {
private String catalogName;
- private Map<String, String> flinkOptions;
+ private Map<String, String> catalogProperties;
private Configuration configuration;
public TestCatalogConfigurable() {}
@@ -263,7 +263,7 @@ public class TestCatalogUtil {
@Override
public void initialize(String name, Map<String, String> properties) {
this.catalogName = name;
- this.flinkOptions = properties;
+ this.catalogProperties = properties;
}
@Override