Flink Sql-Clients occurs arctic table not exists exception but it exists in the show tables list. #675

YesOrNo828 · 2022-11-21T08:48:59Z

YesOrNo828
Nov 21, 2022
Collaborator

Flink version: 1.14.6
Arctic version: 0.4.0-snapshot
Operate the arctic quickstart in the flink-SQL-clients step.
Using the local_catalog in the Flink-SQL-Clients.
desc test_table;
flink-sql-client.log file:

2022-11-21 16:30:46,855 DEBUG com.netease.arctic.shaded.org.apache.iceberg.hadoop.HadoopTableOperations [] - Metadata for table not found in directory /home/hzzhangyongxiang/arctic-0.4.0-SNAPSHOT/local_warehouse/test_db/test_table/base/metadata
java.io.FileNotFoundException: File does not exist: /home/hzzhangyongxiang/arctic-0.4.0-SNAPSHOT/local_warehouse/test_db/test_table/base/metadata/version-hint.text
    at org.apache.hadoop.hdfs.server.namenode.INodeFile.valueOf(INodeFile.java:72)
    at org.apache.hadoop.hdfs.server.namenode.INodeFile.valueOf(INodeFile.java:62)
    at org.apache.hadoop.hdfs.server.namenode.FSDirStatAndListingOp.getBlockLocations(FSDirStatAndListingOp.java:170)
    at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getBlockLocations(FSNamesystem.java:1897)
    at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.getBlockLocations(NameNodeRpcServer.java:697)
    at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.getBlockLocations(ClientNamenodeProtocolServerSideTranslatorPB.java:381)
    at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
    at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:501)
    at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:989)
    at org.apache.hadoop.ipc.Server$RpcCall.run(Server.java:927)
    at org.apache.hadoop.ipc.Server$RpcCall.run(Server.java:866)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:422)
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1893)
    at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2690)

    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:1.8.0_152]
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[?:1.8.0_152]
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:1.8.0_152]
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[?:1.8.0_152]
    at org.apache.hadoop.ipc.RemoteException.instantiateException(RemoteException.java:106) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.ipc.RemoteException.unwrapRemoteException(RemoteException.java:73) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DFSClient.callGetBlockLocations(DFSClient.java:1237) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DFSClient.getLocatedBlocks(DFSClient.java:1222) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DFSClient.getLocatedBlocks(DFSClient.java:1210) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DFSInputStream.fetchLocatedBlocksAndGetLastBlockLength(DFSInputStream.java:306) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DFSInputStream.openInfo(DFSInputStream.java:272) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DFSInputStream.<init>(DFSInputStream.java:264) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DFSClient.open(DFSClient.java:1535) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DistributedFileSystem$3.doCall(DistributedFileSystem.java:304) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DistributedFileSystem$3.doCall(DistributedFileSystem.java:299) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.hdfs.DistributedFileSystem.open(DistributedFileSystem.java:312) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.fs.FileSystem.open(FileSystem.java:768) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at com.netease.arctic.shaded.org.apache.iceberg.hadoop.HadoopTableOperations.findVersion(HadoopTableOperations.java:309) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.shaded.org.apache.iceberg.hadoop.HadoopTableOperations.refresh(HadoopTableOperations.java:102) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.shaded.org.apache.iceberg.hadoop.HadoopTableOperations.current(HadoopTableOperations.java:83) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.shaded.org.apache.iceberg.hadoop.HadoopTables.load(HadoopTables.java:96) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.BaseArcticCatalog.lambda$loadKeyedTable$1(BaseArcticCatalog.java:187) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.table.TableMetaStore.lambda$doAs$0(TableMetaStore.java:315) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_152]
    at javax.security.auth.Subject.doAs(Subject.java:360) ~[?:1.8.0_152]
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1734) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at com.netease.arctic.table.TableMetaStore.doAs(TableMetaStore.java:313) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.BaseArcticCatalog.loadKeyedTable(BaseArcticCatalog.java:187) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.BaseArcticCatalog.loadTableByMeta(BaseArcticCatalog.java:174) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.BaseArcticCatalog.loadTable(BaseArcticCatalog.java:167) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.ArcticCatalog.tableExists(ArcticCatalog.java:104) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.flink.catalog.ArcticCatalog.getTable(ArcticCatalog.java:174) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at org.apache.flink.table.catalog.CatalogManager.getPermanentTable(CatalogManager.java:425) ~[flink-table_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.catalog.CatalogManager.getTable(CatalogManager.java:395) ~[flink-table_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1264) ~[flink-table_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeOperation(CliClient.java:625) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:447) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$1(CliClient.java:332) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at java.util.Optional.ifPresent(Optional.java:159) [?:1.8.0_152]
    at org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:325) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
