云服务器内容精选

华为云首页用户手册

调测Flink应用

MAPREDUCE服务 MRS-查看Flink应用运行结果:操作步骤

操作步骤查看Flink应用运行结果数据。当用户查看执行结果时，需要在Flink的web页面上查看Task Manager的Stdout日志。当执行结果输出到文件或者其他由Flink应用程序指定途径，您可以通过指定文件或其他途径获取到运行结果数据。以下用Checkpoint、Pipeline和配置表与流JOIN为例：查看Checkpoint结果和文件结果在flink的“taskmanager.out”文件中，用户可以通过Flink的WebUI查看“task manager”标签下的out按钮查看。有两种方式查看Checkpoint文件。若将checkpoint的快照信息保存到HDFS，则通过执行hdfs dfs -ls hdfs://hacluster/flink-checkpoint/命令查看。若将checkpoint的快照信息保存到本地文件，则可直接登录到各个节点查看。查看Stream SQL Join结果结果在flink的“taskmanager.out”文件中，用户可以通过Flink的WebUI查看“task manager”标签下的out按钮查看。使用Flink Web页面查看Flink应用程序运行情况 Flink Web页面主要包括了Overview、Running Jobs、Completed Jobs、Task Managers、Job Manager和Logout等部分。在YARN的Web UI界面，查找到对应的Flink应用程序。单击应用信息的最后一列“ApplicationMaster”，即可进入Flink Web页面。查看程序执行的打印结果：找到对应的Task Manager，查看对应的Stdout标签日志信息。查看Flink日志获取应用运行情况有两种方式获取Flink日志，分别为通过Flink Web页面或者Yarn的日志 Flink Web页面可以查看Task Managers、Job Manager部分的日志。 Yarn页面主要包括了Job Manager日志以及GC日志等。页面入口：在YARN的Web UI界面，查找到对应的Flink应用程序。单击应用信息的第一列ID，然后选择Logs列单击进去即可打开。

MAPREDUCE服务 MRS 调测Flink应用
MAPREDUCE服务 MRS-调测Flink SpringBoot样例程序:SpringBoot样例工程的命令行形式运行

SpringBoot样例工程的命令行形式运行在IDEA界面使用Maven执行install。当输出“BUILD SUC CES S”，表示编译成功，如下图所示。编译成功后将会在样例工程的target下生成含有“flink-dws-sink-example-1.0.0-SNAPSHOT”字段的Jar包。在Linux上进入客户端安装目录，如“/opt/client/Flink/flink/conf”作为作为运行目录，将1中生成的“target”目录下包名中含有“flink-dws-sink-example-1.0.0-SNAPSHOT”字段的Jar包放进该路径。执行以下命令创建yarn-session。 yarn-session.sh -t ssl/ -nm "session-spring11" -d 执行以下命令启动SpringBoot服务。执行 GaussDB （DWS）样例 flink run flink-dws-sink-example.jar

MAPREDUCE服务 MRS 调测Flink应用