小编Jyn*_*oot的帖子

目标是让每个人都获得每个失败管道的通知(由他们自行决定).目前,我们任何人都可以在这个项目分支上运行管道,管道的创建者会收到一封电子邮件,其他人都没有.我已经尝试了通知级别设置为watch和custom (with failed pipelines checked)在项目组与没有成功的全球水平.有关通知的帮助页面显示自定义通知级别的失败管道复选框通知管道的作者(这是我遇到的行为).有没有办法让多人收到管道故障的通知？

• 使用Gitlab CE v10.0
• 有团体(安全::内部)
• 集团有项目(安全::内部)
• 项目已安排pipleine(近乎运行)
• 管道运行集成测试(故意失败)
• 我创建的时间表(时间表必须有所有者)
• 当自动管道运行并失败时,我收到一封电子邮件(好)
• 没有其他人收到电子邮件(坏)

我需要一个Java 8的多线程示例.

我需要能够手动选择线程数.

在下面的示例中,我遇到Thread.currentThread().getName()的问题,我需要使用lambda表达式.

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Thread {

    public static void main(String args[]) {
       ExecutorService service = Executors.newFixedThreadPool(10);
       for (int i =0; i<100; i++){
           service.submit(new Task(i));
       }
    }

final class Task implements Runnable{
    private int taskId;

    public Task(int id){
        this.taskId = id;
    }

    @Override
    public void run() {
        System.out.println("Task ID : " + this.taskId +" performed by "
            + Thread.currentThread().getName());
    }
}

代码：

LivyClient client = null;
try
{
  String livyUrl = "http://dummy16814.zycus.net:8998";
  client = new LivyClientBuilder().setURI(new URI(livyUrl)).build();

  String piJar = "E:\\livy_old.jar";
  System.err.printf("Uploading %s to the Spark context...\n", piJar);
  client.uploadJar(new File(piJar)).get();

  int samples = 10;
  System.err.printf("Running PiJob with %d samples...\n", samples);

  double pi = client.submit(new PiJob()).get();
  System.out.println("Pi is roughly: " + pi);
}
finally
{
  client.stop(true);
}

上传jar时遇到异常

正在将E：\ livy_old.jar上载到Spark上下文...线程“主”中的异常java.util.concurrent.ExecutionException：java.io.IOException：错误的请求：“要求失败：本地路径/root/.livy-sessions /61a5e39c-d199-4bb8-967b-960b4e3e9ee3/livy_old.jar无法添加到用户会话。” 在java.util.concurrent.FutureTask.report（FutureTask.java:122）在java.util.concurrent.FutureTask.get（FutureTask.java:192）在com.zycus.spark.PiJob.main（PiJob.java:64） ）由以下原因引起：java.io.IOException：错误的请求：“请求失败：本地路径/root/.livy-sessions/61a5e39c-d199-4bb8-967b-960b4e3e9ee3/livy_old.jar无法添加到用户会话中。” com.cloudera.livy.client.http.LivyConnection上的com.cloudera.livy.client.http.LivyConnection.sendRequest（LivyConnection.java:197）处。