[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: * 2efe0a255bfd628258f269c05e63a10a1f59f794 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

wangyang0918 commented on pull request #15524: URL: https://github.com/apache/flink/pull/15524#issuecomment-846785372 @xintongsong Thanks for the thorough analysis and solution. It makes sense to me to scope out the multiple leader sessions related code changes. After this PR, we could gua

[GitHub] [flink] wangyang0918 edited a comment on pull request #15524: [FLINK-21667][runtime] Defer starting ResourceManager to after obtaining leadership.

wangyang0918 edited a comment on pull request #15524: URL: https://github.com/apache/flink/pull/15524#issuecomment-846785372 @xintongsong Thanks for the thorough analysis and solution. It makes sense to me to scope out the multiple leader sessions related code changes. After this PR, we co

[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: * 5bf86bc69fefd2855cd8ca928b8e06f79a24bdc1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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 @@ p

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17350250#comment-17350250 ] Shuo Cheng edited comment on FLINK-19926 at 5/24/21, 5:56 AM:

[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&focusedCommentId=17350250#comment-17350250 ] Shuo Cheng commented on FLINK-19926: Hi, [~satyamshekhar], I've test the case you pr

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17350232#comment-17350232 ] Yang Wang commented on FLINK-20219: --- Since FLINK-20695 has been merged, we will not ha

[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 testVerbose

[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 cluster

[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 tes

[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 testVerbose

[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 a

[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&focusedCommentId=17350230#comment-17350230 ] ighack commented on FLINK-22758: I can't use 1.13 > java.lang.IllegalStateException: Tr

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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 a

[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 `SqlClientTest#testIn

[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&focusedCommentId=17350222#comment-17350222 ] Gavin Lee commented on FLINK-18592: --- Is there any follow-up on this issue? Met it on F

[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&focusedCommentId=17350220#comment-17350220 ] Shengkai Fang commented on FLINK-22758: --- I think this bug has been fixed during th

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-fl

[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 the

[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&focusedCommentId=17350213#comment-17350213 ] ighack edited comment on FLINK-22758 at 5/24/21, 2:40 AM: -- # do

[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&focusedCommentId=17350213#comment-17350213 ] ighack edited comment on FLINK-22758 at 5/24/21, 2:40 AM: -- # do

[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&focusedCommentId=17350213#comment-17350213 ] ighack edited comment on FLINK-22758 at 5/24/21, 2:39 AM: -- # do

[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&focusedCommentId=17350213#comment-17350213 ] ighack edited comment on FLINK-22758 at 5/24/21, 2:38 AM: -- # do

[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 use

[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&focusedCommentId=17350213#comment-17350213 ] ighack commented on FLINK-22758: # dowload flink # tar -xzvf flink # copy 3 jar files

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalCorrelateToJoinFromTemporalTableFun

[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 > WindowJoinUtil.con

[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&focusedCommentId=17350209#comment-17350209 ] Yang Wang commented on FLINK-17707: --- This PR is waiting for FLINK-21667. > Support co

[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 rep

[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, ple

[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&focusedCommentId=17350207#comment-17350207 ] Yang Wang commented on FLINK-21383: --- The error of {{sed}} does not affect using the na

[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, p

[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&focusedCommentId=17350202#comment-17350202 ] Shengkai Fang commented on FLINK-22758: --- Could you tell us the step to reproduce t

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17350196#comment-17350196 ] Jianzhang Chen commented on FLINK-22393: Hi [~jark][~xccui][~klion26], my issue

[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 the

[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 sessi

[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 Iss

[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&focusedCommentId=17350189#comment-17350189 ] Seth Wiesman commented on FLINK-22750: -- I found the setup in the workshop to be ove

[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 Bot|https://github.com/apache/flink-jira-b

[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 Bot|https://github.com/apache/flink-jira-b

[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) Pri

[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 Bot|https://github.com/apache/flink-jira-b

[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 Bot|https://g

[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) Pri

[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) Thi

[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) Thi

[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) Thi

[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 Bot|https://github.com/apache/flink-jira-b

[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) Thi

[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) Thi

[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 ma

[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 Bot|https://github.com/apac

[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 Bot|https://github.com/apache/flink-jira-b

[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) Pri

[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) Thi

[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) Thi

[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) Thi

[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 Bot|https://github.com/apache/flink-jir

[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) Thi

[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) Thi

[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 Bot|https://github.com/apache/flink-jira-b

[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) Thi

[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 Bot|https://github.com/apache/flink-jir

[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 Bot|https://git

[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 Bot|http

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[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 but

[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 +1,177

[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 @@ +/*

  1   2   >