Caused by: org.apache.hadoop.ipc.RemoteException: File does not exist: /home/hzzhangyongxiang/arctic-0.4.0-SNAPSHOT/local_warehouse/test_db/test_table/base/metadata/version-hint.text
    at org.apache.hadoop.hdfs.server.namenode.INodeFile.valueOf(INodeFile.java:72)
    at org.apache.hadoop.hdfs.server.namenode.INodeFile.valueOf(INodeFile.java:62)
    at org.apache.hadoop.hdfs.server.namenode.FSDirStatAndListingOp.getBlockLocations(FSDirStatAndListingOp.java:170)
    at org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getBlockLocations(FSNamesystem.java:1897)
    at org.apache.hadoop.hdfs.server.namenode.NameNodeRpcServer.getBlockLocations(NameNodeRpcServer.java:697)
    at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolServerSideTranslatorPB.getBlockLocations(ClientNamenodeProtocolServerSideTranslatorPB.java:381)
    at org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos$ClientNamenodeProtocol$2.callBlockingMethod(ClientNamenodeProtocolProtos.java)
    at org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker.call(ProtobufRpcEngine.java:501)
    at org.apache.hadoop.ipc.RPC$Server.call(RPC.java:989)
    at org.apache.hadoop.ipc.Server$RpcCall.run(Server.java:927)
    at org.apache.hadoop.ipc.Server$RpcCall.run(Server.java:866)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:422)
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1893)
    at org.apache.hadoop.ipc.Server$Handler.run(Server.java:2690)

    at org.apache.hadoop.ipc.Client.call(Client.java:1476) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.ipc.Client.call(Client.java:1413) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.ipc.ProtobufRpcEngine$Invoker.invoke(ProtobufRpcEngine.java:229) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at com.sun.proxy.$Proxy38.getBlockLocations(Unknown Source) ~[?:?]
    at org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolTranslatorPB.getBlockLocations(ClientNamenodeProtocolTranslatorPB.java:255) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_152]
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_152]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_152]
    at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_152]
    at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:191) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:102) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at com.sun.proxy.$Proxy39.getBlockLocations(Unknown Source) ~[?:?]
    at org.apache.hadoop.hdfs.DFSClient.callGetBlockLocations(DFSClient.java:1235) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    ... 43 more
2022-11-21 16:30:46,869 ERROR com.netease.arctic.table.TableMetaStore                      [] - run with catalog ugi request failed. UGI is root (auth:SIMPLE)
com.netease.arctic.shaded.org.apache.iceberg.exceptions.NoSuchTableException: Table does not exist at location: /home/hzzhangyongxiang/arctic-0.4.0-SNAPSHOT/local_warehouse/test_db/test_table/base
    at com.netease.arctic.shaded.org.apache.iceberg.hadoop.HadoopTables.load(HadoopTables.java:99) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.BaseArcticCatalog.lambda$loadKeyedTable$1(BaseArcticCatalog.java:187) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.table.TableMetaStore.lambda$doAs$0(TableMetaStore.java:315) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_152]
    at javax.security.auth.Subject.doAs(Subject.java:360) ~[?:1.8.0_152]
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1734) ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0]
    at com.netease.arctic.table.TableMetaStore.doAs(TableMetaStore.java:313) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.BaseArcticCatalog.loadKeyedTable(BaseArcticCatalog.java:187) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.BaseArcticCatalog.loadTableByMeta(BaseArcticCatalog.java:174) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.BaseArcticCatalog.loadTable(BaseArcticCatalog.java:167) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.catalog.ArcticCatalog.tableExists(ArcticCatalog.java:104) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at com.netease.arctic.flink.catalog.ArcticCatalog.getTable(ArcticCatalog.java:174) ~[arctic-flink-runtime-1.14-0.4.0-SNAPSHOT.jar:?]
    at org.apache.flink.table.catalog.CatalogManager.getPermanentTable(CatalogManager.java:425) ~[flink-table_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.catalog.CatalogManager.getTable(CatalogManager.java:395) ~[flink-table_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1264) ~[flink-table_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeOperation(CliClient.java:625) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:447) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$1(CliClient.java:332) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at java.util.Optional.ifPresent(Optional.java:159) [?:1.8.0_152]
    at org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:325) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
2022-11-21 16:30:46,871 WARN  org.apache.flink.table.client.cli.CliClient                  [] - Could not execute SQL statement.
org.apache.flink.table.client.gateway.SqlExecutionException: Could not execute SQL statement.
    at org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:211) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeOperation(CliClient.java:625) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:447) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$1(CliClient.java:332) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at java.util.Optional.ifPresent(Optional.java:159) ~[?:1.8.0_152]
    at org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:325) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161) [flink-sql-client_2.12-1.14.6.jar:1.14.6]
Caused by: org.apache.flink.table.api.ValidationException: Tables or views with the identifier 'arctic.test_db.test_table' doesn't exist
    at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1269) ~[flink-table_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    at org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209) ~[flink-sql-client_2.12-1.14.6.jar:1.14.6]
    ... 11 more

Answered by YesOrNo828

Nov 21, 2022

After enabling the DEBUG level in the log4j.properties, found out that using the DistributedFileSystem to find the version hint file, but it does not exist.
It should use the LocalFileSystem to find the version hint file, PLS checks the process environment. Does it include a Hadoop env?

View full answer

YesOrNo828 · 2022-11-21T08:50:50Z

YesOrNo828
Nov 21, 2022
Collaborator Author

After enabling the DEBUG level in the log4j.properties, found out that using the DistributedFileSystem to find the version hint file, but it does not exist.
It should use the LocalFileSystem to find the version hint file, PLS checks the process environment. Does it include a Hadoop env?

0 replies

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Flink Sql-Clients occurs arctic table not exists exception but it exists in the show tables list. #675

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{editor}}'s edit

{{editor}}'s edit

Uh oh!

Replies: 1 comment

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{editor}}'s edit

{{editor}}'s edit

Uh oh!

Select a reply

Uh oh!

Flink Sql-Clients occurs arctic table not exists exception but it exists in the show tables list. #675

Uh oh!

Uh oh!

YesOrNo828 Nov 21, 2022 Collaborator

Replies: 1 comment

Uh oh!

Uh oh!

YesOrNo828 Nov 21, 2022 Collaborator Author

YesOrNo828
Nov 21, 2022
Collaborator

YesOrNo828
Nov 21, 2022
Collaborator Author