Error while fetching metadata with correlation id 37 : {flink_kafka9=LEADER_NOT_AVAILABLE}

A: 这个错误说明无法从Kafka获取元数据，可能是由于Kafka没有可用的leader节点导致的。建议检查Kafka集群的状态和配置，并确保所有节点都在运行且相互通信。如果问题仍然存在，可能需要更新Kafka版本或调整配置。

相关问题

error while fetching metadata with correlation id124

这个错误通常意味着在请求元数据时发生了一个错误。这可能是由于网络问题、服务器故障或其他原因引起的。为了解决这个问题，你可以尝试以下几个步骤：

1. 检查网络连接：确保你的网络连接正常，并且能够访问所需的服务器。你可以尝试通过浏览器访问相关的网站或者使用其他网络相关的工具进行测试。

2. 重试操作：有时候这个错误只是一个临时的问题，重试一次可能会解决。你可以稍等片刻，然后重新发送请求。

3. 检查服务器状态：如果错误持续出现，可能是服务器出现了问题。你可以检查服务器的状态页面或与管理员联系以获取更多信息。

如果以上方法都没有解决问题，你可能需要进一步调查错误的原因。可以查看系统日志、应用程序日志或联系相关技术支持团队以获取更多帮助。

@torch.no_grad() def main(): global args, save_path args = parser.parse_args() data_dir = Path(args.data) print("=> fetching img pairs in '{}'".format(args.data)) if args.output is None: save_path = data_dir/'flow' else: save_path = Path(args.output) print('=> will save everything to {}'.format(save_path)) save_path.makedirs_p() # Data loading code input_transform = transforms.Compose([transforms.Normalize(mean=[0,0,0], std=[255,255,255]) ])

这段代码定义了一个名为 `main` 的函数，并使用装饰器 `@torch.no_grad()` 来禁用梯度计算，以减少内存消耗。

`main` 函数首先使用 `parser.parse_args()` 解析命令行参数，并将结果保存在全局变量 `args` 中。

接下来，代码通过 `Path` 类将命令行参数中的数据文件夹路径转换为 `data_dir` 对象，并打印一条消息指示正在获取图像对。

然后，代码根据命令行参数中的输出文件夹路径创建一个目录，并将其保存在全局变量 `save_path` 中。如果未指定输出文件夹路径，则默认创建一个名为 "flow" 的子目录。

接着，代码创建了一个名为 `input_transform` 的图像转换对象。在这个例子中，它只应用了一个归一化操作，即将图像的像素值从 `[0,0,0]` 到 `[255,255,255]` 范围进行归一化。

以上就是这段代码的主要内容和功能。如果有更多问题，可以继续提问。