我有一个问题，我尝试左加入2流。mergedkey有100多个相同密钥的列表，datastream只有1个与mergedkey相同密钥的列表。我想输入mergedkey与datastream合并后的endstream值。

//get DataStream 
        final KStream<String, GenericRecord> DataStream = builder.stream("Datastreams");
        // Transform merged to Equals Keys to DataStream.Iot
        final KStream<String, GenericRecord> mergedKey = mergedFoIObs
                .map((key, value) -> KeyValue.pair(value.get("Datastream").toString(), value)); 
        // Join the DataStream with MergedStream

        final KStream<String, String> mergedFoIObsData = mergedKey.leftJoin(
                DataStream,
            (value, data) -> {
                try {
                    if(data != null{
                        value.put("Datastream", data.toString());
                        JSONObject jo = (JSONObject) new JSONParser().parse(value.toString());
                        return jo.toJSONString();}
                      return null

                } catch (ParseException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                return null;

            }, JoinWindows.of(10000));

但我的问题是，在endstream中，我只得到一个具有正确值的列表，而其他列表的值为null。
taht意味着第一轮之后数据为空。
当我从datastream转换到ktable时，我遇到了一个问题：我没有得到正确的列表，但是只有37个列表，所以60个列表错了。
我希望你能帮助我。