本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群

[shao.hongxiao]

job graph 阶段
HBaseRowInputFormat.java
this.conf = {Configuration@4841} "Configuration: core-default.xml, core-site.xml, hbase-default.xml, hbase-site.xml"
 quietmode = true
 allowNullValueProperties = false
 resources = {ArrayList@4859}  size = 2
 finalParameters = {Collections$SetFromMap@4860}  size = 0
 loadDefaults = true
 updatingResource = {ConcurrentHashMap@4861}  size = 343
 properties = {Properties@4862}  size = 343
 overlay = {Properties@4863}  size = 2
 classLoader = {Launcher$AppClassLoader@4864}


Executor job 阶段  InstantiationUtil.java    readObjectFromConfig
userCodeObject = {HBaseRowInputFormat@13658}
 tableName = "test_shx"
 schema = {HBaseTableSchema@13660}
 conf = null
 readHelper = null
 endReached = false
 table = null
 scan = null
 resultScanner = null
 currentRow = null
 scannedRows = 0
 runtimeContext = null


恳请各位大神相帮


| |
邵红晓
|
|
邮箱：[hidden email]
|
签名由网易邮箱大师定制

[Leonard Xu]

Hi, hongxiao

Please do not send user question to [hidden email] <mailto:[hidden email]>, [hidden email] <mailto:[hidden email]> is used for development discussion and only accept English from convenience consideration. [hidden email] <mailto:[hidden email]> mail only used for subscribing  mails from [hidden email] <mailto:[hidden email]> [1],  you do not need CC it too.

Just send your question to [hidden email] <mailto:[hidden email]> is enough.

Back to your question, could you post your SQL or program that can reproduce the null issue rather than only a debug information?
And we can keep communication in [hidden email] <mailto:[hidden email]> if you prefer Chinese.

Best,
Leonard Xu
[1] https://flink.apache.org/community.html#mailing-lists <https://flink.apache.org/community.html#mailing-lists>

> 在 2020年5月22日，10:43，shao.hongxiao <[hidden email]> 写道：
>
> job graph 阶段
> HBaseRowInputFormat.java
> this.conf = {Configuration@4841} "Configuration: core-default.xml, core-site.xml, hbase-default.xml, hbase-site.xml"
> quietmode = true
> allowNullValueProperties = false
> resources = {ArrayList@4859}  size = 2
> finalParameters = {Collections$SetFromMap@4860}  size = 0
> loadDefaults = true
> updatingResource = {ConcurrentHashMap@4861}  size = 343
> properties = {Properties@4862}  size = 343
> overlay = {Properties@4863}  size = 2
> classLoader = {Launcher$AppClassLoader@4864}
>
>
> Executor job 阶段  InstantiationUtil.java    readObjectFromConfig
> userCodeObject = {HBaseRowInputFormat@13658}
> tableName = "test_shx"
> schema = {HBaseTableSchema@13660}
> conf = null
> readHelper = null
> endReached = false
> table = null
> scan = null
> resultScanner = null
> currentRow = null
> scannedRows = 0
> runtimeContext = null
>
>
> 恳请各位大神相帮
>
>
> | |
> 邵红晓
> |
> |
> 邮箱：[hidden email]
> |
> 签名由网易邮箱大师定制