回复：flink sql写hbase问题

2021-05-12 文章 allanqinjy
光看异常，应该是你插入了空值吧，你插入hbase的时候做个filter过滤吧，比如你的rowkey空了，你往hbase插入应该是不行的。你可以试试。 | | allanqinjy | | allanqi...@163.com | 签名由网易邮箱大师定制 在2021年05月12日 19:23，酷酷的浑蛋 写道： Mismatch of function's argument data type 'STRING NOT NULL' and actual argument type 'STRING'.sql有些长，大概就是在执行 insert hbase sql时 报了上面的错误，请问

flink es bulk写入是否考虑支持concurrentRequest

2021-05-12 文章 suisuimu
flink版本：1.12.2 es connector版本：es7对应的版本 在ES的官方BulkProcessor中有个concurrentRequest参数，来提高执行的并行度 但是flink es connector中无法设置该参数，查看源码，在ElasticsearchSinkBase类buildBulkProcessor方法中，将concurrentRequest设置为0，使得无法异步执行。

flink es bulk写入是否考虑支持concurrentRequest

2021-05-12 文章 suisuimu
flink版本：1.12.2 es connector版本：es7对应的版本 在ES的官方BulkProcessor中有个concurrentRequest参数，来提高执行的并行度 但是flink es connector中无法设置该参数，查看源码，在ElasticsearchSinkBase类buildBulkProcessor方法中，将concurrentRequest设置为0，使得无法异步执行。

flink sql如何修改执行计划？

2021-05-12 文章 casel.chen
flink sql如何修改执行计划？例如，修改上下游算子不同的并行度，或者将算子链人为打断等等。 我知道如何获取flink sql执行计划，但要怎么人为干预这个执行计划呢？还请大佬解答一下，谢谢！

flink sql写hbase问题

2021-05-12 文章 酷酷的浑蛋
Mismatch of function's argument data type 'STRING NOT NULL' and actual argument type 'STRING'.sql有些长，大概就是在执行 insert hbase sql时 报了上面的错误，请问这种错误是什么原因？

Re: flink on k8s native 测试失败

2021-05-12 文章 Yang Wang
你参数配置错了，应该是kubernetes.rest-service.exposed.type=NodePort Best, Yang 仙剑……情动人间 <1510603...@qq.com> 于2021年5月12日周三 上午9:45写道： > Hi All， > > 我这里在自己搭建的 k8s 测试环境中按照官网的 flink on k8s native > 指南进行测试，然后一直报错，具体情况如下，请求大佬们的帮助，不胜感激。 > > 一、环境 > > k8s v1.18.16 > flink flink-1.12.2 > java openjdk v

Flink-connector-jdbc源码问题疑惑

2021-05-12 文章 丁浩浩
flink版本：1.11 1.首先第一个问题是在1.11的官方文档connectors的jdbc页面上有这样一句话 Notice that scan.partition.lower-bound and scan.partition.upper-bound are just used to decide the partition stride, not for filtering the rows in table. 这与我观看的源码的结果是不一致的，scan.partition.lower-bound and scan.partition.upper-bound 这两个参数会导致数据

回复： prometheus metric中如何设置label

2021-05-12 文章 MOBIN
感觉labe value过滤考虑的情况比较少 private static final Pattern UNALLOWED_CHAR_PATTERN = Pattern.compile("[^a-zA-Z0-9:]"); 只允许数字、字母及冒号，其实自定义label的场景下，带/的情况也有【比如文件路径】、带.的情况也有【主机IP】 | | MOBIN | 签名由网易邮箱大师定制 在2021年05月11日 15:04，Tony Wei 写道： Hi, 1、是否是这种方式增加label 是的，MetricGroup#addGroup(key, value) 的設計其中一個目的就