发表于数据库专区
2020/04/28 07:06

Apache Flink 1.9.3 发布,流处理框架

Apache Flink 1.9.3 已发布,这是 Apache Flink 1.9 系列的第三个 bugfix 版本,总共包含 38 个修复程序以及针对 Flink 1.9.2 的改进。 部分更新内容: [FLINK-14278] - 将 ioExecutor 传入 AbstractDispatcherResourceManagerComponentFactory [FLINK-15908] - 在 1.9.x 文档中添加支持'pip install'的描述 [FLINK-15909] - 在后续 1.9.x 版本中加入 PyPI 的发布流程 [FLINK-15938] - 修复 StreamingJoinOperator 和 Streamin...

2
4
发表于数据库专区
2020/02/02 08:25

Apache Flink 1.9.2 发布,流处理框架

Apache Flink 1.9.2 发布了,Apache Flink 项目的目标是开发一个流处理系统,以统一和支持多种形式的实时和离线数据处理应用程序以及事件驱动的应用程序。 此版本带来大量 bug 修复,摘取部分如下: Bug [FLINK-10377] - 删除 TwoPhaseCommitSinkFunction.notifyCheckpointComplete 中的前提条件 [FLINK-10435] - Ctrl + C 之后客户端偶尔会挂起 [FLINK-11120] - TIMESTAMPADD 函数无法正确处理 TIME [FLINK-11835] - ZooKeeper...

2
2
发表于数据库专区
2019/12/14 07:44

Apache Flink 1.8.3 发布,开源流处理框架

