SQL-gateway Failed to Run

2023-07-02 Thread Xiaolong Wang
Hi, I've tested the Flink SQL-gateway to run some simple Hive queries but met some exceptions. Environment Description: Run on : Kubernetes Deployment Mode: Session Mode (created by a flink-kubernetes-operator) Steps to run: 1. Apply a `flinkdeployment` of flink session cluster to flink operator

Re: Flink TCP custom source - secured server socket

2023-07-02 Thread Martin
This is a conclusion I also came across implementing an application receiving events via TCP/HTTP. This also brings the benefit, as already said, that you can use the modern ecosystem for implementing such things and don't need to so it yourself. I summarized my conclusions developing my applic

Re: Flink TCP custom source - secured server socket

2023-07-02 Thread Jan Lukavský
Hi, in plain TCP socket, there is no 'state' you can return to when restoring from checkpoint. All you can do is reopening the socket. You would have to ensure fault-tolerance by some (custom) higher-level protocol you implement, including persistent storage, replication, etc. You will soon s