[GitHub] [samza] mynameborat commented on a diff in pull request #1640: SAMZA-2741: [Pipeline Drain] Fix ApplicationUtil.isHighLevelApiJob to work for anonymous and lambda `SamzaApplication` classes

mynameborat commented on code in PR #1640: URL: https://github.com/apache/samza/pull/1640#discussion_r1017221725 ## samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java: ## @@ -46,6 +46,11 @@ public enum ApplicationMode { BATCH } + public enum Appli

[GitHub] [samza] mynameborat commented on a diff in pull request #1640: SAMZA-2741: [Pipeline Drain] Fix ApplicationUtil.isHighLevelApiJob to work for anonymous and lambda `SamzaApplication` classes

mynameborat commented on code in PR #1640: URL: https://github.com/apache/samza/pull/1640#discussion_r1016065159 ## samza-core/src/main/java/org/apache/samza/container/RunLoopFactory.java: ## @@ -69,6 +69,8 @@ public static Runnable createRunLoop(scala.collection.immutable.Map