[GitHub] [flink] lirui-apache commented on a change in pull request #16040: [FLINK-20926][maxwell][json] Allow to read metadata for maxwell-json format

2021-06-06 Thread GitBox
lirui-apache commented on a change in pull request #16040: URL: https://github.com/apache/flink/pull/16040#discussion_r645538658 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDecodingFormat.java ## @@ -0,0 +1,194 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #14861: [FLINK-21088][runtime][checkpoint] Pass the flag about whether a operator is fully finished on recovery

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #14861: URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467 ## CI report: * b460330c657cf91a570f2f6235fd58e218656972 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] SteNicholas commented on pull request #16013: [FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client

2021-06-06 Thread GitBox
SteNicholas commented on pull request #16013: URL: https://github.com/apache/flink/pull/16013#issuecomment-855644975 @wuchong , I have addressed your detailed comments and updated this pull request. Could you please help to review again? Sorry for later update. -- This is an automated me

[jira] [Commented] (FLINK-14437) Drop the legacy planner

2021-06-06 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358377#comment-17358377 ] Timo Walther commented on FLINK-14437: -- Hi [~jark], yes supporting batch mode in {{

[jira] [Updated] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per operator in SQL

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17173: Priority: Major (was: Minor) > Supports query hint to config "IdleStateRetentionTime" per operator in SQL

[jira] [Updated] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per operator in SQL

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17173: Labels: (was: auto-deprioritized-major) > Supports query hint to config "IdleStateRetentionTime" per ope

[GitHub] [flink] flinkbot commented on pull request #16087: [FLINK-22895][docs] Table common document misspelled

2021-06-06 Thread GitBox
flinkbot commented on pull request #16087: URL: https://github.com/apache/flink/pull/16087#issuecomment-855639276 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-22896) Flink sql supports parallelism at the operator level

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358374#comment-17358374 ] Jark Wu commented on FLINK-22896: - The community had some discussion to use query hint t

[jira] [Updated] (FLINK-22895) Table common document misspelled

2021-06-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22895: --- Labels: pull-request-available (was: ) > Table common document misspelled > ---

[GitHub] [flink] sujun1020 opened a new pull request #16087: [FLINK-22895][docs] Table common document misspelled

2021-06-06 Thread GitBox
sujun1020 opened a new pull request #16087: URL: https://github.com/apache/flink/pull/16087 ## What is the purpose of the change Fix document spelling errors ## Brief change log Update 4 documents with 8 errors ## Verifying this change This change is a

[GitHub] [flink] lixmgl commented on pull request #16086: [FLINK-22585] Add deprecated message when -m yarn-cluster is used

2021-06-06 Thread GitBox
lixmgl commented on pull request #16086: URL: https://github.com/apache/flink/pull/16086#issuecomment-855636510 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific c

[GitHub] [flink-statefun] tzulitai closed pull request #238: [backport-2.2] [FLINK-21956] Improve error message when Kafka key is missing

2021-06-06 Thread GitBox
tzulitai closed pull request #238: URL: https://github.com/apache/flink-statefun/pull/238 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] curcur commented on pull request #15200: [FLINK-21355] Send changes to the state changelog

2021-06-06 Thread GitBox
curcur commented on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-855628016 Thanks @rkhachatryan for addressing the comments! Some remaining points to discuss offline 1. why "MERGE_NS" is named "stateMerged" instead of "mergeNamespaces" 2. Whe

[GitHub] [flink] curcur commented on a change in pull request #15200: [FLINK-21355] Send changes to the state changelog

2021-06-06 Thread GitBox
curcur commented on a change in pull request #15200: URL: https://github.com/apache/flink/pull/15200#discussion_r646289736 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMapState.java ## @@ -96,12 +164,39

[jira] [Commented] (FLINK-22818) IgnoreInFlightDataITCase fails on azure

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358370#comment-17358370 ] Xintong Song commented on FLINK-22818: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-22896) Flink sql supports parallelism at the operator level

2021-06-06 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-22896: - Summary: Flink sql supports parallelism at the operator level Key: FLINK-22896 URL: https://issues.apache.org/jira/browse/FLINK-22896 Project: Flink Issue

