已有0人关注此标签
想问一下配置Gitlab merge触发pipeline ,构建成功或者失败都返回到gitlab状态吗？比如构建失败禁止merge
作者： k8s小能手
232人浏览
0人回答
想问一下配置Gitlab merge触发pipeline ,构建成功或者失败都返回到gitlab状态吗？比如构建失败禁止merge
Flink on Yarn启动的TaskManager只有一个
作者： mz111
144人浏览
0人回答
Flink On Yarn 模式，单个任务提交的时候，任务提交成功了，但是我的TaskManager只启动了一个，其他的TaskManager都没启动起来，当然资源也没法用，这是为什么啊？？？我的启动命令是这样的：flink -m yar…
redis 连接问题
作者： 李博 bluemind
125人浏览
1人回答
redis经常进行连接就会报错 redis.exceptions.ConnectionError: Error 99 connecting to 127.0.0.1:6379. Cannot assign requested addres…
如何在Airflow中将参数传递给PythonOperator
作者： 一码平川MACHEL
620人浏览
2人回答
我刚开始使用Airflow，任何人都可以告诉我如何将参数传递给PythonOperator，如下所示： t5_send_notification = PythonOperator( task_id='t5_send_notificatio…
Jenkins Kubernetes插件：如何从Dockerfile构建图像并在图像中运行步骤
作者： k8s小能手
403人浏览
1人回答
我正在使用Jenkins kubernetes-plugin。是否可以从Dockerfile构建docker镜像，然后在创建的图像中运行步骤？该插件需要在pod模板中指定一个图像，所以我的第一次尝试是使用docker-in-docker，…
PySpark在创建包含现有列名的新列时读取多个文件
作者： 社区小助手
323人浏览
1人回答
我想使用pyspark 读取n个 csv文件。csv具有相同的模式，但具有不同的列名称。 在阅读这些文件时，我想创建一个包含第一列名称的子字符串的附加列“管道”。 我该如何实现呢？ df = spark.read.format("csv"…
Apache Spark ML Pipeline：过滤数据集中的空行
作者： 社区小助手
339人浏览
1人回答
在我的Spark ML Pipeline（Spark 2.3.0）中我使用RegexTokenizer如下： val regexTokenizer = new RegexTokenizer() .setInputCol("text")…
Pyspark错误：使用交叉验证时“字段rawPrediction不存在”
作者： 社区小助手
358人浏览
1人回答
我一直在尝试使用CrossValidator我的训练数据，但我总是收到错误消息： "An error occurred while calling o80267.evaluate.: java.lang.IllegalArgumentEx…
Beam jar无法在远程flink群集上运行
作者： flink小助手
438人浏览
1人回答
使用带有Flink 1.5.3的beam 2.6进行测试。beam运行本地flink runner没有问题。但无法在flink群集上运行。尝试mvn和flink提交作业。当使用mvn运行时，我用过： mvn clean package -…
PySpark线性回归数据集中具有比数据点更多的特征
作者： 社区小助手
409人浏览
1人回答
我正在使用PySpark开发一个简单的文本挖掘应用程序。目标是将特定文档分类为垃圾邮件或非垃圾邮件。我有大约1000个文件来训练模型（n）。 清理数据（正交误差校正，词干等）后，我使用IDF提取特征向量。默认情况下，此向量化方法的要素维度…
错误没有指定Runner并且在类路径上找不到DirectRunner
作者： flink小助手
741人浏览
1人回答
"我正在运行flink 1.6.1的单节点flink集群上运行字数统计示例 并继续得到这个错误。 我正在使用beam版本2.8.0。 错误 jobmanager_1 | 2018-10-28 07:20:41,401 ERROR or…
