我的輸入數據如下所示：id,vin,url,exteriorColor,interiorColor,design,transmission,lastcrawled,mileage,price,certified,dealerId,historyType,MSRP114722309,19XVC2F35PR012846,http://www.pohankaacura.com/auto/used-2017-acura-ilx-chantilly-va-near-buckeystown-md/24742881/,Modern Steel,graystone,0,8-Speed Dual-Clutch,2018-02-05 01:49:47 UTC,1646,22550,0,28453我想構建一個 Beam 管道，它將從 csv 文件中讀取這些數據，獲取 vin 并計算 vin 在文件中出現的次數。所以我想按 vin 分組并計算計數。我希望我的最終輸出在一個平面文件中。我錯過了注釋，所以我現在已經添加了它，但是我得到了一個不同的錯誤，我在這里也找不到解決方案。下面是我的代碼。import org.apache.beam.sdk.Pipeline;import org.apache.beam.sdk.io.TextIO;import org.apache.beam.sdk.options.PipelineOptions;import org.apache.beam.sdk.options.PipelineOptionsFactory;import org.apache.beam.sdk.transforms.*;import org.apache.beam.sdk.values.KV;public class p1 {    public static void main(String[] args) {        PipelineOptions options = PipelineOptionsFactory.create();        Pipeline p = Pipeline.create(options);        p.apply(TextIO.read().from("~/slow_storage_drive/beam_test_files/one_vin.csv"))                .apply("Parse&ConvertToKV", MapElements.via(                        new SimpleFunction<String, KV<String, Integer>>() {                            public KV<String, Integer> apply(String input){                                String[] split = input.split(",");                                String key = split[1];                                Integer value = 1;                                return KV.of(key, value);                            }                        }                ))我嘗試使用以下命令運行程序：mvn compile -X exec:java -Dexec.mainClass=p1 -Pdirect-runner我收到以下錯誤：[ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.6.0:java (default-cli) on project emr_beam_test: An exception occured while executing the Java class. java.lang.IllegalStateException: Invisible parameter type of p1$2 arg0 for public p1$2$DoFnInvoker(p1$2) -> [Help 1]我無法理解我做錯了什么。誰能幫幫我嗎？