[
https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17254378#comment-17254378
]
Zhilong Hong edited comment on FLINK-20747 at 12/24/20, 2:59 AM:
-----------------------------------------------------------------
Hi, [~zengjinbo], thank you for proposing this issue. Would you mind translate
the title and description into English? Because most Flink developers speak
English rather than Chinese. It would be confused of them to see this JIRA.
was (Author: thesharing):
Hi, [~zengjinbo], thank you for proposing this issue. Would you mind change the
title and description into English? Because most Flink developers speak English
rather than Chinese. It would be confused for them to see this JIRA.
> max 函数冲突报ClassCastException异常
> -----------------------------
>
> Key: FLINK-20747
> URL: https://issues.apache.org/jira/browse/FLINK-20747
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.12.0
> Reporter: zengjinbo
> Priority: Critical
> Fix For: 1.12.0
>
> Attachments: image-2020-12-23-18-04-21-079.png
>
>
> 由于新版1.12.0发布，sql改造过程中，发现1.11.1中能正常执行sql，报异常
> java.lang.ClassCastException: java.lang.Integer cannot be cast to
> org.apache.flink.table.data.StringDatajava.lang.ClassCastException:
> java.lang.Integer cannot be cast to org.apache.flink.table.data.StringData at
> org$apache$flink$table$planner$functions$aggfunctions$MaxWithRetractAggFunction$MaxWithRetractAccumulator$Converter.toInternal(Unknown
> Source) at
> org.apache.flink.table.data.conversion.StructuredObjectConverter.toInternal(StructuredObjectConverter.java:92)
> at
> org.apache.flink.table.data.conversion.StructuredObjectConverter.toInternal(StructuredObjectConverter.java:47)
> at
> org.apache.flink.table.data.conversion.DataStructureConverter.toInternalOrNull(DataStructureConverter.java:59)
> at GroupAggsHandler$875.getAccumulators(Unknown Source) at
> org.apache.flink.table.runtime.operators.aggregate.GroupAggFunction.processElement(GroupAggFunction.java:175)
> at
> org.apache.flink.table.runtime.operators.aggregate.GroupAggFunction.processElement(GroupAggFunction.java:45)
> at
> org.apache.flink.streaming.api.operators.KeyedProcessOperator.processElement(KeyedProcessOperator.java:85)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:193)
> at
> org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.processElement(StreamTaskNetworkInput.java:179)
> at
> org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput.emitNext(StreamTaskNetworkInput.java:152)
> at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:67)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:372)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:186)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:575)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:539)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:722) at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:547)
>
>
> !image-2020-12-23-18-04-21-079.png!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
