Flink Jar作业相关问题 Flink Jar作业是否支持上传配置文件,要如何操作? 自定义(JAR)作业支持上传配置文件。 1.将配置文件通过程序包管理上传到DLI; 2.在Flink jar作业的其他依赖文件参数中,选择创建的DLI程序包; 3.在代码中通过ClassName.class.getClassLoader().getResource("userData/fileName")加载该文件(其中,“fileName”为需要访问的文件名,“ClassName”为需要访问该文件的类名)。 Flink Jar 包冲突,导致提交失败 问题描述 用户Flink程序的依赖包与DLI Flink平台的内置依赖包冲突,导致提交失败。 解决方案 查看是否已包含DLI Flink运行平台中已经存在的包,如果存在,则需要将自己的Jar包删除。 Flink Jar作业访问DWS启动异常,提示客户端连接数太多错误 问题描述 提交Flink Jar作业访问DWS数据仓库服务时,提示启动失败,作业日志报如下错误信息。 FATAL: Already too many clients, active/nonactive/reserved: 5/508/3 原因分析 当前访问的DWS数据库连接已经超过了最大连接数。错误信息中,nonactive的个数表示空闲连接数,例如,nonactive为508,说明当前有大量的空闲连接。 解决方案 出现该问题时建议通过以下操作步骤解决。 1.登录DWS命令执行窗口,执行以下SQL命令,临时将所有nonactive的连接释放掉。 SELECT PGTERMINATEBACKEND(pid) from pgstatactivity WHERE state'idle'; 2.检查应用程序是否未主动释放连接,导致连接残留。建议优化代码,合理释放连接。 3.在GaussDB(DWS) 控制台设置会话闲置超时时长sessiontimeout,在闲置会话超过所设定的时间后服务端将主动关闭连接。 sessiontimeout默认值为600秒,设置为0表示关闭超时限制,一般不建议设置为0。 sessiontimeout设置方法如下: a.登录GaussDB(DWS) 管理控制台。 b.在左侧导航栏中,单击“集群管理”。 c.在集群列表中找到所需要的集群,单击集群名称,进入集群“基本信息”页面。 d.单击“参数修改”页签,修改参数“sessiontimeout”,然后单击“保存”。 e.在“修改预览”窗口,确认修改无误后,单击“保存”。 Flink Jar作业运行报错,报错信息为Authentication failed