[
https://issues.apache.org/jira/browse/HUDI-5577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruguo Yu updated HUDI-5577:
---------------------------
Description:
It will throw *IllegalArgumentException* If *catalog.path* is *empty* in *dfs*
mode, as below:
{code:java}
Caused by: java.lang.IllegalArgumentException: Can not create a Path from a
null string
at org.apache.hadoop.fs.Path.checkPathArg(Path.java:125)
at org.apache.hadoop.fs.Path.<init>(Path.java:137)
at org.apache.hudi.common.fs.FSUtils.getFs(FSUtils.java:102)
at org.apache.hudi.table.catalog.HoodieCatalog.open(HoodieCatalog.java:103)
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:195)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.createCatalog(TableEnvironmentImpl.java:1297)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1122)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:742)
at com.jd.flink.sql.runtime.SQLExecHelper.execSQL(SQLExecHelper.java:326)
at com.jd.flink.sql.NGMain.main(NGMain.java:41)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:356)
{code}
was:
It will throw *IllegalArgumentException* If *catalog.path* is *empty* in *dfs*
mode, as below:
```java
Caused by: java.lang.IllegalArgumentException: Can not create a Path from a
null string
at org.apache.hadoop.fs.Path.checkPathArg(Path.java:125)
at org.apache.hadoop.fs.Path.<init>(Path.java:137)
at org.apache.hudi.common.fs.FSUtils.getFs(FSUtils.java:102)
at org.apache.hudi.table.catalog.HoodieCatalog.open(HoodieCatalog.java:103)
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:195)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.createCatalog(TableEnvironmentImpl.java:1297)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1122)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:742)
at com.jd.flink.sql.runtime.SQLExecHelper.execSQL(SQLExecHelper.java:326)
at com.jd.flink.sql.NGMain.main(NGMain.java:41)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:356)
```
> Validate option catalog.path in dfs mode
> ----------------------------------------
>
> Key: HUDI-5577
> URL: https://issues.apache.org/jira/browse/HUDI-5577
> Project: Apache Hudi
> Issue Type: Improvement
> Components: flink-sql
> Reporter: Ruguo Yu
> Priority: Minor
> Fix For: 0.13.0
>
>
> It will throw *IllegalArgumentException* If *catalog.path* is *empty* in
> *dfs* mode, as below:
> {code:java}
> Caused by: java.lang.IllegalArgumentException: Can not create a Path from a
> null string
> at org.apache.hadoop.fs.Path.checkPathArg(Path.java:125)
> at org.apache.hadoop.fs.Path.<init>(Path.java:137)
> at org.apache.hudi.common.fs.FSUtils.getFs(FSUtils.java:102)
> at
> org.apache.hudi.table.catalog.HoodieCatalog.open(HoodieCatalog.java:103)
> at
> org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:195)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.createCatalog(TableEnvironmentImpl.java:1297)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1122)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:742)
> at com.jd.flink.sql.runtime.SQLExecHelper.execSQL(SQLExecHelper.java:326)
> at com.jd.flink.sql.NGMain.main(NGMain.java:41)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:356)
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
