[GitHub] [flink] flinkbot edited a comment on pull request #15921: [hotfix][docs]Add the missing slash in the file system url of documentation

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

[jira] [Updated] (FLINK-22669) Support date format in a path when use filesytem as source

2021-05-14 Thread wangqinghuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangqinghuan updated FLINK-22669: - Issue Type: Improvement (was: Bug) > Support date format in a path when use filesytem as source

[jira] [Updated] (FLINK-22669) Support date format in a path when use filesytem as source

2021-05-14 Thread wangqinghuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangqinghuan updated FLINK-22669: - Description: Do we have suggestions to support date format in a file path when using filesystem

[jira] [Created] (FLINK-22669) Support date format in a path when use filesytem as source

2021-05-14 Thread wangqinghuan (Jira)
wangqinghuan created FLINK-22669: Summary: Support date format in a path when use filesytem as source Key: FLINK-22669 URL: https://issues.apache.org/jira/browse/FLINK-22669 Project: Flink Is

[jira] [Created] (FLINK-22668) FLIP-150: Introduce Hybrid Source

2021-05-14 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-22668: Summary: FLIP-150: Introduce Hybrid Source Key: FLINK-22668 URL: https://issues.apache.org/jira/browse/FLINK-22668 Project: Flink Issue Type: Improvement

[GitHub] [flink] Tiaaa commented on a change in pull request #13401: [FLINK-19161][file connector] Add first version of the FLIP-27 File Source

2021-05-14 Thread GitBox
Tiaaa commented on a change in pull request #13401: URL: https://github.com/apache/flink/pull/13401#discussion_r632864479 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/impl/ContinuousFileSplitEnumerator.java ## @@ -0,0 +

[GitHub] [flink] flinkbot edited a comment on pull request #15921: [hotfix][docs]Add the missing slash in the file system url of documentation

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

[GitHub] [flink] flinkbot commented on pull request #15921: [hotfix][docs]Add the missing slash in the file system url of documentation

2021-05-14 Thread GitBox
flinkbot commented on pull request #15921: URL: https://github.com/apache/flink/pull/15921#issuecomment-841511625 ## CI report: * 398fb376fb3c384a365fb4cbcba69210bd9ad1b1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-22667) Fix the wrong file system ln java doc and documentation

2021-05-14 Thread Yishuang Lu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344884#comment-17344884 ] Yishuang Lu commented on FLINK-22667: - The issue is addressed by this pull request: 

[GitHub] [flink] flinkbot commented on pull request #15921: [hotfix][docs]Add the missing slash in the file system url of documentation

2021-05-14 Thread GitBox
flinkbot commented on pull request #15921: URL: https://github.com/apache/flink/pull/15921#issuecomment-841505015 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] lys0716 opened a new pull request #15921: [hotfix][docs]Add the missing slash in the file system url of documentation

2021-05-14 Thread GitBox
lys0716 opened a new pull request #15921: URL: https://github.com/apache/flink/pull/15921 Signed-off-by: Yishuang Lu ## 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 w

[jira] [Created] (FLINK-22667) Fix the wrong file system ln java doc and documentation

2021-05-14 Thread Yishuang Lu (Jira)
Yishuang Lu created FLINK-22667: --- Summary: Fix the wrong file system ln java doc and documentation Key: FLINK-22667 URL: https://issues.apache.org/jira/browse/FLINK-22667 Project: Flink Issue T

[GitHub] [flink] flinkbot edited a comment on pull request #15799: [FLINK-22434] Store suspended execution graphs on termination to keep…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15799: [FLINK-22434] Store suspended execution graphs on termination to keep…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15799: [FLINK-22434] Store suspended execution graphs on termination to keep…

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

[GitHub] [flink] fapaul commented on pull request #15799: [FLINK-22434] Store suspended execution graphs on termination to keep…

2021-05-14 Thread GitBox
fapaul commented on pull request #15799: URL: https://github.com/apache/flink/pull/15799#issuecomment-841337355 @tillrohrmann Thanks for your feedback I have now addressed all your comments, please have another look. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] fapaul commented on a change in pull request #15799: [FLINK-22434] Store suspended execution graphs on termination to keep…

