[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * 09879982e64d6fb8feaa6402d1df6c5c73b05cf0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ https://issues.apache.org/jira/browse/FLINK-20826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20826. --- Assignee: Shuo Cheng Resolution: Fixed Fixed in master: 854562112885c075a0d5f46aeadc37c5cb117009 > Fi

[GitHub] [flink] wuchong merged pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

wuchong merged pull request #14537: URL: https://github.com/apache/flink/pull/14537 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] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * Unknown: [CANCELED](TBD) * 09879982e64d6fb8feaa6402d1df6c5c73b05cf0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * Unknown: [CANCELED](TBD) * 09879982e64d6fb8feaa6402d1df6c5c73b05cf0 UNKNOWN Bot commands The @flinkbot bot supports the fol

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

xuewang commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753259534 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * 72dc489d2eb615514a72df76dc6a4ea9acb4c578 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * Unknown: [CANCELED](TBD) * 72dc489d2eb615514a72df76dc6a4ea9acb4c578 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * Unknown: [CANCELED](TBD) * 72dc489d2eb615514a72df76dc6a4ea9acb4c578 UNKNOWN Bot commands The @flinkbot bot supports the fol

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

xuewang commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753234656 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * a9cbd5110401104135a3ecf96190cb8032cafed1 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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot edited a comment on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * a9cbd5110401104135a3ecf96190cb8032cafed1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-753000655 ## CI report: * a9cbd5110401104135a3ecf96190cb8032cafed1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

flinkbot edited a comment on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN * b1c20c731702fc0ee41ca744acb3287737170dc7 Azure: [FAILURE](https://dev.azure.com/apache-fl

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

flinkbot edited a comment on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN * b1c20c731702fc0ee41ca744acb3287737170dc7 UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot commented on pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

flinkbot commented on pull request #14539: URL: https://github.com/apache/flink/pull/14539#issuecomment-752995836 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-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

[ https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17257043#comment-17257043 ] Xue Wang commented on FLINK-20321: -- Thank you, [~jark]. I just submitted the [PR|https

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

[ 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

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

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

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

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] flinkbot commented on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

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

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

[ 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] yuruguo opened a new pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

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

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

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] flinkbot edited a comment on pull request #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

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 #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

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 #14084: [FLINK-15867][table-planner-blink] Support time-related types for FIRST_VALUE and LAST_VALUE aggregate functions

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

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 #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

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 #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

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 #14526: [FLINK-14814][WebUI] Highlight back pressured and busy nodes in the WebUI

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

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 #14534: [FLINK-20822][hive] Don't check whether a function is generic in hive…

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 #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

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 #14526: [FLINK-14814][webui] Highlighe back pressured and busy nodes in the WebUI

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 #14399: [FLINK-17827] [scala-shell] scala-shell.sh should fail early if no mo…

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 #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

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 #14526: [FLINK-14814][webui] Highlighe back pressured and busy nodes in the WebUI

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 commented on pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

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 #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

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…

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.

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`

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] cshuo commented on pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

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

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

[ 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 opened a new pull request #14537: [FLINK-20826][table] Fix minor bug in `UpdatingTopCityExample`

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

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

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

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

[ 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

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

[ 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] [Commented] (FLINK-20826) Fix bug in streaming SQL examples

[ 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

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

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

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

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 #14526: [FLINK-14814][webui] Display back pressure and causing back pressure ratios

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 #14530: [FLINK-20348][kafka] Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

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 #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

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] wuchong commented on a change in pull request #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

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

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

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

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

[ 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] [Comment Edited] (FLINK-20632) Missing docker images for 1.12 release

[ 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] [Updated] (FLINK-20718) Create busyTimeMsPerSecond metrics

[ 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

[ 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] [Commented] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ 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

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

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

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

[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

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 #14526: [FLINK-14814][webui] Display back pressure and causing back pressure ratios

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 #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

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 #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

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

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

[ 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

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

[ 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-20717) Create backPressuredTimeMsPerSecond metric

[ 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] [Comment Edited] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ 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-14814) Show the vertex that produces the backpressure source in the job

[ 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

[ 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

[ 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] [Closed] (FLINK-20769) Support minibatch to optimize Python UDAF

[ 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

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

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

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

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] pnowojski closed pull request #14507: [FLINK-20718][FLINK-20717][metrics] Add isCausingBackPressureRatio and isBackPressuredRatio metrics

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

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] rkhachatryan commented on a change in pull request #14528: [FLINK-20615] Clean PartitionRequestClientFactory up if createPartitionRequestClient fails

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] flinkbot commented on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

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] echauchot commented on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

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] echauchot commented on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

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

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 removed a comment on pull request #14510: [FLINK-19656] [metrics] filter delimiter in metrics components

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

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

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

[ 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

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

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

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] flinkbot edited a comment on pull request #14535: [FLINK-20026][Connector][Jdbc] Jdbc connector support regular expression

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] 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

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 #14460: [docs/javadoc][hotfix] Explicitly Document task cancellation timeout …

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

[jira] [Created] (FLINK-20825) Upsert-kafka should throw a better exception when the key of the record is NULL

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 commented on pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

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] [Updated] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ 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] chaozwn opened a new pull request #14536: [FLINK-20812][Connector][Hbase] hbase in sql mode,can use 'properties.*' add Configuration parameter.

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

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

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

  1   2   >