暂无个人介绍
能力说明:
了解变量作用域、Java类的结构,能够创建带main方法可执行的java应用,从命令行运行java程序;能够使用Java基本数据类型、运算符和控制结构、数组、循环结构书写和运行简单的Java程序。
暂时未有相关云产品技术能力~
阿里云技能认证
详细说明2023年05月
2021年01月
你觉得阿里云的哪款产品最值得买?现在的阿里云足够具备“性价比”吗? 降价的值得买,不降价的就不值得买了,没降价的性价比太低了,这次降价的只是部分产品,并非所有产品全线降价,对我而言影响不大,因为我用到的产品都没降价,依旧还是那么贵。
我感觉应该是分布式的问题,有些类里的值并没有发送到所有的节点上,大概率是 配置字段是transient 序列化的时候丢失了
Streamingfilesink只能写hdfs,写hive的话,可以在配合jdbc,用 hive的 jdbc
应该是scala版本问题
官网啊
你如果不删除定时器,重新定时会触发两次,你可以测试一下 https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/operators/process_function.html
HADOOP_CLASSPATH 配置了没有?貌似 flink 没识别出 hdfs 环境呢
每一行加日志,看哪一行报错了,看走到哪里了
用table api吧,它有sqlUpdate
需要处理一下,窗口目前不支持cdc格式的数据
https://github.com/uncleguanghui/pyflink_learn/blob/master/examples/README.md 这个我感觉不错
sink不是可以指定字段吗
最新的hudi支持咯 https://mp.weixin.qq.com/s/rI5GnsDVuIwW9TlNoVy8kw
环境中可以配置时间偏移
理论上应该可以,但是没有现成的工具,要自己写
自定义udf函数,将数组转成字符串,应该可以试试
看下这个https://github.com/appleyuchi/Flink_SQL_Client_UDF
那个batch是5000,你可以把batch设置小点就行了
是不是 sql有延时 需要使用 result方法抽取result之后才能运行?
估计 checkpoint 没有做成功吧。