新增Nacos Namespace配置,删除更新至HDFS时Flush操作

This commit is contained in:
unknown
2022-12-16 16:52:33 +08:00
parent 78435d54ea
commit 7c201a8a3f
5 changed files with 10 additions and 7 deletions

View File

@@ -28,7 +28,7 @@ import java.util.concurrent.Executor;
public class SingleHttpSource extends RichHttpSourceFunction<Map<String, byte[]>> {
private static final Logger logger = LoggerFactory.getLogger(HttpSource.class);
private static final Logger logger = LoggerFactory.getLogger(SingleHttpSource.class);
private static HashMap<String, byte[]> knowledgeFileCache;
private Properties nacosProperties;