Skip to content

Commit

Permalink
formate code
Browse files Browse the repository at this point in the history
  • Loading branch information
gaoyan1998 committed Dec 5, 2023
1 parent 79988b5 commit 3eb9426
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public static void main(String[] args) throws Exception {
Submitter.submit(appConfig);
} catch (Exception e) {
log.error("exectue app failed : ", e);
}finally {
} finally {
log.info("Start Monitor Job");
FlinkAppUtil.monitorFlinkTask(appConfig.getTaskId());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public static void main(String[] args) throws Exception {
Submitter.submit(appConfig);
} catch (Exception e) {
log.error("exectue app failed : ", e);
}finally {
} finally {
log.info("Start Monitor Job");
FlinkAppUtil.monitorFlinkTask(appConfig.getTaskId());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public static void main(String[] args) throws Exception {
Submitter.submit(appConfig);
} catch (Exception e) {
log.error("exectue app failed : ", e);
}finally {
} finally {
log.info("Start Monitor Job");
FlinkAppUtil.monitorFlinkTask(appConfig.getTaskId());
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public static void main(String[] args) throws Exception {
Submitter.submit(appConfig);
} catch (Exception e) {
log.error("exectue app failed : ", e);
}finally {
} finally {
log.info("Start Monitor Job");
FlinkAppUtil.monitorFlinkTask(appConfig.getTaskId());
}
Expand Down

0 comments on commit 3eb9426

Please sign in to comment.