代码demopublicstaticvoidmain(String[]args){FlinkManagermanager=newFlinkManager(FLINK_IBU_BI_UBT_CUSTOM_HOTEL_FAVORITE,IS_LOCAL);manager.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);manager.setParallelis