Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Al utilizar el flujo RETRACT en Flink, el mensaje de actualización se finaliza en dos etapas, mientras que al utilizar el flujo UPSERT, se finaliza en una etapa, lo cual es más eficiente. Sin embargo, según esta página, no se permite el flujo UPSERT al convertir una tabla dinámica a . . . Read more
Tengo un flujo de datos en Flink como sigue: Origen -> Operador -> DiscardingSink ¿Hay alguna diferencia entre esto y uno que no tiene Sink? Origen -> Operador -> De mis pruebas parece que se ejecuta igual, aunque en el primer caso veo que el operador y el sink están . . . Read more
Estoy intentando conectar Kafka a Flink y ejecutarlo a través de sql-client.sh. Sin embargo, sin importar lo que haga con .yaml y las bibliotecas, sigo recibiendo el siguiente error: Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue. at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201) at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161) Caused . . . Read more
Fondo: He estado intentando configurar BATCH + STREAMING en la misma aplicación de Flink que se despliega en tiempo de ejecución de Kinesis Analytics. La parte de STREAMING funciona bien, pero tengo problemas para agregar soporte para BATCH. https://stackoverflow.com/questions/69795679/flink-handling-keyed-streams-with-data-older-than-application-watermark https://stackoverflow.com/questions/70137863/apache-flink-batch-mode-failing-for-datastream-apis-with-exception-illegalst La lógica es algo así como esto: streamExecutionEnvironment.setRuntimeMode(RuntimeExecutionMode.BATCH); streamExecutionEnvironment.fromSource(FileSource.forRecordStreamFormat(new TextLineFormat(), . . . Read more
Soy un traductor de IT que traduce documentos. Traduzca lo siguiente al español. No traduzca el código y la salida en markdown. Soy un principiante en el marco de pyflink y me gustaría saber si es posible con él mi caso de uso … Necesito crear ventanas de desplazamiento y . . . Read more