clear query| facets| time Search criteria: .   Results from 1 to 10 from 17 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-10290] Conversion error in StreamScan and BatchScan - Flink - [issue]
...`RowTypeInfo#equals()` only compares field types, and fields names are not considered. When checking the equality of `inputType` and `internalType`, we should compare both filed types and fi...    Author: wangsan , 2018-09-17, 07:34
[expand - 2 more] - Side effect of DataStreamRel#translateToPlan - Flink - [mail # dev]
...Hi Timo,What confused me is why we need to rebuild the pipeline each time we try to convert the RelNode into datastream.In case I have this code (I want to write the query result into two ta...
   Author: wangsan , 2018-08-22, 08:15
[FLINK-9794] JDBCOutputFormat does not consider idle connection and multithreads synchronization - Flink - [issue]
...Current implementation of  JDBCOutputFormat has two potential problems: 1. The Connection was established when JDBCOutputFormat is opened, and will be used all the time. But if this con...    Author: wangsan , 2018-08-05, 13:39
[expand - 2 more] - Confusions About JDBCOutputFormat - Flink - [mail # user]
...Well, I see. If the connection is established when writing data into DB, we need to cache received rows since last write. IMO, maybe we do not need to open connections repeatedly or introduc...
   Author: wangsan , 2018-07-11, 11:09
[expand - 2 more] - Question about Timestamp in Flink SQL - Flink - [mail # user]
...Hi Timo,What I am doing is extracting a timestamp field (may be string format as “2017-11-28 11:00:00” or a long value base on my current timezone) as Event time attribute. So In timestampAn...
   Author: wangsan , 2017-11-29, 09:51
[expand - 1 more] - Hive integration in table API and SQL - Flink - [mail # user]
...Hi Timo,Thanks for your reply. I do notice that the document says "A Table is always bound to a specific TableEnvironment. It is not possible to combine tables of different TableEnvironments...
   Author: wangsan , 2017-11-21, 03:41
[expand - 2 more] - Re:Re: Exception in BucketingSink when cancelling Flink job - Flink - [mail # user]
...Hi,'Join' method can be call with a timeout (as is called in TaskCanceler), so it won't be block forever if  the respective thread is in deadlock state. Maybe calling 'interrupt()' &nbs...
   Author: wangsan , 2017-09-29, 01:45
Question about job canceling in Flink - Flink - [mail # dev]
...Hi all,We are currently using BucketingSink to save data into HDFS in parquet format. But when the flink job was canceled, we always got Exception in BucketingSink¡¯s close method. The detai...
   Author: wangsan , 2017-09-27, 06:55