[jira] [Commented] (FLINK-14053) blink planner dense_rank corner case bug

2019-09-11 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927516#comment-16927516 ] jackylau commented on FLINK-14053: -- [~jark] it is a bug in DenseRankAggFunction.accumulateExpressions.

[jira] [Created] (FLINK-14053) blink planner dense_rank corner case bug

2019-09-11 Thread jackylau (Jira)
jackylau created FLINK-14053: Summary: blink planner dense_rank corner case bug Key: FLINK-14053 URL: https://issues.apache.org/jira/browse/FLINK-14053 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-20 Thread jackylau (Jira)
jackylau created FLINK-14159: Summary: flink rocksdb StreamCompressionDecorator not right Key: FLINK-14159 URL: https://issues.apache.org/jira/browse/FLINK-14159 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934884#comment-16934884 ] jackylau commented on FLINK-14159: -- who is responsible for , and who can see this issue [~lzljs3620320]

[jira] [Updated] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-14159: - Description: I think the current flink rocksdb StreamCompressionDecorator is not right when calling

[jira] [Comment Edited] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934884#comment-16934884 ] jackylau edited comment on FLINK-14159 at 9/21/19 2:36 AM: --- I want to konw who

[jira] [Commented] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-27 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16939204#comment-16939204 ] jackylau commented on FLINK-14159: -- [~klion26], It will be at cost of cpu when the state is large and 

[jira] [Created] (FLINK-14243) flink hiveudf need some check whether it is using cache

2019-09-27 Thread jackylau (Jira)
jackylau created FLINK-14243: Summary: flink hiveudf need some check whether it is using cache Key: FLINK-14243 URL: https://issues.apache.org/jira/browse/FLINK-14243 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-24 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936548#comment-16936548 ] jackylau commented on FLINK-14159: -- [~klion26] Does that mean checkpoint has twice compression when we

[jira] [Comment Edited] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-24 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936548#comment-16936548 ] jackylau edited comment on FLINK-14159 at 9/24/19 8:29 AM: --- [~klion26] Does

