使用MapR MultipleOutputs写入OrcNewOutputFormat时出错
是指在使用MapR的MultipleOutputs类将数据写入OrcNewOutputFormat格式时遇到了错误。
MapR的MultipleOutputs类是Hadoop的一个扩展类，用于将数据输出到多个文件或目录。OrcNewOutputFormat是一种用于存储大规模数据的列式存储格式，具有高压缩比和快速读写的特点。
出现错误可能有多种原因，下面是一些可能的解决方案和建议：
- 检查代码：首先，检查使用MultipleOutputs类的代码是否正确。确保正确设置了输出路径、输出格式和输出键值对等参数。
- 检查依赖：确保项目中包含了正确的MapR和Hadoop依赖。检查版本兼容性，并确保依赖项已正确配置。
- 检查权限：确保对输出路径具有写入权限。如果没有权限，可以尝试更改路径或联系系统管理员获取权限。
- 日志调试：查看错误日志以获取更多详细信息。日志通常会提供有关错误的线索，例如具体的异常信息或错误堆栈跟踪。
- 联系支持：如果以上方法都无法解决问题，建议联系MapR的技术支持团队。他们可以提供更专业的帮助和指导。
关于MapR的MultipleOutputs类和OrcNewOutputFormat格式的更多信息，可以参考腾讯云的相关文档和产品介绍：
请注意，以上答案仅供参考，具体解决方法可能因实际情况而异。
相关·内容
我正在使用MultipleOutputs在Reducer中编写几个文件。但是，当我查看目标文件夹时，我看到文件已被成功写入，但是校验和文件是空的(尽管已创建)。有没有办法让MultipleOutputs也写校验和？
我在“run”方法中添加指定的输出
MultipleOutputs.addNamedOutput(job, "fld1",
TextOutputFormat.class,
Text.class, Text.class);
...
并在Reducer中写入MultipleOutputs对象：
output = new MultipleOutp
浏览 1提问于2014-10-28得票数 0
回答已采纳
我试图在Reducer中使用MultipleOutputs，以便使用分区程序写入多个文件。为此，我试图在Reducer.setup()中使用以下方法构造它的对象：
public static class MOReduce extends Reducer<Text, Integer, Text, Integer> {
private MultipleOutputs mos;
public void setup( Reducer.Context context ) {
mos = new MultipleOutputs( context.getConf
浏览 5提问于2012-02-25得票数 0
回答已采纳
1回答
我使用多个输出编写了MapReduce代码，以便在多个文件中写入数据，但问题是，它创建了多个文件，但没有在其中写入数据，为什么？
IN REDUCE
public MultipleOutputs multipleoutputs;
public void configure(JobConf job)
{
multipleoutputs=new MultipleOutputs(job);
}
public void reduce(....)
{
OutputCo
浏览 2提问于2013-06-11得票数 0
我正在尝试使用Python的parquet模块来读入一些从本地MapR实例编写的Parquet文件。
我用来输出这些拼图文件的命令是：
df.sqlContext.sql("SQL HERE").write.format("parquet").option("mergeSchema", "true").save("/path/to/parquet/test.parquet")
这是文件在我的Linux主机上的样子：
drwxr-xr-x 2 mapr mapr 403 Oct 5 13:56 igayfvpwr
浏览 0提问于2016-10-06得票数 0
我想知道MultipleOutputs、FSDataOutputStream和任务副作用文件在创建不同输出文件方面的优势/区别？
a.使用MultipleOutputs：
MultipleOutputs mos;
void configure()
{
mos.new MultipleOutputs(conf);
}
reduce()
{
mos.getCollector("desired_path", reporter).collect(new Text(key), new Text(val));
}
b.使用FSDataOutputream，我们将输出写入
浏览 0提问于2013-01-19得票数 2
回答已采纳
2回答
我目前有一个程序，其中之一是生成日志输出。问题是，映射器似乎都希望登录到它们正在运行的任何位置。我希望所有这些日志输出都在一个文件中结束。我正在使用log4j记录信息。
我在想，可能会以某种方式将数据从Mapper流回主函数，并以这种方式记录。有可能是这样的吗？有更好的方法来巩固日志吗？
浏览 2提问于2013-10-08得票数 0
回答已采纳
有没有办法使用MultipleOutputs将map reduce输出写到hbase表和文件中？
我在文件中获得输出，但hbase表为空。这就是代码。
FileInputFormat.setInputPaths(job, new Path(
"/path/to/input.txt"));
FileOutputFormat.setOutputPath(job, new Path("/path/to/output"));
job.getConfiguration().set(TableOutputFormat.OUTPUT_T
浏览 8提问于2013-11-25得票数 2
1回答
Hadoop输出控制台
、、、
当我运行带和不带multipleOutputs的mapreduce时，我看到控制台日志之间的差异。
我有一个只有映射程序才能输出到文本文件的作业。
如果没有配置MultipleOutputs，
我的Mapper中的代码片段：
context.write(null,new Text(value));
控制台输出摘录
Map-Reduce Framework
Map input records=2
Map output records=2
与MultipleOutputs，
我的Mapper中的代码片段：
multipleOutputs.write(null,new T
浏览 2提问于2015-12-29得票数 1
回答已采纳
当我每天运行Hadoop作业时，我希望覆盖/重用现有的输出目录。实际上，输出目录将存储每天作业运行结果的汇总输出。如果我指定相同的输出目录，它会给出错误“输出目录已经存在”。
如何绕过此验证？
浏览 0提问于2011-10-10得票数 22
1回答
几天来，我一直在四处寻找，试图找到一种方法，使用减少的数据在hadoop中进一步映射。我有A类的对象作为输入数据，B类的对象作为输出数据。问题是，虽然映射不仅会生成B，而且还会生成新的A。
以下是我想要实现的目标：
1.1 input: a list of As
1.2 map result: for each A a list of new As and a list of Bs is generated
1.3 reduce: filtered Bs are saved as output, filtered As are added to the map jobs
2.1 input:
浏览 1提问于2013-01-14得票数 5
回答已采纳
嗨，我正在运行一个应用程序，它从HBase读取记录并写入文本文件。
我在我的应用程序和自定义分配器中也使用了组合器。我在我的应用程序中使用了41个减速器，因为我需要创建40个减速器输出文件，以满足我在自定义分区程序中的条件。
所有操作都很好，但是当我在应用程序中使用组合器时，它会创建每个区域或每个映射器的映射输出文件。
对于示例，我在我的应用程序中有40个区域，所以40个映射器被初始化，然后它创建40个映射输出文件。但是，减速器不能结合所有的地图输出和生成最终的减速器输出文件，这将是40个减速器输出文件。
文件中的数据是正确的，但没有增加任何文件。
知道我怎么才能得到还原器输出文件。
impo
浏览 5提问于2017-03-31得票数 1
回答已采纳
1回答
当我在小数据上运行代码时，我不会得到下面的错误。但是，当我在更大的数据集上运行相同的代码时，我在使用多个输出时会得到以下错误。救命啊！
org.apache.hadoop.ipc.RemoteException:
org.apache.hadoop.hdfs.protocol.AlreadyBeingCreatedException: failed to create file
/home/users/mlakshm/alop176/data-r-00001 for
DFSClient_attempt_201208010142_0043_r_000001_1 on client 10.0.1
浏览 1提问于2012-08-02得票数 6
回答已采纳
我正在使用Hadoop 0.20，我希望有两个reduce输出文件，而不是一个输出文件。我知道MultipleOutputFormat不能在Hadoop0.20中工作。我将hadoop1.1.1-core jar文件添加到Eclipse中我的项目的构建路径中。但它仍然显示最后一个错误。
下面是我的代码：
public static class ReduceStage extends Reducer<IntWritable, BitSetWritable, IntWritable, Text>
{
private MultipleOutputs mos;
public
浏览 10提问于2013-09-25得票数 1
1回答
在使用安全mapr集群设置oozie服务方面，我们面临一个问题。
我们正在使用MapR安装程序来设置MapR集群。下面是我们遵循的配置和步骤。
MapR版本- 6.1
Os - Ubuntu 16.04
身份验证- Kerberos
节点-单个节点
我们已经通过在安装程序. Enable Secure Cluster 中使用选项启用了Mapr安全性
参考文档-
我们已经在机器上安装了kerberos。
参考文档-
下面的是我们为MapR集群设置kerberos身份验证所执行的命令
参考文档-
sudo kadmin.local
addprinc -randkey mapr/my.clu
浏览 2提问于2021-01-18得票数 0
1回答
我找不到一个特定的链接来向我解释如何在MAPR(文件元数据)中分布元数据。当我查看cloudera / hortonworks /apache hadoop时，我知道元数据存储在namenode的内存中，然后提取内存以定位保存这些块的节点。它在MAPR中是如何工作的，这是我想要理解的。
任何帮助都将不胜感激。
浏览 1提问于2015-06-12得票数 2
2回答
在运行pyspark脚本加载拼图面板时，我遇到了以下错误。
交互模式工作正常：
df_writer = pyspark.sql.DataFrameWriter(df)
df_writer.saveAsTable('test', format='parquet', mode='overwrite',path='xyz/test_table.parquet')
脚本模式抛出错误：
/opt/mapr/spark/spark-2.0.1//bin/spark-submit --jars /opt/mapr/spark/spark-2
浏览 1提问于2017-02-17得票数 2
1回答
我有个问题。如何使用一个映射器和两个减速器(这两个减速器输入都来自地图输出)来实现mapreduce作业？每一种减速器都有自己的输出？另外一件事是，mapper可以有两个或更多的输入？
public static class dpred extends Reducer<Text, DoubleWritable, Text, DoubleWritable>
{
public void reduce1(Text key, Iterable<DoubleWritable> values, Context context) throws IOException, Int
浏览 1提问于2013-10-16得票数 0
回答已采纳
我使用以下命令压缩Hadoop MR作业的输出：
conf.setOutputFormat(TextOutputFormat.class);
TextOutputFormat.setCompressOutput(conf, true);
TextOutputFormat.setOutputCompressorClass(conf, GzipCodec.class);
我使用MultipleOutputs的方式如下：
MultipleOutputs.addMultiNamedOutput(conf, "a", TextOutputFormat.class, Text.class,
浏览 0提问于2013-01-02得票数 0
回答已采纳
我不知道如何使用MultipleOutputs类。我使用它来创建多个输出文件。下面是我的Driver类的代码片段
Configuration conf = new Configuration();
Job job = Job.getInstance(conf);
job.setJarByClass(CustomKeyValueTest.class);//class with mapper and reducer
job.setOutputKeyClass(CustomKey.class);
job.setOutputValueClass(Text.cl
浏览 0提问于2017-04-07得票数 0
可能重复：
ApacheHadoop0.20.203的用户如何处理缺乏对MultipleOutputs的支持(还原器写入多个输出文件)？
Apache的旧版本支持MultipleOutputs，但要使用它们，似乎必须使用不推荐的API。
我还听说Hadoop的某些Cloudera发行版支持最新的MultipleOutputs API，就像在中定义的那样，它应该出现在Hadoop的0.21Apache版本中。
干杯!
浏览 2提问于2011-06-14得票数 1
我试图在splunk中的搜索字符串下面
index=imdc_vms sourcetype=hadoop:app:compass:services TimeoutException with args[/mapr
但是它给出了错误信息
‘SearchParser’中的错误:在'/‘之前缺少一个搜索命令。搜索查询'search index=imdc_vms sourcetype=hadoop:app:compas.{snipped} {errorcontext = with [/mapr}‘的位置'88’时出错。
你能帮我解决这个问题吗。我知道这是因为正斜杠"/“
浏览 4提问于2016-09-10得票数 0
回答已采纳
我使用的是Hadoop 0.21.0。我想输出到两个不同的文件，所以我尝试让MultipleOutputs工作。以下是我的Reduce：
public static class Reduce extends MapReduceBase implements Reducer < Text, Text > {
private MultipleOutputs mos;
public void configure(JobConf conf) {
mos = new MultipleOutputs(conf);
}
public void reduce(Text ke
浏览 1提问于2013-04-07得票数 0
我正在使用Multioutputformat类运行MR代码。part*被附加到我的输出文件的末尾。我该如何避免这种情况呢？
公共类MR_reducer扩展了Reducer {
private MultipleOutputs multipleOutputs;
@Override
protected void setup(Context context) throws IOException,
InterruptedException {
multipleOutputs = new MultipleOutputs(context);
}
@Override
prote
浏览 4提问于2015-12-11得票数 0
2回答
我的MapReduce作业按日期处理数据，需要将输出写入特定的文件夹结构。目前的期望是产生出以下结构：
天数=>日/月/档案
减速器类：
public static class Reducerclass extends Reducer<Text,Text,Text,Text> {
DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
private MultipleOutputs<Text, Text> multipleOutpu
浏览 2提问于2017-11-15得票数 1
2回答
我正在尝试建立一个地图缩减作业。
它运行到完成，但在结束时呈现奇怪的数据。
当我尝试使用system.out.println("debug data")调试它时，它没有显示在屏幕上。
使用java API生成外部日志文件、尝试使用log.severe(“日志数据”)打印到屏幕或使用log4j记录器方法log.info(日志数据)都不起作用。
只有在map reduce作业中出现异常时，我才会看到调试消息。
如何修复它，以便我可以在文件或屏幕上看到调试消息？
浏览 1提问于2012-10-03得票数 5
我试图使用MultipleOutputs来更改减速器中的输出文件名。我使用oozie工作流来运行mapreduce作业。
我无法在oozie工作流中找到添加以下属性的方法-
MultipleOutputs.addNamedOutput(job, "text", TextOutputFormat.class, Text.class, Text.class);
因为它是操作，所以我没有驱动程序类来放置上面的代码。
浏览 0提问于2018-04-16得票数 1
2回答
我想听听你对分割者和MultipleOutputs的看法。
假设我有一个文件，其中包含密钥，如
0:aaa
1:bbb
0:ccc
0:ddd
...
1:zzz
我希望有两个文件:一个文件包含以0:开头的键，另一个包含以1:开头的键。我应该使用哪种方法：
1)使用自定义分区程序，它将解析键并为getPartition()返回0或1。
2)在缩减阶段使用，解析密钥，并为MultipleOutputs.write的namedOutput参数提供zero或one。
哪一个更好？对我来说，更好的原因是还原机只处理一个文件。
浏览 3提问于2013-11-30得票数 0
回答已采纳
1回答
我有几个蜂窝表，我试图使用智能数据访问虚拟表在HANA中访问。我正在使用MapR钻取odbc驱动程序并相应地设置dsn。现在，我能够刷新我的远程源代码，创建虚拟表。但是，当我试图查询虚拟表时，它会出错。在分析了访问演练的查询之后，我注意到模式名称包含在双引号中，这导致了问题的出现。
e.g. Select * from "hive.schma".table1;
我正在尝试设置quoting_identifier = "，这帮助我查询已经创建的虚拟表，但是我失去了模式刷新功能和虚拟表创建功能。
我用的是：HANA 1 SPS 12, Drill 1.16.0.0, Map
浏览 4提问于2020-05-15得票数 0
3回答
我有一个使用org.apache.hadoop.mapreduce.lib.output.MultipleOutputs编写多个输出的代码。
Reducer将结果写入预先创建的位置，因此我不需要默认的o/p目录(其中包含_history和_SUCCESS目录)。
在再次运行我的作业之前，我每次都必须删除它们。
所以我删除了TextOutputFormat.setOutputPath(job1,new Path(outputPath));行。但是，这给出了(预期的)错误org.apache.hadoop.mapred.InvalidJobConfException: Output directo
浏览 4提问于2013-09-24得票数 0
以下是场景
Reducer1
/
Mapper - - Reducer2
\
ReducerN
在reducer中，我想将数据写到不同的文件中，假设reducer看起来像这样
def reduce():
for line in sys.STDIN:
if(line == type1):
create_type_1_file(line)
if(line == type2):
create_type_2_file(line)
if(lin
浏览 2提问于2011-10-11得票数 0
我试着像这个例子一样使用multipleOutputs
所以我有：
MultipleOutputs.addNamedOutput(job, "out1", TextOutputFormat.class, Text.class, Text.class);
MultipleOutputs.addNamedOutput(job, "out2", TextOutputFormat.class, Text.class, Text.class);
但是我得到了以下错误：
The method addNamedOutput(Job, String, Class<? ex
浏览 0提问于2016-07-02得票数 0
2回答
在我的hadoop代码中，我有4个reducer，我总是有4个output Files，这是很正常的，因为每个reducer将其结果放在一个文件中。这里我的问题是:我如何才能有且只有一个输出文件？
问题是，我有一个迭代的mapreduce作业，它接受一个输入文件，将其分成块，并将每个块提供给一个映射器，所以这就是为什么我必须收集所有的reducers结果并将它们放在一个输出文件中，以便以相同的方式将该输出文件划分为4个部分，然后每个部分都被提供给一个映射器，依此类推。
浏览 0提问于2014-03-11得票数 2
我在MapR5.0上运行Spark2.1
在本地模式下启动星火时，我会得到以下异常
我的火花默认(重要配置)
spark.sql.hive.metastore.version 0.13.1
spark.sql.hive.metastore.jars
/opt/mapr/lib/maprfs-5.0.0-mapr.jar:
/opt/mapr/hadoop/hadoop-0.20.2/conf:
/opt/mapr/hadoop/hadoo
浏览 0提问于2017-03-02得票数 2
我是Hadoop的新手。我正在试用字数统计程序。
现在，为了尝试多个输出文件，我使用了MultipleOutputFormat。这个链接帮助我做到了这一点。
在我的司机课上我有
MultipleOutputs.addNamedOutput(conf, "even",
org.apache.hadoop.mapred.TextOutputFormat.class, Text.class,
IntWritable.class);
MultipleOutputs.addNamedOutput(conf, "od
浏览 1提问于2010-08-16得票数 16
回答已采纳
1回答
如何在烫伤中存储输出
、、、、
我正在尝试将管道输出到不同的目录中，以便每个目录的输出将基于某些ids进行存储桶。因此，在一个普通的map reduce代码中，我将使用MultipleOutputs类，并且我将在reducer中执行类似这样的操作。
protected void reduce(final SomeKey key,
final Iterable<SomeValue> values,
final Context context) {
...
for (SomeValue value: values) {
String bucketId = compute
浏览 7提问于2015-02-06得票数 1
在我的MapReduce代码中，在还原器方面，我正在实现MultipleOutputs，并且我已经将input拆分附加到它上。我希望输出文件名作为我的键值，而不是keyvalue-r-00000。如何删除尾随值。这是我在减速机那边的代码。
String last = map.lastKey();
String tab2[] = last.split(",");
String line1 = "[" + tab2[2] + "," + tab2[3] + "," + tab2[8] + "]&
浏览 0提问于2014-12-15得票数 0
回答已采纳
我想写两种不同类型的输出从同一个还原器，到两个不同的目录。
我可以使用hadoop中的多输出特性来写入不同的文件，但它们都会转到同一个输出文件夹。
我希望将每个文件从相同的还原到不同的文件夹。
有办法这样做吗？
如果我尝试将"hello/testfile“作为第二个参数，它将显示invaid参数。所以我不能写到不同的文件夹。
如果上述情况不可能，映射程序是否可以只从输入文件夹读取特定文件？
请帮帮我。
提前感谢！
谢谢你的回复。我可以使用上述方法成功地读取一个文件。但在分布式模式下，我无法做到这一点。在减速机里，我设置了：
mos.getCollector(&
浏览 0提问于2012-07-14得票数 4
回答已采纳
我想知道，当多个节点尝试使用FileSystem append(Path p)方法访问HDFS上的同一个文件时，Hadoop是否具有某种同步保护？
我在工作的映射阶段将值附加到文本文件中，我想知道如果两个映射器同时尝试访问同一个文件会发生什么？我不希望它们相互覆盖，最好是让节点等待访问该文件，直到其他节点完成该文件时，以便在任何时候只有一个节点打开该文件。
BufferedWriter br=new BufferedWriter(new OutputStreamWriter(fs.append(new Path(tempFilePath))));
br.appe
浏览 2提问于2014-08-09得票数 0
回答已采纳
我试图从reducer向不同的文件写入(键和值)，但我只得到了键和值的一个输出文件。
public static class Reduce
extends Reducer<Text,Text,Text,Text> {
private MultipleOutputs <Text,Text>mos;
@Override
protected void setup(Context context) throws IOException, InterruptedException {
super.setup(context);
浏览 2提问于2014-03-13得票数 0
我正在使用新的Hadoop API编写一系列map-reduce作业。我计划使用将所有这些都放在一起，但我似乎找不到一种方法来从工作流中的map-reduce节点执行多个输出流。
我遇到过一个讨论在Oozie中使用多个输出的，但是除了创建一个Java任务并将其直接添加到Oozie pipline之外，没有其他解决方案。
有没有办法通过workflow.xml中的map-reduce节点来实现这一点
编辑：
Chris的解决方案确实奏效了，尽管我希望有更好的方法。以下是我所做的确切更改。
我在workflow.xml文件中添加了以下内容：
<property>
<na
浏览 4提问于2012-03-22得票数 5
回答已采纳
1回答
已安装但不能工作
、、
嗨，我正在处理分布式环境和安装hadoop，但是当我这样做时，我会出错。
fatal: [server2.impetus.co.in] => to use the 'ssh' connection type with passwords, you must install the sshpass program
上面写着安装sshpass所以我做了
[root@server2 mapr]# yum install sshpass
Loaded plugins: fastestmirror, refresh-packagekit, security
Setting up I
浏览 0提问于2015-11-07得票数 1
回答已采纳
当我尝试通过python进行钻取时，我得到了以下错误：
Traceback (most recent call last): File "/home/ubuntu/ChurnPrediction/OBDCtest.py", line 5, in <module> conn = pyodbc.connect("DSN=drill64", autocommit=True) pyodbc.Error: ('01000', "[01000] [unixODBC][Driver Manager]Can't open
浏览 0提问于2016-10-14得票数 0
1回答
正在尝试将NFS共享装载到Windows 2012 R2服务器，但不确定如何解释引发的错误。
以管理员身份运行powershell并输入以下命令...
PS C:\Windows\system32> whoami
domain\myuser
PS C:\Windows\system32> mount -o nolock mapr006:/mapr z:
New-PSDrive : Parameter cannot be processed because the parameter name 'o' is ambiguous. Possible matches
浏览 131提问于2019-08-21得票数 1
回答已采纳
当我使用MRUnit运行基本MultipleOutputs时，会得到以下异常：
java.lang.NullPointerException
at org.apache.hadoop.fs.Path.<init>(Path.java:105)
at org.apache.hadoop.fs.Path.<init>(Path.java:94)
at org.apache.hadoop.mapreduce.lib.output.FileOutputFormat.getDefaultWorkFile(FileOutputFormat.java:264)
at org.apac
浏览 4提问于2015-04-30得票数 0
回答已采纳
我是hadoop的新手。
我听说mapR是更好的挂载hadoop HDFS的方式而不是fuse。
但是大多数相关文章只是描述了mapR hadoop，而不是纯粹的apache hadoop。
谁有使用mapR安装纯apache hadoop的经验？
提前谢谢。
浏览 3提问于2013-06-17得票数 0
我使用的是Hadoop 0.20.203.0。我想输出到两个不同的文件，所以我尝试让MultipleOutputs工作。
下面是我的配置方法：
public static void main(String[] args) throws Exception {
Configuration conf = new Configuration();
String[] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs();
if (otherArgs.length != 2) {
System.err.println
浏览 2提问于2012-03-27得票数 0
回答已采纳
我目前有一个使用MultipleOutputs向多个HDFS位置发送数据的MapReduce作业。完成后，我将使用HBase客户端调用(在MR之外)向几个HBase表添加一些相同的元素。使用TableOutputFormat将HBase输出添加为额外的MultipleOutputs会很好。这样，我就可以分发我的HBase处理。
问题是，我不能让它工作。有没有人在MultipleOutputs中使用过TableOutputFormat ...？使用多个HBase输出？
基本上，我正在设置我的收藏家，就像这样....
Outputcollector<ImmutableBytesWritabl
浏览 0提问于2011-05-13得票数 4
回答已采纳
在我的map-reduce作业中，我使用4个reducer来实现reducer作业。因此，通过这样做，最终输出将生成4个part-files。
我的问题是，我如何将hadoop的配置设置为只输出一个部分文件，尽管hadoop使用4个reducers来工作？
浏览 0提问于2013-03-12得票数 4
回答已采纳
1回答
带卡夫卡错误的电火花流
、、、
在MapR环境下，我正在使用星火2.1.0版本的Kafka0.9，我试着从卡夫卡主题读到火花流。但是，当我运行Kafkautils createDirectStream命令时，会遇到以下错误。
z:org.apache.spark.streaming.kafka09.KafkaUtilsPythonHelper.createDirectStream.：调用py4j.protocol.Py4JError时出错跟踪: py4j.Py4JException:方法createDirectStream(类createDirectStream类，类java.util.HashMap)不存在
我正在
浏览 1提问于2018-03-02得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
