Public Repository

Last pushed: 3 months ago
Short Description
flink quick start
Full Description

2017年7月28日:

Tag:08

  1. OpenJDK里找不到jconsole,jps这些调试命令,换成了Sun JDK 1.8.1_121了。
  2. 修改bin/start-local.sh,加入JMX调试参数,jconsole可通过50013端口远程调试。

docker run -p 8081:8081 -p 50013:50013 -it shenqian/my-flink:08 bash

2017年3月14日:

Tag:02
官网的QuickStack:https://ci.apache.org/projects/flink/flink-docs-release-1.2/quickstart/setup_quickstart.htm

按照这个文档,快速搭建了一个docker镜像。在内存1G的虚拟机上跑不起来,在2G的虚拟机上可以运行。参见/root/readme.txt,可以快速跑起来。用OpenJDK就可以运行。

任务运行:
实际上是有两个子任务在运行:一个是flatmap()处理输入流,一个是做Reduce操作(计算wordcount)

Docker Pull Command
Owner
shenqian

Comments (0)