flink 1,10 1,12 diferencia
Porque en Flink 1.10, el desarrollo de tareas actual no es lo suficientemente fácil de usar y requiere mucho código, lo que también hará que Flink SQL sea largo.
El conector SQL de Flink 1.12 es compatible con el conector Kafka Upsert, que también es nuestra demanda empresarial interna de una plataforma en tiempo real.
Beneficios: es conveniente para los usuarios desarrollar tareas en tiempo real que necesitan obtener los registros más recientes de Kafka, como este binlog->;Kafka, y luego los usuarios agregan operaciones. Existen muchos escenarios de este tipo que pueden mejorar la eficiencia del desarrollo laboral en tiempo real. Al mismo tiempo, 1.12 está optimizado y el rendimiento será mejor que el rendimiento puro de last_value.
La capacidad del nivel de producción de las operaciones de hilo de Flink en k8 es:
Todas las operaciones de Flinkjar han sido del tamaño de k8. Las operaciones de Flink SQL todavía se ejecutan en Yarn porque se encuentran en las primeras etapas. popularidad Para permitir el cálculo en tiempo real de todos los tamaños k8 de Flink Jar.
Por lo tanto, nuestras operaciones de Flink SQL también deben migrarse a K8. En la actualidad, Flink 1.12 ha satisfecho las funciones de Flink k8s a nivel de producción, por lo que Flink SQL K8s se cambia para utilizar directamente las capacidades de On k8s de la comunidad.
Riesgo: aunque no hay problemas para comunicarse con las personas de la comunidad, POC primero debe verificar las funciones específicas de Flink 1.12 en k8. Las capacidades de Flink en k8 en la comunidad pueden ser aceptables. .
Puede restringir el uso de algunas funciones de k8s por nuestra parte, como el uso de hostpath volome e Ingress. En este caso, puede que sea necesario cambiar el código fuente subyacente para obtener soporte rápido (la comunidad se ha puesto en contacto con JIRA).