Skip to content

Commit f09f1e1

Browse files
amogh-jahagirdardanielcweeks
authored andcommitted
Revert "Spark: Add "Iceberg" prefix to SparkTable name string for SparkUI (#5629)" (#7273)
1 parent fb60c3d commit f09f1e1

File tree

2 files changed

+1
-11
lines changed

2 files changed

+1
-11
lines changed

spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/SparkTable.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ public Table table() {
163163

164164
@Override
165165
public String name() {
166-
return String.format("Iceberg %s", icebergTable.name());
166+
return icebergTable.toString();
167167
}
168168

169169
public Long snapshotId() {

spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkTable.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -57,14 +57,4 @@ public void testTableEquality() throws NoSuchTableException {
5757
Assert.assertNotSame("References must be different", table1, table2);
5858
Assert.assertEquals("Tables must be equivalent", table1, table2);
5959
}
60-
61-
@Test
62-
public void testTableName() throws NoSuchTableException {
63-
CatalogManager catalogManager = spark.sessionState().catalogManager();
64-
TableCatalog catalog = (TableCatalog) catalogManager.catalog(catalogName);
65-
Identifier identifier = Identifier.of(tableIdent.namespace().levels(), tableIdent.name());
66-
String actualTableName = catalog.loadTable(identifier).name();
67-
String expectedTableName = String.format("Iceberg %s.%s", catalogName, tableIdent);
68-
Assert.assertEquals("Table name mismatched", expectedTableName, actualTableName);
69-
}
7060
}

0 commit comments

Comments
 (0)