This is an automated email from the ASF dual-hosted git repository.
rymurr 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 df93538 Fix null tableName when logging in checkCommitStatus for
Nessie tables and enforce tableName is implemented at compile time (#2630)
df93538 is described below
commit df93538a7626442d8bc9318d887e4e71a2f14351
Author: Kyle Bendickson <[email protected]>
AuthorDate: Mon May 24 07:21:34 2021 -0700
Fix null tableName when logging in checkCommitStatus for Nessie tables and
enforce tableName is implemented at compile time (#2630)
---
.../main/java/org/apache/iceberg/BaseMetastoreTableOperations.java | 4 +---
.../main/java/org/apache/iceberg/nessie/NessieTableOperations.java | 5 +++++
2 files changed, 6 insertions(+), 3 deletions(-)
diff --git
a/core/src/main/java/org/apache/iceberg/BaseMetastoreTableOperations.java
b/core/src/main/java/org/apache/iceberg/BaseMetastoreTableOperations.java
index 49a08a7..e81a148 100644
--- a/core/src/main/java/org/apache/iceberg/BaseMetastoreTableOperations.java
+++ b/core/src/main/java/org/apache/iceberg/BaseMetastoreTableOperations.java
@@ -69,9 +69,7 @@ public abstract class BaseMetastoreTableOperations implements
TableOperations {
* catalogName + "." + database + "." + table.
* @return The full name
*/
- protected String tableName() {
- return null;
- }
+ protected abstract String tableName();
@Override
public TableMetadata current() {
diff --git
a/nessie/src/main/java/org/apache/iceberg/nessie/NessieTableOperations.java
b/nessie/src/main/java/org/apache/iceberg/nessie/NessieTableOperations.java
index bc0dad2..7c877a7 100644
--- a/nessie/src/main/java/org/apache/iceberg/nessie/NessieTableOperations.java
+++ b/nessie/src/main/java/org/apache/iceberg/nessie/NessieTableOperations.java
@@ -67,6 +67,11 @@ public class NessieTableOperations extends
BaseMetastoreTableOperations {
}
@Override
+ protected String tableName() {
+ return key.toString();
+ }
+
+ @Override
protected void doRefresh() {
try {
reference.refresh();