Apache Flink 1.8.3 发布了,更新内容如下: 改进 [FLINK-12848] - RowTypeInfo 中的方法 equals() 应该考虑fieldsNames [FLINK-13729] - 更新网站生成依赖性 [FLINK-13965] - 将 hasDeprecatedKeys 和 deprecatedKeys 方法保留在 ConfigOption中,并使用 @Deprecated 批注对其进行标记 [FLINK-13967] - 通过 collect_license_files.sh 生成完整的二进制许可 [FLINK-13968] - 添加 travis 检查以确保二进制许可的正确性 [FLINK...

4
12
发表于数据库专区
2019/12/09 07:33

Apache Flink 1.9.1 发布,流处理框架

Apache Flink 1.9.1 发布了,Apache Flink 项目的目标是开发一个流处理系统,以统一和支持多种形式的实时和离线数据处理应用程序以及事件驱动的应用程序。 此版本带来大量 bug 修复,摘取部分如下: Bug [FLINK-11630] - 本身终止时,TaskExecutor 不等待任务终止 [FLINK-13490] - 修复读取 JDBC 时一列值是否为空,以下值全部为空 [FLINK-13941] - 通过不清除 S3 中的小零件文件来防止数据丢失 [FLINK-12501] - AvroTypeSerial...

5
11
发表于数据库专区
2019/09/15 07:31

Apache Flink 1.8.2 发布,开源流处理框架

Apache Flink 1.8.2 已发布,这是 Apache Flink 1.8 系列的第二个 bugfix 版本,此版本包含 23 个修复和小改进。 Maven <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.8.2</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-streaming-java_2.11</artifactId> <version>1.8.2</version> </dependency...

0
5
发表于数据库专区
2019/08/24 07:23

Apache Flink 1.9.0 发布,开源流处理框架

Apache Flink 1.9.0 已经发布,Apache Flink 项目的目标是开发一个流处理系统,以统一和支持多种形式的实时和离线数据处理应用程序以及事件驱动的应用程序。 此版本包括批处理作业的批处理式恢复,以及新的基于闪烁的表 API 和 SQL 查询引擎的预览,还有状态处理器 API 的可用性,它是最常见的请求特性之一,允许用户使用 Flink DataSet 作业读写保存点。最后,包括一个重新设计的 WebUI 和 Flink 新的 Python Table API 的预览...

2
13
发表于数据库专区
2019/07/04 07:52

Apache Flink 1.8.1 稳定版发布,开源流处理框架

Apache Flink 1.8.1 已发布,这是 Apache Flink 1.8 系列的首个 bugfix 版本,此版本也与之前的 1.x.y 版本 API 兼容。 1.8.1 包含了超过 40 个修复程序和小的改进,官方建议所有用户都升级到最新版本。 Maven <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-java</artifactId> <version>1.8.1</version> </dependency> <dependency> <groupId>org.apache.flink</groupId> <artifactI...

3
9
发表于数据库专区
2019/04/11 06:57

Apache Flink 1.8.0 发布,开源流处理框架

Apache Flink 1.8.0 已发布,该版本与之前的 1.x.y 版本 API 兼容。Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 新特性和改进: Schema Evolution Story 最终版 基于 TTL 持续清除旧状态 使用用户定义的函数和聚合进行 SQL 模式检测 符合 RFC 的 CSV 格式 新的 KafkaDeserializationSchema,可以直接访问 ConsumerRecord FlinkKinesisConsumer 中的分片水印选项 DynamoDB...

0
11
发表于数据库专区
2019/02/26 07:20

Apache Flink 1.6.4 发布,开源流处理框架

Apache Flink 1.6.4 已发布,这是 1.6 系列的第四个修复版本,包含超过25项的修复及对 1.6.3.版本的改进,建议所有用户升级。Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 新版部分更新内容如下: Bug [FLINK-10721] - Kafka discovery-loop exceptions may be swallowed [FLINK-10761] - MetricGroup#getAllVariables can deadlock [FLINK-10774] - connection leak when...

1
8
发表于数据库专区
2019/02/19 07:10

Apache Flink 1.7.2 发布,流处理框架

Apache Flink 1.7.2 发布了,Flink 是一个流处理框架,应用于分布式、高性能、始终可用的与准确的数据流应用程序。 这是 1.7 的第二个 bugfix 版本,包含 40 多个 bug 修复与一些较小的改进,涉及几个关键的恢复性问题和 Flink 流连接器中的问题。 具体查看发布公告。 此外还增加了一个新特性:支持 StreamingFileSink 的 SequenceFile。 更新 Maven 依赖: <dependency>   <groupId>org.apache.flink</groupId>   <arti...

4
11
发表于数据库专区
2019/01/09 08:06

阿里收购 Apache Flink 商业公司 Data Artisans

1月8日,德国媒体 tech.eu 报道称,阿里巴巴以 9000 万欧元的价格收购了位于柏林的创业公司 Data Artisans 。Data Artisans 由开源流处理框架 Apache Flink 的核心团队组建,专为企业提供高吞吐、低延迟的大规模数据解决方案,以便企业能够即时响应数据,从而更合理、更快速地做出业务决策。 图片来自 tech.eu 之后,阿里巴巴的企业新闻网站 Alizila 和 DA 平台的官方博客都发布了收购的消息,并表示阿里作为 Apache Flink 最大...

4
14
发表于数据库专区
2018/12/29 06:49

Apache Flink 1.5.6 发布,流处理框架

Apache Flink 1.5.6 发布了,Flink 是一个流处理框架,应用于分布式、高性能、始终可用的与准确的数据流应用程序。 主要更新如下: [FLINK-4173] - flink-metrics 中用 maven-shade-plugin 替换 maven-assembly-plugin [FLINK-9869] - 批量发送分区信息以提高性能 [FLINK-10613] - 删除 HBaseConnectorITCase 中的 logger 强制转换 [FLINK-10614] - 将 test_batch_allround.sh e2e 更新到新的测试基础架构 [FLINK-10637] - 使用...

0
7
发表于数据库专区
2018/12/24 07:05

Apache Flink 1.6.3 发布,开源流处理框架

Apache Flink 1.6.3 已发布,这是 1.6 系列的第三个修复版本,包含80项多项修复及改进,建议所有用户升级。Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 部分更新内容如下: Improvement [FLINK-4173] - Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics [FLINK-10353] - Restoring a KafkaProducer with Semantic.EXACTLY_ONCE from a savepoint wr...

0
6
发表于数据库专区
2018/12/23 07:34

Apache Flink 1.7.1 发布,开源流处理框架

Apache Flink 1.7.1 已发布,此版本包括27项修复及针对 Flink 1.7.0 的小改进。建议所有用户升级。Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 Sub-task [FLINK-10252] - Handle oversized metric messages [FLINK-10367] - Avoid recursion stack overflow during releasing SingleInputGate [FLINK-10522] - Check if RecoverableWriter supportsResume and act accord...

0
10
发表于数据库专区
2018/12/02 07:38

Apache Flink 1.7.0 发布,支持 Scala 2.12

Apache Flink 1.7.0 已发布,Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 新特性和改进: 支持 Scala 2.12 State Evolution:现在能够更灵活地调整长时间运行的应用的用户状态模式,同时保持与先前保存点的兼容性。 Exactly-once S3 StreamingFileSink MATCH_RECOGNIZE Support in Streaming SQL Temporal Tables and Temporal Joins in Streaming SQL Miscellaneous Fea...

0
6
发表于数据库专区
2018/10/30 07:24

Apache Flink 1.5.5 和 1.6.2 发布,通用数据处理平台

Apache Flink 1.5.5 和 1.6.2 发布了。Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。Apache Flink 也是高效和分布式的通用数据处理平台。Apache Flink 声明式的数据分析开源系统,结合了分布式 MapReduce 类平台的高效,灵活的编程和扩展性。同时在并行数据库发现查询优化方案。 1.5.5 是 Apache Flink 1.5 系列的第五个 bugfix 版本,包括超过 20 个修复程序和一些小改进,...

0
8
发表于数据库专区
2018/09/22 07:35

Apache Flink 1.5.4 发布,开源流处理框架

Apache Flink 1.5.4 发布了,Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 这是 Apache Flink 1.5 系列的第四个 bugfix 版本,包括超过 20 个修复程序和一些小改进,主要改进如下: [FLINK-10082] - 在 Slf4jReporter 中初始化 StringBuilder 时可估计大小 [FLINK-10131] - 改进 ResultSubpartition 的日志记录 [FLINK-10137] - YARN: Log completed Containers [FLINK-10...

0
8
发表于数据库专区
2018/09/21 07:48

Apache Flink 1.6.1 发布,新增输入/输出缓冲区指标

Apache Flink 1.6.1 发布了,Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 这是 1.6 系列的第一个 bugfix 版本,此版本包括 60 个修复程序和一些小改进,主要新特性与改进如下: [FLINK-10022] - 新增输入/输出缓冲区指标 [FLINK-9859] - 更多的 Akka 配置项 [FLINK-9899] - 添加更多指标到 Kinesis 源连接器 [FLINK-9962] - 允许用户在 DateTimeBucketer 中指定 TimeZone...

0
4
发表于数据库专区
2018/08/11 07:26

Apache Flink 1.6.0 发布,分布式高性能流处理框架

Apache Flink 1.6.0 已发布。Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 Apache Flink 1.6.0 继续围绕使用户能够无缝地运行快速数据处理并轻松构建数据驱动和数据密集型应用而改进,主要包括: 新增对 state TTL 的原生支持。此功能允许在 state 到期后进行清理; 继续完善 1.5.0 重构的 Flink 分布式架构,并简化容器设置; 进一步改进 SQL CLI,使得针对大量数据源执行...

2
7
发表于数据库专区
2018/08/01 07:49

Apache Flink 1.5.2 发布,通用数据处理平台

Apache Flink 社区发布了 Apache Flink 1.5 系列的第二个修正版本。Apache Flink 是高效和分布式的通用数据处理平台。Apache Flink 声明式的数据分析开源系统,结合了分布式 MapReduce 类平台的高效,灵活的编程和扩展性。同时在并行数据库发现查询优化方案。 下载地址 >>> http://flink.apache.org/downloads.html 此版本包含 20 多个修复程序和针对 Flink 1.5.1 的小改进。点击这里查看所有修复的详细列表,开发团队强烈建议所...

1
8
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页