duplicated block id: 1 size: 130 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala (442:605) - streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SqlCommandParser.scala (411:574) duplicated block id: 2 size: 45 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (99:168) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (99:168) duplicated block id: 3 size: 43 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts (201:246) - streampark-console/streampark-console-webapp/src/views/spark/app/utils/index.ts (149:194) duplicated block id: 4 size: 35 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/src/main/scala/org/apache/streampark/flink/core/TableContext.scala (50:104) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/src/main/scala/org/apache/streampark/flink/core/TableContext.scala (50:104) duplicated block id: 5 size: 34 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useApp.tsx (82:118) - streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkAction.tsx (85:121) duplicated block id: 6 size: 32 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/SparkYarnBuildPipeline.scala (82:117) - streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkYarnApplicationBuildPipeline.scala (79:114) duplicated block id: 7 size: 26 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/src/main/scala/org/apache/streampark/flink/connector/elasticsearch6/sink/ES6Sink.scala (111:151) - streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch7/src/main/scala/org/apache/streampark/flink/connector/elasticsearch7/sink/ES7Sink.scala (108:145) duplicated block id: 8 size: 22 cleaned lines of code in 7 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (39:69) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (35:65) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (38:68) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (39:69) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (48:79) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (35:65) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/src/main/scala/org/apache/streampark/flink/core/StreamTableContext.scala (49:80) duplicated block id: 9 size: 18 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts (63:82) - streampark-console/streampark-console-webapp/src/views/spark/app/utils/index.ts (56:75) duplicated block id: 10 size: 18 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/FlinkApplicationController.java (253:272) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/controller/SparkApplicationController.java (242:261) duplicated block id: 11 size: 16 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/src/main/scala/org/apache/streampark/flink/connector/elasticsearch5/internal/ESSinkFunction.scala (56:73) - streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/src/main/scala/org/apache/streampark/flink/connector/elasticsearch6/internal/ESSinkFunction.scala (55:72) duplicated block id: 12 size: 13 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/components/State.tsx (196:212) - streampark-console/streampark-console-webapp/src/views/spark/app/components/State.tsx (196:212) duplicated block id: 13 size: 14 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts (29:44) - streampark-console/streampark-console-webapp/src/views/spark/app/utils/index.ts (22:37) duplicated block id: 14 size: 14 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplicationConfig.java (131:146) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationConfig.java (79:94) duplicated block id: 15 size: 13 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala (94:108) - streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SqlCommandParser.scala (94:108) duplicated block id: 16 size: 13 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/src/main/scala/org/apache/streampark/flink/connector/elasticsearch6/sink/ES6Sink.scala (75:91) - streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch7/src/main/scala/org/apache/streampark/flink/connector/elasticsearch7/sink/ES7Sink.scala (76:90) duplicated block id: 17 size: 13 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useApp.tsx (43:57) - streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkAction.tsx (46:60) duplicated block id: 18 size: 12 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/src/main/scala/org/apache/streampark/flink/connector/elasticsearch5/util/ElasticsearchUtils.scala (26:39) - streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/src/main/scala/org/apache/streampark/flink/connector/elasticsearch6/util/ElasticsearchUtils.scala (26:39) duplicated block id: 19 size: 12 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java (241:256) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationManageServiceImpl.java (196:211) duplicated block id: 20 size: 10 cleaned lines of code in 5 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (51:62) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (51:62) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (51:62) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (51:62) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (51:62) duplicated block id: 21 size: 10 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala (137:148) - streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SqlCommandParser.scala (137:148) duplicated block id: 22 size: 10 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/SparkK8sApplicationBuildPipeline.scala (217:228) - streampark-flink/streampark-flink-packer/src/main/scala/org/apache/streampark/flink/packer/pipeline/impl/FlinkK8sApplicationBuildPipeline.scala (239:250) duplicated block id: 23 size: 10 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBuildPipelineServiceImpl.java (487:498) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java (645:656) duplicated block id: 24 size: 9 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts (84:94) - streampark-console/streampark-console-webapp/src/views/spark/app/utils/index.ts (77:87) duplicated block id: 25 size: 9 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/utils/index.ts (189:199) - streampark-console/streampark-console-webapp/src/views/spark/app/utils/index.ts (137:147) duplicated block id: 26 size: 8 cleaned lines of code in 5 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (29:38) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (29:38) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (29:38) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (29:38) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (29:38) duplicated block id: 27 size: 8 cleaned lines of code in 5 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (40:49) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (40:49) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (40:49) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (40:49) - streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/src/main/scala/org/apache/streampark/flink/core/FlinkClusterClient.scala (40:49) duplicated block id: 28 size: 8 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/scala/org/apache/streampark/flink/connector/hbase/internal/HBaseSourceFunction.scala (157:166) - streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/src/main/scala/org/apache/streampark/flink/connector/mongo/internal/MongoSourceFunction.scala (152:161) duplicated block id: 29 size: 8 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useApp.tsx (74:86) - streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkAction.tsx (77:89) duplicated block id: 30 size: 8 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationBuildPipelineServiceImpl.java (527:537) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationBuildPipelineServiceImpl.java (685:695) duplicated block id: 31 size: 8 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/FlinkAppHttpWatcher.java (214:223) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/watcher/SparkAppHttpWatcher.java (165:174) duplicated block id: 32 size: 7 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala (124:132) - streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SqlCommandParser.scala (124:132) duplicated block id: 33 size: 7 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/SqlCommandParser.scala (613:621) - streampark-spark/streampark-spark-core/src/main/scala/org/apache/streampark/spark/core/util/SqlCommandParser.scala (582:590) duplicated block id: 34 size: 7 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/components/State.tsx (96:106) - streampark-console/streampark-console-webapp/src/views/spark/app/components/State.tsx (96:106) duplicated block id: 35 size: 6 cleaned lines of code in 3 files: - streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkCheckpointWatcher.scala (53:60) - streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala (69:76) - streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkMetricsWatcher.scala (53:60) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/src/main/scala/org/apache/streampark/flink/connector/clickhouse/internal/ClickHouseSinkWriter.scala (82:89) - streampark-flink/streampark-flink-connector/streampark-flink-connector-http/src/main/scala/org/apache/streampark/flink/connector/http/internal/HttpSinkWriter.scala (71:78) duplicated block id: 37 size: 6 cleaned lines of code in 3 files: - streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/scala/org/apache/streampark/flink/connector/hbase/internal/HBaseSourceFunction.scala (168:176) - streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/scala/org/apache/streampark/flink/connector/jdbc/internal/JdbcSourceFunction.scala (135:142) - streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/src/main/scala/org/apache/streampark/flink/connector/mongo/internal/MongoSourceFunction.scala (163:171) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/FlinkClientEntrypoint.scala (38:45) - streampark-spark/streampark-spark-client/streampark-spark-client-core/src/main/scala/org/apache/streampark/spark/client/SparkClientEndpoint.scala (33:40) duplicated block id: 39 size: 6 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts (323:330) - streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkTableAction.ts (298:305) duplicated block id: 40 size: 6 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationActionServiceImpl.java (231:239) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/SparkApplicationActionServiceImpl.java (174:182) duplicated block id: 41 size: 6 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplication.java (498:505) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplication.java (397:404) duplicated block id: 42 size: 6 cleaned lines of code in 2 files: - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/FlinkApplicationBackup.java (57:64) - streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/SparkApplicationBackup.java (59:66) duplicated block id: 43 size: 7 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts (283:291) - streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkTableAction.ts (259:267) duplicated block id: 44 size: 9 cleaned lines of code in 2 files: - streampark-console/streampark-console-webapp/src/views/flink/app/hooks/useAppTableAction.ts (294:304) - streampark-console/streampark-console-webapp/src/views/spark/app/hooks/useSparkTableAction.ts (270:280)