[jira] [Created] (FLINK-14046) DDL property 'format.fields.#.type' should ignore case

2019-09-10 Thread hailong wang (Jira)
hailong wang created FLINK-14046: Summary: DDL property 'format.fields.#.type' should ignore case Key: FLINK-14046 URL: https://issues.apache.org/jira/browse/FLINK-14046 Project: Flink Issue

[jira] [Created] (FLINK-14064) Support Project Push down to LookupableTableSource

2019-09-11 Thread hailong wang (Jira)
hailong wang created FLINK-14064: Summary: Support Project Push down to LookupableTableSource Key: FLINK-14064 URL: https://issues.apache.org/jira/browse/FLINK-14064 Project: Flink Issue Type

[jira] [Created] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

2019-09-29 Thread hailong wang (Jira)
hailong wang created FLINK-14273: Summary: when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing Key: FLINK-14273 URL: https://issues.apache.

[jira] [Created] (FLINK-14274) RuntimeContext can be get from FunctionContext

2019-09-29 Thread hailong wang (Jira)
hailong wang created FLINK-14274: Summary: RuntimeContext can be get from FunctionContext Key: FLINK-14274 URL: https://issues.apache.org/jira/browse/FLINK-14274 Project: Flink Issue Type: I

[jira] [Created] (FLINK-14275) Window Aggregate function support a RichFunction

2019-09-29 Thread hailong wang (Jira)
hailong wang created FLINK-14275: Summary: Window Aggregate function support a RichFunction Key: FLINK-14275 URL: https://issues.apache.org/jira/browse/FLINK-14275 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14274) RuntimeContext can be get from FunctionContext

2019-09-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940328#comment-16940328 ] hailong wang commented on FLINK-14274: -- Thank you for your reply,  I agree this is

[jira] [Commented] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

2019-09-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940637#comment-16940637 ] hailong wang commented on FLINK-14273: -- I'd like to fix this problem, thx. > when

[jira] [Commented] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

2019-09-30 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940741#comment-16940741 ] hailong wang commented on FLINK-14273: -- Hi Jark Wu, Thank you for your reply. Or we

[jira] [Commented] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

2019-09-30 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941378#comment-16941378 ] hailong wang commented on FLINK-14273: -- Thank you. Jark Wu, I had submit a PR, I ap

[jira] [Commented] (FLINK-14275) Window Aggregate function support a RichFunction

2019-10-12 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950055#comment-16950055 ] hailong wang commented on FLINK-14275: -- Hi, [~jark], thanks for you tip. In my side

[jira] [Commented] (FLINK-14275) Window Aggregate function support a RichFunction

2019-10-12 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950225#comment-16950225 ] hailong wang commented on FLINK-14275: -- Hi [~jark], I have some confusion. Accordin

[jira] [Commented] (FLINK-14242) Collapse task names in job graph visualization if too long

2019-10-14 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950952#comment-16950952 ] hailong wang commented on FLINK-14242: -- For now, SQL jobs always have quite long na

[jira] [Commented] (FLINK-11203) FunctionContext of AggregateFunction will not be initialized for window GroupBy

2019-10-14 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951466#comment-16951466 ] hailong wang commented on FLINK-11203: --  Hi, [~hequn8128], can we do this according

[jira] [Commented] (FLINK-20440) `LAST_VALUE` aggregate function can not be used in hop window

2020-12-01 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241472#comment-17241472 ] hailong wang commented on FLINK-20440: -- Hi [~zouyunhe] ,this is duplicate with  [FL

[jira] [Commented] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format

2020-12-02 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242483#comment-17242483 ] hailong wang commented on FLINK-20454: -- Hi [~jark] ,can I take this issue~ > Allow

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

2020-12-07 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19659: - Description: Currently, Array type supports `equals` and `not_equals` when element types are th

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

2020-12-07 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19659: - Description: Currently, Array type supports `equals` and `not_equals` when element types are th

