es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

IntelliJ no puede encontrar la utilidad Flink Test Harness.

Estoy tratando de utilizar OneInputStreamOperatorTestHarness de Apache Flink (org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness), pero IntelliJ no puede resolver el símbolo.

He seguido la documentación oficial, este blog oficial en el sitio web de Flink y esta pregunta en Stack Overflow.

Tags:  , , ,

Answer

  1. Avatar for davy.ai

    Si estás utilizando IntelliJ IDEA y encuentras un error donde no se puede resolver el símbolo OneInputStreamOperatorTestHarness de Apache Flink, hay algunos pasos que puedes seguir para intentar resolver el problema.

    En primer lugar, asegúrate de tener las dependencias necesarias de Flink agregadas a tu proyecto. Puedes hacer esto añadiendo lo siguiente a tu archivo pom.xml:

    <dependency>
        <groupid>org.apache.flink</groupid>
        <artifactid>flink-streaming-java_2.11</artifactid>
        <version>${flink.version}</version>
        <scope>test</scope>
    </dependency>
    

    Como alternativa, si estás utilizando Gradle, agrega lo siguiente a tu archivo build.gradle:

    dependencies {
        testImplementation 'org.apache.flink:flink-streaming-java_2.11:${flink.version}'
    }
    

    Asegúrate de reemplazar ${flink.version} con el número de versión correspondiente.

    Si has agregado las dependencias y aún encuentras el error, intenta invalidar la caché de IntelliJ IDEA y reiniciar el IDE. Puedes hacer esto yendo a File > Invalidate Caches / Restart.

    Si el problema persiste, verifica que hayas importado correctamente las clases necesarias. Deberías tener las siguientes importaciones al comienzo de tu clase de prueba:

    import org.apache.flink.streaming.api.datastream.DataStream;
    import org.apache.flink.streaming.api.functions.ProcessFunction;
    import org.apache.flink.streaming.api.functions.source.SourceFunction;
    import org.apache.flink.streaming.api.operators.ProcessOperator;
    import org.apache.flink.streaming.api.operators.StreamOperator;
    import org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness;
    

    Si aún no puedes resolver el símbolo, asegúrate de estar utilizando una versión compatible de Flink con la clase OneInputStreamOperatorTestHarness. Esta clase se introdujo en Flink 1.3.0, por lo que si estás utilizando una versión anterior de Flink, es posible que encuentres problemas.

    Si ninguno de estos pasos resuelve el problema, es posible que necesites pedir ayuda en la lista de correo o en los foros de Flink.

Comments are closed.