- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我需要一些帮助才能知道我在这里缺少什么。
我正在尝试为我的实验室(本地主机)从定制的values.yml文件部署流集应用程序。我试图将Pod部署在“streamset-ns” 命名空间上。我面临以下错误。
stderr:在streamset-ns命名空间中找不到资源。
任务下的主脚本
- name: Listing all Namespaces
command: "kubectl get namespaces"
register: namespace_list
- name: Checking if streamsets is installed in "{{streamsets_namespace}}"
command: "kubectl get pods -n {{streamsets_namespace}}"
register: if_streamsets
- set_fact:
message: "{{ ((task_type == 'install') and ('deployed' in if_streamsets.stdout)) or ((task_type == 'uninstall') and ('deployed' in if_streamsets.stdout)) | ternary('streamsets is installed', 'streamsets is not installed') }}"
- debug:
msg: "{{message}}"
- name: Checking streamsets running status
block:
- debug:
msg: "streamsets is already deployed in {{streamsets_namespace}}"
- name: Getting deployed pod status
command: "kubectl get pods -n {{streamsets_namespace}}"
register: streamsets_pod_status
- debug:
var: streamsets_pod_status.stdout_lines
when: "'streamsets' in if_streamsets.stdout and 'deployed' in if_streamsets.stdout"
- name: Installing streamsets
block:
- name: Create a Kubernetes namespace for streamsets
k8s:
name: "{{streamsets_namespace}}"
api_version: v1
kind: Namespace
state: present
when: "streamsets_namespace not in namespace_list.stdout_lines"
# - name: Adding Helm Repository for Streamsets
# command: "{{helm_location}}/helm repo add streamsets {{streamsets_helm_charts}}"
# register: helm_repo_results
# changed_when: False
# failed_when: "'Error' in helm_repo_results.stderr"
#
- name: Applying Template Module
template:
src: "roles/streamsets/templates/values.yml.j2"
dest: "/home/{{ansible_user}}/values.yml"
mode: '0644'
- name: Install streamsets using Command Module
command: "kubectl create -f /home/{{ansible_user}}/values.yml -n {{streamsets_namespace}}"
register: streamsets_result
failed_when: "'Error' in streamsets_result.stderr"
- debug:
var: streamsets_result.stdout_lines
# - name: Checking Streamsets Deployment Status
# action:
# shell kubectl get pods -n "{{streamsets_namespace}}"| grep "{{streamsets_release_name}}" | grep '1/1' |wc -l
# register: streamsets_deployment_status
# until: streamsets_deployment_status.stdout|int == streamsets_replicas | int
# retries: 5
# delay: 60
#
# - debug:
# var: streamsets_deployment_status.stdout_lines
- name: Checking Streamsets Deployment Status
command: kubectl -n "{{streamsets_namespace}}" wait --for=condition=Ready pods --all --timeout=180s
register: Streamsets_pod_status
failed_when: "'Error' in Streamsets_pod_status.stderr"
- name: Removing deployed configuration files for Streamsets
file:
path: "/home/{{ansible_user}}/values.yml"
state: absent
when: "'install' == task_type and 'streamsets' not in if_streamsets.stdout and 'deployed' not in if_streamsets.stdout"
- name: Unistalling streamsets from K8s
block:
- name: Removing Statefulsets & Service from "{{streamsets_namespace}}"
action:
shell kubectl -n "{{streamsets_namespace}}" delete statefulsets "{{streamsets_release_name}}" && kubectl -n "{{streamsets_namespace}}" delete service "{{streamsets_release_name}}"-service
register: streamsets_removal_status
- debug:
var: streamsets_removal_status.stdout_lines
# - name: Checking PVC status in "{{streamsets_namespace}}"
# shell: kubectl get pvc -n "{{streamsets_namespace}}" | grep -v NAME | cut -d ' ' -f1
# register: streamsets_pvc_status
# - debug:
# var: streamsets_pvc_status.stdout_lines
# - name: Delete occupied pvc for streamsets
# command: "kubectl delete pvc -n {{streamsets_namespace}} {{streamsets_pvc_status.stdout}}"
# register: pvc_delete_status
# when: streamsets_pvc_status.stdout_lines != ''
# - debug:
# var: pvc_delete_status.stdout_lines
when: "'uninstall' == task_type and 'streamsets' in if_streamsets.stdout and 'deployed' in if_streamsets.stdout"
- name: Playbook Signature
block:
- debug:
msg: "No 'task_type' supplied. Playbook signature: ansible-playbook -i <hosts file> <playbook> --extra-vars 'task_type=<install/uninstall>'"
when: "task_type == '' or ('install' or 'uninstall') not in task_type"
---
apiVersion: v1
kind: Service
metadata:
name: streamsets-service
labels:
name: streamsets
spec:
type: NodePort
ports:
- port: {{streamsets_port}}
targetPort: 18630
nodePort: {{streamsets_nodePort}}
selector:
role: streamsets
---
apiVersion: apps/v1
kind: StatefulSet
metadata:
name: streamsets
spec:
serviceName: streamsets-service
replicas: {{streamsets_replicas}}
selector:
matchLabels:
name: streamsets
template:
metadata:
labels:
role: streamsets
environment: test
replicaset: streamsetsRepSet
spec:
terminationGracePeriodSeconds: 10
containers:
- name: {{streamsets_image_container}}
image: {{streamsets_image_name}}:{{streamsets_image_version}}
imagePullPolicy: Always
ports:
- containerPort: 18630
volumeMounts:
- name: data
mountPath: /data
volumeClaimTemplates:
- metadata:
name: data
spec:
accessModes: [ "ReadWriteOnce" ]
storageClassName: {{streamsets_storageClass}}
resources:
requests:
storage: {{streamsets_storage_volume}}
最佳答案
当我查看您已作为评论发布的错误时,看来selector
中的不匹配。
selector:
matchLabels:
name: streamsets
template:
metadata:
labels:
role: streamsets
environment: test
replicaset: streamsetsRepSet
selector:
matchLabels:
name: streamsets
template:
metadata:
labels:
name: streamsets
关于kubernetes - 在streamset-ns命名空间中找不到资源,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61415860/
我的团队需要使用旧版本的 StreamSet,即 2.5 版。但在 3.8 版本中,我们希望在旧环境中包含一些重要的处理器,即 JDBC 元数据处理器。 已完成的工作如下: 使用 StreamSets
我们的团队正在探索 HDFS 到本地数据提取的选项。我们被建议使用 StreamSet,但团队中没有人对此有任何想法。谁能帮助我了解这是否符合我们将数据从 HDFS 提取到本地系统的要求? 只是一个额
我正在阅读有关 Kafka 和 StreamSets 的文章,我的理解是 Kafka 充当生产者系统和订阅者之间的经纪人。生产者将数据推送到Kafka集群,订阅者从Kafka拉取数据 StreamsS
我在 Cloudera Distribution 上使用 StreamSets,试图从这个网站 http://files.data.gouv.fr/sirene/ 获取一些数据 我在选择 HTTP 客
即使看了教程,我也不是很清楚架构。我们如何在分布式环境中扩展流集?比方说,我们的输入数据速度从源开始增加,那么如何确保 SDC 不会出现性能问题?将运行多少守护进程?是 Master worker 架
我正在使用 Streamset 数据收集器 3.19.1 版,目前正在尝试将 Streamset 与 LDAP 服务器集成以进行身份验证,我成功进行了集成,但是我们在配置角色和组方面遇到了困难,就
我已经构建并部署了以下 docker-compose.yml 文件: services: solr1: container_name: solr1 image: solr:5-sl
我正在尝试将文本数据从本地目录提取到 HDFS,在提取之前我需要将文本转换为有效的 json。为此,我正在使用 JavaScript Evaluator 处理器。 在 javascript 评估器中我
在cdc的情况下,StreamSets Data Collector有没有办法根据源数据库自动在目标数据库中创建表? 我正在从源读取数据:mssql 并写入目标 postgresql。如果我对源中的
我需要安排 JDBC 消费者作业在每天早上 5 点运行,据我所知,当我在早上 5 点开始作业并在查询间隔中设置 24 小时时,我可以让作业在凌晨 5 点运行. 但我需要安排第一个实例在早上 5 点开始
我正在使用 ansible 脚本在 k8s 主节点上部署流集。我正在检查流集仪表板是否可以通过 http://127.0.0.1 访问。 :{{streamsets_nodePort}} 其中stre
我计划做一个类项目,并且正在研究一些可以自动化或设置系统之间数据流的技术,发现有几个技术,即 Apache NiFi 和 StreamSets(据我所知)。我无法理解的是它们与可以使用它们的用例之间的
我正在使用 HttpClient origin 将文件从 HTTP url 流式传输到 Hadoop 目标,但目标中的文件名附加了一些随机 uuid。我希望文件名与源中的一样。 示例:源文件名为 RE
我正在尝试构建一个 JAVA 客户端以 POST 到 RESTApi,但是,在这样做时我收到错误“用户未经过身份验证”。 在查看 API 服务文档时,我发现我必须先获取身份验证 token ,然后才能
试图弄清楚是否可以使用 apache NiFi 或 Streamsets 实现连接。这样我就可以定期从 HBase 读取数据,与其他表连接并将少量字段写入 Hive 表。 或者有没有其他工作流管理器工
我在 CDH 5.7.0 版上使用流集 从 HDFS(源)加载文件并在 Solr(目标)上创建记录的示例工作流程。验证失败 - SOLR_03 - 无法连接到 Solr 实例:org.apache.s
我正在尝试在 StreamSets 中设置 Mysql-BinaryLog,但它提示无法加载驱动程序实例。 我的.cnf: [mysqld] server-id = 22334
我正在 CentOS 上的 Docker 中运行 StreamSets。尝试在 Jython 中导入 python 包,它返回以下错误: SCRIPTING_05 - Script error whi
我正在尝试从 mapr fs origin 进行简单的数据移动到 mapr fs destination (这不是我的用例,只是为了测试目的做这个简单的 Action )。尝试 validate 时这
我是一名优秀的程序员,十分优秀!