org.apache.flink.shaded.curator.org.apache.curator.utils.ZKPaths.deleteChildren()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 13:01:37 38 4

@Override
public void shutdown(JobStatus jobStatus) throws Exception {
  if (jobStatus.isGloballyTerminalState()) {
    LOG.info("Shutting down");
    for (CompletedCheckpoint checkpoint : completedCheckpoints) {
      try {
        removeShutdown(checkpoint, jobStatus);
      } catch (Exception e) {
        LOG.error("Failed to discard checkpoint.", e);
      }
    }
    completedCheckpoints.clear();
    String path = "/" + client.getNamespace();
    LOG.info("Removing {} from ZooKeeper", path);
    ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, true);
  } else {
    LOG.info("Suspending");
    // Clear the local handles, but don't remove any state
    completedCheckpoints.clear();
    // Release the state handle locks in ZooKeeper such that they can be deleted
    checkpointsInZooKeeper.releaseAll();
  }
}

@Override
public void shutdown(JobStatus jobStatus) throws Exception {
  if (jobStatus.isGloballyTerminalState()) {
    LOG.info("Shutting down");
    for (CompletedCheckpoint checkpoint : completedCheckpoints) {
      tryRemoveCompletedCheckpoint(
        checkpoint,
        completedCheckpoint -> completedCheckpoint.discardOnShutdown(jobStatus));
    }
    completedCheckpoints.clear();
    String path = "/" + client.getNamespace();
    LOG.info("Removing {} from ZooKeeper", path);
    ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, true);
  } else {
    LOG.info("Suspending");
    // Clear the local handles, but don't remove any state
    completedCheckpoints.clear();
    // Release the state handle locks in ZooKeeper such that they can be deleted
    checkpointsInZooKeeper.releaseAll();
  }
}

@Override
public void shutdown(JobStatus jobStatus) throws Exception {
  if (jobStatus.isGloballyTerminalState()) {
    LOG.info("Shutting down");
    for (CompletedCheckpoint checkpoint : completedCheckpoints) {
      tryRemoveCompletedCheckpoint(
        checkpoint,
        completedCheckpoint -> completedCheckpoint.discardOnShutdown(jobStatus));
    }
    completedCheckpoints.clear();
    String path = "/" + client.getNamespace();
    LOG.info("Removing {} from ZooKeeper", path);
    ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, true);
  } else {
    LOG.info("Suspending");
    // Clear the local handles, but don't remove any state
    completedCheckpoints.clear();
    // Release the state handle locks in ZooKeeper such that they can be deleted
    checkpointsInZooKeeper.releaseAll();
  }
}

38 4 0

• android - 什么是 autovalue.shaded 或者什么是 shaded jar？

  我正在寻找一种方法来解析字符串以获取 int，然后偶然发现: NumberUtils.toInt("blah",99); 我将它输入到我的 IDE 中，它会自动为我导入它: import autova

• C++ OpenGL : Ray Trace Shading Isn't Properly Shading

  我是一名 CS 学生，在我们的期末考试中，我们被告知要通过光线追踪在多个球体上构建反射。这几乎就是我们得到的指导，除了完成后的外观图片。所以我需要球体，它们是反射(使用光线追踪)映射到它们上的，并带有

• java - 如何跳过 maven antrun copy/shade :shade goal dynamically?

  我正在使用 maven 来配置由多个小型服务组成的应用程序。大多数用 java 开发的服务共享相同的 maven 配置，如在相同的构建生命周期中，一些共享资源(如 spring AMQP)。 所以我在

• java - 将 HbaseTestingUtility 与 hbase-shaded-server 和 hbase-shaded-client 一起使用

  我正在尝试使用 HBaseTestingUtility 1.2 与 hbase-shaded-client & hbase-shaded-server .它向我抛出了以下异常。谁能告诉我如何避免这种情

• java - maven-shade-plugin 报告 : Error creating shaded jar: . ..target/classes(是一个目录)

  当使用 m2eclipse 工具为为 Maven Shade Plugin 配置的项目在 eclipse 中运行 Maven 构建时，构建失败并显示以下错误消息: 无法执行目标 org.apache.

• maven-shade-plugin - 在类 org.apache.maven.plugins.shade.resource.ManifestResourceTransformer 中找不到 'resource'

  我直接从 apache maven 文档中复制了 maven shade 插件的配置 https://maven.apache.org/plugins/maven-shade-plugin/examp

