Flink任务报错记录

亦凉 2021-09-25 14:22 1460阅读 0赞

### 1、报错信息如下 ###

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Zero-length character strings have no serializable string representation.  
 at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:302)  
 at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198)![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA5pyq56uf_size_134_color_FFFFFF_t_70_g_se_x_16][]

sql中的字段类型和ddl中的字段类型没对上，或者字段名称，个数没对上

### 2、时间转为unix时间 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA5pyq56uf_size_38_color_FFFFFF_t_70_g_se_x_16][]

转完之后的类型是BIGINT

### 3、经纬度同步到es ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA5pyq56uf_size_21_color_FFFFFF_t_70_g_se_x_16][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA5pyq56uf_size_119_color_FFFFFF_t_70_g_se_x_16][]

报错是经度和维度搞反了，正确如下：

concat(wd,',',jd) as location

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA5pyq56uf_size_134_color_FFFFFF_t_70_g_se_x_16]: /images/20210923/c55db753ba4b465db66c1bf45a740cfb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA5pyq56uf_size_38_color_FFFFFF_t_70_g_se_x_16]: /images/20210923/75b2be6cf2b84135bafe44ef9d70511b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA5pyq56uf_size_21_color_FFFFFF_t_70_g_se_x_16]: /images/20210923/d4b1011eaadd45f5a23db583890ebfbd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA5pyq56uf_size_119_color_FFFFFF_t_70_g_se_x_16]: /images/20210923/c8a1ecf3ea4a4dbd8d377fe9b0b5effa.png

发表评论取消回复

表情：

评论列表（有 0 条评论，1460人围观）

还没有评论，来说两句吧...

相关阅读

相关 flink测试redis sink报错

具体报错根据报错定位到一个错误栈:Caused by: redis.clients.jedis.exceptions.JedisConnectionException: ...

- 日理万妓/ 2024年04月22日 06:52/ 0 赞/ 6 阅读

相关 Flink 报错

错信息1： Error:(20, 36) could not find implicit value for evidence parameter of typ...

￡神魔★判官ぃ/ 2024年04月20日 09:12/ 0 赞/ 146 阅读

相关记一次TopN 引起的Flink任务报错--转载

起因最近临近双十一，你们也知道，电商类公司到双十一的时候有多忙。压测、稳定性、实时大屏，一堆事情要在双十一之前完成。加上我们最近在做数据平台相关的事情，简直忙到爆炸。就

喜欢ヅ旅行/ 2022年12月18日 14:55/ 0 赞/ 228 阅读

相关 Flink 提交任务报错: NoClassDefFoundError: javax/ws/rs/ext/MessageBodyReader

一. 报错信息: [yarn@master01 flink-1.12.0]$ flink run -t yarn-per-job -c org.apache.f

本是古典何须时尚/ 2022年11月15日 11:17/ 0 赞/ 526 阅读

相关 Flink报错记录

[20210910 10:16:40.107] [DEBUG] [main] [StreamGraph.java:391][addOperator] Vertex: 2

矫情吗；*/ 2022年09月11日 00:24/ 0 赞/ 252 阅读

相关 Flink 任务报错:flink FileNotFoundException: JAR file does not exist: -yn

如图： ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3U

￡神魔★判官ぃ/ 2022年08月31日 15:12/ 0 赞/ 110 阅读

相关 JavaWeb 报错记录

一.Could not autowire field org.springframework.beans.factory.BeanCreationException: E

古城微笑少年丶/ 2022年04月18日 05:39/ 0 赞/ 420 阅读

相关 Flink 广播变量 asScala报错

如下图： ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV

蔚落/ 2022年04月13日 04:56/ 0 赞/ 206 阅读

相关 Flink 报错

报错信息1： Error:(20, 36) could not find implicit value for evidence parameter of type

水深无声/ 2021年12月01日 18:36/ 0 赞/ 304 阅读

相关 Flink任务报错记录

1、报错信息如下 org.apache.flink.client.program.ProgramInvocationException: The main method

亦凉/ 2021年09月25日 14:22/ 0 赞/ 1461 阅读