搞定了 def dfs(x:Int):Int= 改成 def dfs(x:Int) 不写'='号就行了……没想到原来方法是可以不写等号的:sweat:

@犀牛 为啥突然在这里艾特我了，一脸懵逼~

发现CDH里没有flink，捣鼓了半天想自己编译个flink1.12版的集成进去，怎么也搞不定，最后用了1.9的：
链接：https://pan.baidu.com/s/1sQWNyXrK9K5XB1pDKrdvnw
提取码：i1gj

各台服务器的内存和磁盘都什么配置的？以前尝试装过但因为硬件配置不够一直失败

11111

@青牛 哦~

@青牛 往哪传？

localhost换成主机名或者地址就好了。

@苏牛 等待时间我改成了wait_timeout=388000 ，重启MySQL之后还是不行~

我换了讲义里写的继承UDF的原始版的就可以用了，但还是搞不懂继承GenericUDF的为啥不行

select f1(ip) from nginx_log_avro1;
-chgrp: 'DESKTOP-9K6C5LV\??' does not match expected pattern for group
Usage: hadoop fs [generic options] -chgrp [-R] GROUP PATH...
OK
c0
美国
河南省郑州市
河南省郑州市
河南省郑州市
河南省郑州市