[GitHub] [flink] flinkbot commented on pull request #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

2020-12-31 Thread GitBox
flinkbot commented on pull request #14534: URL: https://github.com/apache/flink/pull/14534#issuecomment-752881342 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] flinkbot edited a comment on pull request #14399: [FLINK-17827] [scala-shell] scala-shell.sh should fail early if no mo…

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14399: URL: https://github.com/apache/flink/pull/14399#issuecomment-745854885 ## CI report: * b77668657f364d87999556ee746e5d995b79443f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * fa8c7d4a20ce5d51d831e3ccf3b48e04129e2535 Azure: [SUCCESS](https://dev.azure.com/apache-flin

[jira] [Commented] (FLINK-20581) java.lang.NoClassDefFoundError: Could not initialize class org.apache.flink.util.JavaGcCleanerWrapper

2020-12-31 Thread seanliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256883#comment-17256883 ] seanliu commented on FLINK-20581: - I have the same problem When I run the official websi

[jira] [Commented] (FLINK-20801) Using asynchronous methods in operators causes serialization problems

2020-12-31 Thread lafeier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256884#comment-17256884 ] lafeier commented on FLINK-20801: - Yes, there is a performance gap between using Async I

[jira] [Comment Edited] (FLINK-20581) java.lang.NoClassDefFoundError: Could not initialize class org.apache.flink.util.JavaGcCleanerWrapper

2020-12-31 Thread seanliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256883#comment-17256883 ] seanliu edited comment on FLINK-20581 at 12/31/20, 8:21 AM:

[GitHub] [flink] flinkbot commented on pull request #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

2020-12-31 Thread GitBox
flinkbot commented on pull request #14534: URL: https://github.com/apache/flink/pull/14534#issuecomment-752886442 ## CI report: * 7c096f9a7dcf044d1d60afc33e3782379286093b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * fa8c7d4a20ce5d51d831e3ccf3b48e04129e2535 Azure: [SUCCESS](https://dev.azure.com/apache-flin

[GitHub] [flink] flinkbot edited a comment on pull request #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14534: URL: https://github.com/apache/flink/pull/14534#issuecomment-752886442 ## CI report: * 7c096f9a7dcf044d1d60afc33e3782379286093b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fsk119 commented on a change in pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-31 Thread GitBox
fsk119 commented on a change in pull request #14508: URL: https://github.com/apache/flink/pull/14508#discussion_r550414819 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java ## @@ -90,6 +92,10 @@ public Json

[GitHub] [flink] fsk119 commented on a change in pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-31 Thread GitBox
fsk119 commented on a change in pull request #14508: URL: https://github.com/apache/flink/pull/14508#discussion_r550430737 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonFormatFactory.java ## @@ -43,6 +43,7 @@ import java

[GitHub] [flink] xiaoHoly opened a new pull request #14535: [FLINK-20026][Connector][Jdbc] Jdbc connector support regular expression

2020-12-31 Thread GitBox
xiaoHoly opened a new pull request #14535: URL: https://github.com/apache/flink/pull/14535 ## What is the purpose of the change Jdbc connector support regular expression ## Brief change log ## Verifying this change This change is a trivial

[jira] [Updated] (FLINK-20026) Jdbc connector support regular expression

2020-12-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20026: --- Labels: pull-request-available (was: ) > Jdbc connector support regular expression > --

[GitHub] [flink] flinkbot commented on pull request #14535: [FLINK-20026][Connector][Jdbc] Jdbc connector support regular expression

2020-12-31 Thread GitBox
flinkbot commented on pull request #14535: URL: https://github.com/apache/flink/pull/14535#issuecomment-752895593 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] curcur commented on pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-31 Thread GitBox
curcur commented on pull request #14460: URL: https://github.com/apache/flink/pull/14460#issuecomment-752895866 I rebuild the docs, let's see whether it fixes the problem. This is an automated message from the Apache Git Serv

[GitHub] [flink] flinkbot edited a comment on pull request #14533: [hotfix][docs]fix typo in Create statements page

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14533: URL: https://github.com/apache/flink/pull/14533#issuecomment-752874534 ## CI report: * 3e017300a6f8f5bf807493a83eb46230af0a4827 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14532: Draft for Web-UI

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14532: URL: https://github.com/apache/flink/pull/14532#issuecomment-752840091 ## CI report: * 6799c6817ba7fc5af0a23996e62b30e7fb2b56b5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14460: URL: https://github.com/apache/flink/pull/14460#issuecomment-749464826 ## CI report: * 5f59e7821f3e7649b5449307a7a4817a4d0036f5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536 ## CI report: * 9dfbf0f8575de20c3c3d672ce1bf64f3c5e2ed93 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14535: [FLINK-20026][Connector][Jdbc] Jdbc connector support regular expression

