苏州网站建设方法,银川网站建设效果,网站收录免费咨询,怎么更改公司网站域名1、Flink 的 抽象层次有几种Stateful stream processingCore APITableSQL 2、Window 类型(1)TimeWindowTumbling Window(滚动窗口)Sliding Window(滑动窗口)Session Window(会话窗口)Global Window(全局窗口)(2)countWindow(3)自定义window 3、Time 类型事件时间、注入时间和Pr…1、Flink 的 抽象层次有几种Stateful stream processingCore APITableSQL 2、Window 类型(1)TimeWindowTumbling Window(滚动窗口)Sliding Window(滑动窗口)Session Window(会话窗口)Global Window(全局窗口)(2)countWindow(3)自定义window 3、Time 类型事件时间、注入时间和Processing Time4、Checkpoint的理解轻量级容错机制(全局异步局部同步)保证exactly-once 语义用于内部失败的恢复基本原理通过往source 注入barrierbarrier作为checkpoint的标志5、Savepoint流处理过程中的状态历史版本具有可以replay的功能外部恢复应用重启和升级两种方式触发Cancel with savepoint手动主动触发$s bin/flink savepoint :jobId [:targetDirectory]$ bin/flink cancel -s [:targetDirectory] :jobId6、Flink runtime architectureJob ManagerTask MangerClient角色间的通信(Akka)数据的传输Netty7、什么是soltssolts 槽slot 的数量通常与每个 TaskManager 的可用 CPU 内核数成比例。一般情况下你的 slot 数是你每个 TaskManager 的 cpu 的核数。8、什么是状态Definitiontask/operator在某个时刻的中间结果SnapshotEffect记录状态并且在失败时用于恢复Basic typeOperator state、Keyed state9、RestartStrategiesRestart Strategies4种重启策略10、statebacked有几种(3种)Apache Flink 1.8 Documentation: State Backends//env.setStateBackend(new MemoryStateBackend());//env.setStateBackend(new FsStateBackend(hdfs://hadoop100:9000/flink/checkpoints));//env.setStateBackend(new RocksDBStateBackend(hdfs://hadoop100:9000/flink/checkpoints,true));11、运行模式Job模式独享Dispatcher和ResourceManager资源按需申请适合⼤大作业Session模式共享Dispatcher和ResourceManager共⽤用TaskManager适合规模⼩小运⾏行行时间短的作业12、全量聚合和增量聚合 window全量聚合ProcessWindowFunction增量聚合ReduceFunction、AggregateFunction、FoldFunction
