flink application模式找不到mysql包,请问是什么原因呢?
Dinky 1.01版本已经在lib,extends文件夹添加了mysql-connector-java-8.0.25.jar文件但是启动flink application模式,报下面的错误java.la......
数仓架构构建实战思路(九)ETL部分建设
Dinky进行在线编程。是非常不错的一种ETL解决方案。有时间大家可以多了解下。最后,一定要注意一下,在进行ETL数据处理的时候,一定要取消数据的一致性,确保ExactlyOnce......
数仓架构构建实战思路(七)技术架构选型很重要
Dinky做在线开发,极大的减少企业的成本。备注:1、做好技术选型之后,一定要把相关的框架搭建起来,并且做好相关的压力测试,最好是全链路的压力测试,避免到时候上线出现某些节点的瓶颈。2、当然压测之后,一定要出一份.....
使用Dinky flink cdc把数据写入到hase中报错:hbase-default.xml file seems to be for an older version
把数据写入到hbase中报错:Caused by: java.lang.RuntimeException: hbase-default.xml file seems to be for an older vers.....
热文Flink CDC实战系列(三)Flink cdc 把mysql数据写入到clickhouse
Dinky进行演示,下面直接开始:1)准备Dinky环境这里的话我们直接使用Dinky1.0版本,正好做下Dinky1.0版本的测试。详细的安装和使用可参考:《Dinky使用教程》。这里我们已经准备好了一个Dinky...
热文Flink CDC实战系列(二)Flink cdc 把mysql数据写入到kafka
Dinky进行演示,下面直接开始:1)准备Dinky环境这里的话我们直接使用Dinky1.0版本,正好做下Dinky1.0版本的测试。详细的安装和使用可参考:《Dinky使用教程》。这里我们已经准备好了一个Dinky...
使用Dinky编写flinksql把数据同步到elasticsearch中报错,提示:org.apache.flink.table.types.logical.utils.LogicalTypeChe
Dinky编写flinksql把数据同步到elasticsearch中报错,提示:Caused by: org.apache.flink.table.api.ValidationException: Unable.....
Dinky运行flink sql任务报错,提示:Cannot discover a connector using option: 'connector'='elasticsearch-7'
Dinky运行flink sql任务报错,提示:Caused by: org.apache.flink.table.api.ValidationException: Could not find any fact.....
Dinky运行flink sql任务报错,提示:Could not find any factory for identifier 'mysql-cdc'
Dinky运行flink sql任务报错,提示:Caused by: org.apache.flink.table.api.ValidationException: Could not find any fact.....
Dinky执行flink sql报错:Multiple factories for identifier 'default' that implement
Dinky执行flink sql报错,提示如下:Caused by: org.apache.flink.table.api.ValidationException: Multiple factories for......
热文Dinky 实时计算平台系列(二十三)Dinky0.x版本升级到1.0版本的踩坑之路
Dinky1.0版本发布了,在这里详细记录下对应的踩坑之路。本文档会进行长期持续的更新。1)jdk问题这里我服务器安装的jdk的版本,但是启动的时候报错了,提示:Unrecognized VM option '...
Dinky1.0版本部署的时候启动后无法访问,应该是启动出错了,但是没有生成logs文件,如何排查
Dinky1.0的时候,执行启动命令后显示成功了,如下图:但是却无法访问,使用jps查看,竟然没启动起来,如下图:想要查看日志log,但是Dinky的目录里面没有logs文件夹,如下图:请问应......