2020-12-31 Thread GitBox
flinkbot commented on pull request #14535: URL: https://github.com/apache/flink/pull/14535#issuecomment-752901366 ## CI report: * 14d72b3b9718fa2f404534d3569332825a7b2680 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] chaozwn opened a new pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

2020-12-31 Thread GitBox
chaozwn opened a new pull request #14536: URL: https://github.com/apache/flink/pull/14536 ## What is the purpose of the change This pull request makes hbase in sql mode,can use 'properties.*' add Configuration parameter e.g 'properties.hbase.security.authenticati

[jira] [Updated] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

2020-12-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20812: --- Labels: pull-request-available (was: ) > flink connector hbase(1.4,2.2) too few control par

[GitHub] [flink] flinkbot commented on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

2020-12-31 Thread GitBox
flinkbot commented on pull request #14536: URL: https://github.com/apache/flink/pull/14536#issuecomment-752903382 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] [Created] (FLINK-20825) Upsert-kafka should throw a better exception when the key of the record is NULL

2020-12-31 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20825: - Summary: Upsert-kafka should throw a better exception when the key of the record is NULL Key: FLINK-20825 URL: https://issues.apache.org/jira/browse/FLINK-20825 Pro

[GitHub] [flink] flinkbot edited a comment on pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14460: URL: https://github.com/apache/flink/pull/14460#issuecomment-749464826 ## CI report: * 5f59e7821f3e7649b5449307a7a4817a4d0036f5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536 ## CI report: * 9dfbf0f8575de20c3c3d672ce1bf64f3c5e2ed93 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14535: [FLINK-20026][Connector][Jdbc] Jdbc connector support regular expression

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14535: URL: https://github.com/apache/flink/pull/14535#issuecomment-752901366 ## CI report: * 14d72b3b9718fa2f404534d3569332825a7b2680 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann commented on a change in pull request #14528: [FLINK-20615] Clean PartitionRequestClientFactory up if createPartitionRequestClient fails

2020-12-31 Thread GitBox
tillrohrmann commented on a change in pull request #14528: URL: https://github.com/apache/flink/pull/14528#discussion_r550443289 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java ## @@ -69,36 +68,34 @@ N

[GitHub] [flink] echauchot commented on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
echauchot commented on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-752907676 @zentol I remade the work from scratch using _FrontMetricGroup_ for filter/delimiter injection: - I made sure that the configured delimiter is used in filtering when cr

[jira] [Commented] (FLINK-20809) Limit push down with Hive table doesn't work when using with filter

2020-12-31 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256920#comment-17256920 ] Shengkai Fang commented on FLINK-20809: --- Hi all. I don't think it's a bug. Curren

[GitHub] [flink] echauchot commented on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
echauchot commented on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-752908017 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] echauchot removed a comment on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
echauchot removed a comment on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-752908017 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] echauchot commented on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
echauchot commented on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-752908614 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] echauchot commented on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
echauchot commented on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-752908798 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] echauchot commented on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
echauchot commented on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-752909374 CI does not seem to be triggered. This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

2020-12-31 Thread GitBox
flinkbot commented on pull request #14536: URL: https://github.com/apache/flink/pull/14536#issuecomment-752909965 ## CI report: * f66faaa7fd4901814134ab3d8993c52838fd77bf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] rkhachatryan commented on a change in pull request #14528: [FLINK-20615] Clean PartitionRequestClientFactory up if createPartitionRequestClient fails

2020-12-31 Thread GitBox
rkhachatryan commented on a change in pull request #14528: URL: https://github.com/apache/flink/pull/14528#discussion_r550447001 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java ## @@ -69,36 +68,34 @@ N

[GitHub] [flink] pnowojski closed pull request #14507: [FLINK-20718][FLINK-20717][metrics] Add isCausingBackPressureRatio and isBackPressuredRatio metrics

2020-12-31 Thread GitBox
pnowojski closed pull request #14507: URL: https://github.com/apache/flink/pull/14507 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 t

[GitHub] [flink] pnowojski commented on pull request #14507: [FLINK-20718][FLINK-20717][metrics] Add isCausingBackPressureRatio and isBackPressuredRatio metrics

