[jira] [Created] (FLINK-24893) SQL Client prompt customisation

Sergey Nuyanzin created FLINK-24893: --- Summary: SQL Client prompt customisation Key: FLINK-24893 URL: https://issues.apache.org/jira/browse/FLINK-24893 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

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

[jira] [Assigned] (FLINK-24580) Kinesis connect time out error is not handled as recoverable

[ https://issues.apache.org/jira/browse/FLINK-24580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24580: -- Assignee: John Karp > Kinesis connect time out error is not handled as recoverable >

[jira] [Assigned] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-18202: -- Assignee: xingyuan cheng > Introduce Protobuf format > - > >

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443608#comment-17443608 ] Martijn Visser commented on FLINK-18202: [~complone] I've assigned it to you. Lo

[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443605#comment-17443605 ] Arvid Heise commented on FLINK-6573: That's good looking already :) Looking forward t

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * 01ddc5f4a8a166281889407602bf9dd0514a211d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443602#comment-17443602 ] Arvid Heise commented on FLINK-24763: - How does the fetcher thread determines if the

[GitHub] [flink] flinkbot edited a comment on pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

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

[GitHub] [flink] flinkbot edited a comment on pull request #17791: Unhandled exception java.io.IOException: Connection reset by peer

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

[jira] [Commented] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443600#comment-17443600 ] wangbaohua commented on FLINK-24885: Yes, the BeanField field is null, but why does

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 0e9e25f17ee96839873e30207d4561b741ab245b Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-24592) FlinkSQL multiline parser improvements

[ https://issues.apache.org/jira/browse/FLINK-24592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24592: Parent: FLINK-24890 Issue Type: Sub-task (was: Improvement) > FlinkSQL multiline

[GitHub] [flink] flinkbot edited a comment on pull request #17791: Unhandled exception java.io.IOException: Connection reset by peer

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

[jira] [Closed] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

[ https://issues.apache.org/jira/browse/FLINK-24690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24690. Resolution: Fixed Fixed in: * master ** 6c82d0b2c5fce2d1bdea61cbc5d713e10945d44f * 1.14.1

[GitHub] [flink] dawidwys merged pull request #17737: [FLINK-24690][runtime] Changed the calculation of reaching buffer deb…

dawidwys merged pull request #17737: URL: https://github.com/apache/flink/pull/17737 -- 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. To unsubscribe, e-mail: issues-unsubs

[GitHub] [flink] dawidwys merged pull request #17780: [FLINK-24690][runtime] Changed the calculation of reaching buffer deb…

dawidwys merged pull request #17780: URL: https://github.com/apache/flink/pull/17780 -- 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. To unsubscribe, e-mail: issues-unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

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

[jira] [Updated] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24885: Fix Version/s: 1.15.0 1.14.1 1.13.4 > ProcessElement Interfa

[jira] [Commented] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443579#comment-17443579 ] Caizhi Weng commented on FLINK-24885: - I've reproduced this case. This is because So

[jira] [Updated] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24885: Component/s: Table SQL / Runtime (was: API / DataStream)

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

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

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r749048095 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java ## @@ -

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r749048095 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java ## @@ -

[jira] [Closed] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Echo Lee closed FLINK-24891. Resolution: Fixed > PrometheusPushGatewayReporter support filter label keys >

[GitHub] [flink] snuyanzin commented on a change in pull request #17771: [FLINK-24813][table-planner]Improve ImplicitTypeConversionITCase

snuyanzin commented on a change in pull request #17771: URL: https://github.com/apache/flink/pull/17771#discussion_r749047151 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInFunctionTestBase.java ## @@ -193,7 +193,6 @

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r749046291 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -600,

[GitHub] [flink] EchoLee5 closed pull request #17790: [FLINK-24891][METRICS] PrometheusPushGatewayReporter support filter label keys

EchoLee5 closed pull request #17790: URL: https://github.com/apache/flink/pull/17790 -- 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. To unsubscribe, e-mail: issues-unsubs

[jira] [Commented] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443569#comment-17443569 ] Echo Lee commented on FLINK-24891: -- [~wangyang0918] Yes, this is exactly what i want.

[GitHub] [flink] flinkbot edited a comment on pull request #17790: [FLINK-24891][METRICS] PrometheusPushGatewayReporter support filter label keys

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

[jira] [Comment Edited] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443565#comment-17443565 ] ZhuoYu Chen edited comment on FLINK-6573 at 11/15/21, 6:43 AM:

[jira] [Updated] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-6573: --- Attachment: (was: image-2021-11-15-14-35-04-364.png) > Flink MongoDB Connector >

[jira] [Updated] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-6573: --- Attachment: image-2021-11-15-14-41-07-514.png > Flink MongoDB Connector > --- > >

[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443565#comment-17443565 ] ZhuoYu Chen commented on FLINK-6573: [~arvid] {color:#33}Thank you for reminding

[jira] [Updated] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-6573: --- Attachment: (was: image-2021-11-15-14-35-40-394.png) > Flink MongoDB Connector >

[GitHub] [flink] flinkbot edited a comment on pull request #17791: Unhandled exception java.io.IOException: Connection reset by peer

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

[GitHub] [flink] lincoln-lil commented on a change in pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

lincoln-lil commented on a change in pull request #17792: URL: https://github.com/apache/flink/pull/17792#discussion_r749034827 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/LimitableBulkFormat.java ## @@ -105,8 +111,16 @@ privat

[jira] [Commented] (FLINK-24842) Make outputs depends on tails for the iteration body

[ https://issues.apache.org/jira/browse/FLINK-24842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443562#comment-17443562 ] Yun Gao commented on FLINK-24842: - Fix on master via 540762700ce7cfe502a62a81505cc133b9

[jira] [Closed] (FLINK-24842) Make outputs depends on tails for the iteration body

[ https://issues.apache.org/jira/browse/FLINK-24842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24842. --- Fix Version/s: 0.1.0 Resolution: Fixed > Make outputs depends on tails for the iteration body > -

[GitHub] [flink-ml] gaoyunhaii closed pull request #31: [FLINK-24842][iteration] Make outputs depends on tails for the iteration body

gaoyunhaii closed pull request #31: URL: https://github.com/apache/flink-ml/pull/31 -- 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. To unsubscribe, e-mail: issues-unsubsc

[jira] [Updated] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-6573: --- Attachment: image-2021-11-15-14-35-40-394.png > Flink MongoDB Connector > --- > >

[jira] [Commented] (FLINK-24891) PrometheusPushGatewayReporter support filter label keys

[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443561#comment-17443561 ] Yang Wang commented on FLINK-24891: --- I am not sure whether {{metrics.reporter.\{report

[jira] [Updated] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-6573: --- Attachment: image-2021-11-15-14-35-04-364.png > Flink MongoDB Connector > --- > >

[jira] [Commented] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443560#comment-17443560 ] Caizhi Weng commented on FLINK-24885: - [~wangbaohua] is it possible that {{kafkaData

[jira] [Updated] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24885: Priority: Major (was: Blocker) > ProcessElement Interface parameter Collector : java.lang.NullPo

[jira] [Comment Edited] (FLINK-24885) ProcessElement Interface parameter Collector : java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443560#comment-17443560 ] Caizhi Weng edited comment on FLINK-24885 at 11/15/21, 6:34 AM: --

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-966782262 @Airblader @tillrohrmann @StephanEwen @tisonkun @gaoyunhaii Excuse me, Could you help me to check it if you have free time ? Thanks a lot. -- This is an automated me

[jira] [Comment Edited] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443546#comment-17443546 ] Jingsong Lee edited comment on FLINK-24763 at 11/15/21, 6:20 AM: -

[jira] [Comment Edited] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443546#comment-17443546 ] Jingsong Lee edited comment on FLINK-24763 at 11/15/21, 6:06 AM: -

[jira] [Comment Edited] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443545#comment-17443545 ] Jingsong Lee edited comment on FLINK-24763 at 11/15/21, 5:58 AM: -

[jira] [Comment Edited] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443545#comment-17443545 ] Jingsong Lee edited comment on FLINK-24763 at 11/15/21, 5:54 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink-ml] guoweiM commented on a change in pull request #31: [FLINK-24842][iteration] Make outputs depends on tails for the iteration body

guoweiM commented on a change in pull request #31: URL: https://github.com/apache/flink-ml/pull/31#discussion_r748980501 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/Iterations.java ## @@ -367,6 +377,8 @@ private static void addCriteriaStream(

[GitHub] [flink-ml] guoweiM commented on a change in pull request #31: [FLINK-24842][iteration] Make outputs depends on tails for the iteration body

guoweiM commented on a change in pull request #31: URL: https://github.com/apache/flink-ml/pull/31#discussion_r748977842 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/Iterations.java ## @@ -252,29 +253,38 @@ private static DataStreamList createItera

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink-ml] zhipeng93 opened a new pull request #34: [FLINK-24279] [hotfix]: fix nullpointer exception when broadcast variables are cleaned

zhipeng93 opened a new pull request #34: URL: https://github.com/apache/flink-ml/pull/34 This PR fixes the concurrency bug in the following case: Step1: BroadcastVariableReceiverOperator#endInput Step2: BroadcastVariableReceiverOperator#initializeState Step3: AbstractBroadcastWr

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot commented on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot commented on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

flinkbot commented on pull request #17793: URL: https://github.com/apache/flink/pull/17793#issuecomment-968529486 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-21565) Support more integer types in TIMESTAMPADD

[ https://issues.apache.org/jira/browse/FLINK-21565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21565: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was: auto

[GitHub] [flink] shenzhu opened a new pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

shenzhu opened a new pull request #17793: URL: https://github.com/apache/flink/pull/17793 ## What is the purpose of the change This pull request adds support for more integer types in `TIMESTAMPADD`. ## Brief change log - Add support from `TINYINT`/`SMALLINT`

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[jira] [Closed] (FLINK-24882) Make SQL format identifier NOT case-sensitive.

[ https://issues.apache.org/jira/browse/FLINK-24882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moses closed FLINK-24882. - Resolution: Not A Problem > Make SQL format identifier NOT case-sensitive. > ---

[GitHub] [flink] flinkbot commented on pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

flinkbot commented on pull request #17792: URL: https://github.com/apache/flink/pull/17792#issuecomment-968525307 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 #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

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

[GitHub] [flink] shenzhu commented on a change in pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

shenzhu commented on a change in pull request #17788: URL: https://github.com/apache/flink/pull/17788#discussion_r748995473 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/Catalog.java ## @@ -520,6 +520,20 @@ void alterFunction( v

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[jira] [Updated] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24763: --- Labels: pull-request-available test-stability (was: test-stability) > ParquetFileSystemITCa

[GitHub] [flink] JingsongLi opened a new pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

JingsongLi opened a new pull request #17792: URL: https://github.com/apache/flink/pull/17792 ## What is the purpose of the change Exceptions in `ParquetFileSystemITCase.testLimitableBulkFormat` ``` 2021-11-03T22:10:11.5215786Z Nov 03 22:10:11 Caused by: java.lang.IllegalStateEx

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443546#comment-17443546 ] Jingsong Lee commented on FLINK-24763: -- CC: [~sewen] [~becket_qin] Do we have a bet

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443545#comment-17443545 ] Jingsong Lee commented on FLINK-24763: -- The reason is `globalNumberRead` in the `Li

[jira] [Comment Edited] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443534#comment-17443534 ] Jingsong Lee edited comment on FLINK-24763 at 11/15/21, 4:16 AM: -

[jira] [Comment Edited] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443534#comment-17443534 ] Jingsong Lee edited comment on FLINK-24763 at 11/15/21, 4:15 AM: -

[jira] [Created] (FLINK-24892) FLIP-187: Adaptive Batch Job Scheduler

Lijie Wang created FLINK-24892: -- Summary: FLIP-187: Adaptive Batch Job Scheduler Key: FLINK-24892 URL: https://issues.apache.org/jira/browse/FLINK-24892 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink] gaurav726 commented on a change in pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

gaurav726 commented on a change in pull request #17754: URL: https://github.com/apache/flink/pull/17754#discussion_r748991806 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactoryTest.java ## @@ -174,6 +

[GitHub] [flink] gaurav726 commented on a change in pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

gaurav726 commented on a change in pull request #17754: URL: https://github.com/apache/flink/pull/17754#discussion_r748991713 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java ## @@ -146,10 +1

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink] xuyangzhong commented on a change in pull request #17734: [FLINK-23305][table]Support semi/anti interval joins

xuyangzhong commented on a change in pull request #17734: URL: https://github.com/apache/flink/pull/17734#discussion_r748990493 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/interval/SemiAntiTimeIntervalJoin.java ## @

[GitHub] [flink] xuyangzhong commented on a change in pull request #17734: [FLINK-23305][table]Support semi/anti interval joins

xuyangzhong commented on a change in pull request #17734: URL: https://github.com/apache/flink/pull/17734#discussion_r748990493 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/interval/SemiAntiTimeIntervalJoin.java ## @

  1   2   3   >