2021-05-14 Thread GitBox
fapaul commented on a change in pull request #15799: URL: https://github.com/apache/flink/pull/15799#discussion_r632633257 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java ## @@ -685,16 +684,16 @@ public void testJobSuspensionWh

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2021-05-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344651#comment-17344651 ] Timo Walther commented on FLINK-13414: -- Great to see this lively discussion around

[GitHub] [flink] flinkbot edited a comment on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

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

[jira] [Created] (FLINK-22666) Add more test cases for brigding to Scala DataStream API

2021-05-14 Thread Timo Walther (Jira)
Timo Walther created FLINK-22666: Summary: Add more test cases for brigding to Scala DataStream API Key: FLINK-22666 URL: https://issues.apache.org/jira/browse/FLINK-22666 Project: Flink Issu

[jira] [Closed] (FLINK-22475) Datagen connector does not list its available options with placeholders

2021-05-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22475. Fix Version/s: 1.13.1 1.14.0 Resolution: Fixed Fixed in 1.14.0: abd3da9

[GitHub] [flink] twalthr closed pull request #15896: [FLINK-22475][table-common][table-api-java-bridge] Provide placeholder options (*.'#'.*) for datagen connector

2021-05-14 Thread GitBox
twalthr closed pull request #15896: URL: https://github.com/apache/flink/pull/15896 -- 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 #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

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

[jira] [Comment Edited] (FLINK-22660) Incorrect flink documentation example

2021-05-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344581#comment-17344581 ] Timo Walther edited comment on FLINK-22660 at 5/14/21, 1:15 PM: --

[jira] [Closed] (FLINK-22660) Incorrect flink documentation example

