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

2021-05-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343867#comment-17343867 ] hailong wang commented on FLINK-20454: -- [~caozhen1937] Sure, thanks for taking this

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

2021-01-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263988#comment-17263988 ] hailong wang commented on FLINK-20454: -- Yes, the avro reader schema will be wrong t

[jira] [Commented] (FLINK-20851) flink datagen produce NULL value

2021-01-05 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259372#comment-17259372 ] hailong wang commented on FLINK-20851: -- Could you make sure your flink version is 1

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

2021-01-05 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259371#comment-17259371 ] hailong wang commented on FLINK-20454: -- Sure. For this, Maybe we should use writeSc

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

2021-01-05 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258956#comment-17258956 ] hailong wang commented on FLINK-20454: -- I want to discuss what metadata make sense

[jira] [Created] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord

2021-01-05 Thread hailong wang (Jira)
hailong wang created FLINK-20853: Summary: Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord Key: FLINK-20853 URL: https://issues.apache.org/jira/browse/FLINK-20853

[jira] [Commented] (FLINK-17767) Add offset support for TUMBLE, HOP, SESSION group windows

2020-12-27 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17255455#comment-17255455 ] hailong wang commented on FLINK-17767: -- Great!It good to be included in TVF. I can

[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-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] [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-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] [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-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] [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-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] [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] [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] [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] [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] [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-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] [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-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] [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-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] [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-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] [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] [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] [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-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-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] [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-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] [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] [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] [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] [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-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-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] [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] [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] [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] [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] [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-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] [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-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) 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=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-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-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-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] [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] [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] [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] [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: - Summary: Incorrect result when compare two binary fields (was: Incorrect result when compare tw

[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] [Closed] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

2020-10-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang closed FLINK-19753. Resolution: Not A Problem > Introduce 'STRCMP' function to compare between two string fields > ---

[jira] [Commented] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

2020-10-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223435#comment-17223435 ] hailong wang commented on FLINK-19753: -- The compare operator convert the result of

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

2020-10-29 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: - Fix Version/s: (was: 1.12.0) 1.13.0 > Array type supports equals and not_

[jira] [Commented] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

2020-10-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222874#comment-17222874 ] hailong wang commented on FLINK-19753: -- Hi [~jark] Is it reasonable to support STRC

[jira] [Commented] (FLINK-19861) Improve the document of now() function

2020-10-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222871#comment-17222871 ] hailong wang commented on FLINK-19861: -- Okay, I open a pr for it. > Improve the do

[jira] [Commented] (FLINK-19861) Improve the document of now() function

2020-10-29 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222832#comment-17222832 ] hailong wang commented on FLINK-19861: -- I prefer to improve as follow, {code:java}

[jira] [Created] (FLINK-19861) Improve the document of now() function

2020-10-28 Thread hailong wang (Jira)
hailong wang created FLINK-19861: Summary: Improve the document of now() function Key: FLINK-19861 URL: https://issues.apache.org/jira/browse/FLINK-19861 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-19587) Error result when casting binary type as varchar

2020-10-28 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222158#comment-17222158 ] hailong wang commented on FLINK-19587: -- Opened a new pull request, https://github.

[jira] [Commented] (FLINK-19587) Error result when casting binary type as varchar

2020-10-28 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222044#comment-17222044 ] hailong wang commented on FLINK-19587: -- [~jark] OK, I will open a new pr soon. > E

[jira] [Commented] (FLINK-19587) Error result when casting binary type as varchar

2020-10-28 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222009#comment-17222009 ] hailong wang commented on FLINK-19587: -- I just saw you have did it. I closed it. :D

[jira] [Commented] (FLINK-19587) Error result when casting binary type as varchar

2020-10-28 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222007#comment-17222007 ] hailong wang commented on FLINK-19587: -- Hi [~jark], I open a pr for 1.11. https://

[jira] [Commented] (FLINK-19777) Fix NullPointException for WindowOperator.close()

2020-10-25 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220443#comment-17220443 ] hailong wang commented on FLINK-19777: -- You are right. More correctly, the dispose

[jira] [Commented] (FLINK-19777) Fix NullPointException for WindowOperator.close()

2020-10-23 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219638#comment-17219638 ] hailong wang commented on FLINK-19777: -- Hi [~jark], I wonder under what circumstanc

[jira] [Updated] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

2020-10-21 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19753: - Issue Type: New Feature (was: Improvement) > Introduce 'STRCMP' function to compare between two

[jira] [Updated] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

2020-10-21 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19753: - Description: 'STRCMP' function have be supported by mysql[1] and calcite[2] which is useful to

[jira] [Updated] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

2020-10-21 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19753: - Description: 'STRCMP' function have be supported by mysql[1] and calcite[2] which is useful to

[jira] [Created] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

2020-10-21 Thread hailong wang (Jira)
hailong wang created FLINK-19753: Summary: Introduce 'STRCMP' function to compare between two string fields Key: FLINK-19753 URL: https://issues.apache.org/jira/browse/FLINK-19753 Project: Flink

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

2020-10-17 Thread hailong wang (Jira)
hailong wang created FLINK-19691: Summary: Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector Key: FLINK-19691 URL: https://issues.apache.org/jira/browse/FLINK-19691

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-10-17 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215819#comment-17215819 ] hailong wang commented on FLINK-19687: -- Hi [~xiaozilong], the physical execution pl

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

2020-10-16 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17215374#comment-17215374 ] hailong wang commented on FLINK-19659: -- WDYT [~jark],  CC in your free time~ > Arr

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

2020-10-16 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: - Fix Version/s: 1.12.0 > Array type supports equals and not_equals operator when element types ar

[jira] [Updated] (FLINK-19660) Translate page 'table_environment.zh.md' into Chinese

2020-10-15 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19660: - Component/s: API / Python > Translate page 'table_environment.zh.md' into Chinese >

[jira] [Commented] (FLINK-19660) Translate page 'table_environment.zh.md' into Chinese

2020-10-15 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214756#comment-17214756 ] hailong wang commented on FLINK-19660: -- Hi [~dianfu], Could you please assign this

[jira] [Created] (FLINK-19660) Translate page 'table_environment.zh.md' into Chinese

2020-10-15 Thread hailong wang (Jira)
hailong wang created FLINK-19660: Summary: Translate page 'table_environment.zh.md' into Chinese Key: FLINK-19660 URL: https://issues.apache.org/jira/browse/FLINK-19660 Project: Flink Issue T

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

2020-10-15 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 is the same

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

2020-10-15 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-10-15 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 is the same

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

2020-10-15 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 is the same

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

2020-10-15 Thread hailong wang (Jira)
hailong wang created FLINK-19659: Summary: Array type supports equals and not_equals operator when element types are different but castable Key: FLINK-19659 URL: https://issues.apache.org/jira/browse/FLINK-19659

[jira] [Commented] (FLINK-19618) Broken link in docs

2020-10-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213549#comment-17213549 ] hailong wang commented on FLINK-19618: -- [~dian.fu] Yes, Thank you for assgining to

[jira] [Updated] (FLINK-19618) Broken link in docs

2020-10-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19618: - Labels: (was: test) > Broken link in docs > --- > > Key: FLINK

[jira] [Updated] (FLINK-19618) Broken link in docs

2020-10-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19618: - Labels: test (was: ) > Broken link in docs > --- > > Key: FLINK

[jira] [Updated] (FLINK-19619) Test failed in Azure For EmulatedPubSubSourceTest

2020-10-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19619: - Issue Type: Bug (was: Test) > Test failed in Azure For EmulatedPubSubSourceTest > -

[jira] [Created] (FLINK-19619) Test failed in Azure For EmulatedPubSubSourceTest

2020-10-13 Thread hailong wang (Jira)
hailong wang created FLINK-19619: Summary: Test failed in Azure For EmulatedPubSubSourceTest Key: FLINK-19619 URL: https://issues.apache.org/jira/browse/FLINK-19619 Project: Flink Issue Type:

[jira] [Updated] (FLINK-19618) Broken link in docs

2020-10-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19618: - Summary: Broken link in docs (was: Boken link in docs) > Broken link in docs >

[jira] [Updated] (FLINK-19618) Boken link in docs

2020-10-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19618: - Description: I run the `check_links` shell and found the following broken link, {code:java} ERRO

[jira] [Updated] (FLINK-19618) Boken link in docs

2020-10-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19618: - Description: I run the `check_links` shell and found the following broken link, {code:java} ERRO

[jira] [Created] (FLINK-19618) Boken link in docs

2020-10-13 Thread hailong wang (Jira)
hailong wang created FLINK-19618: Summary: Boken link in docs Key: FLINK-19618 URL: https://issues.apache.org/jira/browse/FLINK-19618 Project: Flink Issue Type: Bug Components: Docu

[jira] [Commented] (FLINK-19587) Error result when casting binary type as varchar

2020-10-13 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212879#comment-17212879 ] hailong wang commented on FLINK-19587: -- Yes [~jark] , Thank you for assigning to me

  1   2   3   >