jtagx
We are the original creators of Apache Flink, the open-source unified batch/stream processing system that powers applications in all types of companies, from tech giants like Alibaba, Amazon, or Netflix, to traditional enterprises like banks or telcos. We contribute heavily to Apache Flink while building enterprise-grade products on top of Flink.
> If you eat beans and fart a lot, do you ever get rid of the smell?
Apache Flink 1.12 with a batch execution mode in DataStream API, K8s HA released
Apache Flink Serialization: Comparison of Kryo,Avro,Thrift,Protobuf and Internal
- Improved Memory Management and Configuration
- Reworked job submission (allowing things like Zeppelin or other interactive notebooks)
- Native Kubernetes integration (there's now multiple ways to submit Flink to K8s)
- Hive integration: Use your Hive tables, UDFs etc. in Flink SQL
- Full TPC-DS coverage for batch: this basically means Flink supports a lot of SQL syntax
- PyFlink supports user defined functions (based on Apache Beam's portability framework). This makes Flink's Python support really strong
... there are many more features in the announcement (1200 tickets were resolved)
Apache Flink 1.10 Announced: Kubernetes, Hive Integration, Full TPC-DS, PyFlink
Apache Flink 1.9.0 Released
Deep-Dive into Apache Flink's Network Stack: Credit-Based Flow Control (Low Lat)
Introducing Serializable ACID Transactions on Streaming Data
Apache Flink 1.3.0 released with incremental checkpointing,retractions in SQL,
From Streams to Tables and Back Again: An Update on Apache Flink's Table&SQL API
My CPU: Intel(R) Core(TM) i7-4910MQ CPU @ 2.90GHz Thoughput on one core ~ 650k events / second. Code: https://github.com/rmetzger/cep-monitoring/tree/throughput