Hi,
When I launch Flink Application Cluster I keep getting a message
" Log file environment variable 'log.file' is not set."
I use console logging via log4j
and I read logs via yarn logs -applicationId
What's the purpose of log.file property?
What this file will contain and on which host sh
Hello,
Using Flink 1.8.1, I'm getting the following error:
*The TypeHint is using a generic variable.This is not supported,
generic types must be fully specified for the TypeHint.*
when trying to create a ListStateDescriptor with a generic type (full
sample code in attachment):
public class
I think this requirement can be satisfied by temporal table function [1],
am I missing anything?
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/streaming/temporal_tables.html#temporal-table-function
Best,
Kurt
On Sat, Mar 28, 2020 at 2:47 PM Maatary Okouya
wrote:
> Hi al
