请问怎么判断filesink写文件成功呢？

可以通过实现 BucketAssigner 接口并使用 onSuccessfulWrite 回调方法来判断文件写入是否成功。

   @Override
    public void onSuccessfulWrite(String bucketPath) {
        // 在写入数据成功后执行的操作
        System.out.println("File written to " + bucketPath);
    }

应该是这个3个参数控制滚动时间 和文件大小。如果还没有滚动 就有一个.inoss的标记，你不可查询。你可以考虑加上唯一的 文件前缀或者后缀，这样你后面的下游服务可以定时扫描文件目录，有了对应前缀或后缀文件再执行任务。此答案出自钉群“【③群】Apache Flink China社区”