How to print log in flink-streaming-java module

Hi all, when i add some log in org.apache.flink.streaming.api.environment( flink-streaming-java module ) and package flink-dist_2.11-1.10.0.jar, but it print nothing in jm or tm log. i did it like this: ``` public JobClient executeAsync(StreamGraph streamGraph) throws Exception { ch

flink1.9.1 RetractStream insert to mysql problem

Hi, I use flink 1.9.1, sql as follows, INSERT INTO a SELECT c1, c2, c3, c4 FROM ( SELECT *,ROW_NUMBER() OVER (PARTITION BY c1, c2, c3 ORDER BY c4 DESC) AS rownum" + FROM t)

Flink1.9.1 TableFunction Unable to serialize

Hi all When I use udf, it throws Unable to serialize Exception as follows: Exception in thread "main" org.apache.flink.table.api.ValidationException: Unable to serialize object 'UserTableFunction' of class ‘udtf.UserTableFunction'. at org.apache.flink.table.utils.EncodingUtils.encod

RichAsyncFunction Timeout

Hi ALL, When I use RichAsyncFunction read data from hbase, it always timeout after a few minutes. but the hbase connection is not close, it also can get data in the override method timeout. Following is the code, does somebody know why trigger timeout. ==

Re: Flink-JDBC JDBCUpsertTableSink keyFields Problem

of your sql to judge > whether your job is append only or has updates. If your job is append only, > that means no result need to be updated. > > If you still have problems, please post your sql and complete error message > to help people understand your use case. > > Pol

Flink-JDBC JDBCUpsertTableSink keyFields Problem

Hi When I use flink-jdbc JDBCUpsertTableSink for sink to mysql, the isAppendOnly is modified to ture, and keyFields is modified to null by StreamExecSink, but i want to upsert, Does this related to sql? the stack as follows: at sink.JDBCUpsertTableSink.setIsAppendOnly(JDBCUpsertTableSink.java:1

Flink SQL GroupBy Excption

Hi ALL, I have a problem when use flink sql, my code like this: ``` tEnv.registerDataStream(“mytable", actionStream, "uid, device_id, rowtime.rowtime”); ``` actionStream is kafka consumer,but this can not run,Exception as follow: ``` org.apache.flink.client.program.ProgramIn

Flink 1.9 Sql Rowtime Error

Hi All: I have define kafka connector Descriptor, and registe Table tEnv.connect(new Kafka() .version("universal") .topic(tableName) .startFromEarliest() .property("zookeeper.connect", “xxx") .property("bootstrap.servers", “xxx") .property("group.id"