企业官网建设流程全解析

网站模板源码,外国网站打开很慢,做资源网站怎么不封,住房城乡建设部举报网站1. JOB 语句能做什么#xff1f; 官方定位很明确#xff1a; Job statements are used for management of Flink jobs. #xff08;JOB 语句用于 Flink 作业管理。#xff09; 也就是说#xff0c;你不需要跑到 Web UI 或 REST API 才能看作业/停作业#xff0c;在 SQL …1. JOB 语句能做什么官方定位很明确Job statements are used for management of Flink jobs.JOB 语句用于 Flink 作业管理。也就是说你不需要跑到 Web UI 或 REST API 才能看作业/停作业在 SQL CLI/Gateway 里也可以“就地管理”。2. SQL CLI 实战三连操作SHOW → DESCRIBE → STOP2.1 SHOW JOBS列出集群作业FlinkSQLSHOWJOBS;------------------------------------------------------------------------------|job id|job name|status|starttime|------------------------------------------------------------------------------|228d70913eab60dda85c5e7f78b5782c|myjob|RUNNING|2023-02-11T05:03:51.523|------------------------------------------------------------------------------输出一般包含job id / job name / status / start time。2.2 DESCRIBE JOB查看某个 job 的信息FlinkSQLDESCRIBEJOB228d70913eab60dda85c5e7f78b5782c;------------------------------------------------------------------------------|job id|job name|status|starttime|------------------------------------------------------------------------------|228d70913eab60dda85c5e7f78b5782c|myjob|RUNNING|2023-02-11T05:03:51.523|------------------------------------------------------------------------------当你从SHOW JOBS拿到 job_id 后下一步通常就是DESCRIBE JOB确认目标是不是你要操作的那个。2.3 STOP JOB停止作业带 SAVEPOINT 示例先设置 savepoint 目录也可以由集群配置提供FlinkSQLSETexecution.checkpointing.savepoint-dirfile:/tmp/;[INFO]Executestatement succeeded.然后停止作业并触发 savepointFlinkSQLSTOP JOB228d70913eab60dda85c5e7f78b5782cWITHSAVEPOINT;-----------------------------------------|savepointpath|-----------------------------------------|file:/tmp/savepoint-3addd4-0b224d9311e6|-----------------------------------------执行后会返回savepoint path这通常就是你后续“从 savepoint 恢复”的关键凭证路径要保存好。3. 语法与关键点官方语义梳理3.1 SHOW JOBSSHOWJOBS作用显示 Flink 集群中的作业。限制只在 SQL CLI 或 SQL Gateway 可用。3.2 DESCRIBE / DESC JOB{DESCRIBE|DESC} JOBjob_id作用显示指定 job_id 的作业信息。限制只在 SQL CLI 或 SQL Gateway 可用。3.3 STOP JOB停止作业可选 SAVEPOINT、可选 DRAINSTOP JOBjob_id[WITHSAVEPOINT][WITHDRAIN]WITH SAVEPOINT停止前做一次 Savepoint含义在停止作业前执行一次 savepointsavepoint 目录配置来源可在集群配置里设置execution.checkpointing.savepoint-dir也可通过SET 语句设置并且SET 的优先级更高也就是你在 SQL CLI 里SET了 savepoint-dir就会覆盖集群默认值。WITH DRAIN在最后一次 checkpoint barrier 前把 watermark 提到最大官方解释是Increase the watermark to the maximum value before the last checkpoint barrier. Use it when you want to terminate the job permanently.直白理解不展开超出原文的机制细节WITH DRAIN是一种“更倾向永久终止”的停止方式它会在停止前把 watermark 推到最大值在最后一次 checkpoint barrier 之前注意STOP JOB同样只在 SQL CLI 或 SQL Gateway 可用。4. 最佳实践生产里怎么用更稳4.1 停作业前先确认目标SHOW → DESCRIBE不要直接 copy job_id 就 stop建议固定流程1SHOW JOBS;2DESCRIBE JOB job_id;确认名称、状态、启动时间等这样能显著减少“停错作业”的概率。4.2 需要可恢复优先用 WITH SAVEPOINT很多生产场景停作业的真实诉求是可恢复、可迁移、可升级。这时优先SETexecution.checkpointing.savepoint-dirfile:/tmp/;STOP JOBjob_idWITHSAVEPOINT;并保存返回的savepoint path。4.3 临时变更 savepoint-dir用 SET 覆盖集群默认如果你只是临时想把 savepoint 输出到某个位置不想改集群配置直接在会话里SETexecution.checkpointing.savepoint-dirfile:/tmp/;官方明确SET 的优先级更高。5. 常见坑点提醒限制坑SHOW JOBS / DESCRIBE JOB / STOP JOB只在SQL CLI / SQL Gateway可用不要在普通 TableEnvironment 的 Java 程序里指望它们能跑通。路径坑开启WITH SAVEPOINT时别忘了 savepoint-dir 的来源与优先级SET cluster config。语义坑WITH DRAIN是用于“永久终止”的场景官方这么建议不要把它当成普通 stop 的默认选项随手用。6. 总结Flink SQL 的 JOB 管理语句很少但非常实用SHOW JOBS列出集群作业DESCRIBE JOB查看指定作业STOP JOB停止作业WITH SAVEPOINT停止前做 savepoint路径由execution.checkpointing.savepoint-dir决定SET 优先WITH DRAIN提升 watermark 到最大值用于永久终止场景