> symbol: method $(java.lang.String)
> location: class esl.job.cag.verwerkingstijden.CagVerwerkingsTijden
What is esl.job.cag.verwerkingstijden.CagVerwerkingsTijden? Sounds like a
bad import? Also, have you checked you have Flink deps aligned?
On Mon, Feb 14, 2022 at 3:17 PM HG <hanspeter.sl...@gmail.com> wrote:
>
> Hi,
>
> When I do :
>
> Table counts = t
> .groupBy($("transactionId"))
> .select($("transactionId"),
> $("handlingTime").sum().as("summedhandlingTime"));
>
> The code below fails with :
>
> cannot find symbol
> .select($("transactionId"),
> $("handlingTime").sum().as("summedhandlingTime"));
> ^
> symbol: method $(java.lang.String)
> location: class esl.job.cag.verwerkingstijden.CagVerwerkingsTijden
>
>
> The same is true when I copy the code below from
> https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/common/
>
> DataStream<Tuple2<Integer, String>> stream1 = env.fromElements(new
> Tuple2<>(1, "hello"));
> DataStream<Tuple2<Integer, String>> stream2 = env.fromElements(new
> Tuple2<>(1, "hello"));
>
> // explain Table API
> Table table1 = tableEnv.fromDataStream(stream1, $("count"),
> $("word"));
> Table table2 = tableEnv.fromDataStream(stream2, $("count"),
> $("word"));
> Table table = table1
> .where($("word").like("F%"))
> .unionAll(table2);
>
>
> Anyone a clue?
>
>
> Regards Hans
>
>
