t; source subtask to read data.
>
> [1]
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface
>
> Best,
> Shammon FY
>
>
> On Tue, May 9, 2023 at 2:37 AM Wei Hou via user wrote:
>>
>> Hi Team,
>>
>>
t; We hit an issue after we upgrade our job from Flink 1.12 to 1.15, there's
> a consistent akka.remote.OversizedPayloadException after job restarts:
>
> Transient association error (association remains live)
> akka.remote.OversizedPayloadException: Discarding oversized payload se
Hi Team,
We hit an issue after we upgrade our job from Flink 1.12 to 1.15, there's
a consistent akka.remote.OversizedPayloadException after job restarts:
Transient association error (association remains live)
akka.remote.OversizedPayloadException: Discarding oversized payload sent to
k version 1.4.2. When I try to run my application on a
> Yarn cluster, I get this error:
>
> 2018-04-23 14:08:13,346 ERROR akka.remote.EndpointWriter
> - Transient association error (association remains live)
> akka.remote.OversizedPayloadException: Discarding ove
gt;
> 2018-04-23 14:08:13,346 ERROR akka.remote.EndpointWriter
> - Transient association error (association remains live)
> akka.remote.OversizedPayloadException: Discarding oversized payload sent
> to Actor[akka.tcp://flink@:37877/user/jobmanager#1227317945]: ma
)
akka.remote.OversizedPayloadException: Discarding oversized payload sent to
Actor[akka.tcp://flink@:37877/user/jobmanager#1227317945]: max allowed size
10485760 bytes, actual size of encoded class
org.apache.flink.runtime.messages.JobManagerMessages$LeaderSessionMessage was
213691138 bytes.
I am trying to override the
