[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
]
Roc Marshal edited comment on FLINK-10230 at 10/12/21, 3:21 AM:
Could you [~jark] [~MartijnVisser] [~twalthr] help me to merge it if there are
nothing inappropriate ? Thank you.
was (Author: rocmarshal):
Could you [~jark] [~MartijnVisser] help me to merge it if there are nothing
inappropriate ? Thank you.
> Support 'SHOW CREATE VIEW' syntax to print the query of a view
> --
>
> Key: FLINK-10230
> URL: https://issues.apache.org/jira/browse/FLINK-10230
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Client
>Reporter: Timo Walther
>Assignee: Roc Marshal
>Priority: Minor
> Labels: auto-deprioritized-major, auto-unassigned,
> pull-request-available
> Fix For: 1.15.0
>
>
> FLINK-10163 added initial support for views in SQL Client. We should add a
> command that allows for printing the query of a view for debugging. MySQL
> offers {{SHOW CREATE VIEW}} for this. Hive generalizes this to {{SHOW CREATE
> TABLE}}. The latter one could be extended to also show information about the
> used table factories and properties.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold to avoid OOM
[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-24489: Description: source code : [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] was: source code : [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] The shared > The size of entryCache in the SharedBuffer should be defined with a threshold > to avoid OOM > -- > > Key: FLINK-24489 > URL: https://issues.apache.org/jira/browse/FLINK-24489 > Project: Flink > Issue Type: Improvement > Components: Library / CEP >Affects Versions: 1.10.0, 1.11.0, 1.12.0, 1.13.0, 1.14.0 >Reporter: Roc Marshal >Priority: Major > > source code : > [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold to avoid OOM
[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-24489: Description: source code : [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] The shared was:[here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] > The size of entryCache in the SharedBuffer should be defined with a threshold > to avoid OOM > -- > > Key: FLINK-24489 > URL: https://issues.apache.org/jira/browse/FLINK-24489 > Project: Flink > Issue Type: Improvement > Components: Library / CEP >Affects Versions: 1.10.0, 1.11.0, 1.12.0, 1.13.0, 1.14.0 >Reporter: Roc Marshal >Priority: Major > > source code : > [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] > The shared > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold to avoid OOM
[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-24489: Summary: The size of entryCache in the SharedBuffer should be defined with a threshold to avoid OOM (was: The size of entryCache in the SharedBuffer should be defined with a threshold) > The size of entryCache in the SharedBuffer should be defined with a threshold > to avoid OOM > -- > > Key: FLINK-24489 > URL: https://issues.apache.org/jira/browse/FLINK-24489 > Project: Flink > Issue Type: Improvement > Components: Library / CEP >Affects Versions: 1.10.0, 1.11.0, 1.12.0, 1.13.0, 1.14.0 >Reporter: Roc Marshal >Priority: Major > > [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold
[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426967#comment-17426967 ] Roc Marshal commented on FLINK-24489: - IMO, There need a size threshold to avoid OOM. > The size of entryCache in the SharedBuffer should be defined with a threshold > - > > Key: FLINK-24489 > URL: https://issues.apache.org/jira/browse/FLINK-24489 > Project: Flink > Issue Type: Improvement > Components: Library / CEP >Affects Versions: 1.10.0, 1.11.0, 1.12.0, 1.13.0, 1.14.0 >Reporter: Roc Marshal >Priority: Major > > [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (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:comment-tabpanel=17420528#comment-17420528 ] Roc Marshal edited comment on FLINK-24215 at 10/10/21, 2:18 PM: Could you [~dianfu] please assign this task to me ? Thank you very much. was (Author: rocmarshal): Could someone please assign this task to me ? Thank you very much. > Timeout exception in submitting a job by > RemoteStreamEnvironment/RemoteEnvironment > -- > > Key: FLINK-24215 > URL: https://issues.apache.org/jira/browse/FLINK-24215 > Project: Flink > Issue Type: Improvement > Components: API / DataStream >Affects Versions: 1.13.0, 1.12.3, 1.13.2 >Reporter: Roc Marshal >Priority: Not a Priority > > Cause: The job dependency resources is too big to transport to JobManager in > the limitted time. > Should the 'get' method of CompletableFuture be called with timeout > parameters in `RemoteStreamEnvironment/RemoteEnvironment` to limit the case? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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
]
Roc Marshal edited comment on FLINK-10230 at 10/9/21, 11:16 AM:
Could you [~jark] [~MartijnVisser] help me to merge it if there are nothing
inappropriate ? Thank you.
was (Author: rocmarshal):
Could you [~MartijnVisser] help me to merge it if there are nothing
inappropriate ? Thank you.
> Support 'SHOW CREATE VIEW' syntax to print the query of a view
> --
>
> Key: FLINK-10230
> URL: https://issues.apache.org/jira/browse/FLINK-10230
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Client
>Reporter: Timo Walther
>Assignee: Roc Marshal
>Priority: Minor
> Labels: auto-deprioritized-major, auto-unassigned,
> pull-request-available
> Fix For: 1.15.0
>
>
> FLINK-10163 added initial support for views in SQL Client. We should add a
> command that allows for printing the query of a view for debugging. MySQL
> offers {{SHOW CREATE VIEW}} for this. Hive generalizes this to {{SHOW CREATE
> TABLE}}. The latter one could be extended to also show information about the
> used table factories and properties.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold
[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17426550#comment-17426550 ] Roc Marshal commented on FLINK-24489: - cc [~jark] [~aljoscha] [~pnowojski] . > The size of entryCache in the SharedBuffer should be defined with a threshold > - > > Key: FLINK-24489 > URL: https://issues.apache.org/jira/browse/FLINK-24489 > Project: Flink > Issue Type: Improvement > Components: Library / CEP >Affects Versions: 1.10.0, 1.11.0, 1.12.0, 1.13.0, 1.14.0 >Reporter: Roc Marshal >Priority: Major > > [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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
]
Roc Marshal edited comment on FLINK-10230 at 10/9/21, 6:17 AM:
---
Could you [~MartijnVisser] help me to merge it if there are nothing
inappropriate ? Thank you.
was (Author: rocmarshal):
Could someone help me to merge it if there are nothing inappropriate ? Thank
you.
> Support 'SHOW CREATE VIEW' syntax to print the query of a view
> --
>
> Key: FLINK-10230
> URL: https://issues.apache.org/jira/browse/FLINK-10230
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Client
>Reporter: Timo Walther
>Assignee: Roc Marshal
>Priority: Minor
> Labels: auto-deprioritized-major, auto-unassigned,
> pull-request-available
> Fix For: 1.15.0
>
>
> FLINK-10163 added initial support for views in SQL Client. We should add a
> command that allows for printing the query of a view for debugging. MySQL
> offers {{SHOW CREATE VIEW}} for this. Hive generalizes this to {{SHOW CREATE
> TABLE}}. The latter one could be extended to also show information about the
> used table factories and properties.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold
[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-24489: Affects Version/s: 1.11.0 1.12.0 1.13.0 1.14.0 > The size of entryCache in the SharedBuffer should be defined with a threshold > - > > Key: FLINK-24489 > URL: https://issues.apache.org/jira/browse/FLINK-24489 > Project: Flink > Issue Type: Improvement > Components: Library / CEP >Affects Versions: 1.10.0, 1.11.0, 1.12.0, 1.13.0, 1.14.0 >Reporter: Roc Marshal >Priority: Major > > [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold
Roc Marshal created FLINK-24489: --- Summary: The size of entryCache in the SharedBuffer should be defined with a threshold Key: FLINK-24489 URL: https://issues.apache.org/jira/browse/FLINK-24489 Project: Flink Issue Type: Improvement Components: Library / CEP Affects Versions: 1.10.0 Reporter: Roc Marshal [here|https://github.com/apache/flink/blob/c3cb886ee73b5fee23b2bccff0f5e4d45a30b3a1/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java#L79] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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=17425936#comment-17425936 ] Roc Marshal commented on FLINK-15352: - Could someone help me to merge it if there are nothing inappropriate ? Thank you for your help. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (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
]
Roc Marshal commented on FLINK-10230:
-
Could someone help me to merge it if there are nothing inappropriate ? Thank
you.
> Support 'SHOW CREATE VIEW' syntax to print the query of a view
> --
>
> Key: FLINK-10230
> URL: https://issues.apache.org/jira/browse/FLINK-10230
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Client
>Reporter: Timo Walther
>Assignee: Roc Marshal
>Priority: Minor
> Labels: auto-deprioritized-major, auto-unassigned,
> pull-request-available
> Fix For: 1.15.0
>
>
> FLINK-10163 added initial support for views in SQL Client. We should add a
> command that allows for printing the query of a view for debugging. MySQL
> offers {{SHOW CREATE VIEW}} for this. Hive generalizes this to {{SHOW CREATE
> TABLE}}. The latter one could be extended to also show information about the
> used table factories and properties.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (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=17422036#comment-17422036
]
Roc Marshal commented on FLINK-10230:
-
[~airblader] Thank you so much for your suggestions. I updated the pr. Could
you please help me to review it ?
> Support 'SHOW CREATE VIEW' syntax to print the query of a view
> --
>
> Key: FLINK-10230
> URL: https://issues.apache.org/jira/browse/FLINK-10230
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Client
>Reporter: Timo Walther
>Assignee: Roc Marshal
>Priority: Minor
> Labels: auto-deprioritized-major, auto-unassigned,
> pull-request-available
> Fix For: 1.15.0
>
>
> FLINK-10163 added initial support for views in SQL Client. We should add a
> command that allows for printing the query of a view for debugging. MySQL
> offers {{SHOW CREATE VIEW}} for this. Hive generalizes this to {{SHOW CREATE
> TABLE}}. The latter one could be extended to also show information about the
> used table factories and properties.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[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=17419055#comment-17419055 ] Roc Marshal edited comment on FLINK-15352 at 9/29/21, 9:36 AM: --- Hi, [~MartijnVisser] [~airblader] I made some changes based on your suggestions. Would you like to review it for me? Thank you so much for your attention. was (Author: rocmarshal): Hi, [~MartijnVisser] [~airblader] I made some changes based on your suggestions. Would you like to review it for me? Thank you so much for your attention. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows.
[ https://issues.apache.org/jira/browse/FLINK-24383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420526#comment-17420526 ] Roc Marshal edited comment on FLINK-24383 at 9/29/21, 2:07 AM: --- Hi, [~jark] [~xtsong] , Could you please assign this ticket to me ? Thank you. was (Author: rocmarshal): Hi, [~jark], Could you please assign this ticket to me ? Thank you. > Remove the deprecated SlidingTimeWindows and TumblingTimeWindows. > - > > Key: FLINK-24383 > URL: https://issues.apache.org/jira/browse/FLINK-24383 > Project: Flink > Issue Type: Improvement > Components: API / DataStream >Affects Versions: 1.14.0 >Reporter: Roc Marshal >Priority: Major > > Remove deprecated > org.apache.flink.streaming.api.windowing.assigners.TumblingTimeWindows > & SlidingTimeWindows -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (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:comment-tabpanel=17420528#comment-17420528 ] Roc Marshal commented on FLINK-24215: - Could someone please assign this task to me ? Thank you very much. > Timeout exception in submitting a job by > RemoteStreamEnvironment/RemoteEnvironment > -- > > Key: FLINK-24215 > URL: https://issues.apache.org/jira/browse/FLINK-24215 > Project: Flink > Issue Type: Improvement > Components: API / DataStream >Affects Versions: 1.13.0, 1.12.3, 1.13.2 >Reporter: Roc Marshal >Priority: Not a Priority > > Cause: The job dependency resources is too big to transport to JobManager in > the limitted time. > Should the 'get' method of CompletableFuture be called with timeout > parameters in `RemoteStreamEnvironment/RemoteEnvironment` to limit the case? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows.
[ https://issues.apache.org/jira/browse/FLINK-24383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420526#comment-17420526 ] Roc Marshal commented on FLINK-24383: - Hi, [~jark], Could you please assign this ticket to me ? Thank you. > Remove the deprecated SlidingTimeWindows and TumblingTimeWindows. > - > > Key: FLINK-24383 > URL: https://issues.apache.org/jira/browse/FLINK-24383 > Project: Flink > Issue Type: Improvement > Components: API / DataStream >Affects Versions: 1.14.0 >Reporter: Roc Marshal >Priority: Major > > Remove deprecated > org.apache.flink.streaming.api.windowing.assigners.TumblingTimeWindows > & SlidingTimeWindows -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows.
Roc Marshal created FLINK-24383: --- Summary: Remove the deprecated SlidingTimeWindows and TumblingTimeWindows. Key: FLINK-24383 URL: https://issues.apache.org/jira/browse/FLINK-24383 Project: Flink Issue Type: Improvement Components: API / DataStream Affects Versions: 1.14.0 Reporter: Roc Marshal Remove deprecated org.apache.flink.streaming.api.windowing.assigners.TumblingTimeWindows & SlidingTimeWindows -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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=17419055#comment-17419055 ] Roc Marshal commented on FLINK-15352: - Hi, [~MartijnVisser] [~airblader] I made some changes based on your suggestions. Would you like to review it for me? Thank you so much for your attention. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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 ] Roc Marshal edited comment on FLINK-15352 at 9/20/21, 3:27 AM: --- Could you [~jark] [~twalthr] [~Leonard Xu] [~pnowojski] [~alpinegizmo] ersonhelp me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. was (Author: rocmarshal): Could you [~jark] [~twalthr] [~Leonard Xu] [~pnowojski] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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=17416993#comment-17416993 ] Roc Marshal edited comment on FLINK-15352 at 9/20/21, 3:24 AM: --- [~MartijnVisser] Thank you so much for your help.:) Looking forward to the work next. was (Author: rocmarshal): [~MartijnVisser] Thank you so much for your help.:) Looking forward to the work next. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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=17416993#comment-17416993 ] Roc Marshal commented on FLINK-15352: - [~MartijnVisser] Thank you so much for your help.:) Looking forward to the work next. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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 ] Roc Marshal edited comment on FLINK-15352 at 9/16/21, 12:56 PM: Could you [~jark] [~twalthr] [~Leonard Xu] [~pnowojski] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. was (Author: rocmarshal): Could you [~jark] [~twalthr] [~Thesharing] [~pnowojski] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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 ] Roc Marshal edited comment on FLINK-15352 at 9/16/21, 7:55 AM: --- Could you [~jark] [~twalthr] [~Thesharing] [~pnowojski] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. was (Author: rocmarshal): Could you [~jark] [~twalthr] [~phoenixjiangnan] [~airblader] [~Thesharing] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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 ] Roc Marshal edited comment on FLINK-15352 at 9/16/21, 6:15 AM: --- Could you [~jark] [~twalthr] [~phoenixjiangnan] [~airblader] [~Thesharing] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. was (Author: rocmarshal): Could you [~jark] [~twalthr] [~phoenixjiangnan] [~airblader] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Issue Comment Deleted] (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:all-tabpanel ] Roc Marshal updated FLINK-15352: Comment: was deleted (was: :)Could someone help me to review this pr? Thank you very much.) > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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=17413946#comment-17413946 ] Roc Marshal commented on FLINK-15352: - :)Could someone help me to review this pr? Thank you very much. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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 ] Roc Marshal edited comment on FLINK-15352 at 9/10/21, 10:07 AM: Could you [~jark] [~twalthr] [~phoenixjiangnan] [~airblader] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. was (Author: rocmarshal): Could you [~jark] [~brckner] [~phoenixjiangnan] [~airblader] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (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=17413011#comment-17413011
]
Roc Marshal commented on FLINK-10230:
-
[~twalthr] [~jark] Could you assign this ticket to me ? Thank you.
> Support 'SHOW CREATE VIEW' syntax to print the query of a view
> --
>
> Key: FLINK-10230
> URL: https://issues.apache.org/jira/browse/FLINK-10230
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Client
>Reporter: Timo Walther
>Priority: Minor
> Labels: auto-deprioritized-major, auto-unassigned,
> pull-request-available
> Fix For: 1.14.0
>
>
> FLINK-10163 added initial support for views in SQL Client. We should add a
> command that allows for printing the query of a view for debugging. MySQL
> offers {{SHOW CREATE VIEW}} for this. Hive generalizes this to {{SHOW CREATE
> TABLE}}. The latter one could be extended to also show information about the
> used table factories and properties.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[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 ] Roc Marshal edited comment on FLINK-15352 at 9/8/21, 3:38 PM: -- Could you [~jark] [~brckner] [~phoenixjiangnan] [~airblader] help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. was (Author: rocmarshal): Would someone like to help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (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 ] Roc Marshal updated FLINK-24215: Summary: Timeout exception in submitting a job by RemoteStreamEnvironment/RemoteEnvironment (was: Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment) > Timeout exception in submitting a job by > RemoteStreamEnvironment/RemoteEnvironment > -- > > Key: FLINK-24215 > URL: https://issues.apache.org/jira/browse/FLINK-24215 > Project: Flink > Issue Type: Improvement > Components: API / DataStream >Affects Versions: 1.13.0, 1.12.3, 1.13.2 >Reporter: Roc Marshal >Priority: Not a Priority > > Cause: The job dependency resources is too big to transport to JobManager in > the limitted time. > Should the 'get' method of CompletableFuture be called with timeout > parameters in `RemoteStreamEnvironment/RemoteEnvironment` to limit the case? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-24215) Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment
[ https://issues.apache.org/jira/browse/FLINK-24215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-24215: Issue Type: Improvement (was: Bug) > Timeout exception in submitting job by > RemoteStreamEnvironment/RemoteEnvironment > > > Key: FLINK-24215 > URL: https://issues.apache.org/jira/browse/FLINK-24215 > Project: Flink > Issue Type: Improvement > Components: API / DataStream >Affects Versions: 1.13.0, 1.12.3, 1.13.2 >Reporter: Roc Marshal >Priority: Not a Priority > > Cause: The job dependency resources is too big to transport to JobManager in > the limitted time. > Should the 'get' method of CompletableFuture be called with timeout > parameters in `RemoteStreamEnvironment/RemoteEnvironment` to limit the case? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-24215) Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment
Roc Marshal created FLINK-24215: --- Summary: Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment Key: FLINK-24215 URL: https://issues.apache.org/jira/browse/FLINK-24215 Project: Flink Issue Type: Technical Debt Components: API / DataStream Affects Versions: 1.13.2, 1.12.3, 1.13.0 Reporter: Roc Marshal Cause: The job dependency resources is too big to transport to JobManager in the limitted time. Should the 'get' method of CompletableFuture be called with timeout parameters in `RemoteStreamEnvironment/RemoteEnvironment` to limit the case? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-24215) Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment
[ https://issues.apache.org/jira/browse/FLINK-24215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-24215: Issue Type: Bug (was: Technical Debt) > Timeout exception in submitting job by > RemoteStreamEnvironment/RemoteEnvironment > > > Key: FLINK-24215 > URL: https://issues.apache.org/jira/browse/FLINK-24215 > Project: Flink > Issue Type: Bug > Components: API / DataStream >Affects Versions: 1.13.0, 1.12.3, 1.13.2 >Reporter: Roc Marshal >Priority: Major > > Cause: The job dependency resources is too big to transport to JobManager in > the limitted time. > Should the 'get' method of CompletableFuture be called with timeout > parameters in `RemoteStreamEnvironment/RemoteEnvironment` to limit the case? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-24215) Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment
[ https://issues.apache.org/jira/browse/FLINK-24215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-24215: Priority: Not a Priority (was: Major) > Timeout exception in submitting job by > RemoteStreamEnvironment/RemoteEnvironment > > > Key: FLINK-24215 > URL: https://issues.apache.org/jira/browse/FLINK-24215 > Project: Flink > Issue Type: Bug > Components: API / DataStream >Affects Versions: 1.13.0, 1.12.3, 1.13.2 >Reporter: Roc Marshal >Priority: Not a Priority > > Cause: The job dependency resources is too big to transport to JobManager in > the limitted time. > Should the 'get' method of CompletableFuture be called with timeout > parameters in `RemoteStreamEnvironment/RemoteEnvironment` to limit the case? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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=17412003#comment-17412003
]
Roc Marshal edited comment on FLINK-10230 at 9/8/21, 3:20 PM:
--
Hi, [~twalthr], [~jark], [~yanghua], I investigated the syntax in other
systems.
-
MySQL
syntax:
SHOW CREATE VIEW _view_name_
[https://dev.mysql.com/doc/refman/8.0/en/show-create-view.html]
-
snowflake
syntax: don't surpported yet.
[https://docs.snowflake.com/en/sql-reference/sql/desc-view.html]
trino
syntax: SHOW CREATE VIEW view_name
[https://trino.io/docs/current/sql/show-create-view.html]
--
hive
syntax: {{SHOW CREATE TABLE ([db_name.]table_name|view_name);}}
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowCreateTable]
---
spark
syntax: don't surpported yet.
[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-views.html]
presto
syntax: SHOW CREATE VIEW view_name
[https://prestodb.io/docs/current/sql/show-create-view.html]
--
Please let me know what are your opinions.
Thank you for your attention.
was (Author: rocmarshal):
Hi, [~twalthr], [~jark], [~yanghua], I investigated the syntax in other
systems.
MySQL
syntax:
SHOW CREATE VIEW _view_name_
[https://dev.mysql.com/doc/refman/8.0/en/show-create-view.html]
--
Prestodb
syntax:
-
snowflake
syntax: don't surpported yet.
[https://docs.snowflake.com/en/sql-reference/sql/desc-view.html]
-
trino
syntax: SHOW CREATE VIEW view_name
[https://trino.io/docs/current/sql/show-create-view.html]
--
hive
syntax: {{SHOW CREATE TABLE ([db_name.]table_name|view_name);}}
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowCreateTable]
---
spark
syntax: don't surpported yet.
[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-views.html]
presto
syntax: SHOW CREATE VIEW view_name
[https://prestodb.io/docs/current/sql/show-create-view.html]
Please let me know what are your opinions.
Thank you for your attention.
> Support 'SHOW CREATE VIEW' syntax to print the query of a view
> --
>
> Key: FLINK-10230
> URL: https://issues.apache.org/jira/browse/FLINK-10230
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Client
>Reporter: Timo Walther
>Priority: Minor
> Labels: auto-deprioritized-major, auto-unassigned,
> pull-request-available
> Fix For: 1.14.0
>
>
> FLINK-10163 added initial support for views in SQL Client. We should add a
> command that allows for printing the query of a view for debugging. MySQL
> offers {{SHOW CREATE VIEW}} for this. Hive generalizes this to {{SHOW CREATE
> TABLE}}. The latter one could be extended to also show information about the
> used table factories and properties.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (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=17412003#comment-17412003
]
Roc Marshal commented on FLINK-10230:
-
Hi, [~twalthr], [~jark], [~yanghua], I investigated the syntax in other
systems.
MySQL
syntax:
SHOW CREATE VIEW _view_name_
[https://dev.mysql.com/doc/refman/8.0/en/show-create-view.html]
--
Prestodb
syntax:
-
snowflake
syntax: don't surpported yet.
[https://docs.snowflake.com/en/sql-reference/sql/desc-view.html]
-
trino
syntax: SHOW CREATE VIEW view_name
[https://trino.io/docs/current/sql/show-create-view.html]
--
hive
syntax: {{SHOW CREATE TABLE ([db_name.]table_name|view_name);}}
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowCreateTable]
---
spark
syntax: don't surpported yet.
[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-views.html]
presto
syntax: SHOW CREATE VIEW view_name
[https://prestodb.io/docs/current/sql/show-create-view.html]
Please let me know what are your opinions.
Thank you for your attention.
> Support 'SHOW CREATE VIEW' syntax to print the query of a view
> --
>
> Key: FLINK-10230
> URL: https://issues.apache.org/jira/browse/FLINK-10230
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Client
>Reporter: Timo Walther
>Priority: Minor
> Labels: auto-deprioritized-major, auto-unassigned,
> pull-request-available
> Fix For: 1.14.0
>
>
> FLINK-10163 added initial support for views in SQL Client. We should add a
> command that allows for printing the query of a view for debugging. MySQL
> offers {{SHOW CREATE VIEW}} for this. Hive generalizes this to {{SHOW CREATE
> TABLE}}. The latter one could be extended to also show information about the
> used table factories and properties.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[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=17409327#comment-17409327 ] Roc Marshal commented on FLINK-15352: - Would someone like to help me to review the PR ? And I uploaded the type mapping information int the attachment for reviewers . Thank you very much. > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Issue Comment Deleted] (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:all-tabpanel ] Roc Marshal updated FLINK-15352: Comment: was deleted (was: Could someone help me to advance it ? Thank you.:)) > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-24043) Reuse the code of 'check savepoint preconditions'.
[ https://issues.apache.org/jira/browse/FLINK-24043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406605#comment-17406605 ] Roc Marshal commented on FLINK-24043: - Thanks [~jark] for the reply. Hi, [~gaoyunhaii] [~tangyun] Could you help me to review it if you have free time? Thank you. > Reuse the code of 'check savepoint preconditions'. > --- > > Key: FLINK-24043 > URL: https://issues.apache.org/jira/browse/FLINK-24043 > Project: Flink > Issue Type: Technical Debt > Components: Runtime / Task >Reporter: Roc Marshal >Priority: Minor > Labels: pull-request-available > > [here|https://github.com/apache/flink/blob/da944a8c90477d7b0210024028abd1011e250f14/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java#L822] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406547#comment-17406547 ] Roc Marshal commented on FLINK-22885: - Could someone help me to review this PR ? :) > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22885 > URL: https://issues.apache.org/jira/browse/FLINK-22885 > Project: Flink > Issue Type: New Feature > Components: Table SQL / API >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Major > Labels: pull-request-available > > h1. Support 'SHOW COLUMNS'. > SHOW COLUMNS ( FROM | IN ) [ [NOT] LIKE ] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-24043) Reuse the code of 'check savepoint preconditions'.
[ https://issues.apache.org/jira/browse/FLINK-24043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406546#comment-17406546 ] Roc Marshal commented on FLINK-24043: - [~jark] [~dianfu] Could you help me to review this PR ? Thank you very much. > Reuse the code of 'check savepoint preconditions'. > --- > > Key: FLINK-24043 > URL: https://issues.apache.org/jira/browse/FLINK-24043 > Project: Flink > Issue Type: Technical Debt > Components: Runtime / Task >Reporter: Roc Marshal >Priority: Minor > Labels: pull-request-available > > [here|https://github.com/apache/flink/blob/da944a8c90477d7b0210024028abd1011e250f14/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java#L822] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-24043) Reuse the code of 'check savepoint preconditions'.
Roc Marshal created FLINK-24043: --- Summary: Reuse the code of 'check savepoint preconditions'. Key: FLINK-24043 URL: https://issues.apache.org/jira/browse/FLINK-24043 Project: Flink Issue Type: Technical Debt Components: Runtime / Task Reporter: Roc Marshal [here|https://github.com/apache/flink/blob/da944a8c90477d7b0210024028abd1011e250f14/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java#L822] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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=17406071#comment-17406071 ] Roc Marshal commented on FLINK-15352: - Could someone help me to advance it ? Thank you.:) > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405742#comment-17405742 ] Roc Marshal edited comment on FLINK-23943 at 8/27/21, 10:58 AM: [~trohrmann] I reviewed the source operator carefully according to your suggestions. As you said, I used the default `cancel()` of SourceFunction method, which causes the error. So, it isn't a bug. [~chesnay] [~trohrmann] Thank you for your attention and guidance. I'll close the jira. was (Author: rocmarshal): [~trohrmann] I reviewed the source operator carefully according to your suggestion. As you said, I used the default `cancel()` of SourceFunction method, which causes the error. So, it isn't a bug. [~chesnay] [~trohrmann] Thank you for your attention and guidance. I'll close the jira. > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing, Runtime / Task >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal closed FLINK-23943. --- Resolution: Not A Bug > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing, Runtime / Task >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405742#comment-17405742 ] Roc Marshal commented on FLINK-23943: - [~trohrmann] I reviewed the source operator carefully according to your suggestion. As you said, I used the default `cancel()` of SourceFunction method, which causes the error. So, it isn't a bug. [~chesnay] [~trohrmann] Thank you for your attention and guidance. I'll close the jira. > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing, Runtime / Task >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405519#comment-17405519 ] Roc Marshal edited comment on FLINK-23943 at 8/27/21, 3:46 AM: --- [~trohrmann] [~chesnay] Yes. The problem is reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. was (Author: rocmarshal): [~trohrmann] [~chesnay] Yes. the problem is reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405519#comment-17405519 ] Roc Marshal edited comment on FLINK-23943 at 8/27/21, 3:45 AM: --- [~trohrmann] [~chesnay] Yes. the problem is reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. was (Author: rocmarshal): [~trohrmann] [~chesnay] Yes. the problem reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405519#comment-17405519 ] Roc Marshal edited comment on FLINK-23943 at 8/27/21, 1:45 AM: --- [~trohrmann] [~chesnay] Yes. the problem reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. was (Author: rocmarshal): [~trohrmann] [~chesnay] Yes. I'm trying to locate the problem. I will upload more fine-grained log information later . > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405519#comment-17405519 ] Roc Marshal commented on FLINK-23943: - [~trohrmann] [~chesnay] Yes. I'm trying to locate the problem. I will upload more fine-grained log information later . > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-23943: Labels: REST_API (was: rest) > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-23943: Labels: rest (was: ) > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: rest > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Issue Comment Deleted] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[
https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roc Marshal updated FLINK-23943:
Comment: was deleted
(was: ---jobmanager.log
2021-08-24 19:29:28,047 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Trigger heartbeat request.
2021-08-24 19:29:28,053 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Received heartbeat from 172.25.7.212:51798-6c6004.
2021-08-24 19:29:29,786 INFO org.apache.flink.runtime.jobmaster.JobMaster [] -
Triggering stop-with-savepoint for job f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,800 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
checkpoint 1 (type=SAVEPOINT_SUSPEND) @ 1629804569787 for job
f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,829 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Received
acknowledge message for checkpoint 1 from task 0409635d4e01383381cea6322e226a54
of job f08b743cea0468fa3ed1d00e32962755 at 172.25.7.212:51798-6c6004 @ bogon
(dataPort=51800).
2021-08-24 19:29:29,871 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Received
acknowledge message for checkpoint 1 from task 314d5caeb9871d74f5b00bdf1e4868ab
of job f08b743cea0468fa3ed1d00e32962755 at 172.25.7.212:51798-6c6004 @ bogon
(dataPort=51800).
2021-08-24 19:29:29,891 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Stop-with-savepoint transitioned from WaitingForSavepoint to SavepointCreated
on savepoint creation handling for job f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,895 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Completed
checkpoint 1 for job f08b743cea0468fa3ed1d00e32962755 (872 bytes in 103 ms).
2021-08-24 19:29:29,895 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint
state: OperatorState(operatorID: c09dc291fad93d575e015871097bfc60, parallelism:
1, maxParallelism: 128, coordinatorState: (none), sub task states: 1, total
size (bytes): 0), OperatorState(operatorID: 20ba6b65f97481d5570070de90e4e791,
parallelism: 1, maxParallelism: 128, coordinatorState: (none), sub task states:
1, total size (bytes): 872), OperatorState(operatorID:
bc764cd8ddf7a0cff126f51c16239658, parallelism: 1, maxParallelism: 128,
coordinatorState: (none), sub task states: 0, total size (bytes): 0)
-taskmanager.log--
2021-08-24 19:29:29,805 DEBUG
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Trigger checkpoint
1@1629804569787 for 0409635d4e01383381cea6322e226a54.
2021-08-24 19:29:29,806 DEBUG
org.apache.flink.streaming.runtime.tasks.StreamTask [] - Starting checkpoint
(1) SAVEPOINT_SUSPEND on task Source: Custom Source (1/1)#0
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.runtime.io.network.partition.consumer.ChannelStatePersister []
- found barrier 1, lastSeenBarrier = -1 (COMPLETED) @
InputChannelInfo\{gateIdx=0, inputChannelIdx=0}
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
[] - Map -> Sink: Print to Std. Out (1/1)#0
(314d5caeb9871d74f5b00bdf1e4868ab): Received barrier from channel
InputChannelInfo\{gateIdx=0, inputChannelIdx=0} @ 1.
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
[] - Map -> Sink: Print to Std. Out (1/1)#0
(314d5caeb9871d74f5b00bdf1e4868ab): Triggering checkpoint 1 on the barrier
announcement at 1629804569787.
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.tasks.StreamTask [] - Starting checkpoint
(1) SAVEPOINT_SUSPEND on task Map -> Sink: Print to Std. Out (1/1)#0
2021-08-24 19:29:29,814 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Source: Custom Source (1/1)#0,5,Flink Task Threads] took
1 ms.
2021-08-24 19:29:29,814 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Map -> Sink: Print to Std. Out (1/1)#0,5,Flink Task
Threads] took 1 ms.
2021-08-24 19:29:29,816 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Map -> Sink: Print to Std. Out (1/1)#0,5,Flink Task
Threads] took 0 ms.
2021-08-24 19:29:29,816 DEBUG
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl [] -
Source: Custom Source (1/1)#0 - finished synchronous part of checkpoint 1.
Alignment duration: 0 ms, snapshot duration -1 ms, is unaligned checkpoint :
false
2021-08-24 19:29:29,818 DEBUG
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - Source:
Custom Source (1/1)#0 - started executing asynchronous part of checkpoint 1.
[jira] [Updated] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-23943: Attachment: flink-roc-taskexecutor-0-MacBook-Pro.local.log flink-roc-standalonesession-0-MacBook-Pro.local.log > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403775#comment-17403775 ] Roc Marshal edited comment on FLINK-23943 at 8/24/21, 12:26 PM: Should the source operators in the job implement `StopableFunction` interface ? Could the job not be stopped by visiting `stop` url in REST API if all source operators are not both implemented from the `StopableFunction`? was (Author: rocmarshal): Should the source operators in the job implement `StopableFunction` interface ? Could the job not be stopped if all source operators are not both implemented from the `StopableFunction`? > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403775#comment-17403775 ] Roc Marshal commented on FLINK-23943: - Should the source operators in the job implement `StopableFunction` interface ? Could the job not be stopped if all source operators are not both implemented from the `StopableFunction`? > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[
https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403769#comment-17403769
]
Roc Marshal commented on FLINK-23943:
-
---jobmanager.log
2021-08-24 19:29:28,047 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Trigger heartbeat request.
2021-08-24 19:29:28,053 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Received heartbeat from 172.25.7.212:51798-6c6004.
2021-08-24 19:29:29,786 INFO org.apache.flink.runtime.jobmaster.JobMaster [] -
Triggering stop-with-savepoint for job f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,800 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
checkpoint 1 (type=SAVEPOINT_SUSPEND) @ 1629804569787 for job
f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,829 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Received
acknowledge message for checkpoint 1 from task 0409635d4e01383381cea6322e226a54
of job f08b743cea0468fa3ed1d00e32962755 at 172.25.7.212:51798-6c6004 @ bogon
(dataPort=51800).
2021-08-24 19:29:29,871 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Received
acknowledge message for checkpoint 1 from task 314d5caeb9871d74f5b00bdf1e4868ab
of job f08b743cea0468fa3ed1d00e32962755 at 172.25.7.212:51798-6c6004 @ bogon
(dataPort=51800).
2021-08-24 19:29:29,891 DEBUG org.apache.flink.runtime.jobmaster.JobMaster [] -
Stop-with-savepoint transitioned from WaitingForSavepoint to SavepointCreated
on savepoint creation handling for job f08b743cea0468fa3ed1d00e32962755.
2021-08-24 19:29:29,895 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Completed
checkpoint 1 for job f08b743cea0468fa3ed1d00e32962755 (872 bytes in 103 ms).
2021-08-24 19:29:29,895 DEBUG
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint
state: OperatorState(operatorID: c09dc291fad93d575e015871097bfc60, parallelism:
1, maxParallelism: 128, coordinatorState: (none), sub task states: 1, total
size (bytes): 0), OperatorState(operatorID: 20ba6b65f97481d5570070de90e4e791,
parallelism: 1, maxParallelism: 128, coordinatorState: (none), sub task states:
1, total size (bytes): 872), OperatorState(operatorID:
bc764cd8ddf7a0cff126f51c16239658, parallelism: 1, maxParallelism: 128,
coordinatorState: (none), sub task states: 0, total size (bytes): 0)
-taskmanager.log--
2021-08-24 19:29:29,805 DEBUG
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Trigger checkpoint
1@1629804569787 for 0409635d4e01383381cea6322e226a54.
2021-08-24 19:29:29,806 DEBUG
org.apache.flink.streaming.runtime.tasks.StreamTask [] - Starting checkpoint
(1) SAVEPOINT_SUSPEND on task Source: Custom Source (1/1)#0
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.runtime.io.network.partition.consumer.ChannelStatePersister []
- found barrier 1, lastSeenBarrier = -1 (COMPLETED) @
InputChannelInfo\{gateIdx=0, inputChannelIdx=0}
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
[] - Map -> Sink: Print to Std. Out (1/1)#0
(314d5caeb9871d74f5b00bdf1e4868ab): Received barrier from channel
InputChannelInfo\{gateIdx=0, inputChannelIdx=0} @ 1.
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
[] - Map -> Sink: Print to Std. Out (1/1)#0
(314d5caeb9871d74f5b00bdf1e4868ab): Triggering checkpoint 1 on the barrier
announcement at 1629804569787.
2021-08-24 19:29:29,808 DEBUG
org.apache.flink.streaming.runtime.tasks.StreamTask [] - Starting checkpoint
(1) SAVEPOINT_SUSPEND on task Map -> Sink: Print to Std. Out (1/1)#0
2021-08-24 19:29:29,814 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Source: Custom Source (1/1)#0,5,Flink Task Threads] took
1 ms.
2021-08-24 19:29:29,814 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Map -> Sink: Print to Std. Out (1/1)#0,5,Flink Task
Threads] took 1 ms.
2021-08-24 19:29:29,816 DEBUG
org.apache.flink.runtime.state.SnapshotStrategyRunner [] -
DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous
part) in thread Thread[Map -> Sink: Print to Std. Out (1/1)#0,5,Flink Task
Threads] took 0 ms.
2021-08-24 19:29:29,816 DEBUG
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl [] -
Source: Custom Source (1/1)#0 - finished synchronous part of checkpoint 1.
Alignment duration: 0 ms, snapshot duration -1 ms, is unaligned checkpoint :
false
2021-08-24 19:29:29,818 DEBUG
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - Source:
Custom Source (1/1)#0 - started executing asynchronous part of
[jira] [Commented] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403748#comment-17403748 ] Roc Marshal commented on FLINK-23943: - Hi, [~chesnay] ,When I visit the http://localhost:port[/jobs//stop|https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/ops/rest_api/#jobs-jobid-stop] with the savepoint parameters by the post method, the job was still running . > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-23943: Description: * "/jobs/:jobid/stop" in REST API can't stop the target job. * It can trigger a savepoint with the parameters. * The interface document link https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop was: * "/jobs/:jobid/stop" in REST API can't stop the target job. * It can trigger a savepoint with the parameters. > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
Roc Marshal created FLINK-23943: --- Summary: "/jobs/:jobid/stop" in REST API can't stop the target job. Key: FLINK-23943 URL: https://issues.apache.org/jira/browse/FLINK-23943 Project: Flink Issue Type: Bug Components: Runtime / REST Affects Versions: 1.13.2 Reporter: Roc Marshal * "/jobs/:jobid/stop" in REST API can't stop the target job. * It can trigger a savepoint with the parameters. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (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:all-tabpanel ] Roc Marshal updated FLINK-15352: Attachment: research-results.tar.gz > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC, Table SQL / Ecosystem >Reporter: Bowen Li >Assignee: Roc Marshal >Priority: Minor > Attachments: research-results.tar.gz > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-23909) Remove redundant variables and improve some style format in coding.
Roc Marshal created FLINK-23909: --- Summary: Remove redundant variables and improve some style format in coding. Key: FLINK-23909 URL: https://issues.apache.org/jira/browse/FLINK-23909 Project: Flink Issue Type: Improvement Components: Connectors / JDBC, Deployment / YARN, Scala Shell Affects Versions: 1.13.2 Reporter: Roc Marshal -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-23716) Translate the 'Zipping Elements in a DataSet' page inito Chinese
Roc Marshal created FLINK-23716: --- Summary: Translate the 'Zipping Elements in a DataSet' page inito Chinese Key: FLINK-23716 URL: https://issues.apache.org/jira/browse/FLINK-23716 Project: Flink Issue Type: Improvement Components: Documentation Reporter: Roc Marshal https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/dataset/zip_elements_guide/ -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-23716) Translate the 'Zipping Elements in a DataSet' page inito Chinese
[ https://issues.apache.org/jira/browse/FLINK-23716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-23716: Labels: chinese-translation (was: ) > Translate the 'Zipping Elements in a DataSet' page inito Chinese > > > Key: FLINK-23716 > URL: https://issues.apache.org/jira/browse/FLINK-23716 > Project: Flink > Issue Type: Improvement > Components: Documentation >Reporter: Roc Marshal >Priority: Minor > Labels: chinese-translation > > https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/dataset/zip_elements_guide/ -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-22885) Support 'SHOW COLUMNS'.
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22885: Description: h1. Support 'SHOW COLUMNS'. SHOW COLUMNS ( FROM | IN ) [ [NOT] LIKE ] was: h1. Support 'SHOW COLUMNS'. SHOW COLUMNS ( FROM | IN ) [LIKE ] > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22885 > URL: https://issues.apache.org/jira/browse/FLINK-22885 > Project: Flink > Issue Type: New Feature > Components: Table SQL / API >Reporter: Roc Marshal >Priority: Major > > h1. Support 'SHOW COLUMNS'. > SHOW COLUMNS ( FROM | IN ) [ [NOT] LIKE ] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392665#comment-17392665 ] Roc Marshal commented on FLINK-22885: - Could someone please help me to advance this jira? Close the JIRA or continue to improve the JIRA？ Thank you very much. > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22885 > URL: https://issues.apache.org/jira/browse/FLINK-22885 > Project: Flink > Issue Type: New Feature > Components: Table SQL / API >Reporter: Roc Marshal >Priority: Major > > h1. Support 'SHOW COLUMNS'. > SHOW COLUMNS ( FROM | IN ) [LIKE ] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Issue Comment Deleted] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.
[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22860: Comment: was deleted (was: Hi, [~twalthr] Could you please help me to advance this PR ? Thank you.) > Supplement 'HELP' command prompt message for SQL-Cli. > - > > Key: FLINK-22860 > URL: https://issues.apache.org/jira/browse/FLINK-22860 > Project: Flink > Issue Type: Improvement > Components: Table SQL / Client >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: attach.png > > > !attach.png! -- This message was sent by Atlassian Jira (v8.3.4#803005)
[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=17378572#comment-17378572 ] Roc Marshal commented on FLINK-15352: - Hi, [~phoenixjiangnan] [~jark] , Could you please assign this ticket to me ? Thank you.:) > develop MySQLCatalog to connect Flink with MySQL tables and ecosystem > -- > > Key: FLINK-15352 > URL: https://issues.apache.org/jira/browse/FLINK-15352 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC >Reporter: Bowen Li >Priority: Minor > Labels: auto-deprioritized-major > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.
[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378450#comment-17378450 ] Roc Marshal commented on FLINK-22860: - [~jark] [~lzljs3620320] The PR is ready. Could you please help me to review it ? Thank you very much. > Supplement 'HELP' command prompt message for SQL-Cli. > - > > Key: FLINK-22860 > URL: https://issues.apache.org/jira/browse/FLINK-22860 > Project: Flink > Issue Type: Improvement > Components: Table SQL / Client >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: attach.png > > > !attach.png! -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.
[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17376949#comment-17376949 ] Roc Marshal edited comment on FLINK-22860 at 7/9/21, 6:37 AM: -- Hi, [~twalthr] Could you please help me to advance this PR ? Thank you. was (Author: rocmarshal): Could someone please help me to advance this PR ? Thank you. > Supplement 'HELP' command prompt message for SQL-Cli. > - > > Key: FLINK-22860 > URL: https://issues.apache.org/jira/browse/FLINK-22860 > Project: Flink > Issue Type: Improvement > Components: Table SQL / Client >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: attach.png > > > !attach.png! -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22860) Supplement 'HELP' command prompt message for SQL-Cli.
[ https://issues.apache.org/jira/browse/FLINK-22860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17376949#comment-17376949 ] Roc Marshal commented on FLINK-22860: - Could someone please help me to advance this PR ? Thank you. > Supplement 'HELP' command prompt message for SQL-Cli. > - > > Key: FLINK-22860 > URL: https://issues.apache.org/jira/browse/FLINK-22860 > Project: Flink > Issue Type: Improvement > Components: Table SQL / Client >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Minor > Labels: pull-request-available > Attachments: attach.png > > > !attach.png! -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-23028) Improve documentation for pages of SQL.
[ https://issues.apache.org/jira/browse/FLINK-23028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365953#comment-17365953 ] Roc Marshal commented on FLINK-23028: - Could someone kindly help me to advance this PR? Thank you.:) > Improve documentation for pages of SQL. > --- > > Key: FLINK-23028 > URL: https://issues.apache.org/jira/browse/FLINK-23028 > Project: Flink > Issue Type: Improvement > Components: Documentation, Table SQL / API >Reporter: Roc Marshal >Priority: Minor > Labels: pull-request-available > > Wrong style in > [https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/sql/create/#create-function] > section. > Wrong style in > [https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/sql/drop/#drop-function] > section. > Wrong style in > [https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/sql/alter/#alter-function] > section. > Add the description about drop catalog in the page of > [https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sql/drop/] > . > 'catloag' of > [https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/sql/use/#use-catloag] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-23028) Improve documentation for pages of SQL.
Roc Marshal created FLINK-23028: --- Summary: Improve documentation for pages of SQL. Key: FLINK-23028 URL: https://issues.apache.org/jira/browse/FLINK-23028 Project: Flink Issue Type: Improvement Components: Documentation Reporter: Roc Marshal Wrong style in [https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/sql/create/#create-function] section. Wrong style in [https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/sql/drop/#drop-function] section. Wrong style in [https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/sql/alter/#alter-function] section. Add the description about drop catalog in the page of [https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sql/drop/] . 'catloag' of [https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/dev/table/sql/use/#use-catloag] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361588#comment-17361588 ] Roc Marshal commented on FLINK-22885: - For the time being, it would be feasible to support this DDL. Because we have designed some DDL statements based on catalog. If we need to consider whether to support a simplified INFORMATION_ SCHEMA paradigm, maybe we can start from transforming the existing catalog to the simple INFORMATION_ SCHEMA. Of course, it requires special discussion and research. > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22885 > URL: https://issues.apache.org/jira/browse/FLINK-22885 > Project: Flink > Issue Type: New Feature > Components: Table SQL / API >Reporter: Roc Marshal >Priority: Major > > h1. Support 'SHOW COLUMNS'. > SHOW COLUMNS ( FROM | IN ) [LIKE ] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Closed] (FLINK-22296) Introduce Preconditions-util into Python API
[ https://issues.apache.org/jira/browse/FLINK-22296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal closed FLINK-22296. --- Resolution: Later Close it for now. [~dian.fu] Thank you for your reply. > Introduce Preconditions-util into Python API > > > Key: FLINK-22296 > URL: https://issues.apache.org/jira/browse/FLINK-22296 > Project: Flink > Issue Type: Improvement > Components: API / Python >Reporter: Roc Marshal >Priority: Minor > Labels: auto-deprioritized-major > > Similar to the > [Preconditions|https://github.com/apache/flink/blob/87efae4d3180a52e16240a0b4bbb197f85acd22c/flink-core/src/main/java/org/apache/flink/util/Preconditions.java#L43] > class in flink java API -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22296) Introduce Preconditions-util into Python API
[ https://issues.apache.org/jira/browse/FLINK-22296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359912#comment-17359912 ] Roc Marshal commented on FLINK-22296: - Hi, [~nicholasjiang] [~dian.fu] If it's of little significance, I will close this JIRA. > Introduce Preconditions-util into Python API > > > Key: FLINK-22296 > URL: https://issues.apache.org/jira/browse/FLINK-22296 > Project: Flink > Issue Type: Improvement > Components: API / Python >Reporter: Roc Marshal >Priority: Minor > Labels: auto-deprioritized-major > > Similar to the > [Preconditions|https://github.com/apache/flink/blob/87efae4d3180a52e16240a0b4bbb197f85acd22c/flink-core/src/main/java/org/apache/flink/util/Preconditions.java#L43] > class in flink java API -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22921) SQL Client can't resolve the escape of " ' " correctly.
[ https://issues.apache.org/jira/browse/FLINK-22921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359702#comment-17359702 ] Roc Marshal commented on FLINK-22921: - I'm glad to do it. The target JIRA ID is FLINK-22934 > SQL Client can't resolve the escape of " ' " correctly. > --- > > Key: FLINK-22921 > URL: https://issues.apache.org/jira/browse/FLINK-22921 > Project: Flink > Issue Type: Bug > Components: Table SQL / Client >Reporter: Roc Marshal >Priority: Major > Labels: SQL > Attachments: escape1.jpeg, escape2.jpeg, escape3.jpeg, escape4.jpeg, > escape5.jpeg > > > Such as follows: > where =... > or > where like ... -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-22934) Add instructions for using the " ' " escape syntax of SQL client
[ https://issues.apache.org/jira/browse/FLINK-22934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22934: Description: # FLINK-22921 > Add instructions for using the " ' " escape syntax of SQL client > > > Key: FLINK-22934 > URL: https://issues.apache.org/jira/browse/FLINK-22934 > Project: Flink > Issue Type: Improvement > Components: Documentation, Table SQL / Client >Affects Versions: 1.13.0, 1.13.1 >Reporter: Roc Marshal >Priority: Major > > # FLINK-22921 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-22934) Add instructions for using the " ' " escape syntax of SQL client
Roc Marshal created FLINK-22934: --- Summary: Add instructions for using the " ' " escape syntax of SQL client Key: FLINK-22934 URL: https://issues.apache.org/jira/browse/FLINK-22934 Project: Flink Issue Type: Improvement Components: Documentation, Table SQL / Client Affects Versions: 1.13.1, 1.13.0 Reporter: Roc Marshal -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-22921) SQL Client can't resolve the escape of " ' " correctly.
[ https://issues.apache.org/jira/browse/FLINK-22921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359324#comment-17359324 ] Roc Marshal edited comment on FLINK-22921 at 6/8/21, 12:43 PM: --- [~jark] Thank you very much for your guidance (y). It would be better if this could be declared in the documentation. was (Author: rocmarshal): [~jark] Thank you very much for your guidance. It would be better if this could be declared in the documentation. > SQL Client can't resolve the escape of " ' " correctly. > --- > > Key: FLINK-22921 > URL: https://issues.apache.org/jira/browse/FLINK-22921 > Project: Flink > Issue Type: Bug > Components: Table SQL / Client >Reporter: Roc Marshal >Priority: Major > Labels: SQL > Attachments: escape1.jpeg, escape2.jpeg, escape3.jpeg, escape4.jpeg, > escape5.jpeg > > > Such as follows: > where =... > or > where like ... -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22921) SQL Client can't resolve the escape of " ' " correctly.
[ https://issues.apache.org/jira/browse/FLINK-22921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359324#comment-17359324 ] Roc Marshal commented on FLINK-22921: - [~jark] Thank you very much for your guidance. It would be better if this could be declared in the documentation. > SQL Client can't resolve the escape of " ' " correctly. > --- > > Key: FLINK-22921 > URL: https://issues.apache.org/jira/browse/FLINK-22921 > Project: Flink > Issue Type: Bug > Components: Table SQL / Client >Reporter: Roc Marshal >Priority: Major > Labels: SQL > Attachments: escape1.jpeg, escape2.jpeg, escape3.jpeg, escape4.jpeg, > escape5.jpeg > > > Such as follows: > where =... > or > where like ... -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22921) SQL Client can't resolve the escape of " ' " correctly.
[ https://issues.apache.org/jira/browse/FLINK-22921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359283#comment-17359283 ] Roc Marshal commented on FLINK-22921: - 1.13.1 [~yanbit] > SQL Client can't resolve the escape of " ' " correctly. > --- > > Key: FLINK-22921 > URL: https://issues.apache.org/jira/browse/FLINK-22921 > Project: Flink > Issue Type: Bug > Components: Table SQL / Client >Reporter: Roc Marshal >Priority: Major > Labels: SQL > Attachments: escape1.jpeg, escape2.jpeg, escape3.jpeg, escape4.jpeg, > escape5.jpeg > > > Such as follows: > where =... > or > where like ... -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-22921) SQL Client can't resolve the escape of "'" correctly.
[ https://issues.apache.org/jira/browse/FLINK-22921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22921: Description: Such as follows: where =... or where like ... was: Such as follows: where =... or where like ... !escape1.jpeg! > SQL Client can't resolve the escape of "'" correctly. > - > > Key: FLINK-22921 > URL: https://issues.apache.org/jira/browse/FLINK-22921 > Project: Flink > Issue Type: Bug > Components: Table SQL / Client >Reporter: Roc Marshal >Priority: Major > Labels: SQL > Attachments: escape1.jpeg, escape2.jpeg, escape3.jpeg, escape4.jpeg, > escape5.jpeg > > > Such as follows: > where =... > or > where like ... -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-22921) SQL Client can't resolve the escape of " ' " correctly.
[ https://issues.apache.org/jira/browse/FLINK-22921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22921: Summary: SQL Client can't resolve the escape of " ' " correctly. (was: SQL Client can't resolve the escape of "'" correctly.) > SQL Client can't resolve the escape of " ' " correctly. > --- > > Key: FLINK-22921 > URL: https://issues.apache.org/jira/browse/FLINK-22921 > Project: Flink > Issue Type: Bug > Components: Table SQL / Client >Reporter: Roc Marshal >Priority: Major > Labels: SQL > Attachments: escape1.jpeg, escape2.jpeg, escape3.jpeg, escape4.jpeg, > escape5.jpeg > > > Such as follows: > where =... > or > where like ... -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-22921) SQL Client can't resolve the escape of "'" correctly.
Roc Marshal created FLINK-22921: --- Summary: SQL Client can't resolve the escape of "'" correctly. Key: FLINK-22921 URL: https://issues.apache.org/jira/browse/FLINK-22921 Project: Flink Issue Type: Bug Components: Table SQL / Client Reporter: Roc Marshal Attachments: escape1.jpeg, escape2.jpeg, escape3.jpeg, escape4.jpeg, escape5.jpeg Such as follows: where =... or where like ... !escape1.jpeg! -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17359208#comment-17359208 ] Roc Marshal commented on FLINK-22885: - [~jark] ,[~Leonard Xu],[~twalthr] What's your opinions? > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22885 > URL: https://issues.apache.org/jira/browse/FLINK-22885 > Project: Flink > Issue Type: New Feature > Components: Table SQL / API >Reporter: Roc Marshal >Priority: Major > > h1. Support 'SHOW COLUMNS'. > SHOW COLUMNS ( FROM | IN ) [LIKE ] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-22885) Support 'SHOW COLUMNS'.
[
https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358540#comment-17358540
]
Roc Marshal edited comment on FLINK-22885 at 6/7/21, 11:09 AM:
---
*Note:* *The above table shows that there are several problems that cannot be
adjusted, please ignore it. Refer to the information below, Please.*
* *MySQL*
* *primitive syntax support*: SHOW [EXTENDED] [FULL] \{COLUMNS| FIELDS}
\{FROM| IN} _tbl_name_ [{FROM | IN} _db_name_] [LIKE 'pattern'| WHERE expr]
* *optional strategy*:query from meta schema store.
* *reference link*:[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]
* *SparkSQL*
* *primitive syntax support*: SHOW COLUMNS table_identifier [ database ]
* *optional strategy*: unknown
* *reference
link*:[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]
* *Hive*
* *primitive syntax support*: SHOW COLUMNS (FROM|IN) table_name [(FROM| IN)
db_name] {{ [ LIKE }} {{'pattern_with_wildcards'}} {{]}};
* *optional strategy*: unknown
* *reference link*: https://issues.apache.org/jira/browse/HIVE-18373
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
* *Presto*
* *primitive syntax support*: SHOW COLUMNS FROM
* *optional strategy*: unknown
* *reference link*: [https://prestodb.io/docs/current/sql/show-columns.html]
* *Snowflake*
* *primitive syntax support*: SHOW COLUMNS [ LIKE '' ] [ IN \{
ACCOUNT | [ DATABASE ] | [ SCHEMA ] | [ TABLE ]
| [ VIEW ] }]
* *optional strategy*: unknown
* *reference link*:
[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]
* *Trino*
* *primitive syntax support*: SHOW COLUMNS FROM table [ LIKE pattern ]
* *optional strategy*:unknown
* *reference link*: [https://trino.io/docs/current/sql/show-columns.html]
* *PostgreSQL*
* *primitive syntax support*: disable
* *optional strategy*: "SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " OR "\d+ "
* *reference link*:[https://www.postgresql.org/docs/current/sql.html]
was (Author: rocmarshal):
*Note:* *The above table shows that there are several problems that cannot be
adjusted, please ignore it. Refer to the information below, Please.*
* *MySQL*
* *primitive syntax support*: SHOW [EXTENDED] [FULL] \{COLUMNS| FIELDS}
\{FROM| IN} _tbl_name_ [\{FROM | IN} _db_name_] [LIKE 'pattern'| WHERE expr]
* *optional strategy*:query from meta schema store.
* *reference link*:[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]
* *SparkSQL*
* *primitive syntax support*: SHOW COLUMNS table_identifier [ database ]
* *optional strategy*: unknown
* *reference
link*:[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]
* *Hive*
* *primitive syntax support*: SHOW COLUMNS (FROM|IN) table_name [(FROM| IN)
db_name] {{ [ LIKE }} {{'pattern_with_wildcards'}} {{]}};
* *optional strategy*: unknown
* *reference link*: https://issues.apache.org/jira/browse/HIVE-18373
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
* *Presto*
* *primitive syntax support*: SHOW COLUMNS FROM
* *optional strategy*: unknown
* *reference link*: [https://prestodb.io/docs/current/sql/show-columns.html]
* *Snowflake*
* *primitive syntax support*: SHOW COLUMNS [ LIKE '' ] [ IN \{
ACCOUNT | [ DATABASE ] | [ SCHEMA ] | [ TABLE ]
| [ VIEW ] }]
* *optional strategy*: unknown
* *reference link*:
[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]
* *Trino*
* *primitive syntax support*: SHOW COLUMNS FROM table [ LIKE pattern ]
* *optional strategy*:unknown
* *reference link*: [https://trino.io/docs/current/sql/show-columns.html]
* *PostgreSQL*
* *primitive syntax support*: disable
* *optional strategy*: "SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " OR "\d+ "
* *reference link*:[https://www.postgresql.org/docs/current/sql.html]
> Support 'SHOW COLUMNS'.
> ---
>
> Key: FLINK-22885
> URL: https://issues.apache.org/jira/browse/FLINK-22885
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Reporter: Roc Marshal
>Priority: Major
>
> h1. Support 'SHOW COLUMNS'.
> SHOW COLUMNS ( FROM | IN ) [LIKE ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Comment Edited] (FLINK-22885) Support 'SHOW COLUMNS'.
[
https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358540#comment-17358540
]
Roc Marshal edited comment on FLINK-22885 at 6/7/21, 11:08 AM:
---
*Note:* *The above table shows that there are several problems that cannot be
adjusted, please ignore it. Refer to the information below, Please.*
* *MySQL*
* *primitive syntax support*: SHOW [EXTENDED] [FULL] \{COLUMNS| FIELDS}
\{FROM| IN} _tbl_name_ [\{FROM | IN} _db_name_] [LIKE 'pattern'| WHERE expr]
* *optional strategy*:query from meta schema store.
* *reference link*:[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]
* *SparkSQL*
* *primitive syntax support*: SHOW COLUMNS table_identifier [ database ]
* *optional strategy*: unknown
* *reference
link*:[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]
* *Hive*
* *primitive syntax support*: SHOW COLUMNS (FROM|IN) table_name [(FROM| IN)
db_name] {{ [ LIKE }} {{'pattern_with_wildcards'}} {{]}};
* *optional strategy*: unknown
* *reference link*: https://issues.apache.org/jira/browse/HIVE-18373
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
* *Presto*
* *primitive syntax support*: SHOW COLUMNS FROM
* *optional strategy*: unknown
* *reference link*: [https://prestodb.io/docs/current/sql/show-columns.html]
* *Snowflake*
* *primitive syntax support*: SHOW COLUMNS [ LIKE '' ] [ IN \{
ACCOUNT | [ DATABASE ] | [ SCHEMA ] | [ TABLE ]
| [ VIEW ] }]
* *optional strategy*: unknown
* *reference link*:
[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]
* *Trino*
* *primitive syntax support*: SHOW COLUMNS FROM table [ LIKE pattern ]
* *optional strategy*:unknown
* *reference link*: [https://trino.io/docs/current/sql/show-columns.html]
* *PostgreSQL*
* *primitive syntax support*: disable
* *optional strategy*: "SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " OR "\d+ "
* *reference link*:[https://www.postgresql.org/docs/current/sql.html]
was (Author: rocmarshal):
*Note:* *The above table shows that there are several problems that cannot be
adjusted, please ignore it. Refer to the information below, Please.*
* *MySQL*
* *primitive syntax support*: SHOW [EXTENDED] [FULL] \{COLUMNS| FIELDS}
\{FROM| IN} _tbl_name_ [\{FROM | IN} _db_name_] [LIKE 'pattern'| WHERE expr]
* *optional strategy*:query from meta schema store.
* *reference link*:[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]
* *SparkSQL*
* *primitive syntax support*: SHOW COLUMNS table_identifier [ database ]
* *optional strategy*: unknown
* *reference
link*:[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]
* *Hive*
* *primitive syntax support*: SHOW COLUMNS (FROM|IN) table_name [(FROM| IN)
db_name] {{ [ LIKE }} {{'pattern_with_wildcards'}} {{]}};
* *optional strategy*: unknown
* *reference link*: https://issues.apache.org/jira/browse/HIVE-18373
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
* *Presto*
* *primitive syntax support*: SHOW COLUMNS FROM
* *optional strategy*: unknown
* *reference link*: [https://prestodb.io/docs/current/sql/show-columns.html]
* *Snowflake*
* *primitive syntax support*: SHOW COLUMNS [ LIKE '' ] [ IN \{
ACCOUNT | [ DATABASE ] | [ SCHEMA ] | [ TABLE ]
| [ VIEW ] }]
* *optional strategy*: unknown
* *reference link*:
[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]
* *Trino*
* *primitive syntax support*: SHOW COLUMNS FROM table [ LIKE pattern ]
* *optional strategy*:unknown
* *reference link*: [https://trino.io/docs/current/sql/show-columns.html]
* *PostgreSQL*
* *primitive syntax support*: disable
* *optional strategy*: "SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " OR "\d+ "
* *reference link*:[https://www.postgresql.org/docs/current/sql.html]
> Support 'SHOW COLUMNS'.
> ---
>
> Key: FLINK-22885
> URL: https://issues.apache.org/jira/browse/FLINK-22885
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Reporter: Roc Marshal
>Priority: Major
>
> h1. Support 'SHOW COLUMNS'.
> SHOW COLUMNS ( FROM | IN ) [LIKE ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.
[
https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358540#comment-17358540
]
Roc Marshal commented on FLINK-22885:
-
*Note:* *The above table shows that there are several problems that cannot be
adjusted, please ignore it. Refer to the information below, Please.*
* *MySQL*
* *primitive syntax support*: SHOW [EXTENDED] [FULL] \{COLUMNS| FIELDS}
\{FROM| IN} _tbl_name_ [\{FROM | IN} _db_name_] [LIKE 'pattern'| WHERE expr]
* *optional strategy*:query from meta schema store.
* *reference link*:[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]
* *SparkSQL*
* *primitive syntax support*: SHOW COLUMNS table_identifier [ database ]
* *optional strategy*: unknown
* *reference
link*:[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]
* *Hive*
* *primitive syntax support*: SHOW COLUMNS (FROM|IN) table_name [(FROM| IN)
db_name] {{ [ LIKE }} {{'pattern_with_wildcards'}} {{]}};
* *optional strategy*: unknown
* *reference link*: https://issues.apache.org/jira/browse/HIVE-18373
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
* *Presto*
* *primitive syntax support*: SHOW COLUMNS FROM
* *optional strategy*: unknown
* *reference link*: [https://prestodb.io/docs/current/sql/show-columns.html]
* *Snowflake*
* *primitive syntax support*: SHOW COLUMNS [ LIKE '' ] [ IN \{
ACCOUNT | [ DATABASE ] | [ SCHEMA ] | [ TABLE ]
| [ VIEW ] }]
* *optional strategy*: unknown
* *reference link*:
[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]
* *Trino*
* *primitive syntax support*: SHOW COLUMNS FROM table [ LIKE pattern ]
* *optional strategy*:unknown
* *reference link*: [https://trino.io/docs/current/sql/show-columns.html]
* *PostgreSQL*
* *primitive syntax support*: disable
* *optional strategy*: "SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " OR "\d+ "
* *reference link*:[https://www.postgresql.org/docs/current/sql.html]
> Support 'SHOW COLUMNS'.
> ---
>
> Key: FLINK-22885
> URL: https://issues.apache.org/jira/browse/FLINK-22885
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Reporter: Roc Marshal
>Priority: Major
>
> h1. Support 'SHOW COLUMNS'.
> SHOW COLUMNS ( FROM | IN ) [LIKE ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Comment Edited] (FLINK-22885) Support 'SHOW COLUMNS'.
[
https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358500#comment-17358500
]
Roc Marshal edited comment on FLINK-22885 at 6/7/21, 10:48 AM:
---
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] \{COLUMNS\| FIELDS}
\{FROM \| IN}
_tbl_name_ [\{FROM \| IN}
_db_name_] [LIKE 'pattern'\| WHERE expr]|query from meta schema
store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM\| IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN \{ ACCOUNT \| [ DATABASE ]
\| [ SCHEMA ] \| [ TABLE ] \| [ VIEW ]
}]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]|
|
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+
"|[https://www.postgresql.org/docs/current/sql.html]|
was (Author: rocmarshal):
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] \{COLUMNS\| FIELDS}
\{FROM \| IN}
_tbl_name_ [\{FROM \| IN}
_db_name_] [LIKE 'pattern' \| WHERE expr]|query from meta schema
store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM \| IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN \{ ACCOUNT \| [ DATABASE ]
\| [ SCHEMA ] \| [ TABLE ] \| [ VIEW ]
}]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]|
|
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+
"|[https://www.postgresql.org/docs/current/sql.html]|
> Support 'SHOW COLUMNS'.
> ---
>
> Key: FLINK-22885
> URL: https://issues.apache.org/jira/browse/FLINK-22885
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Reporter: Roc Marshal
>Priority: Major
>
> h1. Support 'SHOW COLUMNS'.
> SHOW COLUMNS ( FROM | IN ) [LIKE ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Comment Edited] (FLINK-22885) Support 'SHOW COLUMNS'.
[
https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358500#comment-17358500
]
Roc Marshal edited comment on FLINK-22885 at 6/7/21, 10:47 AM:
---
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] \{COLUMNS\| FIELDS}
\{FROM \| IN}
_tbl_name_ [\{FROM \| IN}
_db_name_] [LIKE 'pattern' \| WHERE expr]|query from meta schema
store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM \| IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN \{ ACCOUNT \| [ DATABASE ]
\| [ SCHEMA ] \| [ TABLE ] \| [ VIEW ]
}]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]|
|
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+
"|[https://www.postgresql.org/docs/current/sql.html]|
was (Author: rocmarshal):
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] {COLUMNS
\| FIELDS}
\{FROM \| IN}
_tbl_name_ [\{FROM \| IN}
_db_name_] [LIKE 'pattern' \| WHERE expr]|query from meta schema
store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM \| IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN { ACCOUNT
\| [ DATABASE ]
\| [ SCHEMA ]
\| [ TABLE ]
\| [ VIEW ]
}]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]|
|
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+
"|[https://www.postgresql.org/docs/current/sql.html]|
> Support 'SHOW COLUMNS'.
> ---
>
> Key: FLINK-22885
> URL: https://issues.apache.org/jira/browse/FLINK-22885
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Reporter: Roc Marshal
>Priority: Major
>
> h1. Support 'SHOW COLUMNS'.
> SHOW COLUMNS ( FROM | IN ) [LIKE ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Comment Edited] (FLINK-22885) Support 'SHOW COLUMNS'.
[
https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358500#comment-17358500
]
Roc Marshal edited comment on FLINK-22885 at 6/7/21, 10:45 AM:
---
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] {COLUMNS
\| FIELDS}
\{FROM \| IN}
_tbl_name_ [\{FROM \| IN}
_db_name_] [LIKE 'pattern' \| WHERE expr]|query from meta schema
store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM \| IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN { ACCOUNT
\| [ DATABASE ]
\| [ SCHEMA ]
\| [ TABLE ]
\| [ VIEW ]
}]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]|
|
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+
"|[https://www.postgresql.org/docs/current/sql.html]|
was (Author: rocmarshal):
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] \{COLUMNS \\| FIELDS}
{FROM \\| IN} _tbl_name_ [\{FROM \| IN}
_db_name_] [LIKE '_pattern_' \\| WHERE _expr_]|query from meta schema
store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM\\|IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN \{ ACCOUNT \\| [ DATABASE ]
\\| [ SCHEMA ] \\| [ TABLE ] \\| [ VIEW ]
}]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]|
|
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+
"|[https://www.postgresql.org/docs/current/sql.html]|
> Support 'SHOW COLUMNS'.
> ---
>
> Key: FLINK-22885
> URL: https://issues.apache.org/jira/browse/FLINK-22885
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Reporter: Roc Marshal
>Priority: Major
>
> h1. Support 'SHOW COLUMNS'.
> SHOW COLUMNS ( FROM | IN ) [LIKE ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Comment Edited] (FLINK-22885) Support 'SHOW COLUMNS'.
[
https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358500#comment-17358500
]
Roc Marshal edited comment on FLINK-22885 at 6/7/21, 10:37 AM:
---
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] \{COLUMNS \\| FIELDS}
{FROM \\| IN} _tbl_name_ [\{FROM \| IN}
_db_name_] [LIKE '_pattern_' \\| WHERE _expr_]|query from meta schema
store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM\\|IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN \{ ACCOUNT \\| [ DATABASE ]
\\| [ SCHEMA ] \\| [ TABLE ] \\| [ VIEW ]
}]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]|
|
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+
"|[https://www.postgresql.org/docs/current/sql.html]|
was (Author: rocmarshal):
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] {COLUMNS \| FIELDS} {FROM \| IN} _tbl_name_
[{FROM \| IN} _db_name_] [LIKE '_pattern_' \| WHERE _expr_]|query from meta
schema store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM\|IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN { ACCOUNT \| [ DATABASE ]
\| [ SCHEMA ] \| [ TABLE ] \| [ VIEW ]
}
]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]| |
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+ "
|[https://www.postgresql.org/docs/current/sql.html]| |
> Support 'SHOW COLUMNS'.
> ---
>
> Key: FLINK-22885
> URL: https://issues.apache.org/jira/browse/FLINK-22885
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Reporter: Roc Marshal
>Priority: Major
>
> h1. Support 'SHOW COLUMNS'.
> SHOW COLUMNS ( FROM | IN ) [LIKE ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.
[
https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358500#comment-17358500
]
Roc Marshal commented on FLINK-22885:
-
[~jark] Thank you for your attention. And I make a table to describe the state
of the 'SHOW COLUMNS' syntax in other DB engines.
Look forward to your reply.
||database||primitive syntax support||optional strategy||reference link||
|MySQL|SHOW [EXTENDED] [FULL] {COLUMNS \| FIELDS} {FROM \| IN} _tbl_name_
[{FROM \| IN} _db_name_] [LIKE '_pattern_' \| WHERE _expr_]|query from meta
schema store.|[https://dev.mysql.com/doc/refman/8.0/en/show-columns.html]| |
|SparkSQL| {{SHOW COLUMNS table_identifier [ database
]}}|unknown|[https://spark.apache.org/docs/latest/sql-ref-syntax-aux-show-columns.html]|
|
|Hive|SHOW COLUMNS (FROM\|IN) table_name [(FROM\|IN) db_name] {{ [ LIKE }}
{{'pattern_with_wildcards'}} {{]}};|unknown| #
[https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ShowColumns]
# https://issues.apache.org/jira/browse/HIVE-18373| | |
|Presto|SHOW COLUMNS FROM
|unknown|[https://prestodb.io/docs/current/sql/show-columns.html]| |
|Snowflake|SHOW COLUMNS [ LIKE '' ] [ IN { ACCOUNT \| [ DATABASE ]
\| [ SCHEMA ] \| [ TABLE ] \| [ VIEW ]
}
]|unknown|[https://docs.snowflake.com/en/sql-reference/sql/show-columns.html]| |
|Trino|SHOW COLUMNS FROM table [ LIKE pattern
]|unknown|[https://trino.io/docs/current/sql/show-columns.html]| |
|PostgreSQL|disable|"SELECT
table_name,
column_name,
data_type
FROM
information_schema.columns
WHERE
table_name = '';"
OR
"\d " / "\d+ "
|[https://www.postgresql.org/docs/current/sql.html]| |
> Support 'SHOW COLUMNS'.
> ---
>
> Key: FLINK-22885
> URL: https://issues.apache.org/jira/browse/FLINK-22885
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Reporter: Roc Marshal
>Priority: Major
>
> h1. Support 'SHOW COLUMNS'.
> SHOW COLUMNS ( FROM | IN ) [LIKE ]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358352#comment-17358352 ] Roc Marshal commented on FLINK-22885: - [~jark] There's no doubt that "SHOW CREATE TABLE" command can show the information of all the columns in the table. However, when there are many table fields, I hope to use this command 'SHOW COLUMNS ( FROM | IN ) [LIKE ]' to find quickly some information about the target field. > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22885 > URL: https://issues.apache.org/jira/browse/FLINK-22885 > Project: Flink > Issue Type: New Feature > Components: Table SQL / API >Reporter: Roc Marshal >Priority: Major > Labels: SQL > > h1. Support 'SHOW COLUMNS'. > SHOW COLUMNS ( FROM | IN ) [LIKE ] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-22885) Support 'SHOW COLUMNS'.
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22885: Issue Type: New Feature (was: Improvement) > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22885 > URL: https://issues.apache.org/jira/browse/FLINK-22885 > Project: Flink > Issue Type: New Feature > Components: Table SQL / API >Reporter: Roc Marshal >Priority: Major > Labels: SQL > > h1. Support 'SHOW COLUMNS'. > SHOW COLUMNS ( FROM | IN ) [LIKE ] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358040#comment-17358040 ] Roc Marshal commented on FLINK-22885: - [~Leonard Xu] I'm interested in this jira. Could you assign this ticket to me ? :) Thank you. > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22885 > URL: https://issues.apache.org/jira/browse/FLINK-22885 > Project: Flink > Issue Type: Improvement > Components: Table SQL / API >Reporter: Roc Marshal >Priority: Major > Labels: SQL > > h1. Support 'SHOW COLUMNS'. > SHOW COLUMNS ( FROM | IN ) [LIKE ] -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-22885) Support 'SHOW COLUMNS'.
Roc Marshal created FLINK-22885: --- Summary: Support 'SHOW COLUMNS'. Key: FLINK-22885 URL: https://issues.apache.org/jira/browse/FLINK-22885 Project: Flink Issue Type: Improvement Components: Table SQL / API Reporter: Roc Marshal h1. Support 'SHOW COLUMNS'. SHOW COLUMNS ( FROM | IN ) [LIKE ]. -- This message was sent by Atlassian Jira (v8.3.4#803005)
