- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperRunningJobsRegistry.createZkPath()
方法的一些代码示例,展示了ZooKeeperRunningJobsRegistry.createZkPath()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperRunningJobsRegistry.createZkPath()
方法的具体详情如下:
包路径:org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperRunningJobsRegistry
类名称:ZooKeeperRunningJobsRegistry
方法名:createZkPath
暂无
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
private void writeEnumToZooKeeper(JobID jobID, JobSchedulingStatus status) throws Exception {
final String zkPath = createZkPath(jobID);
this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
this.client.setData().forPath(zkPath, status.name().getBytes(ENCODING));
}
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
@Override
public void clearJob(JobID jobID) throws IOException {
checkNotNull(jobID);
try {
final String zkPath = createZkPath(jobID);
this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
this.client.delete().forPath(zkPath);
}
catch (Exception e) {
throw new IOException("Failed to clear job state from ZooKeeper for job " + jobID, e);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
private void writeEnumToZooKeeper(JobID jobID, JobSchedulingStatus status) throws Exception {
final String zkPath = createZkPath(jobID);
this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
this.client.setData().forPath(zkPath, status.name().getBytes(ENCODING));
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
@Override
public void clearJob(JobID jobID) throws IOException {
checkNotNull(jobID);
try {
final String zkPath = createZkPath(jobID);
this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
this.client.delete().forPath(zkPath);
}
catch (Exception e) {
throw new IOException("Failed to clear job state from ZooKeeper for job " + jobID, e);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime
private void writeEnumToZooKeeper(JobID jobID, JobSchedulingStatus status) throws Exception {
final String zkPath = createZkPath(jobID);
this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
this.client.setData().forPath(zkPath, status.name().getBytes(ENCODING));
}
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
private void writeEnumToZooKeeper(JobID jobID, JobSchedulingStatus status) throws Exception {
final String zkPath = createZkPath(jobID);
this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
this.client.setData().forPath(zkPath, status.name().getBytes(ENCODING));
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
@Override
public void clearJob(JobID jobID) throws IOException {
checkNotNull(jobID);
try {
final String zkPath = createZkPath(jobID);
this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
this.client.delete().forPath(zkPath);
}
catch (Exception e) {
throw new IOException("Failed to clear job state from ZooKeeper for job " + jobID, e);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime
@Override
public void clearJob(JobID jobID) throws IOException {
checkNotNull(jobID);
try {
final String zkPath = createZkPath(jobID);
this.client.newNamespaceAwareEnsurePath(zkPath).ensure(client.getZookeeperClient());
this.client.delete().forPath(zkPath);
}
catch (Exception e) {
throw new IOException("Failed to clear job state from ZooKeeper for job " + jobID, e);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
@Override
public JobSchedulingStatus getJobSchedulingStatus(JobID jobID) throws IOException {
checkNotNull(jobID);
try {
final String zkPath = createZkPath(jobID);
final Stat stat = client.checkExists().forPath(zkPath);
if (stat != null) {
// found some data, try to parse it
final byte[] data = client.getData().forPath(zkPath);
if (data != null) {
try {
final String name = new String(data, ENCODING);
return JobSchedulingStatus.valueOf(name);
}
catch (IllegalArgumentException e) {
throw new IOException("Found corrupt data in ZooKeeper: " +
Arrays.toString(data) + " is no valid job status");
}
}
}
// nothing found, yet, must be in status 'PENDING'
return JobSchedulingStatus.PENDING;
}
catch (Exception e) {
throw new IOException("Get finished state from zk fail for job " + jobID.toString(), e);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime
@Override
public JobSchedulingStatus getJobSchedulingStatus(JobID jobID) throws IOException {
checkNotNull(jobID);
try {
final String zkPath = createZkPath(jobID);
final Stat stat = client.checkExists().forPath(zkPath);
if (stat != null) {
// found some data, try to parse it
final byte[] data = client.getData().forPath(zkPath);
if (data != null) {
try {
final String name = new String(data, ENCODING);
return JobSchedulingStatus.valueOf(name);
}
catch (IllegalArgumentException e) {
throw new IOException("Found corrupt data in ZooKeeper: " +
Arrays.toString(data) + " is no valid job status");
}
}
}
// nothing found, yet, must be in status 'PENDING'
return JobSchedulingStatus.PENDING;
}
catch (Exception e) {
throw new IOException("Get finished state from zk fail for job " + jobID.toString(), e);
}
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
@Override
public JobSchedulingStatus getJobSchedulingStatus(JobID jobID) throws IOException {
checkNotNull(jobID);
try {
final String zkPath = createZkPath(jobID);
final Stat stat = client.checkExists().forPath(zkPath);
if (stat != null) {
// found some data, try to parse it
final byte[] data = client.getData().forPath(zkPath);
if (data != null) {
try {
final String name = new String(data, ENCODING);
return JobSchedulingStatus.valueOf(name);
}
catch (IllegalArgumentException e) {
throw new IOException("Found corrupt data in ZooKeeper: " +
Arrays.toString(data) + " is no valid job status");
}
}
}
// nothing found, yet, must be in status 'PENDING'
return JobSchedulingStatus.PENDING;
}
catch (Exception e) {
throw new IOException("Get finished state from zk fail for job " + jobID.toString(), e);
}
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
@Override
public JobSchedulingStatus getJobSchedulingStatus(JobID jobID) throws IOException {
checkNotNull(jobID);
try {
final String zkPath = createZkPath(jobID);
final Stat stat = client.checkExists().forPath(zkPath);
if (stat != null) {
// found some data, try to parse it
final byte[] data = client.getData().forPath(zkPath);
if (data != null) {
try {
final String name = new String(data, ENCODING);
return JobSchedulingStatus.valueOf(name);
}
catch (IllegalArgumentException e) {
throw new IOException("Found corrupt data in ZooKeeper: " +
Arrays.toString(data) + " is no valid job status");
}
}
}
// nothing found, yet, must be in status 'PENDING'
return JobSchedulingStatus.PENDING;
}
catch (Exception e) {
throw new IOException("Get finished state from zk fail for job " + jobID.toString(), e);
}
}
本文整理了Java中org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperRunningJobsRegistry.createZkP
本文整理了Java中org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperRunningJobsRegistry.()方法的一些代码
本文整理了Java中org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperRunningJobsRegistry.writeEnum
我是一名优秀的程序员,十分优秀!