[jira] [Commented] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249744#comment-17249744 ] hailong wang commented on FLINK-19691: -- Thanks [~873925...@qq.com]. We first need

[jira] [Commented] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-15 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17249746#comment-17249746 ] hailong wang commented on FLINK-19691: -- Hi [~jark] , WDYT? If this is reasonable,

[jira] [Commented] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-10-31 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224063#comment-17224063 ] hailong wang commented on FLINK-19905: -- Thanks [~lsy] for reporting this. For `Jdbc

[jira] [Updated] (FLINK-19906) Incorrect result when compare two binary fields

2020-10-31 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19906: - Summary: Incorrect result when compare two binary fields (was: Incorrect result when compare tw

[jira] [Created] (FLINK-19906) Incorrect result when compare two binary field

2020-10-31 Thread hailong wang (Jira)
hailong wang created FLINK-19906: Summary: Incorrect result when compare two binary field Key: FLINK-19906 URL: https://issues.apache.org/jira/browse/FLINK-19906 Project: Flink Issue Type: Bu

[jira] [Updated] (FLINK-19906) Incorrect result when compare two binary fields

2020-10-31 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19906: - Affects Version/s: (was: 1.11.0) 1.12.0 1.11.2

[jira] [Updated] (FLINK-19906) Incorrect result when compare two binary fields

2020-10-31 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19906: - Labels: pull-request-available (was: ) > Incorrect result when compare two binary fields >

[jira] [Created] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-01 Thread hailong wang (Jira)
hailong wang created FLINK-19912: Summary: Support ignoreParseErrors option for json serializationSchema Key: FLINK-19912 URL: https://issues.apache.org/jira/browse/FLINK-19912 Project: Flink

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-02 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224679#comment-17224679 ] hailong wang commented on FLINK-19912: -- When MapData key is null, This may cause so

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-02 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224729#comment-17224729 ] hailong wang commented on FLINK-19912: -- Hi [~jark], It is not a case occurred in my

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-03 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225274#comment-17225274 ] hailong wang commented on FLINK-19912: -- Yes, It is necessary to have a investigate.

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-04 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225995#comment-17225995 ] hailong wang commented on FLINK-19912: -- Thank you for your advice [~jark]. For th

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-04 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226042#comment-17226042 ] hailong wang commented on FLINK-19912: -- So I prefer to the second option, which ign

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-04 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226264#comment-17226264 ] hailong wang commented on FLINK-19912: -- In JSON format, How to serialize null key

[jira] [Commented] (FLINK-19912) JSON format fails to serialize map value with null keys

2020-11-04 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226488#comment-17226488 ] hailong wang commented on FLINK-19912: -- +1 to do that, It's more flexible. [~jark]

[jira] [Commented] (FLINK-19995) 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more than one exception

2020-11-05 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226717#comment-17226717 ] hailong wang commented on FLINK-19995: -- I built the master, and made sure that `fl

[jira] [Created] (FLINK-20034) Add maxwell-json format document

2020-11-06 Thread hailong wang (Jira)
hailong wang created FLINK-20034: Summary: Add maxwell-json format document Key: FLINK-20034 URL: https://issues.apache.org/jira/browse/FLINK-20034 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-20037) there is a comment problem in fromValues(AbstractDataType rowType, Object... values) method of TableEnvironment

2020-11-06 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227686#comment-17227686 ] hailong wang commented on FLINK-20037: -- Hi [~yandufeng], Thank you for reporting th

[jira] [Commented] (FLINK-18778) Support the SupportsProjectionPushDown interface for LookupTableSource

2020-11-10 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229199#comment-17229199 ] hailong wang commented on FLINK-18778: -- Hi [~jark], could you assign this to me? >

[jira] [Created] (FLINK-20089) Avro format fails to serialize map value with null keys

2020-11-11 Thread hailong wang (Jira)
hailong wang created FLINK-20089: Summary: Avro format fails to serialize map value with null keys Key: FLINK-20089 URL: https://issues.apache.org/jira/browse/FLINK-20089 Project: Flink Issue

[jira] [Created] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

2020-11-11 Thread hailong wang (Jira)
hailong wang created FLINK-20091: Summary: Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema Key: FLINK-20091 URL: https://issues.apache.org/jira/browse/FLINK-20091 Project: Fli

[jira] [Commented] (FLINK-20102) Update HBase connector documentation for HBase 2.x supporting

2020-11-12 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230486#comment-17230486 ] hailong wang commented on FLINK-20102: -- Hello,I can take it ~ > Update HBase conne

[jira] [Commented] (FLINK-20101) Fix the wrong documentation of FROM_UNIXTIME function

2020-11-12 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230488#comment-17230488 ] hailong wang commented on FLINK-20101: -- I can take it ~ > Fix the wrong documentat

[jira] [Commented] (FLINK-20106) flink 1.10 kafka connector通用版本,使用FlinkFixedPartitioner分区器,获取不到parallelInstanceId,parallelInstanceId始终是0,导致数据都被sink到一个kafka 分区上了

2020-11-12 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230573#comment-17230573 ] hailong wang commented on FLINK-20106: -- Hi [~赵富午], We should use English here for t

[jira] [Commented] (FLINK-20109) java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

2020-11-12 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230606#comment-17230606 ] hailong wang commented on FLINK-20109: -- Hi [~aaronxu], We should use English here f

[jira] [Created] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

2020-11-12 Thread hailong wang (Jira)
hailong wang created FLINK-20110: Summary: Support 'merge' method for first_value and last_value UDAF Key: FLINK-20110 URL: https://issues.apache.org/jira/browse/FLINK-20110 Project: Flink Is

[jira] [Created] (FLINK-20111) Update the description of UDAF `merge` method in User-defined function document

2020-11-12 Thread hailong wang (Jira)
hailong wang created FLINK-20111: Summary: Update the description of UDAF `merge` method in User-defined function document Key: FLINK-20111 URL: https://issues.apache.org/jira/browse/FLINK-20111 Proje

[jira] [Commented] (FLINK-20101) Fix the wrong documentation of FROM_UNIXTIME function

2020-11-12 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230691#comment-17230691 ] hailong wang commented on FLINK-20101: -- This is duplicate of https://issues.apache

[jira] [Commented] (FLINK-19433) An Error example of FROM_UNIXTIME function in document

2020-11-12 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230693#comment-17230693 ] hailong wang commented on FLINK-19433: -- Cherry pick to release-1.11, https://github

[jira] [Commented] (FLINK-20129) Create a zh download page for all optional sql client components

2020-11-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231239#comment-17231239 ] hailong wang commented on FLINK-20129: -- Hi [~dwysakowicz], can I take this issue ?

[jira] [Created] (FLINK-20146) Update zh connector and format dependencies link

2020-11-13 Thread hailong wang (Jira)
hailong wang created FLINK-20146: Summary: Update zh connector and format dependencies link Key: FLINK-20146 URL: https://issues.apache.org/jira/browse/FLINK-20146 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20146) Update zh connector and format dependencies link

2020-11-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231956#comment-17231956 ] hailong wang commented on FLINK-20146: -- Sorry, It can be included  by FLINK-20129

[jira] [Closed] (FLINK-20146) Update zh connector and format dependencies link

2020-11-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang closed FLINK-20146. Resolution: Duplicate > Update zh connector and format dependencies link > ---

[jira] [Created] (FLINK-20163) Translate page 'raw type' into Chinese

2020-11-14 Thread hailong wang (Jira)
hailong wang created FLINK-20163: Summary: Translate page 'raw type' into Chinese Key: FLINK-20163 URL: https://issues.apache.org/jira/browse/FLINK-20163 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-20163) Translate page 'raw format' into Chinese

2020-11-15 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-20163: - Summary: Translate page 'raw format' into Chinese (was: Translate page 'raw type' into Chinese)

[jira] [Commented] (FLINK-20163) Translate page 'raw format' into Chinese

2020-11-15 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232233#comment-17232233 ] hailong wang commented on FLINK-20163: -- Hi [~jark], Could you help to  assign this

[jira] [Commented] (FLINK-19906) Incorrect result when compare two binary fields

2020-11-16 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233236#comment-17233236 ] hailong wang commented on FLINK-19906: -- okay [~jark], I will do it later. > Incorr

[jira] [Commented] (FLINK-19906) Incorrect result when compare two binary fields

2020-11-16 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233258#comment-17233258 ] hailong wang commented on FLINK-19906: -- Created for release-1.11~ https://github.c

[jira] [Created] (FLINK-20250) NPE when invoking AsyncLookupJoinRunner#close method

2020-11-19 Thread hailong wang (Jira)
hailong wang created FLINK-20250: Summary: NPE when invoking AsyncLookupJoinRunner#close method Key: FLINK-20250 URL: https://issues.apache.org/jira/browse/FLINK-20250 Project: Flink Issue Ty

[jira] [Commented] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

2020-11-19 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235895#comment-17235895 ] hailong wang commented on FLINK-20110: -- [~jark] Yes, I can take it, thanks for assi

[jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

2020-11-19 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-20110: - Fix Version/s: 1.13.0 > Support 'merge' method for first_value and last_value UDAF > ---

[jira] [Commented] (FLINK-20314) Empty Calc is not removed by CalcRemoveRule

2020-11-24 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238113#comment-17238113 ] hailong wang commented on FLINK-20314: -- This is for we push watermark acrossing `Fl

[jira] [Commented] (FLINK-20250) NPE when invoking AsyncLookupJoinRunner#close method

2020-11-24 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238225#comment-17238225 ] hailong wang commented on FLINK-20250: -- Sure [~nicholasjiang], We should also add a

[jira] [Commented] (FLINK-20250) NPE when invoking AsyncLookupJoinRunner#close method

2020-11-24 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238226#comment-17238226 ] hailong wang commented on FLINK-20250: -- Hi [~jark], Could you help to assign this t

[jira] [Created] (FLINK-20375) Add a

2020-11-26 Thread hailong wang (Jira)
hailong wang created FLINK-20375: Summary: Add a Key: FLINK-20375 URL: https://issues.apache.org/jira/browse/FLINK-20375 Project: Flink Issue Type: Improvement Reporter: hailong w

[jira] [Updated] (FLINK-20375) Add a switch to control the operator name in SQL

2020-11-26 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-20375: - Component/s: Table SQL / Runtime Description: >From the user-zh email: [http://apache-flink

[jira] [Commented] (FLINK-20375) Add a switch to control the operator name in SQL

2020-11-26 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239335#comment-17239335 ] hailong wang commented on FLINK-20375: -- Thanks for your reminder [~jark], It did tr

[jira] [Commented] (FLINK-20375) Add a switch to control the operator name in SQL

2020-11-26 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239524#comment-17239524 ] hailong wang commented on FLINK-20375: -- Yes, I think this a good way. For if we jus

[jira] [Created] (FLINK-20388) Supports users setting operators' metrics name

2020-11-26 Thread hailong wang (Jira)
hailong wang created FLINK-20388: Summary: Supports users setting operators' metrics name Key: FLINK-20388 URL: https://issues.apache.org/jira/browse/FLINK-20388 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2020-11-26 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239548#comment-17239548 ] hailong wang commented on FLINK-20386: -- Yes, currently we just validate between the

[jira] [Updated] (FLINK-19266) Test fail when running azure in AbstractCloseableRegistryTest#testClose

2020-09-16 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19266: - Summary: Test fail when running azure in AbstractCloseableRegistryTest#testClose (was: Test fa

[jira] [Created] (FLINK-19266) Test fail when run azure in AbstractCloseableRegistryTest#testClose

2020-09-16 Thread hailong wang (Jira)
hailong wang created FLINK-19266: Summary: Test fail when run azure in AbstractCloseableRegistryTest#testClose Key: FLINK-19266 URL: https://issues.apache.org/jira/browse/FLINK-19266 Project: Flink

[jira] [Updated] (FLINK-19266) Test fail when running azure in AbstractCloseableRegistryTest#testClose

2020-09-16 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19266: - Description: Test fail when running azure, the whole stack, {code:java} java.lang.AssertionError

[jira] [Created] (FLINK-19334) Translate page 'Streaming File Sink' into Chinese

2020-09-21 Thread hailong wang (Jira)
hailong wang created FLINK-19334: Summary: Translate page 'Streaming File Sink' into Chinese Key: FLINK-19334 URL: https://issues.apache.org/jira/browse/FLINK-19334 Project: Flink Issue Type:

[jira] [Commented] (FLINK-19334) Translate page 'Streaming File Sink' into Chinese

2020-09-21 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199799#comment-17199799 ] hailong wang commented on FLINK-19334: -- Hi [~jark], Could you please assgin it to m

[jira] [Closed] (FLINK-19266) Test fail when running azure in AbstractCloseableRegistryTest#testClose

2020-09-22 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang closed FLINK-19266. Resolution: Duplicate > Test fail when running azure in AbstractCloseableRegistryTest#testClose >

[jira] [Commented] (FLINK-19266) Test fail when running azure in AbstractCloseableRegistryTest#testClose

2020-09-22 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200085#comment-17200085 ] hailong wang commented on FLINK-19266: -- Thanks for reminding me. I close it. > Tes

[jira] [Created] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

2020-09-22 Thread hailong wang (Jira)
hailong wang created FLINK-19362: Summary: Remove confusing comment for `DOT` operator codegen Key: FLINK-19362 URL: https://issues.apache.org/jira/browse/FLINK-19362 Project: Flink Issue Typ

[jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

2020-09-22 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19362: - Description: `DOT` operator codegen (ExprCodeGenerator#generateCallExpression) has comment as f

[jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

2020-09-22 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19362: - Description: `DOT` operator codegen (ExprCodeGenerator#generateCallExpression) has comment as f

[jira] [Commented] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

2020-09-22 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200100#comment-17200100 ] hailong wang commented on FLINK-19362: -- Correct me if I am wrong, Thanks. > Remove

[jira] [Created] (FLINK-19363) Code of split method grows beyond 64 KB

2020-09-22 Thread hailong wang (Jira)
hailong wang created FLINK-19363: Summary: Code of split method grows beyond 64 KB Key: FLINK-19363 URL: https://issues.apache.org/jira/browse/FLINK-19363 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-23 Thread hailong wang (Jira)
hailong wang created FLINK-19386: Summary: Remove legacy table planner dependecy from connectors and formats Key: FLINK-19386 URL: https://issues.apache.org/jira/browse/FLINK-19386 Project: Flink

[jira] [Commented] (FLINK-19386) Remove legacy table planner dependecy from connectors and formats

2020-09-24 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201345#comment-17201345 ] hailong wang commented on FLINK-19386: -- Hi [~jark], What do you think of it? > Rem

[jira] [Closed] (FLINK-14064) Support Project Push down to LookupableTableSource

2019-12-16 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang closed FLINK-14064. Resolution: Invalid > Support Project Push down to LookupableTableSource > ---

[jira] [Created] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig

2019-12-25 Thread hailong wang (Jira)
hailong wang created FLINK-15393: Summary: Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig Key: FLINK-15393 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Commented] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig

2019-12-25 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003449#comment-17003449 ] hailong wang commented on FLINK-15393: -- Thank you [~jark]. I understand what you me

[jira] [Commented] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig

2019-12-25 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003491#comment-17003491 ] hailong wang commented on FLINK-15393: -- Oh, Thank you very much [~jark]. I have som

[jira] [Comment Edited] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig

2019-12-25 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003491#comment-17003491 ] hailong wang edited comment on FLINK-15393 at 12/26/19 6:54 AM: --

[jira] [Created] (FLINK-15408) Interval join support no equi-condition

2019-12-26 Thread hailong wang (Jira)
hailong wang created FLINK-15408: Summary: Interval join support no equi-condition Key: FLINK-15408 URL: https://issues.apache.org/jira/browse/FLINK-15408 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-26 Thread hailong wang (Jira)
hailong wang created FLINK-15409: Summary: Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement Key: FLINK-15409 URL: https://issues.apache.org/jira/browse/FLINK-1540

[jira] [Commented] (FLINK-15408) Interval join support no equi-condition

2019-12-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004110#comment-17004110 ] hailong wang commented on FLINK-15408: -- Yes, you are right, Thank you [~jark]. I cl

[jira] [Closed] (FLINK-15408) Interval join support no equi-condition

2019-12-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang closed FLINK-15408. Resolution: Later > Interval join support no equi-condition >

[jira] [Commented] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004200#comment-17004200 ] hailong wang commented on FLINK-15409: -- Hi [~jark], It is my pleasure to take it. T

[jira] [Commented] (FLINK-15408) Interval join support no equi-condition

2019-12-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004201#comment-17004201 ] hailong wang commented on FLINK-15408: -- Oh [~jark], I got it wrong :D. Thank you fo

[jira] [Created] (FLINK-15434) testResourceManagerConnectionAfterRegainingLeadership test fail when run azure

2019-12-28 Thread hailong wang (Jira)
hailong wang created FLINK-15434: Summary: testResourceManagerConnectionAfterRegainingLeadership test fail when run azure Key: FLINK-15434 URL: https://issues.apache.org/jira/browse/FLINK-15434 Proje

[jira] [Commented] (FLINK-15434) testResourceManagerConnectionAfterRegainingLeadership test fail when run azure

2019-12-31 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006260#comment-17006260 ] hailong wang commented on FLINK-15434: -- I reproduced this problem on my laptop, and

[jira] [Commented] (FLINK-15434) testResourceManagerConnectionAfterRegainingLeadership test fail when run azure

2020-01-01 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006533#comment-17006533 ] hailong wang commented on FLINK-15434: -- Hi [~chesnay], Could you help me to have a

[jira] [Created] (FLINK-15479) Override explainSource method in JDBCTableSource

2020-01-05 Thread hailong wang (Jira)
hailong wang created FLINK-15479: Summary: Override explainSource method in JDBCTableSource Key: FLINK-15479 URL: https://issues.apache.org/jira/browse/FLINK-15479 Project: Flink Issue Type:

[jira] [Commented] (FLINK-15479) Override explainSource method in JDBCTableSource

2020-01-05 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008578#comment-17008578 ] hailong wang commented on FLINK-15479: -- >From my side, there are two aspects need t

[jira] [Comment Edited] (FLINK-15479) Override explainSource method in JDBCTableSource

2020-01-05 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008578#comment-17008578 ] hailong wang edited comment on FLINK-15479 at 1/6/20 6:49 AM:

[jira] [Issue Comment Deleted] (FLINK-15479) Override explainSource method in JDBCTableSource

2020-01-06 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-15479: - Comment: was deleted (was: From my side, there are two aspects need to be discussed: 1、How to f

[jira] [Commented] (FLINK-15434) testResourceManagerConnectionAfterRegainingLeadership test fail when run azure

2020-01-08 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011503#comment-17011503 ] hailong wang commented on FLINK-15434: -- Hi [~gjy] , Thank you for assigning this ti

  1   2   3   >