Hi
Fabin thanks for reply I fixed the issue that i was facing.
On Tue, Mar 20, 2018 at 7:31 PM, Fabian Hueske wrote:
> Hi,
>
> TBH, I don't have much experience with logging, but you might want to
> consider using Side Outputs [1] to route invalid records into a separate
> stream.
> The stream
Hi,
TBH, I don't have much experience with logging, but you might want to
consider using Side Outputs [1] to route invalid records into a separate
stream.
The stream can then separately handled, be written to files or Kafka or
wherever.
Best,
Fabian
[1]
https://ci.apache.org/projects/flink/flink