2020-12-31 Thread GitBox
pnowojski commented on pull request #14507: URL: https://github.com/apache/flink/pull/14507#issuecomment-752912932 Due to problems with accuracy (caused by sampling intervals) I've abandoned this approach. This PR was superseded by https://github.com/apache/flink/pull/14526 ---

[GitHub] [flink] dianfu closed pull request #14524: [FLINK-20769][python] Support minibatch to optimize Python UDAF

2020-12-31 Thread GitBox
dianfu closed pull request #14524: URL: https://github.com/apache/flink/pull/14524 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 t

[GitHub] [flink] dianfu commented on pull request #14524: [FLINK-20769][python] Support minibatch to optimize Python UDAF

2020-12-31 Thread GitBox
dianfu commented on pull request #14524: URL: https://github.com/apache/flink/pull/14524#issuecomment-752913645 Thanks @HuangXingBo for this great work and thanks @WeiZhong94 for the review. Have merged the PR. This is an au

[jira] [Closed] (FLINK-20769) Support minibatch to optimize Python UDAF

2020-12-31 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20769. --- Assignee: Huang Xingbo Resolution: Fixed Merged to master via f131acd4982aab6c83c3d192326953cf174e808e

[jira] [Updated] (FLINK-14814) Show the vertex that produces the backpressure source in the job

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-14814: --- Attachment: Screenshot 2020-12-31 at 10.27.52.png > Show the vertex that produces the backpr

[jira] [Comment Edited] (FLINK-14814) Show the vertex that produces the backpressure source in the job

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256926#comment-17256926 ] Piotr Nowojski edited comment on FLINK-14814 at 12/31/20, 10:14 AM: --

[jira] [Commented] (FLINK-14814) Show the vertex that produces the backpressure source in the job

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256926#comment-17256926 ] Piotr Nowojski commented on FLINK-14814: New visualisation based on the updated

[jira] [Comment Edited] (FLINK-14814) Show the vertex that produces the backpressure source in the job

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256926#comment-17256926 ] Piotr Nowojski edited comment on FLINK-14814 at 12/31/20, 10:14 AM: --

