I merged your PR for the RowSerializer. Teaching the aggregators to deal
with null values should be a very simple fix in
ExpressionAggregateFunction.scala. There it is simply always aggregating
the values without checking whether they are null. If you want you can also
fix that or I can quickly fix
Hi. I think that we don’t need deploy all modules with scala variation. The
pure java-based modules such as flink-java, flink-core, flink-optimizers, …,
etc. don’t need to be deployed with scala version variation. We need only scala
related modules such as flink-ml, flink-runtime, flink-scala, …
