基于flink1.12.0版本的pyflink开发了一个程序,使用了udaf,想在本地的PyCharm环境调试该功能,在udaf的第一行打了断点,但是没法进入。 可以确认程序有正确运行,因为sink到kafka里看了是有数据的。 请问是否需要什么配置才能进行调试。
guoliubi...@foxmail.com
基于flink1.12.0版本的pyflink开发了一个程序,使用了udaf,想在本地的PyCharm环境调试该功能,在udaf的第一行打了断点,但是没法进入。 可以确认程序有正确运行,因为sink到kafka里看了是有数据的。 请问是否需要什么配置才能进行调试。
guoliubi...@foxmail.com