JYXL created FLINK-22728:
----------------------------
Summary: a problem of loading udf
Key: FLINK-22728
URL: https://issues.apache.org/jira/browse/FLINK-22728
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.13.0
Environment: python3.7
centos 8
pyflink1.13.0
java1.11
Reporter: JYXL
hi:
I'm using the stream udf by python.
udf as bellow:
class MyKeySelector(KeySelector):
def __init__(self, partitions: int=6):
self.partitions = partitions
def get_key(self, value):
return random.randint(0, self.partitions)
when I code it with the main task in the same script, it works,
but when I make it in a simgle script, it cannot work.
the archives as bellow:
project:
| __init__.py
| key_function.py
| main_task.py
I'm confused when I use env.add_python_file method, it cannot work either,
no matter the parameter `file_path` is '~/project' or
'~/project/key_function.py.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
