[Flink] 从 RabbitMQ 读取并计算后输出到 MySQL

实现的需求是从 *RabbitMQ* 读取 *JSON* 格式的消息，处理结果输出到 *MySQL*。 主要参考了 [这篇博客][1] 和 [Apache Flink 中文文档][2

Posted by 佳佳 on 2019-09-18 IT Flink IntelliJ IDEA Scala Sbt

[Sbt] 添加 assembly 命令

通过 `sbt package` 命令打的包是不包含 *compile* scope 的包的，若要包含的话需要使用 `sbt assembly` 命令。 sbt 默认不包含该命令

Posted by 佳佳 on 2019-09-17 IT Scala Sbt

[Flink] java.lang.NoClassDefFoundError: org/apache/flink/api/common...

在 IntelliJ IDEA 中右键 Scala 文件直接运行时报了如下错误（通过 *sbt* 命令是可以正常打包的）： "C:\Program Files\Java\jdk

Posted by 佳佳 on 2019-09-17 IT Flink IntelliJ IDEA Scala Sbt

scalac: Multiple 'scala-library*.jar' files

在 Intellij IDEA 中运行 Scala 项目时显示如下错误： Error:scalac: Multiple 'scala-library*.jar' files (scala-li

Posted by 佳佳 on 2019-09-17 IT IntelliJ IDEA Scala Sbt

通过 IntelliJ IDEA 打包 Flink Scala 项目

在 Windows 上安装 Flink 可以参考 [这里](https://www.liujiajia.me/2019/9/4/install-and-run-flink-on-win

Posted by 佳佳 on 2019-09-10 IT Flink IntelliJ IDEA Scala Sbt


刘佳佳
江苏 - 苏州
软件工程师
梦嘉