moonlightdisco
moonlightdisco_个人页
moonlightdisco
文章
0
问答
253
视频
0
个人介绍
暂无个人介绍
擅长的技术
-
提交了问题
2021-12-08
flink 1.13.1 通过yarn-application运行批应用，处理mysql源一亿条数据
-
提交了问题
2021-12-08
flink 1.14 Hybrid Source切换source时机问题
-
提交了问题
2021-12-08
flink1.12.1 读取kafka的数据写入到clickhouse如何支持upsert操作呢
-
提交了问题
2021-12-08
怎样阻止某些合法用户恶意执行一些非法作业呢？flink框架本身能提供哪些保护手段呢？
-
提交了问题
2021-12-08
Tumbling Windows 窗口可开的最小单位
-
提交了问题
2021-12-08
窗口时间不准
-
提交了问题
2021-12-08
flink的一个场景问题
-
提交了问题
2021-12-08
checkpoint的路径问题
-
提交了问题
2021-12-08
flink1.12.4 写入hdfs报错 java.lang.OutOfMemoryError: D
-
提交了问题
2021-12-08
flink 1.13.2 在 Java/Scala 程序中调用 Python UDF函数，通过yar
-
提交了问题
2021-12-08
FlinkSQL 使用 streamingSink 写入 hive orc数据，如何控制文件数量。
-
提交了问题
2021-12-08
查了下flink官方docker image
-
提交了问题
2021-12-08
flink广播流
-
提交了问题
2021-12-08
如题，我当前是select date_format(xxx, 'yyyyMMdd') as dt..
-
提交了问题
2021-12-07
检查点和保存点
-
提交了问题
2021-12-07
flink on yarn。
-
提交了问题
2021-12-07
flink on native k8s资源弹性伸缩问题
-
提交了问题
2021-12-07
flink on native k8s application模式作业启动慢问题
-
提交了问题
2021-12-07
Flink资源动态分配
-
提交了问题
2021-12-07
flink sql检查点是否可恢复问题
-
提交了问题
2021-12-07
flink new source api， kafka部分对kafka-client的版本要求。
-
提交了问题
2021-12-07
Flink jdbc Connector 特殊类型问题
-
提交了问题
2021-12-07
flink on native k8s调度控制
-
提交了问题
2021-12-07
io.tmp.dirs的配置如何做到高可用？
-
提交了问题
2021-12-07
在进行table转streaming后报一个异常
-
提交了问题
2021-12-07
flinksql 写 hive ，orc格式，应该支持下压缩。
-
提交了问题
2021-12-07
flink的sql写hdfs如何指定文件名称
-
提交了问题
2021-12-07
inStreamingMode和inBatchMode打印内容不同产生的疑惑
-
提交了问题
2021-12-07
flink的job运行一段时间后， checkpoint就一直失败
-
提交了问题
2021-12-07
FlinkSQL写hive orc表开启compact，任务异常重启，compact不生效？
-
提交了问题
2021-12-07
哪里可以下载到downloads/setup-pyflink-virtual-env.sh脚本
-
提交了问题
2021-12-07
jdk11创建hive catalog抛错
-
提交了问题
2021-12-07
如何实现event triggered window？
-
提交了问题
2021-12-07
关于TableAPI的filesystem中compact功能
-
提交了问题
2021-12-07
FlinkSQL源码分段优化中，物理计划转换为ExecNodeGraph的时候，SameRelObj
-
提交了问题
2021-12-07
检查点的start-delay、alignment duration理解。
-
提交了问题
2021-12-07
flink远程调用时环境变量问题
-
提交了问题
2021-12-07
How to run SQL Client by Per-Job
-
提交了问题
2021-12-07
flink rest 端口是通过什么方法进行认证的
-
提交了问题
2021-12-07
keyed state重新指定并行度后，比如2->4或者4->2，请问下是不是会丢失部分老的状态？
-
提交了问题
2021-12-07
Flink工程停止问题
-
提交了问题
2021-12-07
flink web UI job overview 中的算子记录条数不更新
-
提交了问题
2021-12-07
Time attribute will be lost after two(or more) tab
-
提交了问题
2021-12-07
Flink1.13.3 on Native K8s 任务取消问题
-
提交了问题
2021-12-02
增量checkpoint是否可以用来恢复flink作业
-
提交了问题
2021-12-02
增量checkpoint是否可以用来恢复flink作业
-
提交了问题
2021-12-02
关于作业失败从checkpoint重启，触发了过期的窗口计算
-
提交了问题
2021-12-02
动态表时态表版本表，这三个是什么关系？
-
提交了问题
2021-12-02
Flink OperatorChain AsyncWaitOperator
-
提交了问题
2021-12-02
flink 1.13.1 读取hive orc格式表数据，报数组越界错误
暂无更多信息
暂无更多信息
-
回答了问题
2022-01-11
劫持问题导致通过 CDN 请求资源没有返回实际资源文件怎么处理
l 建议使用 HTTPS 访问资源，提高访问安全，可以有效防止此类内容劫持。如何配置 CDN 的 HTTPS 访问资源，详情请参见配置 HTTPS 证书。 l 如果无法解决问题，可能是由以下两个原因导致，此时需要获取运营商协助。 ○ CDN 节点被运营商封了，或者节点本身有问题。 ○ 用户域名被运营商封了。资源来源于《对象存储&视频云35条实战秘籍》，下载链接：https://developer.aliyun.com/topic/download?id=8226赞0 踩0 评论0 -
回答了问题
2022-01-11
按照文档开启了 CDN 的页面优化功能，但是访问 HTML 页面实际并没有优化效果，怎么回事？
该问题可以总结如下： （1）如果源站响应了 Gzip 压缩的内容，CDN 会因为无法 Gunzip 导致页面优化功能不生效 （2）如果希望与 CDN 去智能压缩和页面优化，因此 CDN 层面智能压缩的优先级比页面优化的 优先级高，也会导致页面优化不生效 （3）如果期望使用 CDN 的页面优化，那么需要确保源站服务器关闭 Gzip 压缩。如果源站服务 器是 Nginx，通过修改 Nginx 配置文件里 ngx_http_gzip_module 模块的 gzip_proxied 参数，设定 来自代理服务器的请求，不返回 Gzip 压缩的内容来实现。 （4）另外还有一种比较实现方案，是可以在 CDN 层面配置删除 Accept-Encoding 这个回源 H TTP 请求头。 资源来源于《对象存储&视频云35条实战秘籍》，下载链接：https://developer.aliyun.com/topic/download?id=8226赞0 踩0 评论0 -
提交了问题
2021-12-08
flink 1.13.1 通过yarn-application运行批应用，处理mysql源一亿条数据
-
提交了问题
2021-12-08
flink 1.14 Hybrid Source切换source时机问题
-
提交了问题
2021-12-08
flink1.12.1 读取kafka的数据写入到clickhouse如何支持upsert操作呢
-
提交了问题
2021-12-08
怎样阻止某些合法用户恶意执行一些非法作业呢？flink框架本身能提供哪些保护手段呢？
-
提交了问题
2021-12-08
Tumbling Windows 窗口可开的最小单位
-
提交了问题
2021-12-08
窗口时间不准
-
提交了问题
2021-12-08
flink的一个场景问题
-
提交了问题
2021-12-08
checkpoint的路径问题
-
提交了问题
2021-12-08
flink1.12.4 写入hdfs报错 java.lang.OutOfMemoryError: D
-
提交了问题
2021-12-08
flink 1.13.2 在 Java/Scala 程序中调用 Python UDF函数，通过yar
-
提交了问题
2021-12-08
FlinkSQL 使用 streamingSink 写入 hive orc数据，如何控制文件数量。
-
提交了问题
2021-12-08
查了下flink官方docker image
-
提交了问题
2021-12-08
flink广播流
-
提交了问题
2021-12-08
如题，我当前是select date_format(xxx, 'yyyyMMdd') as dt..
-
回答了问题
2021-12-08
关于flink1.7.2checkpoint本地文件存储，设置文件个数的问题
每个 Checkpoint 生成多少文件，由作业决定，这个不需要用户自己手动设置。 *来自志愿者整理的flink邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-08
启动session 时 ，报错：Could not write the Yarn connectio
java的URI地址不允许带 _ , https://bugs.openjdk.java.net/browse/JDK-8221675 请将 _ 改掉后再试试*来自志愿者整理的flink邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-08
flink 集群
自建集群是哪种方式？ 可以考虑通过yarn集群的per job模式来部署作业，集群的监控可以直接通过yarn的资源管理实现 任务需要更新的时候 可以kill job，保留state 文件，重新提交新的jar包，新的jar包可以设置从老作业的checkPoint文件里恢复继续执行 相关资料可以参考 官方文档/flink china 的资料，希望能有所帮助~*来自志愿者整理的flink邮件归档赞0 踩0 评论0 -
回答了问题
2021-12-08
flink on yarn 的 kerberos 认证问题
kerberos用户的krb5.conf ,user.keytab文件是否在程序运行时加载到了,我之前遇到的kerberos问题是flink读kafka获取不到数据,通过yarn-session模式运行,认证阶段是在yarn-session发布完成的. 最后问题出在kafka通信协议,可以看下hbase端的配置,实现不行 也可以解耦hbase跟flink中间加一个kafka *来自志愿者整理的flink邮件归档赞0 踩0 评论0
滑动查看更多
暂无更多信息