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

2021-11-14 Thread Sergey Nuyanzin (Jira)
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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17793: URL: https://github.com/apache/flink/pull/17793#issuecomment-968529898 ## CI report: * 1f04daffa570d5ca446908c6726b198475e390be Azure:

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

2021-11-14 Thread Martijn Visser (Jira)
[ 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

2021-11-14 Thread Martijn Visser (Jira)
[ 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

2021-11-14 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443608#comment-17443608 ] Martijn Visser commented on FLINK-18202: [~complone] I've assigned it to you. Looking forward to

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

2021-11-14 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443605#comment-17443605 ] Arvid Heise commented on FLINK-6573: That's good looking already :) Looking forward to your PR. We

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * 01ddc5f4a8a166281889407602bf9dd0514a211d Azure:

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

2021-11-14 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443602#comment-17443602 ] Arvid Heise commented on FLINK-24763: - How does the fetcher thread determines if there are remaining

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17792: URL: https://github.com/apache/flink/pull/17792#issuecomment-968524862 ## CI report: * 87ccd1f5232d04d53409eb233bc54722d83f7613 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17791: URL: https://github.com/apache/flink/pull/17791#issuecomment-968466903 ## CI report: * ee5cb12537e5a4e34428c776a03508e56fd92f49 Azure:

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

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

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 0e9e25f17ee96839873e30207d4561b741ab245b Azure:

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

2021-11-14 Thread Sergey Nuyanzin (Jira)
[ 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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17791: URL: https://github.com/apache/flink/pull/17791#issuecomment-968466903 ## CI report: * ee5cb12537e5a4e34428c776a03508e56fd92f49 Azure:

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

2021-11-14 Thread Dawid Wysakowicz (Jira)
[ 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…

2021-11-14 Thread GitBox
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:

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

2021-11-14 Thread GitBox
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:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17537: URL: https://github.com/apache/flink/pull/17537#issuecomment-948566240 ## CI report: * 0530987b082faddf939df514c066c388f287346a Azure:

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

2021-11-14 Thread Caizhi Weng (Jira)
[ 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

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

2021-11-14 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443579#comment-17443579 ] Caizhi Weng commented on FLINK-24885: - I've reproduced this case. This is because SourceConversion

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

2021-11-14 Thread Caizhi Weng (Jira)
[ 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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * b51f758aa256fbc88737f0e12a53e5ed82cd067f Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * b51f758aa256fbc88737f0e12a53e5ed82cd067f Azure:

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

2021-11-14 Thread GitBox
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

2021-11-14 Thread GitBox
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

2021-11-14 Thread Echo Lee (Jira)
[ 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

2021-11-14 Thread GitBox
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

2021-11-14 Thread GitBox
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 ## @@

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

2021-11-14 Thread GitBox
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:

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

2021-11-14 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443569#comment-17443569 ] Echo Lee commented on FLINK-24891: -- [~wangyang0918] Yes, this is exactly what i want. Thanks, I will

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17790: URL: https://github.com/apache/flink/pull/17790#issuecomment-968450011 ## CI report: * 8b0f84eacbeb296a7c2253277ef5ba2ac625c2b8 Azure:

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

2021-11-14 Thread ZhuoYu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443565#comment-17443565 ] ZhuoYu Chen edited comment on FLINK-6573 at 11/15/21, 6:43 AM: --- [~arvid]

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

2021-11-14 Thread ZhuoYu Chen (Jira)
[ 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

2021-11-14 Thread ZhuoYu Chen (Jira)
[ 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

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

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

2021-11-14 Thread ZhuoYu Chen (Jira)
[ 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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17791: URL: https://github.com/apache/flink/pull/17791#issuecomment-968466903 ## CI report: * ee5cb12537e5a4e34428c776a03508e56fd92f49 Azure:

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

2021-11-14 Thread GitBox
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 @@

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

2021-11-14 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443562#comment-17443562 ] Yun Gao commented on FLINK-24842: - Fix on master via

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

2021-11-14 Thread Yun Gao (Jira)
[ 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

2021-11-14 Thread GitBox
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:

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

2021-11-14 Thread ZhuoYu Chen (Jira)
[ 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

2021-11-14 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443561#comment-17443561 ] Yang Wang commented on FLINK-24891: --- I am not sure whether

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

2021-11-14 Thread ZhuoYu Chen (Jira)
[ 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

2021-11-14 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443560#comment-17443560 ] Caizhi Weng commented on FLINK-24885: - [~wangbaohua] is it possible that {{kafkaData1}} produce a

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

2021-11-14 Thread Caizhi Weng (Jira)
[ 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 :

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

2021-11-14 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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.

2021-11-14 Thread GitBox
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

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

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

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

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

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

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

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

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

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 6f0727e525cb34f2a5afbe3207dac73e177ddb33 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 6f0727e525cb34f2a5afbe3207dac73e177ddb33 Azure:

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

2021-11-14 Thread GitBox
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

2021-11-14 Thread GitBox
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

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
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:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17793: URL: https://github.com/apache/flink/pull/17793#issuecomment-968529898 ## CI report: * 1f04daffa570d5ca446908c6726b198475e390be Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
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

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
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

[jira] [Updated] (FLINK-21565) Support more integer types in TIMESTAMPADD

2021-11-14 Thread ASF GitHub Bot (Jira)
[ 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:

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

2021-11-14 Thread GitBox
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

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17792: URL: https://github.com/apache/flink/pull/17792#issuecomment-968524862 ## CI report: * 87ccd1f5232d04d53409eb233bc54722d83f7613 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread Moses (Jira)
[ 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

2021-11-14 Thread GitBox
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

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

2021-11-14 Thread GitBox
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

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

2021-11-14 Thread GitBox
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(

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread ASF GitHub Bot (Jira)
[ 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) >

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

2021-11-14 Thread GitBox
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:

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

2021-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443546#comment-17443546 ] Jingsong Lee commented on FLINK-24763: -- CC: [~sewen] [~becket_qin] Do we have a better way to

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

2021-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443545#comment-17443545 ] Jingsong Lee commented on FLINK-24763: -- The reason is `globalNumberRead` in the

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

2021-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443534#comment-17443534 ] Jingsong Lee edited comment on FLINK-24763 at 11/15/21, 4:16 AM: - I will

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

2021-11-14 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443534#comment-17443534 ] Jingsong Lee edited comment on FLINK-24763 at 11/15/21, 4:15 AM: - I will

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

2021-11-14 Thread Lijie Wang (Jira)
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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * aa3331b4386bc2adbd15fb2658ea490ed30aa4c2 Azure:

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 6f0727e525cb34f2a5afbe3207dac73e177ddb33 Azure:

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

2021-11-14 Thread GitBox
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

2021-11-14 Thread GitBox
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

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

2021-11-14 Thread GitBox
flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 6f0727e525cb34f2a5afbe3207dac73e177ddb33 Azure:

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

2021-11-14 Thread GitBox
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

2021-11-14 Thread GitBox
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   >