Apache Apex Malhar Release 3.3.1-incubating 发布了，Apache Apex 是一个企业级的统一流和批处理引擎。提供高度可伸缩、高性能、容错、有状态、安全和分布式的大数据处理，同时操作起来非常简单容易。 Bug 修复 [APEXMALHAR-1970] - ArrayOutOfBoundary error in One_To_Many Partitioner for 0.9 kafka input operator [APEXMALHAR-1973] - InitialOffset bug and duplication caused by offset checkpoint [APEXMALHAR-1984] - Operators that use Kryo directly would throw exception in local mode [APEXMALHAR-1990] - Occasional concurrent modification exceptions from IdempotentStorageManager [APEXMALHAR-1993] - Committed offsets are not present in offset manager storage for kafka input operator [APEXMALHAR-1994] - Operator partitions are reporting offsets for kafka partitions they don't subscribe to [APEXMALHAR-1998] - Kafka unit test memory requirement breaks Travis CI build [APEXMALHAR-2003] - NPE in FileSplitterInput 增强 [APEXMALHAR-1983] - Support special chars in topics setting for new Kafka Input Operator 下载地址：http://apex.incubator.apache.org/downloads.html Apache Apex 3.3.1-incubating 发布下载地址
