Flink создает исключение NullPointerException при добавлении соли для ключа и агрегации окон в каком-либо поле
#java #apache-flink Вопрос: У меня есть программа, выполняющая 2-фазную агрегацию, чтобы устранить перекос данных в моей работе. И я использовал простой ThreadLocalRandom для создания суффикса к моему оригиналу, например :…