[jira] [Updated] (FLINK-22885) Support 'SHOW COLUMNS'.

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22885: Labels: (was: SQL) > Support 'SHOW COLUMNS'. > --- > > Key: FLINK-22

[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358365#comment-17358365 ] Jark Wu commented on FLINK-22885: - Thanks [~RocMarshal]. Usually, we are cautious to add

[GitHub] [flink] flinkbot edited a comment on pull request #16086: [FLINK-22585] Add deprecated message when -m yarn-cluster is used

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #16086: URL: https://github.com/apache/flink/pull/16086#issuecomment-855570837 ## CI report: * b3e6d58f57c43ab2debb3cf461520bad209c45db Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * 4e5966fdfd351d5acb2ce04747d66b3f540cb12f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur commented on a change in pull request #15200: [FLINK-21355] Send changes to the state changelog

2021-06-06 Thread GitBox
curcur commented on a change in pull request #15200: URL: https://github.com/apache/flink/pull/15200#discussion_r646271862 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMapState.java ## @@ -96,12 +164,39

[jira] [Closed] (FLINK-22855) Translate the 'Overview of Python API' page into Chinese.

2021-06-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22855. --- Resolution: Fixed Merged to - master via 13324049ed5378ca2abae711c09b73498515 - release-1.13 via b73f6c

[jira] [Updated] (FLINK-22855) Translate the 'Overview of Python API' page into Chinese.

2021-06-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22855: Priority: Major (was: Minor) > Translate the 'Overview of Python API' page into Chinese. > --

[GitHub] [flink] dianfu closed pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

2021-06-06 Thread GitBox
dianfu closed pull request #16061: URL: https://github.com/apache/flink/pull/16061 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #16086: [FLINK-22585] Add deprecated message when -m yarn-cluster is used

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #16086: URL: https://github.com/apache/flink/pull/16086#issuecomment-855570837 ## CI report: * b3e6d58f57c43ab2debb3cf461520bad209c45db Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #16061: URL: https://github.com/apache/flink/pull/16061#issuecomment-853573483 ## CI report: * 4075411aeeb5c59602864c346567dd2edab8a3b9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * 4e5966fdfd351d5acb2ce04747d66b3f540cb12f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal commented on a change in pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

2021-06-06 Thread GitBox
RocMarshal commented on a change in pull request #16061: URL: https://github.com/apache/flink/pull/16061#discussion_r646268621 ## File path: docs/content.zh/docs/dev/python/overview.md ## @@ -29,36 +29,33 @@ under the License. Review comment: @dianfu Thank you for you

[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.

2021-06-06 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358352#comment-17358352 ] Roc Marshal commented on FLINK-22885: - [~jark] There's no doubt that "SHOW CREATE T

[GitHub] [flink] flinkbot commented on pull request #16086: [FLINK-22585] Add deprecated message when -m yarn-cluster is used

2021-06-06 Thread GitBox
flinkbot commented on pull request #16086: URL: https://github.com/apache/flink/pull/16086#issuecomment-855570837 ## CI report: * b3e6d58f57c43ab2debb3cf461520bad209c45db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] curcur commented on a change in pull request #15200: [FLINK-21355] Send changes to the state changelog

2021-06-06 Thread GitBox
curcur commented on a change in pull request #15200: URL: https://github.com/apache/flink/pull/15200#discussion_r646260894 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMapState.java ## @@ -71,22 +94,67

[GitHub] [flink] curcur commented on a change in pull request #15200: [FLINK-21355] Send changes to the state changelog

2021-06-06 Thread GitBox
curcur commented on a change in pull request #15200: URL: https://github.com/apache/flink/pull/15200#discussion_r646242033 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -328,

[jira] [Commented] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used

2021-06-06 Thread Rainie Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358346#comment-17358346 ] Rainie Li commented on FLINK-22585: --- Please review pr: https://github.com/apache/flink

[jira] [Commented] (FLINK-22886) Thread leak in RocksDBStateUploader

2021-06-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358345#comment-17358345 ] Yun Tang commented on FLINK-22886: -- Glad to know ready solution. [~mayuehappy], please

[GitHub] [flink] flinkbot commented on pull request #16086: [FLINK-22585] Add deprecated message when -m yarn-cluster is used

2021-06-06 Thread GitBox
flinkbot commented on pull request #16086: URL: https://github.com/apache/flink/pull/16086#issuecomment-855562059 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Assigned] (FLINK-22886) Thread leak in RocksDBStateUploader

2021-06-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-22886: Assignee: Yue Ma > Thread leak in RocksDBStateUploader > --- > >

[jira] [Updated] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used

2021-06-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22585: --- Labels: pull-request-available stale-assigned (was: stale-assigned) > Add deprecated messag

[GitHub] [flink] lixmgl opened a new pull request #16086: [FLINK-22585] Add deprecated message when -m yarn-cluster is used

2021-06-06 Thread GitBox
lixmgl opened a new pull request #16086: URL: https://github.com/apache/flink/pull/16086 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[GitHub] [flink] dianfu commented on a change in pull request #16061: [FLINK-22855][docs-zh] Translate the 'Overview of Python API' page into Chinese.

2021-06-06 Thread GitBox
dianfu commented on a change in pull request #16061: URL: https://github.com/apache/flink/pull/16061#discussion_r646249784 ## File path: docs/content.zh/docs/dev/python/overview.md ## @@ -29,36 +29,33 @@ under the License. {{< img src="/fig/pyflink.svg" alt="PyFlink" class="

[jira] [Commented] (FLINK-22886) Thread leak in RocksDBStateUploader

2021-06-06 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358338#comment-17358338 ] Jiayi Liao commented on FLINK-22886: [~yunta] Hi Yun, [~mayuehappy] is solving this

[jira] [Updated] (FLINK-22853) Flink SQL functions max/min/sum return duplicated records

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22853: Component/s: Connectors / JDBC > Flink SQL functions max/min/sum return duplicated records > -

[jira] [Commented] (FLINK-22853) Flink SQL functions max/min/sum return duplicated records

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358334#comment-17358334 ] Jark Wu commented on FLINK-22853: - [~raypon.wang], thanks for the example, the cause of

[jira] [Assigned] (FLINK-22895) Table common document misspelled

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22895: --- Assignee: sujun > Table common document misspelled > > >

[jira] [Assigned] (FLINK-22673) Add document about add jar related commands

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22673: --- Assignee: Shengkai Fang > Add document about add jar related commands > ---

[GitHub] [flink] wuchong commented on pull request #16013: [FLINK-21742][sql-client] Support REMOVE JAR statement in SQL Client

2021-06-06 Thread GitBox
wuchong commented on pull request #16013: URL: https://github.com/apache/flink/pull/16013#issuecomment-81833 Hi @SteNicholas , do you have time to update it? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * 4e5966fdfd351d5acb2ce04747d66b3f540cb12f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14861: [FLINK-21088][runtime][checkpoint] Pass the flag about whether a operator is fully finished on recovery

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #14861: URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467 ## CI report: * 9e2a17b6c36cd4a6c54716e973cabff190791695 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22895) Table common document misspelled

2021-06-06 Thread sujun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358327#comment-17358327 ] sujun commented on FLINK-22895: --- [~jark]  If the community wants to fix it, you can assign

[jira] [Created] (FLINK-22895) Table common document misspelled

2021-06-06 Thread sujun (Jira)
sujun created FLINK-22895: - Summary: Table common document misspelled Key: FLINK-22895 URL: https://issues.apache.org/jira/browse/FLINK-22895 Project: Flink Issue Type: Bug Components: Docu

[jira] [Commented] (FLINK-22884) Select view columns fail when store metadata with hive

2021-06-06 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358326#comment-17358326 ] Rui Li commented on FLINK-22884: I think we don't have to differentiate whether a view i

[jira] [Comment Edited] (FLINK-22853) Flink SQL functions max/min/sum return duplicated records

2021-06-06 Thread Raypon Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358325#comment-17358325 ] Raypon Wang edited comment on FLINK-22853 at 6/7/21, 3:01 AM:

[jira] [Commented] (FLINK-22853) Flink SQL functions max/min/sum return duplicated records

2021-06-06 Thread Raypon Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358325#comment-17358325 ] Raypon Wang commented on FLINK-22853: - !image-2021-06-07-11-00-05-608.png! > Flink

[jira] [Updated] (FLINK-22853) Flink SQL functions max/min/sum return duplicated records

2021-06-06 Thread Raypon Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raypon Wang updated FLINK-22853: Attachment: image-2021-06-07-11-00-05-608.png > Flink SQL functions max/min/sum return duplicated

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358324#comment-17358324 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22886) Thread leak in RocksDBStateUploader

2021-06-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358323#comment-17358323 ] Yun Tang commented on FLINK-22886: -- Thanks for reporting this, would you like to fix th

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358322#comment-17358322 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-853560762 ## CI report: * 4e5966fdfd351d5acb2ce04747d66b3f540cb12f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358320#comment-17358320 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358321#comment-17358321 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358319#comment-17358319 ] Xintong Song commented on FLINK-22625: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #14861: [FLINK-21088][runtime][checkpoint] Pass the flag about whether a operator is fully finished on recovery

2021-06-06 Thread GitBox
flinkbot edited a comment on pull request #14861: URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467 ## CI report: * 9e2a17b6c36cd4a6c54716e973cabff190791695 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22884) Select view columns fail when store metadata with hive

2021-06-06 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358316#comment-17358316 ] Rui Li commented on FLINK-22884: Thanks [~ELLEX_SHEN] for reporting the issue. Let me kn

[jira] [Commented] (FLINK-22891) FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure

2021-06-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358318#comment-17358318 ] Yangze Guo commented on FLINK-22891: I've run this test over 10,000 times in my loca

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest hangs on azure

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358317#comment-17358317 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Assigned] (FLINK-22894) Window Top-N should allow n=1

2021-06-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22894: Assignee: JING ZHANG > Window Top-N should allow n=1 > - > >

[jira] [Commented] (FLINK-22894) Window Top-N should allow n=1

2021-06-06 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358315#comment-17358315 ] Jingsong Lee commented on FLINK-22894: -- [~alpinegizmo] Thanks! [~qingru zhang] Assi

[jira] [Commented] (FLINK-22673) Add document about add jar related commands

2021-06-06 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358313#comment-17358313 ] Shengkai Fang commented on FLINK-22673: --- Please assign it to me.[~jark] > Add doc

[GitHub] [flink] lirui-apache commented on pull request #15939: [FLINK-15390][Connectors/ORC][Connectors/Hive]List/Map/Struct types support for vectorized orc reader

2021-06-06 Thread GitBox
lirui-apache commented on pull request #15939: URL: https://github.com/apache/flink/pull/15939#issuecomment-855537630 > @lirui-apache @wangwei1025 Do we need update document and update Hive reader? Yes, we can have a separate PR for that. @wangwei1025 do you want to work on it? --

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-06 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358310#comment-17358310 ] Rui Li commented on FLINK-22890: The root cause seems to be {{testStreamingSinkWithTime

[jira] [Commented] (FLINK-22894) Window Top-N should allow n=1

2021-06-06 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358309#comment-17358309 ] JING ZHANG commented on FLINK-22894: [~alpinegizmo] Thanks for reporting the bug. I

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358308#comment-17358308 ] Xintong Song commented on FLINK-22702: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] JingsongLi commented on pull request #15939: [FLINK-15390][Connectors/ORC][Connectors/Hive]List/Map/Struct types support for vectorized orc reader

2021-06-06 Thread GitBox
JingsongLi commented on pull request #15939: URL: https://github.com/apache/flink/pull/15939#issuecomment-855533615 @lirui-apache @wangwei1025 Do we need update document and update Hive reader? -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22067: - Affects Version/s: 1.13.1 > SavepointWindowReaderITCase.testApplyEvictorWindowStateReader >

[jira] [Reopened] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22067: -- There's an instance with the exactly same error stack on the 1.13 branch. Reopening the ticket and

[jira] [Commented] (FLINK-22853) Flink SQL functions max/min/sum return duplicated records

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358307#comment-17358307 ] Jark Wu commented on FLINK-22853: - [~raypon.wang] could you have a check again? It seems

[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358305#comment-17358305 ] Jark Wu commented on FLINK-22885: - Can "SHOW CREATE TABLE" meet your need? > Support '

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358304#comment-17358304 ] Xintong Song commented on FLINK-22457: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Closed] (FLINK-17707) Support configuring replica of Deployment based HA setups

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-17707. Fix Version/s: 1.14.0 Resolution: Done Merged via - master (1.14): 5fe3f5bbc78df4e932113cfc

[GitHub] [flink] xintongsong closed pull request #15286: [FLINK-17707][k8s] Support configuring replicas of JobManager deployment when HA enabled

2021-06-06 Thread GitBox
xintongsong closed pull request #15286: URL: https://github.com/apache/flink/pull/15286 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, pl

[jira] [Closed] (FLINK-22854) Translate 'Apache Flink Documentation' index page to Chinese

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22854. --- Fix Version/s: 1.14.0 Assignee: Roc Marshal Resolution: Fixed Fixed in master: 163690a178c2c

[jira] [Updated] (FLINK-22854) Translate 'Apache Flink Documentation' index page to Chinese

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22854: Component/s: Documentation > Translate 'Apache Flink Documentation' index page to Chinese > --

[GitHub] [flink] wuchong merged pull request #16062: [FLINK-22854][docs-zh] Translate 'Apache Flink Documentation' index page to Chinese.

2021-06-06 Thread GitBox
wuchong merged pull request #16062: URL: https://github.com/apache/flink/pull/16062 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[jira] [Commented] (FLINK-22884) Select view columns fail when store metadata with hive

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358296#comment-17358296 ] Jark Wu commented on FLINK-22884: - cc [~lirui] > Select view columns fail when store me

[jira] [Updated] (FLINK-22884) Select view columns fail when store metadata with hive

2021-06-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22884: Component/s: (was: Table SQL / API) Connectors / Hive > Select view columns fail when

[jira] [Updated] (FLINK-13203) [proper fix] Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

2021-06-06 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-13203: Labels: auto-deprioritized-critical (was: auto-deprioritized-critical stale-major) > [proper fix

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358293#comment-17358293 ] Xintong Song commented on FLINK-22702: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18634: - Labels: auto-unassigned test-stability (was: auto-unassigned stale-major test-stability) > Fli

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358292#comment-17358292 ] Xintong Song commented on FLINK-18634: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] leonardBang commented on a change in pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

2021-06-06 Thread GitBox
leonardBang commented on a change in pull request #16060: URL: https://github.com/apache/flink/pull/16060#discussion_r646222862 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -39,82 +39,175 @@ private CliStrings

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

2021-06-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358291#comment-17358291 ] Xintong Song commented on FLINK-22869: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22874) flink table partition trigger doesn't effect as expectation when sink into hive table

2021-06-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17358290#comment-17358290 ] luoyuxia commented on FLINK-22874: -- [~SpongebobZ] Hi, have you enabled checkpointing fo

[GitHub] [flink] sunxiaoguang edited a comment on pull request #16057: [FLINK-22851][security] Add basic authentication support to job dashboard and REST

2021-06-06 Thread GitBox
sunxiaoguang edited a comment on pull request #16057: URL: https://github.com/apache/flink/pull/16057#issuecomment-854321050 > cc @mbalassi @gyfora > > @sunxiaoguang we've seen you're struggling w/ tests for quite some time and we would like to help you out by contributing our implem

[GitHub] [flink] zentol merged pull request #16085: [hotfix][docs] Corrected artifactId element in example

2021-06-06 Thread GitBox
zentol merged pull request #16085: URL: https://github.com/apache/flink/pull/16085 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [flink] flinkbot commented on pull request #16085: [hotfix][docs] Corrected artifactId element in example

2021-06-06 Thread GitBox
flinkbot commented on pull request #16085: URL: https://github.com/apache/flink/pull/16085#issuecomment-855478563 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] mans2singh opened a new pull request #16085: [hotfix][docs] Corrected artifactId element in example

2021-06-06 Thread GitBox
mans2singh opened a new pull request #16085: URL: https://github.com/apache/flink/pull/16085 ## What is the purpose of the change * Corrected artifactId element in pom ## Brief change log * Corrected artifactId element in pom ## Verifying this change

[jira] [Updated] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

2021-06-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22826: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community ma

[jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

2021-06-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22334: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major) Thi

[jira] [Updated] (FLINK-22285) YARNHighAvailabilityITCase hangs

2021-06-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22285: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability) Pri

[jira] [Updated] (FLINK-13032) Allow Access to Per-Window State in mergeable window ProcessWindowFunction

2021-06-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13032: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira Bot|https:/

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

2021-06-06 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community ma

  1   2   3   >