[jira] [Commented] (FLINK-35876) mysql cdc may change from snapshot mode to binlog mode failed when cpu load of mysql server is 100%

2024-07-23 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868224#comment-17868224 ] Paul Lin commented on FLINK-35876: -- +1. I've experienced a similar problem with CDC 3.0

[jira] [Commented] (FLINK-32315) Support local file upload in K8s mode

2024-01-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810742#comment-17810742 ] Paul Lin commented on FLINK-32315: -- [~mbalassi] Please go ahead. Thanks! > Support loc

[jira] [Commented] (FLINK-32143) Automatic cleanup of terminated flinkdeployments

2023-08-31 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760752#comment-17760752 ] Paul Lin commented on FLINK-32143: -- Looks great! Thanks [~gyfora]  > Automatic cleanup

[jira] [Created] (FLINK-32315) Support local file upload in K8s mode

2023-06-12 Thread Paul Lin (Jira)
Paul Lin created FLINK-32315: Summary: Support local file upload in K8s mode Key: FLINK-32315 URL: https://issues.apache.org/jira/browse/FLINK-32315 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2023-05-29 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727239#comment-17727239 ] Paul Lin commented on FLINK-26541: -- I've created [FLIP-316|https://cwiki.apache.org/co

[jira] [Created] (FLINK-32143) Automatic cleanup of terminated flinkdeployments

2023-05-21 Thread Paul Lin (Jira)
Paul Lin created FLINK-32143: Summary: Automatic cleanup of terminated flinkdeployments Key: FLINK-32143 URL: https://issues.apache.org/jira/browse/FLINK-32143 Project: Flink Issue Type: New Feat

[jira] [Updated] (FLINK-31965) Fix ClassNotFoundException in benchmarks

2023-04-28 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-31965: - Priority: Minor (was: Major) > Fix ClassNotFoundException in benchmarks > -

[jira] [Commented] (FLINK-31965) Fix ClassNotFoundException in benchmarks

2023-04-28 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717573#comment-17717573 ] Paul Lin commented on FLINK-31965: -- Yes, it runs fine with source codes. > Fix ClassNo

[jira] [Updated] (FLINK-31965) Fix ClassNotFoundException in benchmarks

2023-04-27 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-31965: - Description: The benchmarks rely on the test jar of `flink-streaming-java`. However, the jar is set to

[jira] [Created] (FLINK-31965) Fix ClassNotFoundException in benchmarks

2023-04-27 Thread Paul Lin (Jira)
Paul Lin created FLINK-31965: Summary: Fix ClassNotFoundException in benchmarks Key: FLINK-31965 URL: https://issues.apache.org/jira/browse/FLINK-31965 Project: Flink Issue Type: Bug Co

[jira] [Commented] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2023-02-19 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690985#comment-17690985 ] Paul Lin commented on FLINK-26541: -- Is there any ongoing effort currently? I'm happy to

[jira] [Comment Edited] (FLINK-30811) Fix sql gateway can not stop job correctly

2023-02-01 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682881#comment-17682881 ] Paul Lin edited comment on FLINK-30811 at 2/1/23 8:00 AM: -- [~qi

[jira] [Commented] (FLINK-30811) Fix sql gateway can not stop job correctly

2023-01-31 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682881#comment-17682881 ] Paul Lin commented on FLINK-30811: -- [~qingyue] [~fsk119] Sorry for introducing this bug

[jira] [Comment Edited] (FLINK-30677) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails

2023-01-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677720#comment-17677720 ] Paul Lin edited comment on FLINK-30677 at 1/17/23 11:28 AM:

[jira] [Commented] (FLINK-30677) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails

2023-01-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677720#comment-17677720 ] Paul Lin commented on FLINK-30677: -- [~fsk119] I prefer the old approach too. It's insti

[jira] [Comment Edited] (FLINK-30677) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails

2023-01-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17676872#comment-17676872 ] Paul Lin edited comment on FLINK-30677 at 1/17/23 9:13 AM: --- -I

[jira] [Comment Edited] (FLINK-30677) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails

2023-01-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17676872#comment-17676872 ] Paul Lin edited comment on FLINK-30677 at 1/17/23 9:12 AM: --- ~~

[jira] [Commented] (FLINK-30698) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails

2023-01-16 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677278#comment-17677278 ] Paul Lin commented on FLINK-30698: -- Duplicate of https://issues.apache.org/jira/browse/

[jira] [Commented] (FLINK-30677) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails

