Apache Beam抛出无法设置编码器（null）：java

Question

我是Apache Beam的新手，我正在尝试连接mysql数据库的google云实例。当我运行下面的代码段时，它会引发下面的异常。

    Logger logger = LoggerFactory.getLogger(GoogleSQLPipeline.class);

    PipelineOptions options = PipelineOptionsFactory.create();

    Pipeline dataflowPipeline = Pipeline.create();

    dataflowPipeline.apply(JdbcIO.<KV<Integer, String>>read().withCoder(KvCoder.of(VarIntCoder.of(), StringUtf8Coder.of()))
            .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration
                    .create("com.mysql.jdbc.Driver", "jdbc:mysql://<ip from google instance>:3306/foodmart")
                    .withUsername("root").withPassword("root"))
            .withQuery("select accouont_id,account_description  from account")
            .withRowMapper(new JdbcIO.RowMapper<KV<Integer, String>>() {
                @Override
                public KV<Integer, String> mapRow(ResultSet resultSet) throws Exception {
                    // TODO Auto-generated method stub
                    return KV.of(resultSet.getInt(1), resultSet.getString(2));
                }
            }));

    dataflowPipeline.run();

线程“main”java中出现异常。lang.IllegalArgumentException：无法在组织中设置编码器（null）。阿帕奇。梁sdk。重新包装。com.google.常见的基础前提条件。org上的checkArgument（prerequisions.java:122）。阿帕奇。梁sdk。价值观P收集。位于org的setCoder（PCollection.java:265）。阿帕奇。梁sdk。io。jdbc。JdbcIO$已读。在org上展开（JdbcIO.java:325）。阿帕奇。梁sdk。io。jdbc。JdbcIO$已读。在org上展开（JdbcIO.java:272）。阿帕奇。梁sdk。管道applyInternal（Pipeline.java:482）位于org。阿帕奇。梁sdk。管道applyTransform（Pipeline.java:422）位于org。阿帕奇。梁sdk。价值观P贝金。在org上应用（PBegin.java:44）。阿帕奇。梁sdk。管道在com上应用（Pipeline.java:164）。neudesic公司。com。GoogleSQLPipeline。main（GoogleSQLPipeline.java:24）

Answer 1

看起来，我对jar文件有一些问题。我已经重新创建了工作区和项目。然后，相同的代码运行时没有任何问题。

谢啦