Tag: APACHE-FLINK
Estoy leyendo un archivo CSV utilizando Apache Flink y luego transformo los registros en una tabla desde la cual ejecuto una consulta SQL e imprimo los resultados en stdout. Código (simplificado): StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(1); env.setRuntimeMode(RuntimeExecutionMode.BATCH); rowDataStreamSource = env.readFile(…).disableChaining(); final StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env); final Table table = tableEnv.fromChangelogStream(rowDataStreamSource, ordersSchema, . . . Read more
Intenté instalar apache-flink 1.11.2 en Mac MacOs Big Sur 11.6, java 1.8.0_311 y recibí este error: Advertencia: ¡Llamar a bottle :unneeded está obsoleto! No hay un reemplazo. Advertencia: ¡Llamar a bottle :unneeded está obsoleto! No hay un reemplazo. Error: apache-flink: Dependencia especial no compatible :java Cualquier sugerencia será apreciada. Por . . . Read more
¿Cómo se convierte un DateTime con la TZ en un Timestamp(3) en Flink SQL v1.13? TO_TIMESTAMP(‘2021-12-16T20:29:37Z’, ‘yyyy-MM-dd HH:mm:ss’) //retorna NULL TO_TIMESTAMP(‘2021-12-16 20:29:37’, ‘yyyy-MM-dd HH:mm:ss’) //retorna 2021-12-16T20:29:37 TO_TIMESTAMP(‘2021-12-16T20:29:37’, ‘yyyy-MM-dd HH:mm:ss’) //retorna NULL, lo cual es absurdo porque este fue el resultado del segundo ejemplo No acepta la T y Z, sin . . . Read more
Puedo conectarme correctamente a un clúster de Kafka seguro con SSL utilizando las siguientes propiedades del cliente: security.protocol=SSL ssl.truststore.type=PKCS12 ssl.truststore.location=ca.p12 ssl.truststore.password=<redactado> ssl.keystore.type=PKCS12 ssl.keystore.location=user.p12 ssl.keystore.password=<redactado> Sin embargo, estoy desarrollando una aplicación Java que se ejecuta en un entorno en la nube gestionado, donde no tengo acceso al sistema de archivos. Por . . . Read more
Estoy implementando un clúster de sesión de flink (versión: 1.14.0) con alta disponibilidad en Kubernetes. Instalo el clúster utilizando Helm. Cuando Helm se desinstala, el JM (JobManager) y TM (TaskManager) se eliminan, pero los config-maps no se eliminan. NOMBRE DATOS EDAD wcm-aggregation-cluster-dispatcher-leader 2 2d5h wcm-aggregation-cluster-resourcemanager-leader 2 2d5h wcm-aggregation-cluster-restserver-leader 2 2d5h . . . Read more