图挂了，邮件列表不能直接发图片。可以发一下更详细的日志信息吗？
On Tue, Oct 19, 2021 at 6:34 PM xuzh wrote:
> 错误日志
> Exception in thread Thread-14:
> Traceback (most recent call last):
> File "D:\Anaconda3\envs\py37\lib\threading.py", line 926, in
> _bootstrap_inner
> self.run()
> File
> "D:\Anaconda3\envs\py37\lib\sit
Exception in thread Thread-14:
Traceback (most recent call last):
File "D:\Anaconda3\envs\py37\lib\threading.py", line 926, in
_bootstrap_inner
self.run()
File
"D:\Anaconda3\envs\py37\lib\site-packages\apache_beam\runners\worker\data_plane.py",
line 218, in run
while not sel
-- --
??:
"user-zh"
??udfudfjar??
-- --
??:
??udfudfjar??
-- --
??:
"
我试了一下是可以运行的，可以发一下报错吗？
On Mon, Oct 18, 2021 at 6:44 PM xuzh wrote:
> from pyflink.table import ScalarFunction, EnvironmentSettings,
> TableEnvironment, DataTypes
> from pyflink.table.udf import udf
> from pyflink.table.expressions import call, row
>
>
> class HashCode(ScalarFunction):
> def
from pyflink.table import ScalarFunction, EnvironmentSettings,
TableEnvironment, DataTypes
from pyflink.table.udf import udf
from pyflink.table.expressions import call, row
class HashCode(ScalarFunction):
def __init__(self):
self.factor = 12
def eval(self, s):
return has