• java - maven-shade-plugin 错误 : Cannot find setter, 加法器或 org.apache.maven.plugins.shade.resource.ManifestResourceTransformer 中的字段 'resource'

  我试图从 Spring Boot 运行 Hello World 示例。当我在模块上运行“mvn package”时，出现以下错误:- [ERROR] Failed to execute goal or

• java - 执行 org.apache.maven.plugins :maven-shade-plugin:1. 3.1 :shade: java. lang.AbstractMethodError: null 时遇到 API 不兼容

  在尝试构建旧版本的 Apache CXF 2.2.2 时，我一直收到 ma​​ven-shade-plugin 使用的 XmlAppendingTransformer 产生的错误:无法连接以获取 ht

• Maven Shade 插件没有附加阴影神器

  我正在尝试使用 maven-shade-plugin 来区分 Java 6 和 Java 7 Artifact 。我的理解来自this link就是原来的神器会被阴影的神器代替 [INFO] Repl

• Maven shade-plugin重定位不更新资源文件中的条目

  我正在尝试遮阳 aws-java-sdk为了按照提到的建议解决库冲突 here .但我看到 maven-shade-plugin ，资源文件(文本)中的条目没有得到更新。例如 request.hand

• c# - 如何用另一组替换一组颜色 'shades'

  我正在寻找一个“神奇”的功能，它可以拍摄图像并返回副本，但将一组色调替换为另一组色调。 例如我有一张红色鱼的照片:它有各种灰度和黑色和白色，但本质上是各种深浅不一的红色。我想将它传递给这个“魔术”函数

• maven插件之maven-shade-plugin，解决同包同名class共存问题的神器

  开心一刻 有一天螃蟹出门，不小心撞倒了泥鳅泥鳅很生气地说：你是不是瞎啊！螃蟹说：不是啊，我是螃蟹 概述 maven-shade-plugin 官网已经介绍的很详细了，我给大家简单翻译一

• maven插件之maven-shade-plugin，解决同包同名class共存问题的神器

  开心一刻 有一天螃蟹出门，不小心撞倒了泥鳅泥鳅很生气地说：你是不是瞎啊！螃蟹说：不是啊，我是螃蟹 概述 maven-shade-plugin 官网已经介绍的很详细了，我给大家简单翻译一

• java - Maven Shade 重叠类警告

  我在我的项目中使用 commons-io 并想对其进行着色。我遇到了一个我似乎无法弄清楚的警告: [WARNING] commons-io-2.7.jar, murder-1.0-SNAPSHOT.j

• Maven Shade 插件 + 原始字符串

  我正在使用 shade 插件创建一个包含所有依赖项的 jar。在我的 pom.xml 中应用此配置相对简单: org.apache.maven.plugins maven-shade-plugin

• java - Maven Shading 多模块聚合与继承

  上下文 我有一个包含多个模块的 IntelliJ 项目。我正在使用 maven-shade-plugin 来压缩依赖项，同时减少 jar 大小。项目结构如下； 顶级父级 (pom)(聚合 api 和

• scala - Maven-shade-plugin是否可以与scala类一起使用？

  我有一个同时包含Java和Scala组件的maven项目，但是当我使用maven-shade-plugin时，它会同时为Java和Scala文件定位软件包名称，但是仅重命名Java文件中的软件包，Sc

• Maven Shade 插件生成两个 Jars

  到目前为止，我一直在使用 Maven 程序集插件为每个 Artifact 生成两个 JAR - 已编译的源代码和依赖项 - 原因很简单 - 通过网络仅部署已编译的源代码比部署一体化 JAR 快得多具有

• maven - Maven Shade-更改文件名并替换文本

  我试图使用Maven Shade并包装ElasticSearch jar。 之所以这样做，是因为我的项目中Lucene版本之间存在冲突。 但是当我使用Shade时发现了问题。它不会更改META-INF

• maven - 使用maven-shade-plugin时出现依赖冲突怎么办？

  我正在使用 maven-shade-plugin 创建一个可执行 jar，其中包含项目的所有依赖项。有时，这些依赖项会带来自己的依赖项，这些依赖项会与其他库的依赖项发生冲突，并且 maven-shad