[jira] [Commented] (FLINK-25249) Reimplement KafkaSourceTestEnv with KafkaContainer

[ https://issues.apache.org/jira/browse/FLINK-25249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457023#comment-17457023 ] Yuepeng Pan commented on FLINK-25249: - Good idea.  [~renqs]  Sounds great to me. [~arvid] What do

[jira] [Comment Edited] (FLINK-17508) Develop OracleCatalog

[ https://issues.apache.org/jira/browse/FLINK-17508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452942#comment-17452942 ] Yuepeng Pan edited comment on FLINK-17508 at 12/3/21, 11:59 AM: I have

[jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452947#comment-17452947 ] Yuepeng Pan commented on FLINK-9219: [https://github.com/locationtech/jts]  Maybe it could be helpful

[jira] [Commented] (FLINK-17508) Develop OracleCatalog

[ https://issues.apache.org/jira/browse/FLINK-17508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452942#comment-17452942 ] Yuepeng Pan commented on FLINK-17508: - I have implemented the MySQL catalog, which is in review

[jira] [Commented] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450413#comment-17450413 ] Yuepeng Pan commented on FLINK-22315: -  This pull request was marked as ready for review. > Support

[jira] (FLINK-22316) Support MODIFY column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22316 ] Yuepeng Pan deleted comment on FLINK-22316: - was (Author: rocmarshal): Could someone assign this ticket to me ? Thank you. > Support MODIFY column/constraint/watermark for ALTER TABLE

[jira] [Commented] (FLINK-20681) Support specifying the hdfs path when ship archives or files

[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447739#comment-17447739 ] Yuepeng Pan commented on FLINK-20681: - [~MartijnVisser] Thank you. > Support specifying the hdfs

[jira] [Comment Edited] (FLINK-20681) Support specifying the hdfs path when ship archives or files

[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447268#comment-17447268 ] Yuepeng Pan edited comment on FLINK-20681 at 11/22/21, 12:45 PM: - Thanks

[jira] [Commented] (FLINK-20681) Support specifying the hdfs path when ship archives or files

[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447268#comment-17447268 ] Yuepeng Pan commented on FLINK-20681: - Thanks [~jiang7chengzitc] for the reply. It's my pleasure to

[jira] [Commented] (FLINK-20681) Support specifying the hdfs path when ship archives or files

[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447259#comment-17447259 ] Yuepeng Pan commented on FLINK-20681: - Excuse me, [~jiang7chengzitc] , are you still working for it

[jira] [Comment Edited] (FLINK-24002) Support count window with the window TVF

[ https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440889#comment-17440889 ] Yuepeng Pan edited comment on FLINK-24002 at 11/22/21, 6:36 AM: Hi,

[jira] [Commented] (FLINK-24931) Remove deprecated/unused class files in flink-scala module.

[ https://issues.apache.org/jira/browse/FLINK-24931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444930#comment-17444930 ] Yuepeng Pan commented on FLINK-24931: - Hi,   [~igal] [~tzulitai]  , What do you think of it . >

[jira] [Created] (FLINK-24931) Remove deprecated/unused class files in flink-scala module.

Yuepeng Pan created FLINK-24931: --- Summary: Remove deprecated/unused class files in flink-scala module. Key: FLINK-24931 URL: https://issues.apache.org/jira/browse/FLINK-24931 Project: Flink

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442517#comment-17442517 ] Yuepeng Pan commented on FLINK-24489: - In my limited read, I hope to reduce the number of

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442513#comment-17442513 ] Yuepeng Pan commented on FLINK-24489: - !details of the big map object.png! > The size of entryCache

[jira] [Updated] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuepeng Pan updated FLINK-24489: Attachment: details of the big map object.png incoming-reference-to

[jira] [Commented] (FLINK-24833) Prevent use of deprecated APIs in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-24833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442255#comment-17442255 ] Yuepeng Pan commented on FLINK-24833: - Hi, [~sjwiesman] , Could you please assign this ticket to me

[jira] [Commented] (FLINK-24383) Remove the deprecated SlidingTimeWindows, TumblingTimeWindows, BaseAlignedWindowAssigner.

[ https://issues.apache.org/jira/browse/FLINK-24383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441591#comment-17441591 ] Yuepeng Pan commented on FLINK-24383: - Hi,[~trohrmann] ,Could you help  me to check it ? Thank you.

[jira] [Commented] (FLINK-24000) window aggregate support allow lateness

[ https://issues.apache.org/jira/browse/FLINK-24000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440888#comment-17440888 ] Yuepeng Pan commented on FLINK-24000: - Hi, [~qingru zhang] [~MartijnVisser] . I'm very interested in

[jira] [Commented] (FLINK-24002) Support count window with the window TVF

[ https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440889#comment-17440889 ] Yuepeng Pan commented on FLINK-24002: - Hi, [~qingru zhang]  [~twalthr] . Could you please assign

[jira] [Commented] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440155#comment-17440155 ] Yuepeng Pan commented on FLINK-15352: - [~airblader] Thank you so much for the review. I made some

[jira] [Comment Edited] (FLINK-21634) ALTER TABLE statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440006#comment-17440006 ] Yuepeng Pan edited comment on FLINK-21634 at 11/7/21, 1:25 PM: --- Hi,

[jira] [Comment Edited] (FLINK-21634) ALTER TABLE statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440006#comment-17440006 ] Yuepeng Pan edited comment on FLINK-21634 at 11/7/21, 1:23 PM: --- Hi,

[jira] [Commented] (FLINK-21634) ALTER TABLE statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440006#comment-17440006 ] Yuepeng Pan commented on FLINK-21634: - Hi, [~jark] , Thank you so much for looking into this. And a

[jira] [Commented] (FLINK-22316) Support MODIFY column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434139#comment-17434139 ] Yuepeng Pan commented on FLINK-22316: - Could someone assign this ticket to me ? Thank you. >

[jira] [Commented] (FLINK-22732) Restrict ALTER TABLE from setting empty table options

[ https://issues.apache.org/jira/browse/FLINK-22732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434138#comment-17434138 ] Yuepeng Pan commented on FLINK-22732: - Hi, [~jark], Could you assign this ticket to me ? Thank you.

[jira] [Comment Edited] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432915#comment-17432915 ] Yuepeng Pan edited comment on FLINK-24489 at 10/24/21, 2:04 PM:

[jira] [Comment Edited] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433243#comment-17433243 ] Yuepeng Pan edited comment on FLINK-24489 at 10/23/21, 9:44 AM: We

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433243#comment-17433243 ] Yuepeng Pan commented on FLINK-24489: - We cannot control the size of  time interval in users'

[jira] [Updated] (FLINK-24383) Remove the deprecated SlidingTimeWindows, TumblingTimeWindows, BaseAlignedWindowAssigner.

[ https://issues.apache.org/jira/browse/FLINK-24383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuepeng Pan updated FLINK-24383: Summary: Remove the deprecated SlidingTimeWindows, TumblingTimeWindows,

[jira] [Comment Edited] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432915#comment-17432915 ] Yuepeng Pan edited comment on FLINK-24489 at 10/22/21, 11:14 AM: -

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432915#comment-17432915 ] Yuepeng Pan commented on FLINK-24489: - [~dwysakowicz]. Thanks for the reply. The statement like   

[jira] [Comment Edited] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429565#comment-17429565 ] Yuepeng Pan edited comment on FLINK-24489 at 10/22/21, 8:58 AM: Hi,

[jira] [Comment Edited] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429565#comment-17429565 ] Yuepeng Pan edited comment on FLINK-24489 at 10/22/21, 8:54 AM: Hi,

[jira] [Commented] (FLINK-24601) Error in submitting the job

[ https://issues.apache.org/jira/browse/FLINK-24601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432484#comment-17432484 ] Yuepeng Pan commented on FLINK-24601: - !sourcecode.png!   Maybe you could debug the marked line to

[jira] [Updated] (FLINK-24601) Error in submitting the job

[ https://issues.apache.org/jira/browse/FLINK-24601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuepeng Pan updated FLINK-24601: Attachment: sourcecode.png > Error in submitting the job > --- > >

[jira] [Updated] (FLINK-24601) Error in submitting the job

[ https://issues.apache.org/jira/browse/FLINK-24601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuepeng Pan updated FLINK-24601: Attachment: (was: sourcecode.png) > Error in submitting the job > ---

[jira] [Updated] (FLINK-24601) Error in submitting the job

[ https://issues.apache.org/jira/browse/FLINK-24601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuepeng Pan updated FLINK-24601: Attachment: sourcecode.png > Error in submitting the job > --- > >

[jira] [Commented] (FLINK-24601) Error in submitting the job

[ https://issues.apache.org/jira/browse/FLINK-24601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432394#comment-17432394 ] Yuepeng Pan commented on FLINK-24601: - [~sshyamprasath] Could you put more details with the

[jira] [Comment Edited] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409327#comment-17409327 ] Yuepeng Pan edited comment on FLINK-15352 at 10/21/21, 6:47 AM: Could

[jira] [Commented] (FLINK-24601) Error in submitting the job

[ https://issues.apache.org/jira/browse/FLINK-24601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431104#comment-17431104 ] Yuepeng Pan commented on FLINK-24601: - Hi, [~sshyamprasath], the #count() method will call 

[jira] [Commented] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430573#comment-17430573 ] Yuepeng Pan commented on FLINK-15352: - [~MartijnVisser] [~airblader] Thanks for the reply. >

[jira] [Comment Edited] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429565#comment-17429565 ] Yuepeng Pan edited comment on FLINK-24489 at 10/19/21, 7:23 AM: Hi,

[jira] [Comment Edited] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425935#comment-17425935 ] Yuepeng Pan edited comment on FLINK-10230 at 10/18/21, 10:22 AM: - Could

[jira] [Comment Edited] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425935#comment-17425935 ] Yuepeng Pan edited comment on FLINK-10230 at 10/18/21, 9:34 AM: Could

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429565#comment-17429565 ] Yuepeng Pan commented on FLINK-24489: - Hi, [~dwysakowicz], [~airblader], [~twalthr]. If it could

[jira] [Comment Edited] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429247#comment-17429247 ] Yuepeng Pan edited comment on FLINK-22315 at 10/16/21, 9:48 AM: 'alter

[jira] [Comment Edited] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429247#comment-17429247 ] Yuepeng Pan edited comment on FLINK-22315 at 10/15/21, 12:27 PM: - 'alter

[jira] [Commented] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429247#comment-17429247 ] Yuepeng Pan commented on FLINK-22315: - 'alter table add constraint' syntax is availiable

[jira] [Comment Edited] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425935#comment-17425935 ] Yuepeng Pan edited comment on FLINK-10230 at 10/15/21, 10:24 AM: - Could

[jira] [Commented] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429218#comment-17429218 ] Yuepeng Pan commented on FLINK-22315: - Hi, [~jark], I'm interested in this pr. Could you assign

[jira] [Comment Edited] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428173#comment-17428173 ] Yuepeng Pan edited comment on FLINK-24489 at 10/14/21, 2:00 PM: Thanks

[jira] [Comment Edited] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425935#comment-17425935 ] Yuepeng Pan edited comment on FLINK-10230 at 10/14/21, 2:03 AM: Could

[jira] [Updated] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuepeng Pan updated FLINK-24489: Attachment: 截屏2021-10-13 20.28.17.png > The size of entryCache & eventsBufferCache in the

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428173#comment-17428173 ] Yuepeng Pan commented on FLINK-24489: - Thanks [~dwysakowicz] for the reply. Sorry for the

[jira] [Updated] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuepeng Pan updated FLINK-24489: Summary: The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a

[jira] [Issue Comment Deleted] (FLINK-24215) Timeout exception in submitting a job by RemoteStreamEnvironment/RemoteEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuepeng Pan updated FLINK-24215: Comment: was deleted (was: Could you [~dianfu] please assign this task to me ? Thank you very