Thank you for the clarification. That is what I was thinking.
Regards.
On Sat, Apr 17, 2021 at 3:24 AM Arvid Heise wrote:
> Hi Vishal,
>
> no afaik Flink only cancels on restore from a checkpoint or savepoint
> (manual or automatic). That's what I meant with
>
>> they may linger for a longer t
I have tried that too For example :
/tableEnv.createTemporaryView("CreditDetails", creditStream);
tableEnv.executeSql(
"CREATE TABLE output(loanId VARCHAR) with ('connector.type' = 'filesystem',"
+ "'connector.path' = 'file:///path/Downloads/1',"
+ "'format.type' = 'csv')");
Table creditD
Have you tried by using the command?
flink-1.12.2 ./bin/flink run examples/streaming/WordCount.jar --input
file://(file location) --output file://(file location)
for example:
./bin/flink run
/Users/abubakarsiddiqurrahman/Documents/flink/examples/streaming/WordCount.jar
--input
file:///Users/abu
Thanks a lot for the logs. I filed a ticket to track the issue:
https://issues.apache.org/jira/browse/FLINK-22331
I hope somebody with M1 hardware will soon have time to look into it.
On Fri, Apr 16, 2021 at 11:02 AM Klemens Muthmann <
klemens.muthm...@cyface.de> wrote:
> Hi,
>
> I’ve appended yo
Hi Team,
Flink influx db connector `flink-connector-influxdb_2.1` is not present in
Maven , can you please upload the same
https://repo.maven.apache.org/maven2/org/apache/bahir/
Regards,
Vinay Patil
Hi Vishal,
no afaik Flink only cancels on restore from a checkpoint or savepoint
(manual or automatic). That's what I meant with
> they may linger for a longer time if you stop an application entirely (for
> example for an upgrade).
>
Your upgraded application will hopefully be up before Kafka t
