me here . The job fails after this exception is hit
>>>
>>>
>>> 2021-07-13 13:24:58,781 INFO
>>> org.apache.flink.runtime.executiongraph.ExecutionGraph
>>> [] - ExtractTransformProcess -> A
me.executiongraph.ExecutionGraph
>> [] - ExtractTransformProcess -> AsyncFetch (9/60)
>> (3809c73da162e9ab3b7b131077aff105) switched from RUNNING to FAILED on
>> container_e3767_1626191679189_5049_01 _03 @ brdn6162.target.com
>> (dataPort=41107).
> [] - ExtractTransformProcess -> AsyncFetch (9/60)
> (3809c73da162e9ab3b7b131077aff105) switched from RUNNING to FAILED on
> container_e3767_1626191679189_5049_01 _03 @ brdn6162.target.com
> (dataPort=41107).
>
>
> java.lang.Exception: Could not complete
org.apache.flink.runtime.executiongraph.ExecutionGraph
[] - ExtractTransformProcess -> AsyncFetch (9/60)
(3809c73da162e9ab3b7b131077aff105) switched from RUNNING to FAILED on
container_e3767_1626191679189_5049_01 _03 @ brdn6162.target.com
(dataPort=41107).
java.lang.Exception: Could not complete the stream element: Rec