Hi Flink Community:
We are using the pyflink to develop a POC for our project. We encountered some
questions while using the flink.
We are using the flink version 1.2, python3.7, data stream API
1. Do you have examples of providing a python customized class as a `result
type`? Based on the documentation research, we found out only built-in types
are supported in Python. Also, what is the payload size limitation inside the
flink, do we have a recommendation for that?
2. Do you have examples of `flink run --python` data stream API codes to the
cluster? We tried to do that, however the process hangs on a `socket read from
the java gateway`, due to the lack of the missing logs, we are not sure what is
missing while submitting the job.
Regards
Dc
<< {CH} {TS} Anything that can possibly go wrong, it does. >>
