I have a flink-SQL task. (enable savepoint)
I want change it , so I stop itsink and source add a cloumn in oracle tableand modify SQL in flinkwhen I commit it I get a errororg.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStra
metastore.HiveMetaStore: [pool-9-thread-97]: 88:
get_table : db=hivetest tbl=chinese_part"}
{"timestamp":"2021-08-05 15:31:56,895","msg":" INFO
org.apache.hadoop.hive.metastore.HiveMetaStore: [pool-9-thread-97]: 88:
get_table : db=hivetest tbl=chinese_part"}
{"timestamp":"2021-08-06 15:31:56,895","msg":" INFO
org.apache.hadoop.hive.metastore.HiveMetaStore: [pool-9-thread-97]: 88:
get_table : db=hivetest tbl=chinese_part"}
app aslo doesn't print
I don't know when does app to print
swith to jdbc I have the same problem
igyu
sql.foreach(s=>{
tableEnv.executeSql(s)
})
igyu
in my app pom.xml
org.apache.flink
flink-connector-kafka_2.11
1.13.1
provided
and I have copy flink-connector-kafka_2.11-1.13.1.jar to FLINK_HOME/lib/
but I also get a error
ClassNotFoundException: org.apache.kafka.clients.consumer.ConsumerRecord
so
How can fix it?
igyu
I use CDH 6.3.2
flink-1.12.3
I enabel kerberos
I want to use different user with different keytab,because I creat many queue
in YARN , different user use different queue.
igyu
I use CDH 6.3.2
flink-1.12.3
I enabel kerberos
I want to use different user with different keytab,because I creat many queue
in YARN , different user use different queue.
igyu
