本地测试 flink 1.10 hbase sql create table 在反序列化byte之后-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

本地测试 flink 1.10 hbase sql create table 在反序列化byte之后

2021-12-04 20:45:50 43 1

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

恳请各位大神相帮 来自志愿者整理的flink邮件归档来自志愿者整理的FLINK邮件归档

取消 提交回答
全部回答(1)
  • 毛毛虫雨
    2021-12-04 22:35:27

    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.

    来自志愿者整理的flink邮件归档来自志愿者整理的FLINK邮件归档

    0 0
相关问答

3

回答

请教一个范围查询的问题

小文文文 2019-06-14 14:37:01 115302浏览量 回答数 3

4

回答

Spark 【问答合集】

社区小助手 2019-05-29 14:13:40 127082浏览量 回答数 4

10

回答

【精品问答合集】Hbase热门问答

hbase小能手 2019-05-29 14:37:26 120763浏览量 回答数 10

17

回答

【大咖问答】对话PostgreSQL 中国社区发起人之一,阿里云数据库高级专家 德哥

阿里ACE 彭飞 2019-07-10 09:36:10 1033539浏览量 回答数 17

38

回答

[@饭娱咖啡][¥20]对于慢sql有没有什么比较实用的诊断和处理方法?

江小白太白 2018-10-30 18:47:38 142036浏览量 回答数 38

1

回答

在flink集群模式下,能不能指定某个节点的solt来执行一个task?

孙goku 2019-07-01 15:19:09 115787浏览量 回答数 1

2

回答

mySQL数据库报错You have an error in your SQL syntax

落地花开啦 2016-02-14 16:09:24 128800浏览量 回答数 2

8

回答

flink sql 支持checkpoints吗?

游客izljdlkgbdwfc 2019-07-10 17:46:37 123924浏览量 回答数 8

3

回答

HBase mslab.chunksize和G1HeapRegionSize间是否有关系

yauso 2019-07-17 17:14:06 114780浏览量 回答数 3

22

回答

Flink Forward Asia 2021 有奖问答

阿里云实时计算Flink 2021-12-29 17:30:44 421001浏览量 回答数 22
+关注
0
文章
307
问答
问答排行榜
最热
最新
相关电子书
更多
《Nacos架构&原理》
立即下载
《看见新力量:二》电子书
立即下载
云上自动化运维(CloudOps)白皮书
立即下载