[GitHub] [flink] KarmaGYZ commented on a change in pull request #15975: [FLINK-22725][coordination] SlotManagers unregister metrics in suspend()

KarmaGYZ commented on a change in pull request #15975: URL: https://github.com/apache/flink/pull/15975#discussion_r637706827 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManagerTest.java ## @@ -948,4 +955,42 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

flinkbot edited a comment on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-845673686 ## CI report: * 26d7d8b9c71a8ca8303fd0ee190f399c126c14db UNKNOWN * a46d3e1921ab7708ffbb9ced824e62ebc0ee4664 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints

flinkbot edited a comment on pull request #15938: URL: https://github.com/apache/flink/pull/15938#issuecomment-842314070 ## CI report: * 33939b7a2ed84a7564cb69857f31d12a575c9927 Azure:

[jira] [Comment Edited] (FLINK-19926) Wrong results for join post tumble grouping

[ https://issues.apache.org/jira/browse/FLINK-19926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350250#comment-17350250 ] Shuo Cheng edited comment on FLINK-19926 at 5/24/21, 5:56 AM: -- Hi,

[jira] [Commented] (FLINK-19926) Wrong results for join post tumble grouping

[ https://issues.apache.org/jira/browse/FLINK-19926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350250#comment-17350250 ] Shuo Cheng commented on FLINK-19926: Hi, [~satyamshekhar], I've test the case you present above, and

[GitHub] [flink] yittg commented on pull request #15984: [FLINK-21921][k8s] Deal add event as well in retrieval service

yittg commented on pull request #15984: URL: https://github.com/apache/flink/pull/15984#issuecomment-846746683 @wangyang0918 I want to say it's another issue. But i must say your concern is absolutely right, :) -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] JasonLeeCoding commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

JasonLeeCoding commented on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-846744203 > hi, I fix the broken test in branch https://github.com/apache/flink/compare/master...fsk119:local_dev?expand=1 > > Please take a look. OK , I got

[GitHub] [flink] flinkbot edited a comment on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

flinkbot edited a comment on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-845673686 ## CI report: * 26d7d8b9c71a8ca8303fd0ee190f399c126c14db UNKNOWN * a46d3e1921ab7708ffbb9ced824e62ebc0ee4664 Azure:

[GitHub] [flink] fsk119 commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

fsk119 commented on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-846728632 hi, I fix the broken test in branch https://github.com/apache/flink/compare/master...fsk119:local_dev?expand=1 Please take a look. -- This is an automated message from

[GitHub] [flink] flinkbot edited a comment on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

flinkbot edited a comment on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-845673686 ## CI report: * 26d7d8b9c71a8ca8303fd0ee190f399c126c14db UNKNOWN * a46d3e1921ab7708ffbb9ced824e62ebc0ee4664 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * ff58123cc85c7b14cce996b8d04a4c1cfee9e167 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

flinkbot edited a comment on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-845673686 ## CI report: * 26d7d8b9c71a8ca8303fd0ee190f399c126c14db UNKNOWN * a46d3e1921ab7708ffbb9ced824e62ebc0ee4664 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * ff58123cc85c7b14cce996b8d04a4c1cfee9e167 Azure:

[jira] [Commented] (FLINK-20219) Rethink the HA related ZNodes/ConfigMap clean up for session cluster

[ https://issues.apache.org/jira/browse/FLINK-20219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350232#comment-17350232 ] Yang Wang commented on FLINK-20219: --- Since FLINK-20695 has been merged, we will not have job level

[GitHub] [flink] fsk119 commented on a change in pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

fsk119 commented on a change in pull request #15980: URL: https://github.com/apache/flink/pull/15980#discussion_r637665079 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java ## @@ -176,12 +176,14 @@ public void

[jira] [Updated] (FLINK-20219) Rethink the HA related ZNodes/ConfigMap clean up for session cluster

[ https://issues.apache.org/jira/browse/FLINK-20219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-20219: -- Labels: (was: stale-assigned) > Rethink the HA related ZNodes/ConfigMap clean up for session

[GitHub] [flink] JasonLeeCoding commented on a change in pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script

JasonLeeCoding commented on a change in pull request #15980: URL: https://github.com/apache/flink/pull/15980#discussion_r637664244 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java ## @@ -176,12 +176,14 @@ public void

[GitHub] [flink] fsk119 commented on a change in pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

fsk119 commented on a change in pull request #15980: URL: https://github.com/apache/flink/pull/15980#discussion_r637663348 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java ## @@ -176,12 +176,14 @@ public void

[GitHub] [flink] xintongsong commented on pull request #15524: [FLINK-21667][runtime] Defer starting ResourceManager to after obtaining leadership.

xintongsong commented on pull request #15524: URL: https://github.com/apache/flink/pull/15524#issuecomment-846704389 @tillrohrmann Not necessarily. AFAIK, the Yarn RM requires each AM to register only once, but it does not require using the same `AMRMClient(Async)`. That means, in

[jira] [Commented] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350230#comment-17350230 ] ighack commented on FLINK-22758: I can't use 1.13 > java.lang.IllegalStateException: Trying to access

[GitHub] [flink] flinkbot edited a comment on pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

flinkbot edited a comment on pull request #15925: URL: https://github.com/apache/flink/pull/15925#issuecomment-841952583 ## CI report: * 8119d476fa59a7aa35f09c84e285226ff9b3e238 UNKNOWN * 3ac88d154bc72f24202fc0acacdf0b7ad34777de Azure:

[GitHub] [flink] fsk119 commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

fsk119 commented on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-846699608 The reason why the test fails is because the actual statement is without comment but the expected statement still has comments. Therefore, you just modify the expected statement

[GitHub] [flink] fsk119 commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

fsk119 commented on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-846698293 Please also fix the broken test.. I just notice the test fails. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] JasonLeeCoding commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

JasonLeeCoding commented on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-846697743 > Could you add one more test in `SqlClientTest#testInitFile`? Because all these tests are not end to end tests. I think we can reproduce the bug in

[jira] [Commented] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350222#comment-17350222 ] Gavin Lee commented on FLINK-18592: --- Is there any follow-up on this issue? Met it on Flink 1.11.2 with

[jira] [Commented] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350220#comment-17350220 ] Shengkai Fang commented on FLINK-22758: --- I think this bug has been fixed during the  

[GitHub] [flink] flinkbot edited a comment on pull request #15986: [FLINK-22155][table] EXPLAIN statement should validate insert and query separately

flinkbot edited a comment on pull request #15986: URL: https://github.com/apache/flink/pull/15986#issuecomment-845832908 ## CI report: * 9e5ba67bb6d38cddfaa8623a863af7245a86c58f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints

flinkbot edited a comment on pull request #15938: URL: https://github.com/apache/flink/pull/15938#issuecomment-842314070 ## CI report: * 33939b7a2ed84a7564cb69857f31d12a575c9927 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

flinkbot edited a comment on pull request #15925: URL: https://github.com/apache/flink/pull/15925#issuecomment-841952583 ## CI report: * 8119d476fa59a7aa35f09c84e285226ff9b3e238 UNKNOWN * 3ac88d154bc72f24202fc0acacdf0b7ad34777de Azure:

[GitHub] [flink] fsk119 commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

fsk119 commented on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-846694843 Other change looks good to me. -- 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] [Comment Edited] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350213#comment-17350213 ] ighack edited comment on FLINK-22758 at 5/24/21, 2:40 AM: -- # dowload flink #

[jira] [Comment Edited] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350213#comment-17350213 ] ighack edited comment on FLINK-22758 at 5/24/21, 2:40 AM: -- # dowload flink #

[jira] [Comment Edited] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350213#comment-17350213 ] ighack edited comment on FLINK-22758 at 5/24/21, 2:39 AM: -- # dowload flink #

[jira] [Comment Edited] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350213#comment-17350213 ] ighack edited comment on FLINK-22758 at 5/24/21, 2:38 AM: -- # dowload flink #

[GitHub] [flink] yittg commented on pull request #15984: [FLINK-21921][k8s] Deal add event as well in retrieval service

yittg commented on pull request #15984: URL: https://github.com/apache/flink/pull/15984#issuecomment-846691137 @wangyang0918 Could you help to review this simple change? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350213#comment-17350213 ] ighack commented on FLINK-22758: # dowload flink # tar -xzvf flink # copy 3 jar files to

[GitHub] [flink] flinkbot edited a comment on pull request #15986: [FLINK-22155][table] EXPLAIN statement should validate insert and query separately

flinkbot edited a comment on pull request #15986: URL: https://github.com/apache/flink/pull/15986#issuecomment-845832908 ## CI report: * 9e5ba67bb6d38cddfaa8623a863af7245a86c58f Azure:

[GitHub] [flink] wenlong88 commented on a change in pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

wenlong88 commented on a change in pull request #14916: URL: https://github.com/apache/flink/pull/14916#discussion_r636854533 ## File path:

[jira] [Closed] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception

[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22719. Resolution: Fixed Fixed via master: 5ec4755def4f7705b45e2ea154ed8e2857cceda0 >

[jira] [Commented] (FLINK-17707) Support configuring replica of Deployment based HA setups

[ https://issues.apache.org/jira/browse/FLINK-17707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350209#comment-17350209 ] Yang Wang commented on FLINK-17707: --- This PR is waiting for FLINK-21667. > Support configuring

[jira] [Updated] (FLINK-17707) Support configuring replica of Deployment based HA setups

[ https://issues.apache.org/jira/browse/FLINK-17707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17707: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Support configuring

[GitHub] [flink] JingsongLi merged pull request #15963: [FLINK-22719][table-planner-blink] Fall back to regular join instead of thrown exception if a join does not satisfy conditions to translate into

JingsongLi merged pull request #15963: URL: https://github.com/apache/flink/pull/15963 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Commented] (FLINK-21383) Docker image does not play well together with ConfigMap based flink-conf.yamls

[ https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350207#comment-17350207 ] Yang Wang commented on FLINK-21383: --- The error of {{sed}} does not affect using the native K8s

[GitHub] [flink] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-846680704 Thanks for the updates, @galenwarren. I'll try to give it another pass this week. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350202#comment-17350202 ] Shengkai Fang commented on FLINK-22758: --- Could you tell us the step to reproduce this bug? >

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * 34ad465ca419b0afdb399e53deca8b27027f7191 Azure:

[jira] [Commented] (FLINK-22393) Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350196#comment-17350196 ] Jianzhang Chen commented on FLINK-22393: Hi [~jark][~xccui][~klion26], my issue has been labeled

[jira] [Updated] (FLINK-22393) Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-22393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jianzhang Chen updated FLINK-22393: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > Translate

[jira] [Updated] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ighack updated FLINK-22758: --- Description: when I exit sql-client.sh I get a error   Shutting down the session...Shutting down the

[jira] [Created] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

ighack created FLINK-22758: -- Summary: java.lang.IllegalStateException: Trying to access closed classloader Key: FLINK-22758 URL: https://issues.apache.org/jira/browse/FLINK-22758 Project: Flink

[jira] [Commented] (FLINK-22750) Simplify Unit Testing of Remote Functions

[ https://issues.apache.org/jira/browse/FLINK-22750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350189#comment-17350189 ] Seth Wiesman commented on FLINK-22750: -- I found the setup in the workshop to be overly cumbersome,

[jira] [Updated] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20392: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22425) allowedLateness and sideOutput not having an effect

[ https://issues.apache.org/jira/browse/FLINK-22425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22425: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable

[ https://issues.apache.org/jira/browse/FLINK-17482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17482: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

[ https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21578: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22401) Python tests fail with "Slot ... is not allocated by job ..."

[ https://issues.apache.org/jira/browse/FLINK-22401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22401: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-17329) Quickstarts Scala nightly e2e test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17329: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-20558) ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure

[ https://issues.apache.org/jira/browse/FLINK-20558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20558: --- Labels: stale-major test-stability testability (was: test-stability testability) I am the

[jira] [Updated] (FLINK-17087) Use constant port for rest.port when it's set as 0 on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-17087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17087: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-17360) Support custom partitioners in JDBCReadOptions

[ https://issues.apache.org/jira/browse/FLINK-17360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17360: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-17415) Fold API-agnostic documentation into DataStream documentation (chinese)

[ https://issues.apache.org/jira/browse/FLINK-17415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17415: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22435) twitter datastream connector gets Invalid 'expires' attribute

[ https://issues.apache.org/jira/browse/FLINK-22435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22435: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-16780) improve Flink lookup join

[ https://issues.apache.org/jira/browse/FLINK-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16780: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16937) ParquetTableSource should generate correct isFilterPushedDown

[ https://issues.apache.org/jira/browse/FLINK-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16937: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-22405) Support fixed-lengh chars in the LeadLag built-in function

[ https://issues.apache.org/jira/browse/FLINK-22405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22405: --- Labels: stale-major starter (was: starter) I am the [Flink Jira

[jira] [Updated] (FLINK-22336) [umbrella] Enhance testing for built-in functions

[ https://issues.apache.org/jira/browse/FLINK-22336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22336: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-17168) TPC-DS end-to-end test failed on travis due to failed to download data generator

[ https://issues.apache.org/jira/browse/FLINK-17168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17168: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status

[ https://issues.apache.org/jira/browse/FLINK-17362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17362: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-17177) Handle ERROR event correctly in KubernetesResourceManager#onError

[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17177: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-17437) Use StringData instead of BinaryStringData in code generation

[ https://issues.apache.org/jira/browse/FLINK-17437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17437: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16601: --- Labels: stale-assigned (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-17742) Blob file not removed after task was cancelled in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-17742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17742: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden

[ https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17642: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-17532) Update tests to use BatchTestBase#checkTableResult

[ https://issues.apache.org/jira/browse/FLINK-17532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17532: --- Labels: auto-deprioritized-major starter (was: stale-major starter) Priority: Minor

[jira] [Updated] (FLINK-17871) Make the default value of attemptFailuresValidityInterval more reasonable

[ https://issues.apache.org/jira/browse/FLINK-17871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17871: --- Labels: stale-minor (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-17755) Support side-output of expiring states with TTL.

[ https://issues.apache.org/jira/browse/FLINK-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17755: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17231: --- Labels: stale-assigned (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-20312) The documentation is incomplete

[ https://issues.apache.org/jira/browse/FLINK-20312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20312: --- Labels: documentation stale-minor (was: documentation) I am the [Flink Jira

[jira] [Updated] (FLINK-16634) The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id.

[ https://issues.apache.org/jira/browse/FLINK-16634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16634: --- Labels: auto-unassigned stale-assigned (was: auto-unassigned) I am the [Flink Jira

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * 2dc286c697fff7ad6adb68c2a0e6de40d1c20bfe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * 2dc286c697fff7ad6adb68c2a0e6de40d1c20bfe Azure:

[jira] [Commented] (FLINK-22757) Update GCS documentation

[ https://issues.apache.org/jira/browse/FLINK-22757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350139#comment-17350139 ] Galen Warren commented on FLINK-22757: -- In case it's relevant here, I'm working on a

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-846625422 @xintongsong Just pushed a commit, I think this addresses your comments so far except for logging (which I'll still add). Also, I'd like to rework some of the unit tests

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601843 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601877 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601812 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601747 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/utils/BlobUtils.java ## @@ -0,0 +1,63 @@ +/* + * Licensed to

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601731 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/utils/BlobUtils.java ## @@ -0,0 +1,63 @@ +/* + * Licensed to

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601600 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterCommitter.java ## @@ -0,0 +1,150

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601541 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriter.java ## @@ -0,0 +1,145 @@ +/* + *

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601541 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriter.java ## @@ -0,0 +1,145 @@ +/* + *

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601346 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableFsDataOutputStream.java ## @@ -0,0

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637601309 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637600964 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637600964 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@

[GitHub] [flink] galenwarren commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r637600964 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints

flinkbot edited a comment on pull request #15938: URL: https://github.com/apache/flink/pull/15938#issuecomment-842314070 ## CI report: * 82ff9f7a173cdb6d30404571c40096b663fa9c5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints

flinkbot edited a comment on pull request #15938: URL: https://github.com/apache/flink/pull/15938#issuecomment-842314070 ## CI report: * 82ff9f7a173cdb6d30404571c40096b663fa9c5e Azure:

[GitHub] [flink] ashwinkolhatkar commented on a change in pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints

ashwinkolhatkar commented on a change in pull request #15938: URL: https://github.com/apache/flink/pull/15938#discussion_r637591857 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterUncaughtExceptionHandler.java ## @@ -0,0 +1,49 @@ +/* + *

  1   2   >