We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
您好: 我想读本地数据,在数据地址上加 file:// 或者 local:// 或者什么也不加,都报错: Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/fs/osshadoop/OSSFileSystemFactory 查询官方文档[https://ci.apache.org/projects/flink/flink-docs-stable/ops/filesystems/],确定读写local文件的前缀为“file://”,但是仅在linux的python环境尝试成功,但windows的java环境中始终失败,尝试如下: // 不成功 URL = "file://\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv"; // 不成功 URL = "file:///E:/SVN_CODE//alinkdemo/data/input/ChnSentiCorp_htl_all.csv"; // 不成功 URL = "file://E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv"; // 不成功 URL = "file:///E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv"; // 不成功 URL = "file:\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv"; // 不成功 URL = "file:///E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv"; // 不成功 URL = "file:///\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv"; // 不成功 URL = "file://\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv"; // 不成功 URL = "./data/input/ChnSentiCorp_htl_all.csv"; 请问这个问题怎么解决?
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/fs/osshadoop/OSSFileSystemFactory
// 不成功 URL = "file://\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:///E:/SVN_CODE//alinkdemo/data/input/ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file://E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:///E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:///\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file://\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "./data/input/ChnSentiCorp_htl_all.csv";
The text was updated successfully, but these errors were encountered:
No branches or pull requests
您好:
我想读本地数据,在数据地址上加 file:// 或者 local:// 或者什么也不加,都报错:
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/fs/osshadoop/OSSFileSystemFactory
查询官方文档[https://ci.apache.org/projects/flink/flink-docs-stable/ops/filesystems/],确定读写local文件的前缀为“file://”,但是仅在linux的python环境尝试成功,但windows的java环境中始终失败,尝试如下:
// 不成功 URL = "file://\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:///E:/SVN_CODE//alinkdemo/data/input/ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file://E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:///E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:///E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file:///\\E:\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "file://\\SVN_CODE\\alinkdemo\\data\\input\\ChnSentiCorp_htl_all.csv";
// 不成功 URL = "./data/input/ChnSentiCorp_htl_all.csv";
请问这个问题怎么解决?
The text was updated successfully, but these errors were encountered: