玛丽莲梦嘉_个人页
玛丽莲梦嘉
文章
0
问答
136
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
2021年12月
-
12.02 16:03:30
回答了问题
2021-12-02 16:03:30
求问为什么KafkaDynamicSource 在批模式下不能运行
赞0 踩0 评论0 -
12.02 16:03:04回答了问题
2021-12-02 16:03:04
checkpoint持久化问题
赞0 踩0 评论0 -
12.02 16:02:39回答了问题
2021-12-02 16:02:39
flink1.12.0 HA on k8s native运行一段时间后的问题
赞0 踩0 评论0 -
12.02 16:02:09回答了问题
2021-12-02 16:02:09
-
12.02 16:01:44回答了问题
2021-12-02 16:01:44
Flink SQL并发度设置问题
赞0 踩0 评论0 -
12.02 16:01:21回答了问题
2021-12-02 16:01:21
-
12.02 16:01:00回答了问题
2021-12-02 16:01:00
怎么根据业务需求选择合适的flink state
赞0 踩0 评论0 -
12.02 16:00:43回答了问题
2021-12-02 16:00:43
Flink 1.11.2客户端 select * from table怎么解决？
赞0 踩0 评论0 -
12.02 16:00:19回答了问题
2021-12-02 16:00:19
Some questions about limit push down
赞0 踩0 评论0 -
12.02 15:59:58回答了问题
2021-12-02 15:59:58
-
12.02 15:59:15回答了问题
2021-12-02 15:59:15
flink12同时使用引发类冲突问题
赞0 踩0 评论0 -
12.02 15:58:29回答了问题
2021-12-02 15:58:29
jdbc sink无法插入数据怎么办？
赞0 踩0 评论0 -
12.02 15:57:55回答了问题
2021-12-02 15:57:55
flink 1.12 Cancel Job内存未释放？
赞0 踩0 评论0 -
12.02 15:56:43回答了问题
2021-12-02 15:56:43
flink1.12支持hbase1.2吗
赞0 踩0 评论0 -
12.02 15:56:26回答了问题
2021-12-02 15:56:26
flink-sql流平台工具
赞0 踩0 评论0 -
12.02 15:56:05回答了问题
2021-12-02 15:56:05
FlinkSQL 1.10 事件时间声明不能包含系统保留字
赞0 踩0 评论0 -
12.02 15:55:33回答了问题
2021-12-02 15:55:33
pyflink1.11 从Mysql读取Decimal类型数据，数据精度损失问题
赞0 踩0 评论0 -
12.02 15:55:09回答了问题
2021-12-02 15:55:09
pyflink 如何指定csv分隔符为“||”
赞0 踩0 评论0 -
12.02 15:54:41回答了问题
2021-12-02 15:54:41
Flink catalog+hive问题
赞0 踩0 评论0 -
12.02 15:54:11回答了问题
2021-12-02 15:54:11
flink1.12 SQL Client 报错
赞0 踩0 评论0 -
12.02 15:53:47回答了问题
2021-12-02 15:53:47
回撤流-窗口计算
赞0 踩0 评论0 -
12.02 15:53:30回答了问题
2021-12-02 15:53:30
-
12.02 15:53:00回答了问题
2021-12-02 15:53:00
flink 1.12.0 kubernetes-session部署问题
赞0 踩0 评论0 -
12.02 15:52:25回答了问题
2021-12-02 15:52:25
flink-cdc 无法读出binlog，程序也不报错
赞0 踩0 评论0 -
12.02 15:51:20回答了问题
2021-12-02 15:51:20
关于先基于process_time预聚合，再基于event_time聚合的问题。
赞0 踩0 评论0 -
12.02 15:50:26回答了问题
2021-12-02 15:50:26
-
12.02 15:49:22回答了问题
2021-12-02 15:49:22
FlinkSQL 下推的值类型与字段类型不对应
赞0 踩0 评论0 -
12.02 15:48:51回答了问题
2021-12-02 15:48:51
SQL Client并行度设置 问题
赞0 踩0 评论0 -
12.02 15:48:23回答了问题
2021-12-02 15:48:23
CliFrontend 未优先加载用户jar包中的class
赞0 踩0 评论0 -
12.02 15:48:01回答了问题
2021-12-02 15:48:01
-
12.02 15:47:24回答了问题
2021-12-02 15:47:24
使用Flink1.10.0读取hive时source并行度问题怎么解决？
赞0 踩0 评论0 -
12.02 15:47:04回答了问题
2021-12-02 15:47:04
keyby后滚动窗口，watermark如何只触发所在的组，而不触发所有的组？
赞0 踩0 评论0 -
12.02 15:46:17回答了问题
2021-12-02 15:46:17
jobGroph如何以pre-job的方式提交到yarn运行
赞0 踩0 评论0 -
12.02 15:45:38回答了问题
2021-12-02 15:45:38
flink elasticsearch sink 如何能不丢数据
赞0 踩0 评论0 -
12.02 15:44:39回答了问题
2021-12-02 15:44:39
-
12.02 15:39:19回答了问题
2021-12-02 15:39:19
keyby后滚动窗口，watermark如何只触发所在的组，而不触发所有的组
赞0 踩0 评论0 -
12.02 15:38:17回答了问题
2021-12-02 15:38:17
Flink 内存类型相关疑问
赞0 踩0 评论0 -
12.02 15:37:58回答了问题
2021-12-02 15:37:58
flink HiveTableSink 何时支持 streaming 模式写入
赞0 踩0 评论0
暂无更多信息
-
提交了问题
2021-12-03
flink sql 如何实现双流join 的滑动窗口？
-
提交了问题
2021-12-03
Flink实时写入hive异常怎么办？
-
提交了问题
2021-12-03
link 读取 Kafka多个 Partition问题是什么情况？
-
提交了问题
2021-12-03
w1、w2、w3...的watermark只能保证user1、user2、user3的整体数据的有序
-
提交了问题
2021-12-03
有什么更好的方法能对rocksdb的有效期进行设置吗？
-
提交了问题
2021-12-03
如果找到程序中的哪个算子不能恢复呢？
-
提交了问题
2021-12-03
如何找到相对应建议使用的方法或者类，来替换@deprecated修饰的类或方法？
-
提交了问题
2021-12-03
join输出的时候，为什么触发窗口的数据第二条就触发了?
-
提交了问题
2021-12-03
flink 内存溢出 如何排查？
-
提交了问题
2021-12-03
fink新增计算逻辑时kafka从头开始追平消费记录是怎么回事？
-
提交了问题
2021-12-03
flink读取kafka数据进程卡死怎么办呢？
-
提交了问题
2021-12-03
程序运行几个小时候会出现mysql死锁！想了解一下大家是怎么处理sink端 多条记录的操作？
-
提交了问题
2021-12-03
发现hbase-connector模块对guava的依赖有冲突，是否有什么特殊的配置能规避这个问题？
-
提交了问题
2021-12-03
请问，对一个DataStream重复声明watermark，前面的watermark会被覆盖掉吗？
-
提交了问题
2021-12-03
task内存溢出如何解决？
-
提交了问题
2021-12-03
定义自己函数时候，会出现null，flink直接跳过解析array那个函数了吗？
-
提交了问题
2021-12-03
Flink 1.10读取kafka数据，打包jar，提交任务到集群运行测试，遇到问题
-
提交了问题
2021-12-03
连接rabbitmq的时候java有很多包支持，想问一下pyflink有类似的连接支持么？
-
提交了问题
2021-12-03
flink sql ddl 不支持primary key怎么办呢？
-
提交了问题
2021-12-03
如何解决JDBCLookupFunction被缓存导致数据的不及时性？
滑动查看更多
暂无更多信息