Re: Auditing sink using table api

Hi, Yu Thanks for the suggestion.  Ideally the data need to come from the sink being audited, adding another sink serves part of the purpose, but if anything goes wrong in the original sink, I presume it won't be reflected in the additional sink. (correct me If I'm mistaken) I may have to

回复: Auditing sink using table api

Hi Bo, How about write the data to Print Connector[1] simultaneously via insertInto[2]? It will print the data into Taskmanager's Log. Of course, you can choose an appropriate connector according to your audit log storage. Best, Yu Chen [1] https://nightlies.apache.org/flink/flink-docs-releas