Почему ошибка "Пакет org.apache.flink.api.common.eventtime не существует" ⇐ JAVA

[Anonymous]

Я собираю проект Java, который использует Maven для управления проектом.
Версия Java составляет 17.0.16 < /p>
Я включил следующую зависимость в раздел зависимости
(и.e.) < /p>

Код: Выделить всё

org.apache.flink
flink-core
1.20.0

Когда выполняется команда MVN Compile . Происходит следующая ошибка:

Код: Выделить всё

[ERROR] COMPILATION ERROR :
[INFO] -------------------------------------------------------------
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[3,45] package org.apache.flink.api.common.eventtime does not exist
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[4,49] package org.apache.flink.api.common.serialization does not exist
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[5,47] package org.apache.flink.connector.kafka.source does not exist
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[6,70] package org.apache.flink.connector.kafka.source.enumerator.initializer does not exist
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[7,45] package org.apache.flink.connector.kafka.sink does not exist
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[8,45] package org.apache.flink.connector.kafka.sink does not exist
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[9,49] package org.apache.flink.streaming.api.datastream does not exist
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[10,50] package org.apache.flink.streaming.api.environment does not exist
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[16,15] cannot find symbol
symbol:   class StreamExecutionEnvironment
location: class com.radar.bridge_kafka.KafkaStringCopier
< /code>
Первые 16 строк класса kafkastringcopier являются следующими: < /p>
package com.radar.bridge_kafka;

import org.apache.flink.api.common.eventtime.WatermarkStrategy;
import org.apache.flink.api.common.serialization.SimpleStringSchema;
import org.apache.flink.connector.kafka.source.KafkaSource;
import org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer;
import org.apache.flink.connector.kafka.sink.KafkaSink;
import org.apache.flink.connector.kafka.sink.KafkaRecordSerializationSchema;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class KafkaStringCopier {

public static void main(String[] args) throws Exception {
// Set up the execution environment
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
< /code>
Класс org.apache.flink.api.common.eventtime.watermarkStrategy включен в файл "Flink-core-1.20.0.jar". было: < /p>
[ERROR] /home/rdelarosa/flink/pry_flink/pry-flink-1_20-kafka/bridge_kafka/src/main/java/com/radar/bridge_kafka/KafkaStringCopier.java:[3,45] package org.apache.flink.api.common.eventtime does not exist

Я ожидаю, что эта ошибка не произойдет.

Подробнее здесь: https://stackoverflow.com/questions/797 ... t-exist-is