首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

Flink1.12支持对接Atlas【使用Atlas收集Flink元数据】

问题导读 1.Atlas中实体具体指什么? 2.如何为Flink创建Atlas实体类型定义? 3.如何验证元数据收集? 在Cloudera Streaming Analytics中,可以将Flink与Apache Atlas一起使用,以跟踪Flink作业的输入和输出数据。 Atlas是沿袭和元数据管理解决方案,在Cloudera Data Platform上受支持。这意味着可以查找,组织和管理有关Flink应用程序以及它们如何相互关联的数据的不同资产。这实现了一系列数据管理和法规遵从性用例。 有关Atlas的更多信息,请参阅Cloudera Runtime文档。 Flink元数据集合中的Atlas实体 在Atlas中,表示Flink应用程序,Kafka主题,HBase表等的核心概念称为实体。需要了解Flink设置中实体的关系和定义,以增强元数据收集。 为Flink创建Atlas实体类型定义 在提交Flink作业以收集其元数据之前,需要为Flink创建Atlas实体类型定义。在命令行中,需要连接到Atlas服务器并添加预定义的类型定义。还需要在Cloudera Manager中为Flink启用Atlas。 验证元数据收集 启用Atlas元数据收集后,群集上新提交的Flink作业也将其元数据提交给Atlas。可以通过请求有关Atlas挂钩的信息来在命令行中使用消息验证元数据收集。 Flink元数据集合中的Atlas实体 在Atlas中,表示Flink应用程序,Kafka主题,HBase表等的核心概念称为实体。需要了解Flink设置中实体的关系和定义,以增强元数据收集。 在向Atlas提交更新时,Flink应用程序会描述自身以及用作源和接收器的实体。Atlas创建并更新相应的实体,并从收集到的和已经可用的实体创建沿袭。在内部,Flink客户端和Atlas服务器之间的通信是使用Kafka主题实现的。该解决方案被Atlas社区称为Flink挂钩。

02

[PHP] PHP 7.4.4错误修复版本的更改日志

核心: 修复了错误#79329(一个空字节后get_headers()默默地被截断)(CVE-2020-7066) 修复了错误#79244(PHP在解析INI文件时崩溃)的问题。 修复了错误#63206(restore_error_handler无法还原以前的错误掩码)。 COM: 修复了错误#66322(COMPersistHelper :: SaveToFile可以保存到错误的位置)。 修复了错误#79242(COM错误常量与x86上的com_exception代码不匹配)。 修复了错误#79247(垃圾收集变体对象段错误)。 修复了错误#79248(遍历空的VT_ARRAY会引发com_exception)。 修复了错误#79299(com_print_typeinfo打印重复的变量)。 修复了错误#79332(永远不会释放php_istreams)。 修复了错误#79333(com_print_typeinfo()泄漏内存)。 CURL: 修复了错误#79019(复制的cURL处理上载空文件)。 修复了错误#79013(发布带有curl的curlFile时缺少Content-Length)。 DOM: 修复了错误#77569 :(在DomImplementation中写入访问冲突)。 修复了错误#79271(DOMDocumentType :: $ childNodes为NULL)。 Enchant: 修复了错误#79311(在大端架构下,enchant_dict_suggest()失败)。 EXIF: 修复了错误#79282(在exif中使用未初始化的值)(CVE-2020-7064)。 Fileinfo: 修复了错误#79283(libmagic补丁中的Segfault包含缓冲区溢出)。 FPM: 修复了错误#77653(显示运行者而不是实际的错误消息)。 修复了错误#79014(PHP-FPM和主要脚本未知)。 MBstring: 修复了错误#79371(mb_strtolower(UTF-32LE):php_unicode_tolower_full处的堆栈缓冲区溢出)(CVE-2020-7065)。 MySQLi: 修复了错误#64032(mysqli报告了不同的client_version)。 MySQLnd: 已实现FR#79275(在Windows上支持auth_plugin_caching_sha2_password)。 Opcache: 修复了错误#79252(预加载会导致php-fpm在退出过程中出现段错误)。 PCRE: 修复了错误#79188(preg_replace / preg_replace_callback和unicode中的内存损坏)。 修复了错误#79241(preg_match()上的分段错误)。 修复了错误#79257(重复的命名组(?J),即使不匹配,也更倾向于最后一种选择)。 PDO_ODBC: 修复了错误#79038(PDOStatement :: nextRowset()泄漏列值)。 反射: 修复了错误#79062(具有Heredoc默认值的属性对于getDocComment返回false)。 SQLite3: 修复了bug#79294(:: columnType()在SQLite3Stmt :: reset()之后可能失败。 标准: 修复了错误#79254(没有参数的getenv()未显示更改)。 修复了错误#79265(将fopen用于http请求时,主机标头注入不当)。 压缩: 修复了错误#79315(ZipArchive :: addFile不支持开始/长度参数)。

01
领券