You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "宇宙先生 (Jira)" <ji...@apache.org> on 2022/01/04 10:00:04 UTC

[jira] [Created] (FLINK-25515) flink-kafka-consumer

宇宙先生 created FLINK-25515:
----------------------------

             Summary: flink-kafka-consumer
                 Key: FLINK-25515
                 URL: https://issues.apache.org/jira/browse/FLINK-25515
             Project: Flink
          Issue Type: Improvement
    Affects Versions: 1.11.2
            Reporter: 宇宙先生
             Fix For: 1.13.2
         Attachments: image-2022-01-04-17-55-54-810.png, image-2022-01-04-17-56-47-156.png, image-2022-01-04-17-57-03-495.png, image-2022-01-04-17-58-07-031.png, image-2022-01-04-17-59-13-261.png

当我的版本是flink 1.11.2时,kafka中的数据 !image-2022-01-04-17-55-54-810.png!

在我的jar中打印后

!image-2022-01-04-17-56-47-156.png!

!image-2022-01-04-17-57-03-495.png!

当我在pom文件中升级版本为1.13.2后，发现不再截断，

!image-2022-01-04-17-58-07-031.png!

字段类型是decimal,

!image-2022-01-04-17-59-13-261.png!

我想知道，这是flink1.11.2的缺陷吗

     谢谢！



--
This message was sent by Atlassian Jira
(v8.20.1#820001)