啰嗦的话放在最后，先上干货。这篇文章仅为自己记录参考，方便以后新电脑重新配置。有的步骤如果不懂，不会过多解释。 需求 家里无法申请到公网ip，但是买了腾讯云/阿里云等的服务器...
发简信
IP属地：四川
-
Windows远程桌面配置-有网的地方都可访问家里的电脑 -
opentracing建议每个服务使用一个Tracer，Tracer构建当前服务中的span，两个tracer见的通信，按照opentracing的规范，貌似没有理由让tracer见保持通信。
jaeger代码阅读思路整理
jaeger实现了opentracing的规范，对Tracer与Span等接口写了自己的实现。根据opentracing的规范，每个服务建议只有一个Tracer，Tracer...
-
Flink1.10.0与Hive3.1.2集成详细步骤背景 Flink Hive 集成介绍 Flink集群设置 本地开发调试本地开发调试提示 Git相关项目 本文记录了flink1.10.0与hive3.1.2集成时遇到的问题，...
-
Flink-Streaming-State & Fault Tolerance-Checkpointing
Flink中的每个function与operator都可以是有状态的。有状态的function会在处理每个数据时存储数据，使得状态state成为需要更多精细操作的任意类型的o...
-
Flink-Streaming-State & Fault Tolerance-The Broadcast State Pattern
上篇讲了operator state在恢复（重启/故障恢复）时要么使用evenly distributed策略，要么使用union策略，来重启operator的并发实例。op...
-
Flink-Streaming-State & Fault Tolerance-Working with State
这篇文档解释了如何在开发应用时，使用Flink的state。 Keyed State and Operator State 在Flink有两种基本的state：keyed s...
-
Flink-Streaming-State & Fault Tolerance
OverviewWorking with StateThe Broadcast State PatternCheckpointingQueryable StateState ...
-
Flink-Streaming-State & Fault Tolerance-Overview
有状态的函数和操作符会在处理数据时存储一些数据，这使得state成为了任何想要进行精细操作的操作符的关键组成部分。例如： 当应用寻找某些特定的模式的数据时，state可以存储...
-
Flink-Streaming-EventTime-Pre-defined Timestamp Extractors / Watermark Emitters
Flink提供了接口，允许编程者自定义 timesatmp extractor 与 watermark emitter。更确切的说，可以根据情况，实现 AssignerWit...
-
Flink-Streaming-EventTime-Generating Timestamps / Watermarks
这一部分文档，只和使用 event time语义的应用有关。为了使用 event time 语义，流程序需要设置相应的 时间语义 time characteristic. 指...
-
Flink-Streaming-EventTime-Overview
Event Time / Processing Time / Ingestion Time Flink 在流应用中支持不同的时间概念： Processing Time: 处理...
-
Flink-Streaming-EventTime
OverviewGenerating Timestamps / WatermarksPre-defined Timestamp Extractors / Watermark ...
-
Flink-Streaming-overview
Flink中的流应用就是在数据流上应用各种转化（如：filter,update state,difine window,aggregation）。数据流有各种数据源创建而来（...
-
Flink-Basic API Concepts-Java Lambda Expressions
Java 8 引入了一些为了提高编码的速度与间接性的新特性。其中最重要的特性之一，便是“Lambda 表达式”，它打开了使用java进行函数是编程的大门。Lambda表达式允...
-
Flink-Basic API Concepts-overview
Flink程序会在分布式的集合上进行各类转化操作（如，filter,map,update state,join,group,window,aggregate）。集合是由数据源...