黄一刀_个人页
黄一刀
文章
0
问答
1270
视频
0
个人介绍
Java菜鸟一只，基层法律工作者。
擅长的技术
- Java
-
提交了问题
2019-11-22
flink 有那种把多条消息聚合成一条的操作吗，比如说每五十条聚合成一条
-
提交了问题
2019-11-22
各位大佬，都用什么来监控flink集群？
-
提交了问题
2019-11-22
请问下大佬，flink1.7.2对于sql的支持是不是不怎么好啊 ，跑的数据一大就会报错。
-
提交了问题
2019-11-21
请教一下，在yarn上运行，会找不到 org.apache.flink.streaming.util
-
提交了问题
2019-11-21
用asyncIO比直接在map里实现读hbase还慢，在和hbase交互这块儿，每个算子都加了时间统
-
提交了问题
2019-11-21
请问一下各位老师，flink flapmap 中的collector.collect经常出现Buff
-
提交了问题
2019-11-21
有没有大哥指导下，为啥我的自定义函数注册，然后sql中使用不了？
-
提交了问题
2019-11-21
RichSinkFunction close只有任务结束时候才会去调用，但是数据库连接一直拿着，最后
-
提交了问题
2019-11-21
大哥们请问下，如果设置一个一天的窗口，怎么让他里面的状态每天0点自动清除呢？
-
提交了问题
2019-11-21
各位好，请教一下，滑动窗口，每次滑动都全量输出结果，外部存储系统压力大，是否有办法，只输出变化的ke
-
提交了问题
2019-11-20
flink的应用场景是？除了实时
-
提交了问题
2019-11-20
如何基于flink 实现两个很大的数据集的交集 并集 差集
-
提交了问题
2019-11-20
使用cep时，如何动态添加规则？
-
提交了问题
2019-11-20
在页面上写规则，用flink执行，怎么传递给flink？
-
提交了问题
2019-11-20
flink sql 解析复杂的json可以吗？
-
提交了问题
2019-11-20
flink 可以把大量数据写入mysql吗？比如10g
-
提交了问题
2019-11-20
NoSuchMethodError: org.apache.flink.api.java.Utils
-
提交了问题
2019-11-20
flink定时加载外部数据有人做过吗？
-
提交了问题
2019-11-20
我就运行了一个自带的示例，一运行就报错然后web页面就崩了
-
提交了问题
2019-11-20
你们的去重容许有误差？因为bloom filter其实只能给出【肯定不存在】和【可能存在】两种结果。
-
提交了问题
2019-11-20
百亿数据实时去重，有哪位同学实践过吗？
-
提交了问题
2019-11-20
使用Flink sql时,对table使用了group by操作。然后将结果转换为流时是不是只能使用
-
提交了问题
2019-11-20
请问下，想统计未退费的订单数量，如果一个订单退费了（发过来一个update流），flink能做到对结
-
提交了问题
2019-11-20
请问下窗口计算能对历史数据进行处理吗？比如kafka里的写数据没停，窗口计算的应用停掉一段时间再开起
-
提交了问题
2019-11-19
Flink SQL DDL 创建表时，如何定义字段的类型为proctime?
-
提交了问题
2019-11-19
flink里面的broadcast state值，会出现broad流的数据还没put进mapstat
-
提交了问题
2019-11-19
问大家个Hive问题，新建的hive外部分区表， 怎么把HDFS数据一次性全部导入hive里 ？分
-
提交了问题
2019-11-19
大家有没有这种场景，数据从binlog消费，这个信息是订单信息，同一个订单id，会有不同状态的变更，
-
提交了问题
2019-11-19
Flink container was removed这个咋解决的。我有时候没有数据的时候也出现这
-
提交了问题
2019-11-19
kafka能不能通过java获取topic的消息所占空间大小？
-
提交了问题
2019-11-19
一般公司的flink job有没有进程进行守护？有专门的工具或者是自己写脚本？这种情况针对flink
-
提交了问题
2019-11-19
我要用sql做一个规则引擎，需要动态改变规则，如何在flink里面执行？
-
提交了问题
2019-11-19
flink-1.9.1/bin/yarn-session.sh: line 32: construc
-
提交了问题
2019-11-19
想问一下，我要做一个规则引擎，需要动态改变规则，如何在flink里面执行？
-
提交了问题
2019-11-18
各位大佬，以天为单位的窗口有没有遇到过在八点钟的时候会生成一条昨天的记录?
-
提交了问题
2019-11-18
为什么这个这段逻辑 debug的时候 是直接跳过的
-
提交了问题
2019-11-18
大家怎么能动态的改变 flink WindowFunction 窗口数据时间
-
提交了问题
2019-11-18
flink on yarn之后。yarn的日志目录被写满，大家如配置的？
-
提交了问题
2019-11-18
flink 本地main方法执行 window.aggregate 数据正常按key输出的多条，通过
-
提交了问题
2019-11-18
flink社区是推荐部署是： standalone 还是 on yarn？
-
提交了问题
2019-11-18
为什么依赖里明明有这个类还是加载不到啊?
-
提交了问题
2019-11-18
Flink1.9 启动 yarn-session报这个错误 怎么破？
-
提交了问题
2019-11-18
standalone 模式用 checkpoint 恢复任务的时候是直接指定 checkpoint
-
提交了问题
2019-11-18
yarn 模式下，checkpoint 是存在 JobManager的，提交任务也是提交给 JobM
-
提交了问题
2019-11-18
checkpoint机制，会不会把window里面的数据全部放checkpoint里面？
-
提交了问题
2019-11-18
Flink On Yarn的模式下，如果通过REST API 停止Job,并触发savepiont呢
-
提交了问题
2019-11-15
jenkins自动化部署flink的job，一般用什么方案？shell脚本还是api的方式？
-
提交了问题
2019-11-15
各位大佬，开启增量checkpoint 情况下，这个state size 是总的checkpoint
-
提交了问题
2019-11-15
"select rider_id, waybill_status as waybill_sta
-
提交了问题
2019-11-15
你们有试过在同样的3台机器上部署两套kafka吗？
暂无更多信息
暂无更多信息
-
提交了问题
2021-01-31
大佬们，我在启动Flink的JOB时，将job的启动参数保存到了某个常量，但当我在si #Flink
-
提交了问题
2021-01-31
请问 flink1.10版本 table api 可以在stream模式下，写入hive#Flink
-
提交了问题
2021-01-31
请教下大家在使用batchTableEnv的时候，又碰到编译报错吗?#Flink
-
提交了问题
2021-01-31
大佬们flink on yarn部署方式里关于tm.jm.slot资源配置有没有经验总结#Flink
-
提交了问题
2021-01-31
flink的定时器可以实现这个功能吗 就是刚开始定时 之后过期时间是一天 如果在这一天内#Flink
-
提交了问题
2021-01-31
Flink1.12单节点提交任务没问题，开发环境集群升级到flink1.12后提交任务报#Flink
-
提交了问题
2021-01-31
我用flink批量读取hdfs里的csv文件然后写到ES总是运行一会就出错，不知道该从哪#Flink
-
提交了问题
2021-01-31
看了flink官网只有insert 没有update操作吗？#Flink
-
提交了问题
2021-01-31
请问使用debe监听mysql 到kafka，怎么使用窗口统计每日增量？#Flink
-
提交了问题
2021-01-31
有没有PyFlink 的学习文档？#Flink
-
提交了问题
2021-01-31
请问flink sql的结果表是只支持全字段数据插入，不支持指定字段数据插入和更新操作。#Flink
-
提交了问题
2021-01-31
调研了下iceberg和hudi看了下源码，发现支持flink sql的目前也就ice #Flink
-
提交了问题
2021-01-31
请教下，有遇到时区问题的吗，我如下这样处理时间戳，相差8小时，之前没有在flink-co#Flink
-
提交了问题
2021-02-01
大佬们，求教一个问题pyflink任务，当数据量过大（测试是10M以上）就会有这个报错：#Flink
-
提交了问题
2021-01-31
flink dataset 可以连接kafka吗 ？#Flink
-
提交了问题
2021-01-31
flinksql里面array类型如何判断这个array里面是否包含某个值呢?#Flink
-
提交了问题
2021-01-31
有没有Flink SQL Client中UDF的注册流程代码？#Flink
-
提交了问题
2021-01-24
请教个flink CDC的问题；我用api 参考写个了demo；发现我本地每次重启；都会#Flink
-
提交了问题
2021-01-24
flink web-ui stdout打印出来的中文是乱码怎么处理呢？#Flink
-
提交了问题
2021-01-24
flink jdbc写入click house报语法错误，但是打印出来的语句直接拿到库是#Flink
滑动查看更多
暂无更多信息