[jira] [Updated] (FLINK-20717) Create backPressuredTimeMsPerSecond metric

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20717: --- Summary: Create backPressuredTimeMsPerSecond metric (was: Create isBackPressuredRatio metri

[jira] [Updated] (FLINK-20717) Create backPressuredTimeMsPerSecond metric

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20717: --- Description: Create {{backPressuredTimeMsPerSecond}} metric, measured similarly to the exist

[jira] [Updated] (FLINK-20718) Create busyTimeMsPerSecond metrics

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20718: --- Summary: Create busyTimeMsPerSecond metrics (was: Create isCausingBackPressureRatio and isC

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * fd8cbf90a807292b0db7b85bda26f1e717b8

[GitHub] [flink] flinkbot edited a comment on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-751755915 ## CI report: * Unknown: [CANCELED](TBD) * 932157724cf6bd963643aa9970c82ce0e0b2c8fe UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] flinkbot edited a comment on pull request #14526: [FLINK-14814][webui] Display back pressure and causing back pressure ratios

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14526: URL: https://github.com/apache/flink/pull/14526#issuecomment-752592411 ## CI report: * 581fee7ea3a656a997664368665cee270e8d8dc7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disab

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536 ## CI report: * 665de48bdcb5dd56e9fc415183f324e5d7a15e38 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14536: URL: https://github.com/apache/flink/pull/14536#issuecomment-752909965 ## CI report: * f66faaa7fd4901814134ab3d8993c52838fd77bf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14535: [FLINK-20026][Connector][Jdbc] Jdbc connector support regular expression

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14535: URL: https://github.com/apache/flink/pull/14535#issuecomment-752901366 ## CI report: * 14d72b3b9718fa2f404534d3569332825a7b2680 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-14814) Show the vertex that produces the backpressure source in the job

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256927#comment-17256927 ] Piotr Nowojski commented on FLINK-14814: Previous approach using {{isBackPressur

[jira] [Updated] (FLINK-20718) Create busyTimeMsPerSecond metrics

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20718: --- Description: {{busyTimeMsPerSecond}} is defined as {{1000 - idleTimeMsPerSecond}}, and that

[jira] [Updated] (FLINK-20718) Create busyTimeMsPerSecond metrics

2020-12-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20718: --- Description: {{busyTimeMsPerSecond}} is defined as {{1000 - idleTimeMsPerSecond}}, and that

[jira] [Comment Edited] (FLINK-20632) Missing docker images for 1.12 release

2020-12-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256929#comment-17256929 ] Xintong Song edited comment on FLINK-20632 at 12/31/20, 10:26 AM:

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

2020-12-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256929#comment-17256929 ] Xintong Song commented on FLINK-20632: -- The docker guys are still not responding to

[jira] [Created] (FLINK-20826) Fix bug in streaming SQL examples

2020-12-31 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-20826: -- Summary: Fix bug in streaming SQL examples Key: FLINK-20826 URL: https://issues.apache.org/jira/browse/FLINK-20826 Project: Flink Issue Type: New Feature

[GitHub] [flink] wuchong commented on a change in pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

2020-12-31 Thread GitBox
wuchong commented on a change in pull request #10847: URL: https://github.com/apache/flink/pull/10847#discussion_r550422198 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XidImpl.java ## @@ -0,0 +1,102 @@ +/* + * Licensed t

[GitHub] [flink] flinkbot edited a comment on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-751755915 ## CI report: * Unknown: [CANCELED](TBD) * 932157724cf6bd963643aa9970c82ce0e0b2c8fe Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14530: URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495 ## CI report: * 2f237865183b4f66838366b4d7114515a612ed81 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14526: [FLINK-14814][webui] Display back pressure and causing back pressure ratios

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14526: URL: https://github.com/apache/flink/pull/14526#issuecomment-752592411 ## CI report: * af89d36ef1ec641dd9acb240bd211132a52f3798 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14534: URL: https://github.com/apache/flink/pull/14534#issuecomment-752886442 ## CI report: * 7c096f9a7dcf044d1d60afc33e3782379286093b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wuchong commented on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

2020-12-31 Thread GitBox
wuchong commented on pull request #14536: URL: https://github.com/apache/flink/pull/14536#issuecomment-752920523 cc @leonardBang for reviewing. This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Commented] (FLINK-20826) Fix bug in streaming SQL examples

2020-12-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256934#comment-17256934 ] Jark Wu commented on FLINK-20826: - Could you add more descriptions about which code has

[jira] [Commented] (FLINK-20809) Limit push down with Hive table doesn't work when using with filter

2020-12-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17256939#comment-17256939 ] Jark Wu commented on FLINK-20809: - I agree with you [~fsk119]. We can't push down limit

[jira] [Closed] (FLINK-20809) Limit push down with Hive table doesn't work when using with filter

2020-12-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20809. --- Fix Version/s: (was: 1.13.0) Resolution: Not A Problem > Limit push down with Hive table doesn't

[GitHub] [flink] wuchong merged pull request #14533: [hotfix][docs]fix typo in Create statements page

2020-12-31 Thread GitBox
wuchong merged pull request #14533: URL: https://github.com/apache/flink/pull/14533 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

[GitHub] [flink] cshuo opened a new pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

2020-12-31 Thread GitBox
cshuo opened a new pull request #14537: URL: https://github.com/apache/flink/pull/14537 ## What is the purpose of the change There is a minor bug in streaming sql example `UpdatingTopCityExample` ## Brief change log - `UpdatingTopCityExample` ## Veri

[jira] [Updated] (FLINK-20826) Fix bug in streaming SQL examples

2020-12-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20826: --- Labels: pull-request-available (was: ) > Fix bug in streaming SQL examples > --

[GitHub] [flink] cshuo commented on pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

2020-12-31 Thread GitBox
cshuo commented on pull request #14537: URL: https://github.com/apache/flink/pull/14537#issuecomment-752922865 @godfreyhe Could you help review this? This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

2020-12-31 Thread GitBox
flinkbot commented on pull request #14537: URL: https://github.com/apache/flink/pull/14537#issuecomment-752922898 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] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * fd8cbf90a807292b0db7b85bda26f1e717b8

[GitHub] [flink] flinkbot edited a comment on pull request #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14534: URL: https://github.com/apache/flink/pull/14534#issuecomment-752886442 ## CI report: * 7c096f9a7dcf044d1d60afc33e3782379286093b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN * fd8cbf90a807292b0db7b85bda26f1e717b8

[GitHub] [flink] flinkbot commented on pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

2020-12-31 Thread GitBox
flinkbot commented on pull request #14537: URL: https://github.com/apache/flink/pull/14537#issuecomment-752927633 ## CI report: * 0305b23e0bb621cc571b3ff08a1c00fe64bc0ad8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14526: [FLINK-14814][webui] Highlighe back pressured and busy nodes in the WebUI

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14526: URL: https://github.com/apache/flink/pull/14526#issuecomment-752592411 ## CI report: * af89d36ef1ec641dd9acb240bd211132a52f3798 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14537: URL: https://github.com/apache/flink/pull/14537#issuecomment-752927633 ## CI report: * 0305b23e0bb621cc571b3ff08a1c00fe64bc0ad8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14399: [FLINK-17827] [scala-shell] scala-shell.sh should fail early if no mo…

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14399: URL: https://github.com/apache/flink/pull/14399#issuecomment-745854885 ## CI report: * 5d12faf957a2e129df5a32031e9a88e09f7b6ec7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14526: [FLINK-14814][webui] Highlighe back pressured and busy nodes in the WebUI

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14526: URL: https://github.com/apache/flink/pull/14526#issuecomment-752592411 ## CI report: * eb574e5180fff6ceaf7b76035fc8c45c27a9fa09 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN * 50dd8154daca82c54bc3d0decc8e94b6b7cba8d6 Azure: [FAILURE](https://dev.azure.com/apache-flin

[GitHub] [flink] flinkbot edited a comment on pull request #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14534: URL: https://github.com/apache/flink/pull/14534#issuecomment-752886442 ## CI report: * 7c096f9a7dcf044d1d60afc33e3782379286093b Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #14526: [FLINK-14814][WebUI] Highlight back pressured and busy nodes in the WebUI

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14526: URL: https://github.com/apache/flink/pull/14526#issuecomment-752592411 ## CI report: * eb574e5180fff6ceaf7b76035fc8c45c27a9fa09 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14526: [FLINK-14814][WebUI] Highlight back pressured and busy nodes in the WebUI

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14526: URL: https://github.com/apache/flink/pull/14526#issuecomment-752592411 ## CI report: * eb574e5180fff6ceaf7b76035fc8c45c27a9fa09 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14460: URL: https://github.com/apache/flink/pull/14460#issuecomment-749464826 ## CI report: * 9f7dd68a258dd3ccc7655a5e4c8e819822fc1d8c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14536: URL: https://github.com/apache/flink/pull/14536#issuecomment-752909965 ## CI report: * f66faaa7fd4901814134ab3d8993c52838fd77bf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14084: URL: https://github.com/apache/flink/pull/14084#issuecomment-728296283 ## CI report: * 54c17b2c00b65af7eec5fcb13592e0893b2d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14084: URL: https://github.com/apache/flink/pull/14084#issuecomment-728296283 ## CI report: * 54c17b2c00b65af7eec5fcb13592e0893b2d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14510: URL: https://github.com/apache/flink/pull/14510#issuecomment-751755915 ## CI report: * 932157724cf6bd963643aa9970c82ce0e0b2c8fe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14534: URL: https://github.com/apache/flink/pull/14534#issuecomment-752886442 ## CI report: * 5b018f902fac3974828e119081396fea2b999c60 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

2020-12-31 Thread GitBox
flinkbot edited a comment on pull request #14537: URL: https://github.com/apache/flink/pull/14537#issuecomment-752927633 ## CI report: * 0305b23e0bb621cc571b3ff08a1c00fe64bc0ad8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] yuruguo opened a new pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

2020-12-31 Thread GitBox
yuruguo opened a new pull request #14538: URL: https://github.com/apache/flink/pull/14538 ## What is the purpose of the change This PR can support config options 'yarn.ship-archives' and 'yarn.ship-files' specify remote resources on distributed files ystem (such as hdfs) to

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

2020-12-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20681: --- Labels: pull-request-available pull-requests-available (was: pull-requests-available) > Su

[GitHub] [flink] flinkbot commented on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

2020-12-31 Thread GitBox
flinkbot commented on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752988877 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] flinkbot commented on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

2020-12-31 Thread GitBox
flinkbot commented on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] xuewang opened a new pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

2020-12-31 Thread GitBox
xuewang opened a new pull request #14539: URL: https://github.com/apache/flink/pull/14539 ## What is the purpose of the change This pull request aims to fix JIRA issue [FLINK-20321](https://issues.apache.org/jira/browse/FLINK-20321). ## Brief change log Make `de

[jira] [Updated] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

2020-12-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20321: --- Labels: pull-request-available sprint starter (was: sprint starter) > Get NPE when using Av

  1   2   >