[jira] [Updated] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-14243: - Summary: flink hiveudf needs some check when it is using cache (was: flink hiveudf need some check

[jira] [Updated] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-14243: - Description: Flink1.9 brings in hive connector, but it will have some problem when the original hive

[jira] [Commented] (FLINK-14243) flink hiveudf need some check when it is using cache

2019-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940619#comment-16940619 ] jackylau commented on FLINK-14243: -- [~ykt836]  The original udf function uses cache, which you can see

[jira] [Comment Edited] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940639#comment-16940639 ] jackylau edited comment on FLINK-14243 at 9/30/19 3:56 AM: --- [~ykt836] This

[jira] [Updated] (FLINK-14243) flink hiveudf need some check when it is using cache

2019-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-14243: - Summary: flink hiveudf need some check when it is using cache (was: flink hiveudf need some check

[jira] [Updated] (FLINK-14243) flink hiveudf need some check when it is using cache

2019-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-14243: - Description: Flink1.9 bring in hive connector, but it will have some problem when the original hive

[jira] [Commented] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940639#comment-16940639 ] jackylau commented on FLINK-14243: -- This problem I consulted spark community before in wechat spark 

[jira] [Commented] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936290#comment-16936290 ] jackylau commented on FLINK-14159: -- Hi [~klion26],  "If no executionconfig configured, the 

[jira] [Issue Comment Deleted] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-14159: - Comment: was deleted (was: I want to konw who is responsible for , and who can see this issue

[jira] [Comment Edited] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936290#comment-16936290 ] jackylau edited comment on FLINK-14159 at 9/24/19 1:38 AM: --- Hi [~klion26],  

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-06 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968216#comment-16968216 ] jackylau commented on FLINK-14567: -- i means that the framework can not solve it. .User use concat_ws,

[jira] [Commented] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-11-06 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968168#comment-16968168 ] jackylau commented on FLINK-14243: -- [~lzljs3620320] [~jark] yep, i read this HIVE-16196 and related

[jira] [Commented] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-11-06 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968209#comment-16968209 ] jackylau commented on FLINK-14243: -- And i found the flink built in function JsonUtil has a lock 

[jira] [Commented] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-11-06 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968869#comment-16968869 ] jackylau commented on FLINK-14243: -- Hi [~jark]  And i found the flink built in function JsonUtil has a

[jira] [Updated] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-11-04 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-14243: - Attachment: Snipaste_2019-10-30_15-34-09.png > flink hiveudf needs some check when it is using cache >

[jira] [Commented] (FLINK-14243) flink hiveudf needs some check when it is using cache

2019-11-04 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966495#comment-16966495 ] jackylau commented on FLINK-14243: -- Hi [~jark], it is not thread safe, if we call this hive udf from

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

2019-11-04 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966499#comment-16966499 ] jackylau commented on FLINK-14567: -- Is it proper to deliver to the user who knows that the data format

[jira] [Created] (FLINK-15625) flink sql multiple statements syntatic validation supports

2020-01-16 Thread jackylau (Jira)
jackylau created FLINK-15625: Summary: flink sql multiple statements syntatic validation supports Key: FLINK-15625 URL: https://issues.apache.org/jira/browse/FLINK-15625 Project: Flink Issue

[jira] [Updated] (FLINK-15625) flink sql multiple statements syntatic validation supports

2020-01-16 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-15625: - Description: we konw that blink(blink first commits ) parser and calcite parser all support multiple

[jira] [Created] (FLINK-17155) flink in memory catalog can not support hive udf

2020-04-15 Thread jackylau (Jira)
jackylau created FLINK-17155: Summary: flink in memory catalog can not support hive udf Key: FLINK-17155 URL: https://issues.apache.org/jira/browse/FLINK-17155 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-16777) expose Pipeline in JobClient

2020-03-25 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067307#comment-17067307 ] jackylau commented on FLINK-16777: -- Hi [~kkl0u] , Exposing HbaseUpsertFunction, FlinkKafkaConsumer,

[jira] [Commented] (FLINK-16777) expose Pipeline in JobClient

2020-03-27 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068336#comment-17068336 ] jackylau commented on FLINK-16777: -- ok [~kkl0u] thanks for your response. and i want to expose some

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-27 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068357#comment-17068357 ] jackylau commented on FLINK-16774: -- which is my documention, but the language is chinese

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-27 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068345#comment-17068345 ] jackylau commented on FLINK-16774: -- hi [~kkl0u] [~jark]  we want to develop a flink atas hook refering

[jira] [Comment Edited] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-27 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068347#comment-17068347 ] jackylau edited comment on FLINK-16774 at 3/27/20, 6:39 AM: [~kkl0u] we will

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-27 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068347#comment-17068347 ] jackylau commented on FLINK-16774: -- [~kkl0u] we will expose such as in flink HBaseUpsertSinkFunction 

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070664#comment-17070664 ] jackylau commented on FLINK-16774: -- Hi [~jark], thanks for your reply. And i find the google doc miss

[jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-30 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-16774: - Attachment: flink-atlas.pdf > expose HBaseUpsertSinkFunction hTableName and schema for other system >

[jira] [Comment Edited] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-30 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070729#comment-17070729 ] jackylau edited comment on FLINK-16774 at 3/30/20, 6:57 AM: hi [~lirui]

[jira] [Comment Edited] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-30 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070729#comment-17070729 ] jackylau edited comment on FLINK-16774 at 3/30/20, 6:56 AM: hi [~lirui]

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070630#comment-17070630 ] jackylau commented on FLINK-16774: -- hi [~jark] i have edited the sharing setting of google docs, which

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-30 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17070729#comment-17070729 ] jackylau commented on FLINK-16774: -- hi [~lirui] [~jark] beacuse of the atlas google doc missing

[jira] [Created] (FLINK-16775) expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system

2020-03-25 Thread jackylau (Jira)
jackylau created FLINK-16775: Summary: expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system Key: FLINK-16775 URL: https://issues.apache.org/jira/browse/FLINK-16775 Project: Flink

[jira] [Created] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-25 Thread jackylau (Jira)
jackylau created FLINK-16774: Summary: expose HBaseUpsertSinkFunction hTableName and schema for other system Key: FLINK-16774 URL: https://issues.apache.org/jira/browse/FLINK-16774 Project: Flink

[jira] [Created] (FLINK-16777) expose Pipeline in JobClient

2020-03-25 Thread jackylau (Jira)
jackylau created FLINK-16777: Summary: expose Pipeline in JobClient Key: FLINK-16777 URL: https://issues.apache.org/jira/browse/FLINK-16777 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

2020-04-25 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092451#comment-17092451 ] jackylau commented on FLINK-17384: -- for 1) i have already done, can it assign to me  > support read

[jira] [Updated] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

2020-04-25 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-17384: - Description: hi all: when user interacts with hbase should do 2 things when using sql # export

[jira] [Created] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

2020-04-25 Thread jackylau (Jira)
jackylau created FLINK-17384: Summary: support read hbase conf dir from flink.conf just like hadoop_conf Key: FLINK-17384 URL: https://issues.apache.org/jira/browse/FLINK-17384 Project: Flink

[jira] [Updated] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

2020-04-25 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-17384: - Description: hi all: when user interacts with hbase should do 2 things when using sql # export

[jira] [Created] (FLINK-17326) flink sql gateway should support persist meta information such as SessionContext in order to recover

2020-04-22 Thread jackylau (Jira)
jackylau created FLINK-17326: Summary: flink sql gateway should support persist meta information such as SessionContext in order to recover Key: FLINK-17326 URL: https://issues.apache.org/jira/browse/FLINK-17326

[jira] [Commented] (FLINK-17326) flink sql gateway should support persist meta information such as SessionContext in order to recover

2020-04-22 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089619#comment-17089619 ] jackylau commented on FLINK-17326: -- hi [~godfreyhe], will the flink sql gateway support this feature in

[jira] [Commented] (FLINK-17326) flink sql gateway should support persist meta information such as SessionContext in order to recover

2020-04-22 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089648#comment-17089648 ] jackylau commented on FLINK-17326: -- [~ykt836] thanks very much. > flink sql gateway should support

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-05-13 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106080#comment-17106080 ] jackylau commented on FLINK-16713: -- Hi [~jark], our team want to do something for it. so i have two

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-05-13 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106060#comment-17106060 ] jackylau commented on FLINK-16713: -- Hi [~jackray], [~jark] where to find your design docs, we also want

[jira] [Comment Edited] (FLINK-16713) Support source mode of elasticsearch connector

2020-05-13 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106080#comment-17106080 ] jackylau edited comment on FLINK-16713 at 5/13/20, 8:07 AM: Hi [~jark], our

[jira] [Issue Comment Deleted] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

2020-05-18 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-17384: - Comment: was deleted (was: Hi [~liyu],  I have committed my code, but the log is below, which is not

[jira] [Comment Edited] (FLINK-16713) Support source mode of elasticsearch connector

2020-05-13 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106781#comment-17106781 ] jackylau edited comment on FLINK-16713 at 5/14/20, 1:58 AM: ah [~jark],

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-05-13 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106781#comment-17106781 ] jackylau commented on FLINK-16713: -- ah [~jark],  i couldn't describe my ideas. I means why   es source

[jira] [Commented] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

2020-05-15 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108059#comment-17108059 ] jackylau commented on FLINK-17384: -- Hi [~liyu],  I have committed my code, but the log is 

[jira] [Comment Edited] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

2020-05-15 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108059#comment-17108059 ] jackylau edited comment on FLINK-17384 at 5/15/20, 8:04 AM: Hi [~liyu],  I

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

2020-03-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063158#comment-17063158 ] jackylau commented on FLINK-16692: -- i think it is import for us, and can it assign to me > flink

[jira] [Comment Edited] (FLINK-16692) flink joblistener can register from config

2020-03-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063158#comment-17063158 ] jackylau edited comment on FLINK-16692 at 3/20/20, 8:37 AM: i think it is

[jira] [Created] (FLINK-16692) flink joblistener can register from config

2020-03-20 Thread jackylau (Jira)
jackylau created FLINK-16692: Summary: flink joblistener can register from config Key: FLINK-16692 URL: https://issues.apache.org/jira/browse/FLINK-16692 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

2020-03-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063171#comment-17063171 ] jackylau commented on FLINK-16692: -- [~felixzheng] yes, we can define a conf such as

[jira] [Created] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things

2020-03-20 Thread jackylau (Jira)
jackylau created FLINK-16698: Summary: fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things Key: FLINK-16698 URL: https://issues.apache.org/jira/browse/FLINK-16698

[jira] [Comment Edited] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things

2020-03-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063733#comment-17063733 ] jackylau edited comment on FLINK-16698 at 3/21/20, 2:30 AM: hi [~jark]

[jira] [Comment Edited] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things

2020-03-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063733#comment-17063733 ] jackylau edited comment on FLINK-16698 at 3/21/20, 2:28 AM: hi [~jark]

[jira] [Commented] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things

2020-03-20 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063733#comment-17063733 ] jackylau commented on FLINK-16698: -- hi [~jark] [~bli], i prepare to define a interface such as

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

2020-03-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064621#comment-17064621 ] jackylau commented on FLINK-16692: -- HI [~kkl0u],  1) i will move the arguments to DeploymentOptions

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

2020-03-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064766#comment-17064766 ] jackylau commented on FLINK-16692: -- [~kkl0u] ok .thanks  > flink joblistener can register from config

[jira] [Created] (FLINK-19765) flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog

2020-10-22 Thread jackylau (Jira)
jackylau created FLINK-19765: Summary: flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog Key: FLINK-19765 URL: https://issues.apache.org/jira/browse/FLINK-19765

[jira] [Updated] (FLINK-19755) flink cep

2020-10-21 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-19755: - Description: {code:java} symbol tax price rowtime = ===

[jira] [Created] (FLINK-19755) flink cep

2020-10-21 Thread jackylau (Jira)
jackylau created FLINK-19755: Summary: flink cep Key: FLINK-19755 URL: https://issues.apache.org/jira/browse/FLINK-19755 Project: Flink Issue Type: Bug Components: Library / CEP

[jira] [Updated] (FLINK-19755) flink cep docs exist looping match when coming to 17, 14 using AFTER MATCH SKIP TO LAST A 

2020-10-21 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-19755: - Summary: flink cep docs exist looping match when coming to 17, 14 using  AFTER MATCH SKIP TO LAST A 

[jira] [Commented] (FLINK-19755) flink cep

2020-10-21 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218690#comment-17218690 ] jackylau commented on FLINK-19755: -- h5. i think it will exist looping match when coming to 17, 14 using

[jira] [Updated] (FLINK-19755) flink cep

2020-10-21 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-19755: - Environment: (was: I think it will exist looping match when coming to 17, 14 using AFTER MATCH SKIP

[jira] [Closed] (FLINK-19848) flink docs of Building Flink from Source bug

2020-10-28 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau closed FLINK-19848. Resolution: Not A Bug > flink docs of Building Flink from Source bug >

[jira] [Updated] (FLINK-19848) flink docs of Building Flink from Source bug

2020-10-28 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-19848: - Description: To speed up the build you can skip tests, QA plugins, and JavaDocs:   {{mvn clean

[jira] [Created] (FLINK-19848) flink docs of Building Flink from Source bug

2020-10-28 Thread jackylau (Jira)
jackylau created FLINK-19848: Summary: flink docs of Building Flink from Source bug Key: FLINK-19848 URL: https://issues.apache.org/jira/browse/FLINK-19848 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-19755) flink cep docs exist looping match when coming to 17, 14 using AFTER MATCH SKIP TO LAST A 

2020-10-22 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219422#comment-17219422 ] jackylau commented on FLINK-19755: -- hi [~jark] [~dianfu], i modify the data to solve the looping match,

[jira] [Updated] (FLINK-19755) flink cep docs exist looping match when coming to 17, 14 using AFTER MATCH SKIP TO LAST A 

2020-10-22 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-19755: - Attachment: 7CA31459-B125-4cea-8C75-3D101C27A9F9.png

[jira] [Commented] (FLINK-19765) flink SqlUseCatalog.getCatalogName is not unified with SqlCreateCatalog and SqlDropCatalog

2020-10-22 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219405#comment-17219405 ] jackylau commented on FLINK-19765: -- hi [~jark] yeap. thanks. could you review it when the ci passed. >

[jira] [Commented] (FLINK-16993) Support SupportsComputedColumnPushDown in planner

2020-08-06 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172048#comment-17172048 ] jackylau commented on FLINK-16993: -- Hi [~twalthr], could you please  spend some of time replying me?

[jira] [Commented] (FLINK-16993) Support SupportsComputedColumnPushDown in planner

2020-08-11 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175457#comment-17175457 ] jackylau commented on FLINK-16993: -- [~godfreyhe] [~twalthr], Thanks your response very much.  >

[jira] [Commented] (FLINK-17425) Support SupportsFilterPushDown in planner

2020-06-30 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148341#comment-17148341 ] jackylau commented on FLINK-17425: -- Hi [~jark], why this issue is not achieved?  Could it  assign to

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-06-30 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148541#comment-17148541 ] jackylau commented on FLINK-16713: -- Hi Yangze Guo, i have a discussion before and write a FLIP-127 doc.

[jira] [Created] (FLINK-18495) flink filterpushdown can not take effect in blink planner

2020-07-06 Thread jackylau (Jira)
jackylau created FLINK-18495: Summary: flink filterpushdown can not take effect in blink planner Key: FLINK-18495 URL: https://issues.apache.org/jira/browse/FLINK-18495 Project: Flink Issue

[jira] [Commented] (FLINK-18495) flink filterpushdown can not take effect in blink planner

2020-07-06 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151903#comment-17151903 ] jackylau commented on FLINK-18495: -- Hi [~lzljs3620320]. i find the flink 1.12 snpashot  flink planner

[jira] [Commented] (FLINK-17426) Support SupportsLimitPushDown in planner

2020-07-01 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149786#comment-17149786 ] jackylau commented on FLINK-17426: -- Hi [~jark], could it also assign to me?  > Support

[jira] [Commented] (FLINK-18236) flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right

2020-06-16 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136346#comment-17136346 ] jackylau commented on FLINK-18236: -- Hi [~jark] could you please spend some of time reviewing this issue

[jira] [Issue Comment Deleted] (FLINK-18236) flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right

2020-06-16 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-18236: - Comment: was deleted (was: hi [~dwysakowicz] , could you please also review this issue and PR?) >

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-06-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147613#comment-17147613 ] jackylau commented on FLINK-16713: -- Hi guys, I have achieved  it and put the  commits just konw. Could

[jira] [Commented] (FLINK-18231) flink kafka connector exists same qualified class name, whch will cause conflicts when user has all the versions of flink-kafka-connector

2020-06-15 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136227#comment-17136227 ] jackylau commented on FLINK-18231: -- Hi [~becket_qin], Thanks for your response so much. I also agree

[jira] [Commented] (FLINK-18236) flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right

2020-06-15 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136245#comment-17136245 ] jackylau commented on FLINK-18236: -- hi [~dwysakowicz] , could you please also review this issue and PR?

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-06-19 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140953#comment-17140953 ] jackylau commented on FLINK-16713: -- for option1: *original* add this method to ApiCallBridge :      

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-06-19 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140943#comment-17140943 ] jackylau commented on FLINK-16713: -- Hi [~jark] [~echauchot] [~karmagyz], the discussion just has jark 

[jira] [Commented] (FLINK-18236) flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right

2020-06-17 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138945#comment-17138945 ] jackylau commented on FLINK-18236: -- Hi [~rmetzger], Thanks . I found this from the page you attach.

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-06-19 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140302#comment-17140302 ] jackylau commented on FLINK-16713: -- Hi [~jark], thanks for your feedback. i will start a thread to

[jira] [Commented] (FLINK-16713) Support source mode of elasticsearch connector

2020-06-18 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140231#comment-17140231 ] jackylau commented on FLINK-16713: -- Hi [~rmetzger], when i coding the es source connector here 

[jira] [Comment Edited] (FLINK-16713) Support source mode of elasticsearch connector

2020-06-19 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140231#comment-17140231 ] jackylau edited comment on FLINK-16713 at 6/19/20, 6:24 AM: Hi [~rmetzger],

  1   2   3   4   >