实时计算 Flink版操作报错合集之遇到报错ORA-01435用户不存在的问题，该如何解决

问题一：FLINK CDC 2.4.0 earliest-offset模式报这个错怎么做？

FLINK CDC 2.4.0 earliest-offset模式报这个错怎么做？

参考答案：

不要用2.4.0这个包，用2.4.2

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/587217

问题二：咨询个Flink CDC问题，Oracle 19C，有什么解决方案可以参考吗?

咨询个Flink CDC问题，Oracle 19C，遇到 flink cdc 报错 ORA-01435用户不存在,这个遇到过没，有什么解决方案可以参考吗?

参考答案：

遇到Flink CDC报错ORA-01435用户不存在的问题，可以尝试以下解决方案：

1. 检查数据库连接配置：确保Flink CDC正确连接到Oracle数据库，并且提供了正确的用户名、密码和其他必要的凭据。确认使用的用户名具有足够的权限来执行所需的操作。
   
2. 检查Oracle用户配置：在Oracle数据库中，确保所使用的用户名存在，并且具有适当的权限。可以使用以下SQL语句来验证用户是否存在：

SELECT username FROM dba_users WHERE username = '<your_username>';

1. 检查Oracle安全策略：如果使用了Oracle的安全策略，例如使用操作系统认证或透明数据加密（TDE），请确保已正确配置和启用这些策略。可能需要与数据库管理员合作来解决这些问题。
   
2. 检查Flink CDC版本和依赖库：确保使用的Flink CDC版本与Oracle数据库驱动程序兼容。如果使用的是不兼容的版本或依赖库，可能会导致错误日志中出现ORA-01435错误。
   
3. 检查日志输出：查看Flink CDC的日志输出，查找与错误相关的详细信息。日志中可能包含有关错误的更多上下文信息，例如堆栈跟踪、错误代码等。
   
4. 检查网络连接：确保Flink CDC能够通过网络连接到Oracle数据库。可能存在网络配置问题或防火墙限制导致无法建立连接。
   

根据以上步骤进行排查和解决后，应该能够找到并解决Flink CDC报错ORA-01435用户不存在的问题。如果问题仍然存在，建议咨询数据库管理员或Flink社区获取更详细的支持和帮助。

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/587216

问题三：Flink在第一个Sink失败的情况下 导致 在switch 有遇到过嘛？

Flink在第一个Sink失败的情况下 导致 在switch source算子运行状态 从running变成 cancelling 失败

报错 是因为 ResultSet.close()方法阻塞住了， 然后超过 task.cancellation.timeout 设置的时间 taskmanager就宕机了 有大佬遇到过嘛？Source（Mysql ） -> filter -> Sink(Mysql)

-> filter -> SinkWARN org.apache.flink.runtime.taskmanager.Task [] - Task 'DataSource (PFFF7AF61-7336-EF96-F823-31CE49B07791) (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:

java.net.SocketInputStream.socketRead0(Native Method)

java.net.SocketInputStream.socketRead(SocketInputStream.java:116)

java.net.SocketInputStream.read(SocketInputStream.java:171)

java.net.SocketInputStream.read(SocketInputStream.java:141)

com.mysql.jdbc.util.ReadAheadInputStream.fill(ReadAheadInputStream.java:100)

com.mysql.jdbc.util.ReadAheadInputStream.readFromUnderlyingStreamIfNecessary(ReadAheadInputStream.java:143)

com.mysql.jdbc.util.ReadAheadInputStream.read(ReadAheadInputStream.java:173)

com.mysql.jdbc.MysqlIO.readFully(MysqlIO.java:2911)

com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3382)

com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3322)

com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3762)

com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:870)

com.mysql.jdbc.MysqlIO.nextRow(MysqlIO.java:1928)

com.mysql.jdbc.RowDataDynamic.nextRecord(RowDataDynamic.java:378)

com.mysql.jdbc.RowDataDynamic.next(RowDataDynamic.java:358)

com.mysql.jdbc.RowDataDynamic.close(RowDataDynamic.java:158)

com.mysql.jdbc.ResultSetImpl.realClose(ResultSetImpl.java:6703)

com.mysql.jdbc.ResultSetImpl.close(ResultSetImpl.java:848)

*.close(RDBInputFormat.java:433)

org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:207)

org.apache.flink.runtime.taskmanager.Task$$Lambda$671/731154499.run(Unknown Source)

org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)

org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)

org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)

org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)

java.lang.Thread.run(Thread.java:745)

参考答案：

这个问题可能是由于在第一个Sink失败后，Flink尝试关闭ResultSet时阻塞了。你可以尝试增加task.cancellation.timeout的值来解决这个问题

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/587272

问题四：flink1.18 Yarn Application 提交，有人遇见过？

flink1.18 Yarn Application 提交，有人遇见过？

参考答案：

这个问题可能是由于Flink在提交Yarn Application时，无法找到正确的入口类导致的。请检查以下几点：

1. 确保您的Flink程序包含一个名为org.apache.flink.runtime.entrypoint.clusterEntrypoint.ClusterEntryPoint的入口类。这个类是Flink程序的入口点，用于启动应用程序。
   
2. 如果您的程序使用了自定义的入口类，请确保它已经被正确地打包到JAR文件中，并且在Flink的配置文件中指定了正确的入口类。
   
3. 检查Flink的配置文件（例如flink-conf.yaml或flink-conf.properties），确保yarn.application-master和yarn.classpath等配置项正确设置。
   
4. 如果问题仍然存在，您可以尝试在Flink的配置文件中添加以下内容，以禁用自动检测入口类的功能：
   

yarn.application-master: yarn-cluster
yarn.classpath: true

然后重新启动Flink集群并尝试提交应用程序。

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/587265

问题五：Flink给每张mysql的表都配置了一个server-id的范围，请问这种问题怎么排查？

Flink给每张mysql的表都配置了一个server-id的范围，提交多个任务时，还是有一些任务失败，报错如图。请问这种问题怎么排查？

参考答案：

要排查Flink给每张MySQL表配置的server-id范围的问题，可以按照以下步骤进行：

1. 检查MySQL服务器的配置文件（通常是my.cnf或my.ini），确保每个表的server-id范围在配置文件中正确设置。例如：

[mysqld]
server-id=1
log_bin=mysql-bin
binlog-format=ROW
binlog_do_db=your_database_name

1. 确保Flink中的JDBC连接字符串包含正确的server-id。连接字符串应该类似于：

jdbc:mysql://localhost:3306/your_database_name?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=true&serverId=your_server_id

1. 检查Flink作业的配置文件（通常是flink-conf.yaml），确保每个表的server-id范围在配置文件中正确设置。例如：

table.sql-dialect: mysql
table.default-catalog: your_database_name
table.default-schema: your_table_schema
table.whitelist: your_table_name
table.blacklist: your_table_name
table.types.cache: false

1. 如果问题仍然存在，可以尝试在Flink中使用TableEnvironment的executeSql方法执行一条简单的SQL查询，以确认是否可以正常连接到MySQL数据库并获取数据。例如：

String url = "jdbc:mysql://localhost:3306/your_database_name?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=true&serverId=your_server_id";
String query = "SELECT * FROM your_table_name";
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
ResultSet resultSet = env.executeSql(query).fetch();
while (resultSet.next()) {
    // Process the result set here
}

通过以上步骤，你应该能够排查Flink给每张MySQL表配置的server-id范围的问题。如果问题仍然存在，请检查日志文件以获取更多详细信息，并确保所有相关组件和服务正常运行。

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/587260