我有一个应用程序,允许用户批量添加水印到图像。该应用程序只能使用一个线程,一次只能添加一个水印。我希望用户能够更改number of 水印任务线程一次运行:可能是在设置中的1-5,而且我不能使用fixedThreadPool,因为它有固定的池大小。Executors.newCachedThreadPool();,每次用户更改调用ThreadPoolExecutor.setMaxPoolSize(newMaxThreadCount).的线程数时
现在,当我尝试将15图像水印任务提交给最大池
我目前在流应用程序中使用Apache 1.13.2和Java。我使用的是没有窗口功能的键控函数。我已经实现了一个水印策略和每个文档的autoWatermarkInterval配置,虽然我的水印没有前进。通过使用Flink web UI并在我的EventProcessor KeyedProcessFunction中打印当前的水印,我已经对此进行了二次检查,但是水印经常被设置为非常大的负数-9223372036854775808(最低可能的水印)。.keyBy(EnrichedEventPa