[jira] [Commented] (FLINK-17525) Support to parse millisecond and nanoseconds for TIME type in CSV and JSON format

[ https://issues.apache.org/jira/browse/FLINK-17525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221271#comment-17221271 ] liufangliang commented on FLINK-17525: -- [~jark] Can you assgin this to me ? > Supp

[jira] [Comment Edited] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

[ https://issues.apache.org/jira/browse/FLINK-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133852#comment-17133852 ] liufangliang edited comment on FLINK-18044 at 10/27/20, 2:44 AM: -

[jira] [Commented] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216414#comment-17216414 ] liufangliang commented on FLINK-19553: -- [~yunta] ok, thanks. > The format of check

[jira] [Commented] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212893#comment-17212893 ] liufangliang commented on FLINK-19553: -- [~yunta] Thanks for your reply. assign to m

[jira] [Updated] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liufangliang updated FLINK-19553: - Description: As shown in the picture below, The latest completed checkpoint ID is 3, but th

[jira] [Updated] (FLINK-19553) The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liufangliang updated FLINK-19553: - Summary: The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:

[jira] [Updated] (FLINK-19553) The format of checkpoint Completion Time and Failure Time is changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

[ https://issues.apache.org/jira/browse/FLINK-19553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liufangliang updated FLINK-19553: - Description: As shown in the picture below, The latest completed checkpoint ID is 3, but th

[jira] [Created] (FLINK-19553) The format of checkpoint Completion Time and Failure Time is changed from HH:mm:ss to yyyy-MM-dd HH:mm:ss

liufangliang created FLINK-19553: Summary: The format of checkpoint Completion Time and Failure Time is changed from HH:mm:ss to -MM-dd HH:mm:ss Key: FLINK-19553 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Commented] (FLINK-19262) Can not setParallelism for FLIP-27 source

[ https://issues.apache.org/jira/browse/FLINK-19262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196847#comment-17196847 ] liufangliang commented on FLINK-19262: -- [~lzljs3620320] Thanks  > Can not setParal

[jira] [Commented] (FLINK-19262) Can not setParallelism for FLIP-27 source

[ https://issues.apache.org/jira/browse/FLINK-19262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196823#comment-17196823 ] liufangliang commented on FLINK-19262: -- [~lzljs3620320] Can you assign this issue t

[jira] [Commented] (FLINK-19262) Can not setParallelism for FLIP-27 source

[ https://issues.apache.org/jira/browse/FLINK-19262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196811#comment-17196811 ] liufangliang commented on FLINK-19262: -- Hi [~lzljs3620320] , master  {code:java} /

[jira] [Commented] (FLINK-19257) HBase ConnectorDescriptor can not work in Table API of release-1.11

[ https://issues.apache.org/jira/browse/FLINK-19257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196726#comment-17196726 ] liufangliang commented on FLINK-19257: -- [~lzljs3620320] ok > HBase ConnectorDescri

[jira] [Commented] (FLINK-19257) HBase ConnectorDescriptor can not work in Table API of release-1.11

[ https://issues.apache.org/jira/browse/FLINK-19257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196713#comment-17196713 ] liufangliang commented on FLINK-19257: -- Hi [~lzljs3620320], please assign this to m

[jira] [Created] (FLINK-19257) HBase ConnectorDescriptor can not work in Table API of release-1.11

liufangliang created FLINK-19257: Summary: HBase ConnectorDescriptor can not work in Table API of release-1.11 Key: FLINK-19257 URL: https://issues.apache.org/jira/browse/FLINK-19257 Project: Flink

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189161#comment-17189161 ] liufangliang commented on FLINK-18938: -- [~jark] , i will finish it later. > Throw

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188420#comment-17188420 ] liufangliang commented on FLINK-18938: -- Thanks [~twalthr] for your reply.  [~jark] 

[jira] [Commented] (FLINK-16295) Optimize BinaryString.copy to not materialize if there is javaObject

[ https://issues.apache.org/jira/browse/FLINK-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188403#comment-17188403 ] liufangliang commented on FLINK-16295: -- Hi [~lzljs3620320] , there is no class name

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188389#comment-17188389 ] liufangliang commented on FLINK-18938: -- Hi [~twalthr], what do you think of this pa

[jira] [Commented] (FLINK-18604) HBase ConnectorDescriptor can not work in Table API

[ https://issues.apache.org/jira/browse/FLINK-18604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17186354#comment-17186354 ] liufangliang commented on FLINK-18604: -- [~Leonard Xu] [~lzljs3620320]  Thanks.  >

[jira] [Commented] (FLINK-18604) HBase ConnectorDescriptor can not work in Table API

[ https://issues.apache.org/jira/browse/FLINK-18604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17186322#comment-17186322 ] liufangliang commented on FLINK-18604: -- Hi [~Leonard Xu] , What you said is right.

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147176#comment-17147176 ] liufangliang edited comment on FLINK-18202 at 8/21/20, 7:41 AM: --

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181631#comment-17181631 ] liufangliang commented on FLINK-18938: -- [~jark] , Yes , please assign it to me. >

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181601#comment-17181601 ] liufangliang commented on FLINK-18938: -- [~jark] The judgment method is consistent w

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181156#comment-17181156 ] liufangliang commented on FLINK-18938: -- [~jark] I understand what you mean. when w

[jira] [Comment Edited] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 12:22 PM: -

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181135#comment-17181135 ] liufangliang commented on FLINK-18938: -- Hi [~jark], Can you assign it to me ?  The

[jira] [Comment Edited] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 11:49 AM: -

[jira] [Comment Edited] (FLINK-18938) Throw better exception message for quering sink-only connector

[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 11:49 AM: -

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175975#comment-17175975 ] liufangliang commented on FLINK-18202: -- Hi [~libenchao] [~FrankZou] [~jark] , Sound

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166167#comment-17166167 ] liufangliang commented on FLINK-18202: -- Hi [~libenchao] , here's my oponion: 1.2 &

[jira] [Commented] (FLINK-16609) Promotes the column name representation of SQL-CLI

[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17163479#comment-17163479 ] liufangliang commented on FLINK-16609: -- +1  > Promotes the column name representat

[jira] [Commented] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158859#comment-17158859 ] liufangliang commented on FLINK-17789: -- Hi [~lzljs3620320] [~chesnay] , Sorry for

[jira] [Commented] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

[ https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17158039#comment-17158039 ] liufangliang commented on FLINK-17789: -- Hi [~lzljs3620320]  Can i pick this issue

[jira] [Commented] (FLINK-18466) JDBC should fail-fast if the target table doesn't exist

[ https://issues.apache.org/jira/browse/FLINK-18466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151979#comment-17151979 ] liufangliang commented on FLINK-18466: -- Hi [~jark] , I run the unit test methed na

[jira] [Updated] (FLINK-18466) JDBC should fail-fast if the target table doesn't exist

[ https://issues.apache.org/jira/browse/FLINK-18466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liufangliang updated FLINK-18466: - Attachment: image-2020-07-06-19-52-13-070.png > JDBC should fail-fast if the target table doesn'

[jira] [Commented] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

[ https://issues.apache.org/jira/browse/FLINK-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148270#comment-17148270 ] liufangliang commented on FLINK-18044: -- [~becket_qin] Thanks for your reply . Let's

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147354#comment-17147354 ] liufangliang commented on FLINK-18202: -- For reference [https://calcite.apache.org/

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147191#comment-17147191 ] liufangliang commented on FLINK-18202: -- Hi [~libenchao] , Currently protobuf only

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147176#comment-17147176 ] liufangliang commented on FLINK-18202: -- [~tartarus]  sorry for later reply . sever

[jira] [Commented] (FLINK-18314) There are some problems in docs

[ https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136611#comment-17136611 ] liufangliang commented on FLINK-18314: -- okey , thanks for [~jark] your reply . > T

[jira] [Commented] (FLINK-18314) There are some problems in docs

[ https://issues.apache.org/jira/browse/FLINK-18314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136603#comment-17136603 ] liufangliang commented on FLINK-18314: -- +1 , a small mistake in kafka.md  and kafk

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136567#comment-17136567 ] liufangliang commented on FLINK-18202: -- Thanks [~libenchao]  for your reply , happy

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17135671#comment-17135671 ] liufangliang commented on FLINK-18202: -- +1 , [~libenchao]  [~nicholasjiang] I think

[jira] [Updated] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liufangliang updated FLINK-18202: - Attachment: (was: image-2020-06-15-17-08-13-652.png) > Introduce Protobuf format > -

[jira] [Updated] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liufangliang updated FLINK-18202: - Attachment: image-2020-06-15-17-18-03-182.png > Introduce Protobuf format >

[jira] [Updated] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liufangliang updated FLINK-18202: - Attachment: image-2020-06-15-17-08-13-652.png > Introduce Protobuf format >

[jira] [Comment Edited] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129243#comment-17129243 ] liufangliang edited comment on FLINK-17761 at 6/13/20, 2:55 AM: --

[jira] [Commented] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

[ https://issues.apache.org/jira/browse/FLINK-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133852#comment-17133852 ] liufangliang commented on FLINK-18044: -- Hi [~becket_qin], can i pack this issue?

[jira] [Commented] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129969#comment-17129969 ] liufangliang commented on FLINK-17761: -- okey,thanks for your reply > FutureComplet

[jira] [Issue Comment Deleted] (FLINK-17534) Update the interfaces to PublicEvolving and add documentation.

[ https://issues.apache.org/jira/browse/FLINK-17534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liufangliang updated FLINK-17534: - Comment: was deleted (was: Hi [~becket_qin], can i pack this issue ? the current constructor o

[jira] [Commented] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129243#comment-17129243 ] liufangliang commented on FLINK-17761: -- Hi [~becket_qin], can i pack this issue ?

[jira] [Commented] (FLINK-17534) Update the interfaces to PublicEvolving and add documentation.

[ https://issues.apache.org/jira/browse/FLINK-17534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129241#comment-17129241 ] liufangliang commented on FLINK-17534: -- Hi [~becket_qin], can i pack this issue ?

[jira] [Commented] (FLINK-17895) Default value of rows-per-second in datagen can be limited

[ https://issues.apache.org/jira/browse/FLINK-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120077#comment-17120077 ] liufangliang commented on FLINK-17895: -- [~lzljs3620320] can you add a description?

[jira] [Commented] (FLINK-17736) Add flink CEP examples

[ https://issues.apache.org/jira/browse/FLINK-17736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120076#comment-17120076 ] liufangliang commented on FLINK-17736: -- [~lzljs3620320] Can you add a description？

[jira] [Commented] (FLINK-17895) Default value of rows-per-second in datagen can be limited

[ https://issues.apache.org/jira/browse/FLINK-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119480#comment-17119480 ] liufangliang commented on FLINK-17895: -- [~lzljs3620320]  could you please assign th

[jira] [Commented] (FLINK-17201) Implement Streaming ClickHouseSink

[ https://issues.apache.org/jira/browse/FLINK-17201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085454#comment-17085454 ] liufangliang commented on FLINK-17201: -- Amazing > Implement Streaming ClickHouseSi