2021-05-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22660. Resolution: Not A Problem Hi [~tejasub], please note that {{Instant}} is mapped to {{TIMESTAMP_LTZ

[jira] [Commented] (FLINK-15390) List/Map/Struct types support for vectorized orc reader

2021-05-14 Thread Wang Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344568#comment-17344568 ] Wang Wei commented on FLINK-15390: -- Yes, I will work on this feature. > List/Map/Struc

[jira] [Comment Edited] (FLINK-13414) Add support for Scala 2.13

2021-05-14 Thread Nick Burkard (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344555#comment-17344555 ] Nick Burkard edited comment on FLINK-13414 at 5/14/21, 12:12 PM: -

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2021-05-14 Thread Nick Burkard (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344555#comment-17344555 ] Nick Burkard commented on FLINK-13414: -- I love Scala and use it everyday at work, b

[GitHub] [flink] zhipeng93 removed a comment on pull request #15919: [hotfix][docs] Fix typos in BatchTask, MutableRecordReader and Priori…

2021-05-14 Thread GitBox
zhipeng93 removed a comment on pull request #15919: URL: https://github.com/apache/flink/pull/15919#issuecomment-841192362 @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

[GitHub] [flink] zhipeng93 commented on pull request #15919: [hotfix][docs] Fix typos in BatchTask, MutableRecordReader and Priori…

2021-05-14 Thread GitBox
zhipeng93 commented on pull request #15919: URL: https://github.com/apache/flink/pull/15919#issuecomment-841192362 @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 specifi

[GitHub] [flink] flinkbot edited a comment on pull request #15919: [hotfix][docs] Fix typos in BatchTask, MutableRecordReader and Priori…

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

[jira] [Created] (FLINK-22665) Add a Flink BigQuery Connector

2021-05-14 Thread Jira
Jörn Kottmann created FLINK-22665: - Summary: Add a Flink BigQuery Connector Key: FLINK-22665 URL: https://issues.apache.org/jira/browse/FLINK-22665 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

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

[jira] [Commented] (FLINK-9665) PrometheusReporter does not properly unregister metrics

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344506#comment-17344506 ] Guokuai Huang commented on FLINK-9665: -- I encountered a problem, which may be a bug

[jira] [Commented] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344504#comment-17344504 ] Guokuai Huang commented on FLINK-22664: --- This issue is related to: https://issues.

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Description: In the current implementation of AbstractPrometheusReporter, metrics with the sa

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Attachment: (was: Screen Shot 2021-05-14 at 5.30.51 PM.png) > Task metrics are not properl

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Description: In the current implementation of AbstractPrometheusReporter, metrics with the sa

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Attachment: Screen Shot 2021-05-14 at 5.40.22 PM.png > Task metrics are not properly unregiste

[jira] [Commented] (FLINK-22329) Missing credentials in jobconf causes repeated authentication in Hive datasource

2021-05-14 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344497#comment-17344497 ] Junfan Zhang commented on FLINK-22329: -- Update it, please review it again. Thanks [

[GitHub] [flink] zuston edited a comment on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

2021-05-14 Thread GitBox
zuston edited a comment on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-841132963 > Would it be better to inject the credentials when the configuration is firstly created? For example, when we create the JobConf in HiveDynamicTableFactory, or when we cr

[GitHub] [flink] zuston commented on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

2021-05-14 Thread GitBox
zuston commented on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-841132963 > Would it be better to inject the credentials when the configuration is firstly created? For example, when we create the JobConf in HiveDynamicTableFactory, or when we create Hi

[GitHub] [flink] flinkbot edited a comment on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

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

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Description: In the current implementation of AbstractPrometheusReporter, metrics with the sa

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Attachment: Screen Shot 2021-05-14 at 5.30.51 PM.png > Task metrics are not properly unregiste

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Description: In the current implementation of AbstractPrometheusReporter, metrics with the sa

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Attachment: (was: Screen Shot 2021-05-14 at 5.29.12 PM.png) > Task metrics are not properl

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Description: In the current implementation of AbstractPrometheusReporter, metrics with the sa

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Attachment: (was: Screen Shot 2021-05-14 at 2.36.30 PM.png) > Task metrics are not properl

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Attachment: Screen Shot 2021-05-14 at 5.29.12 PM.png > Task metrics are not properly unregiste

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Description: In the current implementation of AbstractPrometheusReporter, metrics with the sa

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-14 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344477#comment-17344477 ] JasonLee commented on FLINK-22655: -- Hi ShengKai,I think adding a judgment condition to

[GitHub] [flink] flinkbot edited a comment on pull request #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

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

[GitHub] [flink-web] loniecc commented on pull request #386: [FLINK-13679] Translate "Code Style - Preamble" page into Chinese

2021-05-14 Thread GitBox
loniecc commented on pull request #386: URL: https://github.com/apache/flink-web/pull/386#issuecomment-841109220 thx, i will try more -- 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

[jira] [Commented] (FLINK-13678) Translate "Code Style - Preamble" page into Chinese

2021-05-14 Thread huzeming (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344473#comment-17344473 ] huzeming commented on FLINK-13678: -- PR has been merged > Translate "Code Style - Pream

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2021-05-14 Thread Guenter Hipler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344470#comment-17344470 ] Guenter Hipler commented on FLINK-13414: as a short addition: my impression why

[jira] [Updated] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22664: -- Description: In the current implementation of AbstractPrometheusReporter, metrics with the sa

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2021-05-14 Thread Guenter Hipler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344459#comment-17344459 ] Guenter Hipler commented on FLINK-13414: [~Zhen-hao], yes Kafka provides "only"

[jira] [Created] (FLINK-22664) Task metrics are not properly unregistered during region failover

2021-05-14 Thread Guokuai Huang (Jira)
Guokuai Huang created FLINK-22664: - Summary: Task metrics are not properly unregistered during region failover Key: FLINK-22664 URL: https://issues.apache.org/jira/browse/FLINK-22664 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

2021-05-14 Thread GitBox
flinkbot commented on pull request #15920: URL: https://github.com/apache/flink/pull/15920#issuecomment-841093374 ## CI report: * a8e11fc11a164e27b672b30f32ffc6a856b68d6b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-22639) ClassLoaderUtil cannot print classpath of FlinkUserCodeClassLoader

2021-05-14 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344397#comment-17344397 ] Yao Zhang commented on FLINK-22639: --- Could you pls assign this to me? > ClassLoaderUt

[GitHub] [flink] dianfu commented on pull request #15913: [FLINK-22649][python][table-planner-blink] Support StreamExecPythonCalc json serialization/deserialization

2021-05-14 Thread GitBox
dianfu commented on pull request #15913: URL: https://github.com/apache/flink/pull/15913#issuecomment-841091002 LGTM. cc @godfreyhe -- 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 s

[GitHub] [flink] lirui-apache commented on pull request #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

2021-05-14 Thread GitBox
lirui-apache commented on pull request #15920: URL: https://github.com/apache/flink/pull/15920#issuecomment-841089233 @leonardBang @JingsongLi Could you take a look? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

2021-05-14 Thread GitBox
flinkbot commented on pull request #15920: URL: https://github.com/apache/flink/pull/15920#issuecomment-841088423 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] [Updated] (FLINK-22661) HiveInputFormatPartitionReader can return invalid data

2021-05-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22661: --- Labels: pull-request-available (was: ) > HiveInputFormatPartitionReader can return invalid

[GitHub] [flink] lirui-apache opened a new pull request #15920: [FLINK-22661][hive] HiveInputFormatPartitionReader can return invalid…

2021-05-14 Thread GitBox
lirui-apache opened a new pull request #15920: URL: https://github.com/apache/flink/pull/15920 … data ## What is the purpose of the change Fix the issue that `HiveInputFormatPartitionReader` returns invalid data when reading from multiple splits ## Brief cha

[GitHub] [flink] flinkbot edited a comment on pull request #15918: [FLINK-22654][table] fix SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

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

[GitHub] [flink] lqjack commented on pull request #15812: remove slotpoolImpl

2021-05-14 Thread GitBox
lqjack commented on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-841082768 @tillrohrmann please review the patch . thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[jira] [Updated] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

2021-05-14 Thread Jinhong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinhong Liu updated FLINK-22663: Labels: YARN (was: ) > Release YARN resource very slow when cancel the job after some NodeManager

[jira] [Assigned] (FLINK-22661) HiveInputFormatPartitionReader can return invalid data

2021-05-14 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-22661: -- Assignee: Rui Li > HiveInputFormatPartitionReader can return invalid data > -

[jira] [Created] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

2021-05-14 Thread Jinhong Liu (Jira)
Jinhong Liu created FLINK-22663: --- Summary: Release YARN resource very slow when cancel the job after some NodeManagers shutdown Key: FLINK-22663 URL: https://issues.apache.org/jira/browse/FLINK-22663 Pr

[jira] [Closed] (FLINK-19796) Error results when use constant decimal array

2021-05-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19796. Fix Version/s: 1.14.0 Resolution: Fixed Fixed via master: 0f51995bc156435eb9e97d2ac15e02251

[GitHub] [flink] JingsongLi merged pull request #15906: [FLINK-19796][table] Explicit casting should be made if the type of a…

2021-05-14 Thread GitBox
JingsongLi merged pull request #15906: URL: https://github.com/apache/flink/pull/15906 -- 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, ple

[GitHub] [flink] flinkbot edited a comment on pull request #15919: [hotfix][docs] Fix typos in BatchTask, MutableRecordReader and Priori…

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

[jira] [Resolved] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-05-14 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-21700. Fix Version/s: 1.14.0 Resolution: Fixed > Allow to disable fetching Hadoop delegation token on Yarn

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

2021-05-14 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344371#comment-17344371 ] Kurt Young commented on FLINK-15440: {quote}if I change the SQL/Table query structur

[GitHub] [flink] flinkbot commented on pull request #15919: [hotfix][docs] Fix typos in BatchTask, MutableRecordReader and Priori…

2021-05-14 Thread GitBox
flinkbot commented on pull request #15919: URL: https://github.com/apache/flink/pull/15919#issuecomment-841057148 ## CI report: * 3615430d7f351a977e95ffa6de7944414d1769c1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r