flink执行计划网址：https://flink.apache.org/visualizer/

问题导读1.Atlas中实体具体指什么？2.如何为Flink创建Atlas实体类型定义？3.如何验证元数据收集？在Cloudera Streaming Analytics中，可以将Flink与Apache Atlas一起使用，以跟踪Flink作业的输入和输出数据。Atlas是沿袭和元数...

Flink实时消费业务数据DemoDebezium监控MySQL用FlinkSQL实时消费1、环境准备## 各组件版本MySQL：5.7.21-log ## 开启binlogkafka_2.11-2.4.1 ## KafkaFlink:1.12.0 ## Flink_1.12.0官方推荐使用Kafka_2.......

项目设计1、实时 Flink实时统计订单成交金额 1、业务数据存储到mysql中2、使用canal将数据实时导到kafka3、手动维护kafka的offset到mysql(结合mysql的事务)4、使用flink去实时处理kafka中的数据5、统计结果输出到`co...

Flink学习笔记一、Flink运行架构1、 Flink 运行时的组件`作业管理器(JobManager)``资源管理器(ResourceManager)``任务管理器(TaskManager)``以及分发器(Dispatcher)` 作业管理器(JobManager) 控制一个应用程序执行的...

Apache Zeppelin是一款类似jupyter notebook的交互式代码编辑器。

在流处理应用中，数据是连续不断的，因此我们不可能等到所有数据都到了才开始处理。当然我们可以每来一个消息就处理一次，但是有时我们需要做一些聚合类的处理，例如：在过去的1分钟内有多少用户点击了我们的网页。在这种情况...

这样的自我介绍还不如前段时间流行的一句话：“我叫xx,我喜欢唱跳、rap、篮球。”起码你还让面试官知道了你的特长。

Flink和Spark类似，也是一种一站式处理的框架；既可以进行批处理（DataSet），也可以进行实时处理（DataStream）。

在病毒查杀，应用安全对抗，静态逆向应用，动态逆向应用，最重要的对象就是，应用程序的内存数据。