The error report is inexplicable, but in fact, the dependency package imported by idea has multiple options, and it is wrong.
The required dependencies are as follows:
import org.apache.flink.api.common.serialization.SimpleStringSchema; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer; import java.util.Collections; import java.util.List; import java.util.Properties;
Read More:
- [Solved] Flink jdbc Error: Access Denied for user ‘root‘@‘10.0.0.x‘ (using password: YES)
- [Solved] Flink Hadoop is not in the classpath/dependencies
- [Solved] Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.typeinfo.TypeInformation
- [Solved] java.lang.noclassdeffounderror when idea runs Flink: org/Apache/flick/API/common/executionconfig
- [Solved] flink Write Files Error: lang.NoClassDefFoundError: org/apache/flink/api/common/typeinfo/TypeInformation
- kafka Error: Error while fetching metadata with correlation
- [Solved] org.apache.spark.SparkException: Kryo serialization failed: Buffer overflow
- How to Solve Springmvc Error: org.springframework.web.servlet.DispatcherServlet
- [Solved] Kafka2.3.0 Error: Timeout of 60000ms expired before the position for partition could be determined
- [Solved] Kafka Error: kafka.common.InconsistentClusterIdException…
- Tencent cloud container easyexcel export excel error NoClassDefFoundError: could not initialize class sun.awt.x11fontmanager
- Huawei kafka Authentication error: Server not found in Kerberos database (7) – LOOKING_UP_SERVER
- [Solved] Hadoop error java.lang.nosuchmethoderror
- Zeppelin reported an error. The JDK version is low
- Apache Altas Compile Error: [ERROR] Failed to execute goal on project atlas-testtools: Could not resolve
- [Sp;ved] Failed to start component [StandardEngine[Catalina].StandardHost[localhost].StandardContext[/ssm]
- Kafka Error while fetching metadata with correlation id 1 : {alarmHis=LEADER_NOT_AVAILABLE}
- [Solved] Hive tez due to: ROOT_INPUT_INIT_FAILURE java.lang.IllegalArgumentException: Illegal Capacity: -38297
- Kafka executes the script to create topic error: error org apache. kafka. common. errors. InvalidReplicationFactorException: Replicati
- [Solved] ERROR RocketmqCommon-Failed to obtain the host name