You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@iceberg.apache.org by GitBox <gi...@apache.org> on 2021/02/01 22:51:56 UTC
[GitHub] [iceberg] stevenzwu commented on pull request #1956: Flink: Upgrade version from 1.11.0 to 1.12.1
stevenzwu commented on pull request #1956:
URL: https://github.com/apache/iceberg/pull/1956#issuecomment-771215176
@openinx I enabled `TestFlinkCatalogTable#testCreateTableIfNotExists()` test. I have to make two adjustments. In particular, I have to remove `WITH ('location'='/tmp/location')"` from the SQL in 2nd create. Otherwise, HadoopCatalog fails the validation. Also, for this test purpose, it is probably not important for the 2nd create to set a new location.
```
Test testCreateTableIfNotExists[catalogName = testhadoop baseNamespace = ](org.apache.iceberg.flink.TestFlinkCatalogTable) failed with:
org.apache.flink.table.api.TableException: Could not execute CreateTable in path `testhadoop`.`db`.`tl`
at org.apache.flink.table.catalog.CatalogManager.execute(CatalogManager.java:796)
at org.apache.flink.table.catalog.CatalogManager.createTable(CatalogManager.java:632)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeOperation(TableEnvironmentImpl.java:776)
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:666)
at org.apache.iceberg.flink.FlinkTestBase.exec(FlinkTestBase.java:103)
at org.apache.iceberg.flink.FlinkTestBase.exec(FlinkTestBase.java:107)
at org.apache.iceberg.flink.FlinkTestBase.sql(FlinkTestBase.java:111)
at org.apache.iceberg.flink.TestFlinkCatalogTable.testCreateTableIfNotExists(TestFlinkCatalogTable.java:139)
...
Caused by: java.lang.IllegalArgumentException: Cannot set a custom location for a path-based table. Expected file:///var/folders/4d/3shff9g95pz81jmgrcn74zl00000gn/T/junit5877951167101792089/db/tl but got /tmp/location
at org.apache.iceberg.relocated.com.google.common.base.Preconditions.checkArgument(Preconditions.java:142)
at org.apache.iceberg.hadoop.HadoopCatalog$HadoopCatalogTableBuilder.withLocation(HadoopCatalog.java:441)
at org.apache.iceberg.CachingCatalog$CachingTableBuilder.withLocation(CachingCatalog.java:191)
at org.apache.iceberg.CachingCatalog.createTable(CachingCatalog.java:104)
at org.apache.iceberg.flink.FlinkCatalog.createTable(FlinkCatalog.java:377)
at org.apache.flink.table.catalog.CatalogManager.lambda$createTable$10(CatalogManager.java:633)
at org.apache.flink.table.catalog.CatalogManager.execute(CatalogManager.java:790)
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org