Re: Query on using two sinks for a Flink job (Flink SQL)

Hi Chen, You should tell flink which table to insert by “INSERT INTO XXX SELECT XXX”. For single non insert query, flink will collect output to the console automatically. Therefore, you don’t need to add insert also works. But you must point out target table specifically when you need to write

回复: Error in /jars/upload curl request

Hi Tauseef, Adding an @ sign before the path will resolve your problem. And I verified that both web and postman upload the jar file properly on the master branch code. If you are still having problems then you can provide some more detailed information. Here are some documents of curl by `man

回复: Handling Schema Variability and Applying Regex Patterns in Flink Job Configuration

Hi Arjun, If you can filter files by a regex pattern, I think the config `source.path.regex-pattern`[1] maybe what you want. 'source.path.regex-pattern' = '...', -- optional: regex pattern to filter files to read under the -- directory of `path` optio

回复: 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