2023-01-14 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17676872#comment-17676872 ] Paul Lin commented on FLINK-30677: -- I couldn't reproduce the error locally. Is that fix

[jira] [Comment Edited] (FLINK-30677) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails

2023-01-13 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17676835#comment-17676835 ] Paul Lin edited comment on FLINK-30677 at 1/14/23 4:16 AM: --- I

[jira] [Commented] (FLINK-30677) SqlGatewayServiceStatementITCase.testFlinkSqlStatements fails

2023-01-13 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17676835#comment-17676835 ] Paul Lin commented on FLINK-30677: --   I think the problem lies here: {code:java} 2023-

[jira] [Updated] (FLINK-28655) Support show jobs statement in SqlGatewayService

2023-01-02 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28655: - Summary: Support show jobs statement in SqlGatewayService (was: Support show jobs statement in SqlGatew

[jira] [Created] (FLINK-30538) Improve error handling of stop job operation

2023-01-01 Thread Paul Lin (Jira)
Paul Lin created FLINK-30538: Summary: Improve error handling of stop job operation Key: FLINK-30538 URL: https://issues.apache.org/jira/browse/FLINK-30538 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-27344) FLIP-222: Support full job lifecycle statements in SQL client

2022-10-13 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616929#comment-17616929 ] Paul Lin commented on FLINK-27344: -- [~AlexeyLV]  Thanks a lot for your input! It's very

[jira] [Commented] (FLINK-27344) FLIP-222: Support full job lifecycle statements in SQL client

2022-10-10 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615441#comment-17615441 ] Paul Lin commented on FLINK-27344: -- [~ekoblov] Sure. It's documented in the FLIP [http

[jira] [Commented] (FLINK-27344) FLIP-222: Support full job lifecycle statements in SQL client

2022-10-07 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614320#comment-17614320 ] Paul Lin commented on FLINK-27344: -- [~ekoblov] Yes, we've roughly considered the stored

[jira] [Updated] (FLINK-28685) Optimize CatalogManager getTable implementation

2022-07-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28685: - Priority: Minor (was: Major) > Optimize CatalogManager getTable implementation > --

[jira] [Commented] (FLINK-28685) Optimize CatalogManager getTable implementation

2022-07-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571188#comment-17571188 ] Paul Lin commented on FLINK-28685: -- Please assign this issue to me. I have fixed it in

[jira] [Updated] (FLINK-28685) Optimize CatalogManager getTable implementation

2022-07-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28685: - Description: Currently, Catalog#getTable(ObjectPath) might be abused in CatalogManager. CatalogManager

[jira] [Created] (FLINK-28685) Optimize CatalogManager getTable implementation

2022-07-25 Thread Paul Lin (Jira)
Paul Lin created FLINK-28685: Summary: Optimize CatalogManager getTable implementation Key: FLINK-28685 URL: https://issues.apache.org/jira/browse/FLINK-28685 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-28656) Support savepoint statements in SqlGatewayService

2022-07-23 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28656: - Component/s: Table SQL / API Table SQL / Gateway > Support savepoint statements in SqlG

[jira] [Updated] (FLINK-28657) Support drop savepoint statement in SqlGatewayService

2022-07-23 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28657: - Component/s: Table SQL / API Table SQL / Gateway > Support drop savepoint statement in

[jira] [Created] (FLINK-28658) Add document for job lifecycle statements

2022-07-23 Thread Paul Lin (Jira)
Paul Lin created FLINK-28658: Summary: Add document for job lifecycle statements Key: FLINK-28658 URL: https://issues.apache.org/jira/browse/FLINK-28658 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28657) Support drop savepoint statement in SqlGatewayService

2022-07-23 Thread Paul Lin (Jira)
Paul Lin created FLINK-28657: Summary: Support drop savepoint statement in SqlGatewayService Key: FLINK-28657 URL: https://issues.apache.org/jira/browse/FLINK-28657 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-28656) Support savepoint statements in SqlGatewayService

2022-07-23 Thread Paul Lin (Jira)
Paul Lin created FLINK-28656: Summary: Support savepoint statements in SqlGatewayService Key: FLINK-28656 URL: https://issues.apache.org/jira/browse/FLINK-28656 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-28655) Support show jobs statement in SqlGatewatService

2022-07-23 Thread Paul Lin (Jira)
Paul Lin created FLINK-28655: Summary: Support show jobs statement in SqlGatewatService Key: FLINK-28655 URL: https://issues.apache.org/jira/browse/FLINK-28655 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28617) Support stop job statement in SqlGatewayService

2022-07-20 Thread Paul Lin (Jira)
Paul Lin created FLINK-28617: Summary: Support stop job statement in SqlGatewayService Key: FLINK-28617 URL: https://issues.apache.org/jira/browse/FLINK-28617 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28391) DefaultBlocklistHandlerTest unstable

2022-07-05 Thread Paul Lin (Jira)
Paul Lin created FLINK-28391: Summary: DefaultBlocklistHandlerTest unstable Key: FLINK-28391 URL: https://issues.apache.org/jira/browse/FLINK-28391 Project: Flink Issue Type: Bug Compon

[jira] [Created] (FLINK-28363) Support drop savepoint statement in SQL client

2022-07-02 Thread Paul Lin (Jira)
Paul Lin created FLINK-28363: Summary: Support drop savepoint statement in SQL client Key: FLINK-28363 URL: https://issues.apache.org/jira/browse/FLINK-28363 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28362) Support savepoint statements in SQL client

2022-07-02 Thread Paul Lin (Jira)
Paul Lin created FLINK-28362: Summary: Support savepoint statements in SQL client Key: FLINK-28362 URL: https://issues.apache.org/jira/browse/FLINK-28362 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-28360) Support stop job statement in SQL client

2022-07-02 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28360: - Summary: Support stop job statement in SQL client (was: Support stop job operation in SQL client) > Su

[jira] [Updated] (FLINK-28361) Support show jobs statement in SQL client

2022-07-02 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-28361: - Summary: Support show jobs statement in SQL client (was: Support show jobs operation in SQL client) >

[jira] [Created] (FLINK-28361) Support show jobs operation in SQL client

2022-07-02 Thread Paul Lin (Jira)
Paul Lin created FLINK-28361: Summary: Support show jobs operation in SQL client Key: FLINK-28361 URL: https://issues.apache.org/jira/browse/FLINK-28361 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28360) Support stop job operation in SQL client

2022-07-02 Thread Paul Lin (Jira)
Paul Lin created FLINK-28360: Summary: Support stop job operation in SQL client Key: FLINK-28360 URL: https://issues.apache.org/jira/browse/FLINK-28360 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-27344) FLIP-222: Support full job lifecycle statements in SQL client

2022-06-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558714#comment-17558714 ] Paul Lin commented on FLINK-27344: -- [~jark][~fsk119][~martijnvisser] please assign this

[jira] [Updated] (FLINK-27344) FLIP-222: Support full job lifecycle statements in SQL client

2022-06-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-27344: - Description: With the efforts in FLIP-24 and FLIP-91, Flink SQL client supports submitting SQL jobs but

[jira] [Resolved] (FLINK-25558) TableResult OK may be empty if returned by multiple queries

2022-05-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin resolved FLINK-25558. -- Resolution: Fixed > TableResult OK may be empty if returned by multiple queries >

[jira] [Updated] (FLINK-27585) JdbcOutpuFormat fails to flush data on checkpoint and causes data loss

2022-05-12 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-27585: - Description: Currently, JdbcOutpuFormat may periodically flush the batches, and store the exception if

[jira] [Created] (FLINK-27585) JdbcOutpuFormat fails to flush data on checkpoint and causes data loss

2022-05-12 Thread Paul Lin (Jira)
Paul Lin created FLINK-27585: Summary: JdbcOutpuFormat fails to flush data on checkpoint and causes data loss Key: FLINK-27585 URL: https://issues.apache.org/jira/browse/FLINK-27585 Project: Flink

[jira] [Created] (FLINK-27344) FLIP-222: Support full query lifecycle statements in SQL client

2022-04-21 Thread Paul Lin (Jira)
Paul Lin created FLINK-27344: Summary: FLIP-222: Support full query lifecycle statements in SQL client Key: FLINK-27344 URL: https://issues.apache.org/jira/browse/FLINK-27344 Project: Flink Issu

[jira] [Commented] (FLINK-26651) The connector CI build timeout in azure

2022-03-21 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510246#comment-17510246 ] Paul Lin commented on FLINK-26651: -- [~leonard] Looks like it's related to this bug htt

[jira] [Created] (FLINK-26720) Support stop-with-savepoint on web UI

2022-03-17 Thread Paul Lin (Jira)
Paul Lin created FLINK-26720: Summary: Support stop-with-savepoint on web UI Key: FLINK-26720 URL: https://issues.apache.org/jira/browse/FLINK-26720 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-23513) Remove old connectors and formats stack around descriptors

2022-03-16 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-23513: - Attachment: Catch(03-16-16-22-14).jpg > Remove old connectors and formats stack around descriptors > ---

[jira] [Commented] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

2022-03-14 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506662#comment-17506662 ] Paul Lin commented on FLINK-26618: -- cc [~jark][~twalthr] > Remove jar statement not al

[jira] [Updated] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

2022-03-12 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-26618: - Description: Currently, `remove jar` statement doesn't remove the corresponding jars in pipeline.jars.

[jira] [Updated] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

2022-03-12 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-26618: - Component/s: Table SQL / Client > Remove jar statement not aligned with pipleline.jars > ---

[jira] [Created] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

2022-03-12 Thread Paul Lin (Jira)
Paul Lin created FLINK-26618: Summary: Remove jar statement not aligned with pipleline.jars Key: FLINK-26618 URL: https://issues.apache.org/jira/browse/FLINK-26618 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25558) TableResult OK may be empty if returned by multiple queries

2022-03-03 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17500575#comment-17500575 ] Paul Lin commented on FLINK-25558: -- Seems that the issue is fixed by FLINK-24685 in Fli

[jira] [Updated] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is gre

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-26204: - Attachment: output-of-window-tvf-test.png > set table.optimizer.distinct-agg.split.enabled to true and u

[jira] [Comment Edited] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497257#comment-17497257 ] Paul Lin edited comment on FLINK-26204 at 2/24/22, 8:43 AM:

[jira] [Comment Edited] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497257#comment-17497257 ] Paul Lin edited comment on FLINK-26204 at 2/24/22, 8:41 AM:

[jira] [Commented] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is g

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497257#comment-17497257 ] Paul Lin commented on FLINK-26204: -- I've reproduced the problem with minimum external d

[jira] [Updated] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is gre

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-26204: - Attachment: WindowTvfTest.java > set table.optimizer.distinct-agg.split.enabled to true and using Window

[jira] [Commented] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is g

2022-02-22 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495963#comment-17495963 ] Paul Lin commented on FLINK-26204: -- [~jark] I reproduced the problem locally. It seems

[jira] [Commented] (FLINK-25558) TableResult OK may be empty if returned by multiple queries

2022-01-06 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17470039#comment-17470039 ] Paul Lin commented on FLINK-25558: -- Working on the fix. Please assign this issue to me.

[jira] [Updated] (FLINK-25558) TableResult OK may be empty if returned by multiple queries

2022-01-06 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-25558: - Component/s: Table SQL / API Affects Version/s: 1.14.0 > TableResult OK may be empty if return

[jira] [Updated] (FLINK-25558) TableResult OK may be empty if returned by multiple queries

2022-01-06 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-25558: - Description: Many queries return `TABLE_RESULT_OK`, which is a static member for reducing memory overhe

[jira] [Created] (FLINK-25558) TableResult OK may be empty if returned by multiple queries

2022-01-06 Thread Paul Lin (Jira)
Paul Lin created FLINK-25558: Summary: TableResult OK may be empty if returned by multiple queries Key: FLINK-25558 URL: https://issues.apache.org/jira/browse/FLINK-25558 Project: Flink Issue Ty

[jira] [Closed] (FLINK-12022) Enable StreamWriter to update file length on sync flush

2021-12-15 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin closed FLINK-12022. Resolution: Won't Fix > Enable StreamWriter to update file length on sync flush >

[jira] [Commented] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-12-14 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17459681#comment-17459681 ] Paul Lin commented on FLINK-24948: -- [~jark] I've prepared a PR, PTAL. Thanks! > Specia

[jira] [Updated] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

2021-11-30 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-22300: - Issue Type: Bug (was: Improvement) > Why TimeEvictor of Keyed Windows evictor do not support Processing

[jira] [Commented] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

2021-11-30 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450970#comment-17450970 ] Paul Lin commented on FLINK-22300: -- [~arvid] For a usage case, how about a global windo

[jira] [Commented] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

2021-11-29 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450847#comment-17450847 ] Paul Lin commented on FLINK-22300: -- [~arvid] Please let me clarify a bit more. The prob

[jira] [Commented] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

2021-11-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448954#comment-17448954 ] Paul Lin commented on FLINK-22300: -- Any follow-ups? I would be happy to take this issue

[jira] [Commented] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-11-22 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447789#comment-17447789 ] Paul Lin commented on FLINK-24948: -- Yes, I'm working on it. May I ask your opinion on t

[jira] [Commented] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-11-22 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447746#comment-17447746 ] Paul Lin commented on FLINK-24948: -- [~jark] Sure. For example, a table name tbl_a with

[jira] [Commented] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-11-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445685#comment-17445685 ] Paul Lin commented on FLINK-24948: -- Working on the fix. Please assign this issue to me.

[jira] [Created] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-11-17 Thread Paul Lin (Jira)
Paul Lin created FLINK-24948: Summary: Special character in column names breaks JDBC statement parsing Key: FLINK-24948 URL: https://issues.apache.org/jira/browse/FLINK-24948 Project: Flink Issu

[jira] [Commented] (FLINK-24628) Invalid JDBC query template when no fields are selected

2021-10-25 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433601#comment-17433601 ] Paul Lin commented on FLINK-24628: -- I'm working on the fix. Please assign this to me. 

[jira] [Created] (FLINK-24628) Invalid JDBC query template when no fields are selected

2021-10-25 Thread Paul Lin (Jira)
Paul Lin created FLINK-24628: Summary: Invalid JDBC query template when no fields are selected Key: FLINK-24628 URL: https://issues.apache.org/jira/browse/FLINK-24628 Project: Flink Issue Type: B

[jira] [Created] (FLINK-24319) Jar not found in ClassLoaderITCase

2021-09-17 Thread Paul Lin (Jira)
Paul Lin created FLINK-24319: Summary: Jar not found in ClassLoaderITCase Key: FLINK-24319 URL: https://issues.apache.org/jira/browse/FLINK-24319 Project: Flink Issue Type: Bug Componen

[jira] [Commented] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

2021-09-02 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408693#comment-17408693 ] Paul Lin commented on FLINK-19816: -- Still getting this error with Flink 1.12.3. The job

[jira] [Updated] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

2021-09-02 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-19816: - Attachment: jm.log > Flink restored from a wrong checkpoint (a very old one and not the last > complete

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403704#comment-17403704 ] Paul Lin commented on FLINK-23725: -- [~sewen] In the cases I met, the users performed a

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-23 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403519#comment-17403519 ] Paul Lin commented on FLINK-23725: -- [~todd5167] You're right. The commit operations sho

[jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

2021-08-21 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-18592: - Priority: Major (was: Minor) > StreamingFileSink fails due to truncating HDFS file failure > --

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-21 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402652#comment-17402652 ] Paul Lin commented on FLINK-23725: -- [~todd5167] Would you like to provide a fix? If not

[jira] [Comment Edited] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-21 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402650#comment-17402650 ] Paul Lin edited comment on FLINK-23725 at 8/21/21, 5:18 PM:

[jira] [Comment Edited] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-21 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402650#comment-17402650 ] Paul Lin edited comment on FLINK-23725 at 8/21/21, 5:17 PM:

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

2021-08-21 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402650#comment-17402650 ] Paul Lin commented on FLINK-23725: -- I've also met this issue. If the file name already

[jira] [Updated] (FLINK-23868) JobExecutionResult printed even if suppressSysout is on

2021-08-19 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-23868: - Summary: JobExecutionResult printed even if suppressSysout is on (was: JobExecutionResult printed event

[jira] [Commented] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401491#comment-17401491 ] Paul Lin commented on FLINK-23868: -- Since this is a minor fix, to facilitate the discus

[jira] [Updated] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-23868: - Description: Environments prints job execution results to stdout by default and provides a flag `suppres

[jira] [Updated] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-23868: - Description: Environments prints job execution results to stdout by default and provided a flag `suppres

[jira] [Created] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread Paul Lin (Jira)
Paul Lin created FLINK-23868: Summary: JobExecutionResult printed event if suppressSysout is on Key: FLINK-23868 URL: https://issues.apache.org/jira/browse/FLINK-23868 Project: Flink Issue Type:

[jira] [Commented] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-18 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401428#comment-17401428 ] Paul Lin commented on FLINK-23727: -- [~paul8263] Thanks for your contribution, but the P

[jira] [Comment Edited] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400787#comment-17400787 ] Paul Lin edited comment on FLINK-23727 at 8/18/21, 5:13 AM:

[jira] [Commented] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400787#comment-17400787 ] Paul Lin commented on FLINK-23727: -- [~paul8263] WRT solutions, I've considered adding a

[jira] [Commented] (FLINK-23703) Support unrecoverable exception class list in configuration

2021-08-12 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398420#comment-17398420 ] Paul Lin commented on FLINK-23703: -- cc [~arvid] [~trohrmann] WDYT? > Support unrecover

[jira] [Updated] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-11 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-23727: - Description: In Kafka use cases, it's valid to send a message with a key and a null payload as a tombsto

  1   2   3   4   >