Re: Support for gRPC in Flink StateFun 2.x

2020-09-19 Thread Igal Shilman
Hi, Your observation is correct, currently the only way to invoke a remote function is trough an HTTP POST request to a service that exposes a StateFun endpoint. The endpoint must implement the client side of a the “RequestReply” protocol as defined by StateFun (basically an invocation contains t

Re: Flink SQL - can I have multiple outputs per job?

2020-09-19 Thread Dan Hill
I figured it out. TableEnvironment.StatementSet. Semi-related, query optimizers can mess up the reuse depending on which tables the join IDs come from. On Fri, Sep 18, 2020 at 9:40 PM Dan Hill wrote: > I have a few results that I want to produce. > - A join B > - A join B join C > - A joi

Flink Table SQL and Job Names

2020-09-19 Thread Dan Hill
I'm getting names like "insert-into_{catalog}.{db}.{table}". Is there a way to customize this with non-deprecated methods?