You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "shao.hongxiao" <17...@163.com> on 2020/05/22 02:43:42 UTC
本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群
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
恳请各位大神相帮
| |
邵红晓
|
|
邮箱：17611022895@163.com
|
签名由网易邮箱大师定制
Re: 本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群
Posted by Leonard Xu <xb...@gmail.com>.
Hi, hongxiao
Please do not send user question to dev@flink.apache.org <ma...@flink.apache.org>, dev@flink.apache.org <ma...@flink.apache.org> is used for development discussion and only accept English from convenience consideration. dev-subscribe@flink.apache.org <ma...@flink.apache.org> mail only used for subscribing mails from dev@flink.apache.org <ma...@flink.apache.org> [1], you do not need CC it too.
Just send your question to user-zh@flink.apache.org <ma...@flink.apache.org> 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 user-zh@flink.apache.org <ma...@flink.apache.org> 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 <17...@163.com> 写道：
>
> 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
>
>
> 恳请各位大神相帮
>
>
> | |
> 邵红晓
> |
> |
> 邮箱：17611022895@163.com
> |
> 签名由网易邮箱大师定制
Re: 本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群
Posted by Leonard Xu <xb...@gmail.com>.
Hi, hongxiao
Please do not send user question to dev@flink.apache.org <ma...@flink.apache.org>, dev@flink.apache.org <ma...@flink.apache.org> is used for development discussion and only accept English from convenience consideration. dev-subscribe@flink.apache.org <ma...@flink.apache.org> mail only used for subscribing mails from dev@flink.apache.org <ma...@flink.apache.org> [1], you do not need CC it too.
Just send your question to user-zh@flink.apache.org <ma...@flink.apache.org> 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 user-zh@flink.apache.org <ma...@flink.apache.org> 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 <17...@163.com> 写道：
>
> 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
>
>
> 恳请各位大神相帮
>
>
> | |
> 邵红晓
> |
> |
> 邮箱：17611022895@163.com
> |
> 签名由网易邮箱大师定制