[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=17221271#comment-17221271 ] liufangliang commented on FLINK-17525: -- [~jark] Can you assgin this to me ? > Support to parse

[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=17133852#comment-17133852 ] liufangliang edited comment on FLINK-18044 at 10/27/20, 2:44 AM: - Hi

[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=17216414#comment-17216414 ] liufangliang commented on FLINK-19553: -- [~yunta] ok, thanks. > The format of checkpoint Completion

[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=17212893#comment-17212893 ] liufangliang commented on FLINK-19553: -- [~yunta] Thanks for your reply. assign to me.  > The

[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

[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

[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

[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:

[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=17196847#comment-17196847 ] liufangliang commented on FLINK-19262: -- [~lzljs3620320] Thanks  > Can not setParallelism for

[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=17196823#comment-17196823 ] liufangliang commented on FLINK-19262: -- [~lzljs3620320] Can you assign this issue to me? I will

[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=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=17196726#comment-17196726 ] liufangliang commented on FLINK-19257: -- [~lzljs3620320] ok > HBase ConnectorDescriptor can not

[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=17196713#comment-17196713 ] liufangliang commented on FLINK-19257: -- Hi [~lzljs3620320], please assign this to me. thanks. >

[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=17189161#comment-17189161 ] liufangliang commented on FLINK-18938: -- [~jark] , i will finish it later. > Throw better exception

[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=17188420#comment-17188420 ] liufangliang commented on FLINK-18938: -- Thanks [~twalthr] for your reply.  [~jark]  What do you

[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=17188403#comment-17188403 ] liufangliang commented on FLINK-16295: -- Hi [~lzljs3620320] , there is no class named BinaryString

[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=17188389#comment-17188389 ] liufangliang commented on FLINK-18938: -- Hi [~twalthr], what do you think of this patch ? > Throw

[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=17186354#comment-17186354 ] liufangliang commented on FLINK-18604: -- [~Leonard Xu] [~lzljs3620320]  Thanks.  > HBase

[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=17186322#comment-17186322 ] liufangliang commented on FLINK-18604: -- Hi [~Leonard Xu] , What you said is right. Can you assign

[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=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=17181631#comment-17181631 ] liufangliang commented on FLINK-18938: -- [~jark] , Yes , please assign it to me. > Throw better

[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=17181601#comment-17181601 ] liufangliang commented on FLINK-18938: -- [~jark] The judgment method is consistent with the judgment

[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=17181156#comment-17181156 ] liufangliang commented on FLINK-18938: -- [~jark] I understand what you mean. when we are quering a

[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=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 12:22 PM: - Hi

[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=17181135#comment-17181135 ] liufangliang commented on FLINK-18938: -- Hi [~jark], Can you assign it to me ?  The following tips

[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=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 11:49 AM: - Hi

[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=17181135#comment-17181135 ] liufangliang edited comment on FLINK-18938 at 8/20/20, 11:49 AM: - Hi

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

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

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

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

[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=17163479#comment-17163479 ] liufangliang commented on FLINK-16609: -- +1  > Promotes the column name representation of SQL-CLI >

[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=17158859#comment-17158859 ] liufangliang commented on FLINK-17789: -- Hi [~lzljs3620320] [~chesnay] , Sorry for my irregular

[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=17158039#comment-17158039 ] liufangliang commented on FLINK-17789: -- Hi [~lzljs3620320]  Can i pick this issue ?  I have

[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=17151979#comment-17151979 ] liufangliang commented on FLINK-18466: -- Hi [~jark] , I run the unit test methed named

[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

[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=17148270#comment-17148270 ] liufangliang commented on FLINK-18044: -- [~becket_qin] Thanks for your reply . Let's go through the

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

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

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

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

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

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

[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=17136611#comment-17136611 ] liufangliang commented on FLINK-18314: -- okey , thanks for [~jark] your reply . > There are some

[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=17136603#comment-17136603 ] liufangliang commented on FLINK-18314: -- +1 , a small mistake in kafka.md  and kafka.zh.md  ,  as

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

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

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

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

[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=17129243#comment-17129243 ] liufangliang edited comment on FLINK-17761 at 6/13/20, 2:55 AM: Hi

[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=17133852#comment-17133852 ] liufangliang commented on FLINK-18044: -- Hi [~becket_qin], can i pack this issue? my solution is

[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=17129969#comment-17129969 ] liufangliang commented on FLINK-17761: -- okey,thanks for your reply > FutureCompletingBlockingQueue

[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=17129243#comment-17129243 ] liufangliang commented on FLINK-17761: -- Hi [~becket_qin], can i pack this issue ? the current

[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

[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=17129241#comment-17129241 ] liufangliang commented on FLINK-17534: -- Hi [~becket_qin], can i pack this issue ? the current

[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=17120077#comment-17120077 ] liufangliang commented on FLINK-17895: -- [~lzljs3620320] can you add a description? > Default value

[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=17120076#comment-17120076 ] liufangliang commented on FLINK-17736: -- [~lzljs3620320] Can you add a description？ > Add flink CEP

[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=17119480#comment-17119480 ] liufangliang commented on FLINK-17895: -- [~lzljs3620320]  could you please assign this issue to me ?

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

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