com.spotify.helios.servicescommon.coordination.ZooKeeperUpdatingPersistentDirectory.put()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 11:00:50 25 4

/**
 * Set the {@link TaskStatus} for the job identified by {@code jobId}.
 */
@Override
public void setTaskStatus(final JobId jobId, final TaskStatus status)
  throws InterruptedException {
 log.debug("setting task status: {}", status);
 taskStatuses.put(jobId.toString(), status.toJsonBytes());
 if (historyWriter != null) {
  try {
   historyWriter.saveHistoryItem(status);
  } catch (Exception e) {
   // Log error here and keep going as saving task history is not critical.
   // This is to prevent bad data in the queue from screwing up the actually important Helios
   // agent operations.
   log.error("Error saving task status {} to ZooKeeper: {}", status, e);
  }
 }
 final TaskStatusEvent event = new TaskStatusEvent(status, System.currentTimeMillis(), agent);
 final byte[] message = event.toJsonBytes();
 for (final EventSender sender : eventSenders) {
  sender.send(taskStatusEventTopic, message);
 }
}

/**
 * Set the {@link TaskStatus} for the job identified by {@code jobId}.
 */
@Override
public void setTaskStatus(final JobId jobId, final TaskStatus status)
  throws InterruptedException {
 log.debug("setting task status: {}", status);
 taskStatuses.put(jobId.toString(), status.toJsonBytes());
 try {
  historyWriter.saveHistoryItem(status);
 } catch (Exception e) {
  // Log error here and keep going as saving task history is not critical.
  // This is to prevent bad data in the queue from screwing up the actually important Helios
  // agent operations.
  log.error("Error saving task status {} to ZooKeeper: {}", status, e);
 }
 final TaskStatusEvent event = new TaskStatusEvent(status, System.currentTimeMillis(), agent);
 kafkaSender.send(KafkaRecord.of(TaskStatusEvent.KAFKA_TOPIC, event.toJsonBytes()));
}

25 4 0

• Eclipse Helios 不会在断点处停止

  我最近从 Eclipse Galileo 升级到 Helios。 Helios 仅在“作为 PHP 脚本”调试时才会在断点处停止，而在“作为网页”调试时则不会。 当作为网页调试时，启动调试 sessi

• Eclipse helios 安装新插件问题

  我正在尝试安装新插件，但是当我选择更新站点时出现此错误 !ENTRY org.eclipse.equinox.p2.core 4 0 2010-10-07 08:57:56.153 !MESSAGE

• Eclipse Helios 未启动

  一年多以前，我曾使用 Eclipse 没有问题，但我将 Helios 下载到一台当前装有 Windows Vista 和 Java 1.6.13 的新计算机上。我提取文件夹并尝试运行 Eclipse

• Eclipse Helios 随机崩溃

  我的 Eclipse 几乎每 10 分钟就崩溃一次，我不知道为什么。这太烦人了。而且我不知道如何解决这个问题。我没有做任何具体的事情来让 eclipse 崩溃。有时我只是打开一个新窗口或单击保存等。这

• eclipse - Helios 有什么重大问题吗？

  我刚刚看到 Eclipse 的新主要版本 ( 3.6 Helios ) 可供下载。我想尝试一下，但在此之前我想知道是否有人遇到过任何重大问题。 我想确定是否可以尝试这个，因为我的项目设置很复杂，通常很

• eclipse helios tomcat错误

  我刚刚在 eclipse Helios 中创建了一个 struts 应用程序。当我作为服务器运行时，我会收到这样的警报。我的浏览器仅在线。 This document cannot be displa

• ios - 推送通知配置 helios

  我正在尝试使用 Helios向我的应用程序发送推送通知。该项目没有提供任何关于在哪里以及如何放置 .pem 文件(用于推送通知的 apns 证书)的描述。我希望 stackoverflow 上的某个人

• com.spotify.helios.ZooKeeperTestingServerManager类的使用及代码示例

  本文整理了Java中com.spotify.helios.ZooKeeperTestingServerManager类的一些代码示例，展示了ZooKeeperTestingServerManager类

• com.spotify.helios.ZooKeeperTestingClusterManager类的使用及代码示例

  本文整理了Java中com.spotify.helios.ZooKeeperTestingClusterManager类的一些代码示例，展示了ZooKeeperTestingClusterManage

• eclipse - Eclipse(Helios)上没有自动完成功能

  我在 Eclipse (Helios) 中的自动完成选项有问题。 我已经检查了 Windows->Preferences->PHP->Editor->Content Assist，那里的一切似乎都是正

• eclipse - Eclipse Helios 中的着色器插件

  我一直无法让出色的 Eclipse Colorer 插件与我当前的 Eclipse(Helios 64 位)副本一起使用。它安装正常，但每当我尝试打开源文件时，都会出现此错误: Colorer 库 n

• java - 无法启动 Eclipse Helios

  我刚刚安装了 Eclipse Helios。当我解压并打开 Eclipse 后，它会询问我的工作区。我选择了路径，它说可以。它打开工作区并说工作台正在加载，突然 Eclipse IDE 关闭，在主 E

• android - Eclipse Helios Android模拟器如何运行示例工程

  您好，我已经安装了带有 android 仿真的 eclipse helios，就像它写的那样 http://www.futuredesktop.org/developing_android_apps_

• java - 找不到要导入的项目 - Helios eclipse

  当为 Helios eclipse 下载 64 位时声称没有找到要导入的项目 - 文件是 swt-3.6-win32-win32-x86_64.zip 这应该是相当简单的!!! 最佳答案 除了乔所说的

• linux - Eclipse Helios 无法加载玩具插件

  我正在尝试安装我在 Fedora 12 下的 Eclipse Helios 20100617-1415 中编写的玩具插件。安装插件的尝试都失败了。该插件在作为 Eclipse 应用程序执行时确实运行(

• java - eclipse helios for maven项目中Sonar插件安装问题

  我正在使用: Eclipse Helios Version: 3.6.2 Sonar Java Analyser 3.1.0.2 在 Eclipse 中安装 Sonar 的步骤: 帮助 -> 安装新软

• java - 不发布的服务模块在 Helios 中不起作用

  我最近将我一直在开发的 webapp 转移到运行 64 位 Eclipse Helios(服务版本 2)的新机器上，并且我正在使用 Maven 插件 M2Eclipse。 我已经通过 Eclipse

• java - Eclipse Helios 忽略断点

  Eclipse 现在快把我逼疯了。这可能是微不足道的，但我就是不明白。每当我想添加断点时，编辑器和断点 View 中的常规图标都会被划掉。 正如您可能已经猜到的，这不是严格意义上的图形问题 ;) 在调

• com.spotify.helios.master.ZooKeeperMasterModel类的使用及代码示例

  本文整理了Java中com.spotify.helios.master.ZooKeeperMasterModel类的一些代码示例，展示了ZooKeeperMasterModel类的具体用法。这些代码示

• com.spotify.helios.servicescommon.ZooKeeperRegistrar类的使用及代码示例

  本文整理了Java中com.spotify.helios.servicescommon.ZooKeeperRegistrar类的一些代码示例，展示了ZooKeeperRegistrar类的具体用法。这