Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Soy nuevo en el marco de transmisión de Flink y estoy tratando de entender los componentes y el flujo. Estoy tratando de ejecutar el ejemplo básico de conteo de palabras utilizando DataStream. Estoy tratando de ejecutar el código en mi IDE. El código se ejecuta sin problemas cuando alimento los . . . Read more
Tengo una tabla de flink, digamos CREATE TABLE source(id int, name string) with (…) y una tabla de destino, digamos CREATE TABLE destination(id int, unique_name string) with (…). El campo unique_name se calcula utilizando lógica empresarial en la función de proceso interna de flink. Por lo tanto, podemos asumir de . . . Read more
Estoy usando flink siddhi y estoy obteniendo un error de falta de memoria mientras proceso objetos grandes. En la secuencia de salida generada por siddhi cep tengo un objeto con más de 200 campos, y tengo algunos operadores después de eso para procesar este objeto. [versión de flink 1.7.2] Código: . . . Read more
Uso FileSink para escribir archivos parquet en S3. Desde la documentación https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/file_sink/ Para formatos codificados por lotes, realizamos un desplazamiento en cada punto de control y el usuario puede especificar condiciones adicionales basadas en el tamaño o el tiempo. No me queda claro cómo puedo establecer las condiciones basadas en . . . Read more
Estoy aprendiendo el marco de trabajo Flink y trabajando en un trabajo de transmisión que leerá datos de un archivo CSV y realizará algunas agregaciones utilizando la API DataStream. Los campos de datos incluyen ciudad, código de estado y valores de población. Los datos estarán claveados por el código de . . . Read more