Flink CDC Mongodb中的NumberLong类型应该用flink sql什么类型对应？

MongoDB的NumberLong类型在Flink SQL中可以用BIGINT类型来映射。在Flink SQL中，BIGINT类型可以存储最大值为9,223,372,036,854,775,807的正负整数，而MongoDB的NumberLong类型的范围也是相同的，因此可以匹配。
然而，如果使用BIGINT类型后只能同步一小部分数据，这可能是因为您的数据超出BIGINT类型的支持范围，或者数据类型不匹配。您可以尝试以下方法来解决这个问题：

1. 检查数据：首先，请检查您的MongoDB中的数据，确保它们不会超过BIGINT类型的支持范围。如果数据超过了此范围，请考虑使用另一种更大的类型（如DECIMAL或VARCHAR）。
2. 使用其他类型：如果数据类型不匹配，您可以尝试使用其他类型，例如DECIMAL或VARCHAR。这可能会更好地匹配您的数据，并允许您同步更多的数据。
3. 数据预处理：您还可以在读取数据之前对数据进行预处理，以确保它们符合所需的格式。例如，您可以使用MongoDB的聚合管道来将数据转换为适当的类型。

在Flink SQL中，MongoDB中的NumberLong类型应该用BIGINT类型对应。如果你发现只同步了一小部分数据，可能是因为你的数据量较小，或者MongoDB的默认分片数量设置得过小。你可以尝试调整MongoDB的分片数量，以便更好地同步所有数据。

看连接器官网的，data type 映射，此回答整理自钉群“Flink CDC 社区”

Flink CDC 支持 MongoDB 中的 NumberLong 类型，但是您需要注意类型映射问题。
在 Flink CDC 过程中，您可以将 NumberLong 映射到 BIGINT 类型来同步数据，但是您还需要关注以下几点：

• MongoDB 中 NumberLong 类型支持的最大值为 9,223,372,036,854,775,807，在 Flink CDC 过程中可能造成精度损失。
• 您可以考虑将 NumberLong 类型映射到 STRING 类型，这样就可以完全保持数值不变。