Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/3511#discussion_r140663596 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java --- @@ -127,6 +127,12 @@ private long autoWatermarkInterval = 0; /** + * The flag determines whether a custom NormalizedKeySorter will be dynamically created + * for underlying data + */ + private boolean codeGenerationForSorterEnabled = false; --- End diff -- 36419beee7938768453d2335daa9d7c29af720c1 I created a Jira for performance tweaking: https://issues.apache.org/jira/browse/FLINK-7680
---