小编Cas*_*sie的帖子

我需要使用以下路由创建 nginx.conf 文件：/assets - 静态文件，/akka - 用于 hello-world akka webapp，/* - 默认页面。我的 default.conf 文件如下所示：

worker_processes  1;

error_log  /var/log/nginx/error.log warn;
pid        /var/run/nginx.pid;


events {
    worker_connections  1024;
}

http {
    include mime.types;
    default_type  application/octet-stream;

    upstream hello-akka{
        server localhost:9000;
    }

    server {
        listen 80;

        location / {
        root   /usr/share/nginx/html;
        index  index.html index.htm;
        }

        location /akka {
        proxy_pass http://hello-akka;
        }

        location /assets {
        root /var/www;
        }   
    }
}

每次重新启动 nginx 服务时，都会收到以下错误消息：

nginx: [emerg] "worker_processes" directive is not allowed here in /etc/nginx/conf.d/default.conf:2
nginx: configuration file …

我需要屏蔽电话号码.它可能包含数字,+(国家代码)和破折号.国家/地区代码可能包含1位或更多位数字.我创建了这种正则表达式来掩盖除了最后4位之外的所有数字:

inputPhoneNum.replaceAll("\\d(?=\\d{4})", "*");

对于这样的输入:+13334445678

我得到了这个结果:+*******5678

但是,它不适用于此类输入:+ 1-333-444-5678 特别是,它返回相同的数字而不做任何更改.虽然所需的输出屏蔽了除最后4位以外的所有数字,加号和短划线.这就是为什么我想知道如何改变我的正则表达式以包括短划线？我将不胜感激任何帮助!

是否可以使用一些 Spark Conf 设置在本地模式下为 Spark Streaming 应用程序设置多个执行程序？目前，例如，当我将spark.executor.instances参数更改为 4时，我看不到 Spark UI 在性能或执行程序数量增加方面的任何变化。

我已经定义了几个用于JSON表示的案例类，但是由于存在很多嵌套的案例类，因此我不确定我是否正确执行了。诸如spec，meta之类的实体的类型均为JSONObject以及Custom对象本身。

这是我定义的所有类：

  case class CustomObject(apiVersion: String,kind: String, metadata: Metadata,spec: Spec,labels: Object,version: String)

  case class Metadata(creationTimestamp: String, generation: Int, uid: String,resourceVersion: String,name: String,namespace: String,selfLink: String)

  case class Spec(mode: String,image: String,imagePullPolicy: String, mainApplicationFile: String,mainClass: String,deps: Deps,driver: Driver,executor: Executor,subresources: Subresources)

  case class Driver(cores: Double,coreLimit: String,memory: String,serviceAccount: String,labels: Labels)

  case class Executor(cores: Double,instances: Double,memory: String,labels: Labels)

  case class Labels(version: String)

  case class Subresources(status: Status)

  case class Status()

  case class Deps()

这是我需要转换的自定义K8s对象的JSON结构：

{
    "apiVersion": "sparkoperator.k8s.io/v1alpha1",
    "kind": "SparkApplication",
    "metadata": {
        "creationTimestamp": "2019-01-11T15:58:45Z",
        "generation": 1,
        "name": "spark-example", …

我一直在尝试使用Kubernetes在本地部署带有架构注册表的Kafka。但是，架构注册表窗格的日志显示此错误消息：

ERROR Server died unexpectedly:  (io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain:51)
org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

这种行为的原因可能是什么？'为了在本地运行Kubernetes，我将Minikube v0.32.0版本与Kubernetes v1.13.0版本一起使用

我的Kafka配置：

apiVersion: v1
kind: Service
metadata:
  name: kafka-1
spec:
  ports:
    - name: client
      port: 9092
  selector:
    app: kafka
    server-id: "1"
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: kafka-1
spec:
  selector:
    matchLabels:
      app: kafka
      server-id: "1"
  replicas: 1
  template:
    metadata:
      labels:
        app: kafka
        server-id: "1"
    spec:
      volumes:
        - name: kafka-data
          emptyDir: {}
      containers:
        - name: server
          image: confluent/kafka:0.10.0.0-cp1
          env:
            - name: KAFKA_ZOOKEEPER_CONNECT
              value: zookeeper-1:2181
            - …

我已经使用Kubernetes中的httpfs设置设置了对HDFS的访问权限，因为我需要访问HDFS数据节点，而不仅是名称节点上的元数据。我可以使用带有telnet的节点端口服务连接到HDFS，但是，当我尝试从HDFS中获取一些信息时-读取文件，检查文件是否存在，会出现错误：

[info]   java.net.SocketTimeoutException: Read timed out
[info]   at java.net.SocketInputStream.socketRead0(Native Method)
[info]   at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
[info]   at java.net.SocketInputStream.read(SocketInputStream.java:171)
[info]   at java.net.SocketInputStream.read(SocketInputStream.java:141)
[info]   at java.io.BufferedInputStream.fill(BufferedInputStream.java:246)
[info]   at java.io.BufferedInputStream.read1(BufferedInputStream.java:286)
[info]   at java.io.BufferedInputStream.read(BufferedInputStream.java:345)
[info]   at sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:735)
[info]   at sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:678)
[info]   at sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1587)

此错误的原因可能是什么？这是用于建立与HDFS文件系统的连接并检查文件是否存在的源代码：

val url = "webhdfs://192.168.99.100:31400"
val fs = FileSystem.get(new java.net.URI(url), new org.apache.hadoop.conf.Configuration())
val check = fs.exists(new Path(dirPath))

由dirPath参数指定的目录位于HDFS上。

HDFS Kubernetes设置如下所示：

apiVersion: v1
kind: Service
metadata:
  name: namenode
spec:
  type: NodePort
  ports:
    - name: client
      port: 8020
    - name: hdfs
      port: 50070
      nodePort: 30070 …

我在大学里有一项任务，我需要使用Median-of-3快速排序按学生的组号对其进行排序。但是我的排序方法无法正常工作-仅对某些元素进行了排序。但是有些要素不会改变立场。我用必要的数据创建了一个Student类，使用Student类型数组的Sortings类。在主类中，我有4种用于此类排序的静态方法，在该类中，我创建了Sortings的实例并调用我的静态方法进行排序。

public static void manual_Sort(Student[]st, int right, int left)
{
    int size = right - left + 1;
    if(size <= 1)
        return;             
    if(size == 2)
    {
        if(st[left].Group_number > st[right].Group_number)
            swap(st,right,left);
        return;
    }
    else
    {
        if(st[left].Group_number > st[right-1].Group_number)
            swap(st,left, right-1);                                 
        if(st[left].Group_number > st[right].Group_number)
            swap(st,left, right);                                       
        if(st[right-1].Group_number > st[right].Group_number )
            swap(st,right-1, right);                                
    }
}


public static int partitionIt(Student[]st, int left, int right,double pivot)
{
    int leftPtr = left;                 
    int rightPtr …