Hi everyone, Python Table API seems to be a little bit buggy.
Some minimal examples of strange behaviors here: https://gist.github.com/nrdhm/88322a68fc3e9a14a5f4ab6ec13403cf Was testing in pyflink-shell in our small cluster with Flink 1.17. Docker image: flink:1.17.1-scala_2.12-java11 The third problem with pandas UDF concerns me the most. It seems like Vectorized UDF do not work at all with .filter() /.where() calls. Columns name are reset to default f0, f1, …, fN and values are not being filtered. And so, I have some questions: 1. Was you able to reproduce these problems? 2. Is it the expected behavior? 3. How can we get around this? Best regards, Alexey
