[GitHub] [flink] Airblader removed a comment on pull request #16006: [FLINK-22770][sql-parser][planner-blink] Expose SET/RESET

Airblader removed a comment on pull request #16006: URL: https://github.com/apache/flink/pull/16006#issuecomment-849333982 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

wuchong commented on pull request #15767: URL: https://github.com/apache/flink/pull/15767#issuecomment-849339161 @PatrickRen once you are fine with the translation. I can help to merge this. -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-21464) Support ADD JAR command in sql client

[ https://issues.apache.org/jira/browse/FLINK-21464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21464. --- Resolution: Fixed Fixed in master: 34ff7537d3746ca6c6e14742eab0982ebde733b0 > Support ADD JAR command in

[GitHub] [flink] wuchong merged pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

wuchong merged pull request #15925: URL: https://github.com/apache/flink/pull/15925 -- 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,

[GitHub] [flink] Airblader commented on pull request #16006: [FLINK-22770][sql-parser][planner-blink] Expose SET/RESET

Airblader commented on pull request #16006: URL: https://github.com/apache/flink/pull/16006#issuecomment-849333982 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

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

[GitHub] [flink] beyond1920 commented on a change in pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

beyond1920 commented on a change in pull request #15997: URL: https://github.com/apache/flink/pull/15997#discussion_r640272825 ## File path:

[GitHub] [flink] beyond1920 commented on a change in pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

beyond1920 commented on a change in pull request #15997: URL: https://github.com/apache/flink/pull/15997#discussion_r640272825 ## File path:

[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-849303032 As far as I know, SQL Client can use comments in both mode(-i and -f). The main problem is we can't use comments around the SQL Client commands, e.g. SET/RESET. -- This is

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 958751f1cbe06cf9163c40e550bc553d6180a77b Azure:

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

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

[GitHub] [flink] beyond1920 commented on a change in pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

beyond1920 commented on a change in pull request #15997: URL: https://github.com/apache/flink/pull/15997#discussion_r640267297 ## File path:

[GitHub] [flink] beyond1920 commented on a change in pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

beyond1920 commented on a change in pull request #15997: URL: https://github.com/apache/flink/pull/15997#discussion_r640267152 ## File path:

[GitHub] [flink] 95chenjz commented on pull request #15767: [FLINK-22393][docs-zh] Translate the page of "Execution Mode (Batch/Streaming)" into Chinese

95chenjz commented on pull request #15767: URL: https://github.com/apache/flink/pull/15767#issuecomment-849291080 > Hi @95chenjz , this translation looks good to me, only some typos and trivial problems. I left some comments. > > Also I don't have the permission to merge PRs, you

[GitHub] [flink] godfreyhe commented on a change in pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

godfreyhe commented on a change in pull request #15997: URL: https://github.com/apache/flink/pull/15997#discussion_r640260862 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 958751f1cbe06cf9163c40e550bc553d6180a77b Azure:

[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-849287222 In fact, I have some doubts that init and file use the same method parseStatement to parse SQL, but file can use comments and init cannot use comments. I think we should

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r640256315 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,213

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 8774a68fe435f2e677a31c7647610c87550fe480 Azure:

[GitHub] [flink] beyond1920 commented on pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

beyond1920 commented on pull request #15997: URL: https://github.com/apache/flink/pull/15997#issuecomment-849271772 cc @godfreyhe -- 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

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352240#comment-17352240 ] Nicolas Ferrario commented on FLINK-18229: -- Hi [~xintongsong], thank you very much! I'll try

[jira] [Comment Edited] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352236#comment-17352236 ] Xintong Song edited comment on FLINK-18229 at 5/27/21, 2:19 AM: Hi

[jira] [Comment Edited] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352236#comment-17352236 ] Xintong Song edited comment on FLINK-18229 at 5/27/21, 2:18 AM: Hi

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 8774a68fe435f2e677a31c7647610c87550fe480 Azure:

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352236#comment-17352236 ] Xintong Song commented on FLINK-18229: -- Hi [~nferrario], Thanks for sharing the information about

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r640239284 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r640239284 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352234#comment-17352234 ] Shengkai Fang commented on FLINK-19973: --- [~twalthr] Sure. I will take a look recently. >

[GitHub] [flink] yittg commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

yittg commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-849258434 Hi @wangyang0918 , i've added the comment why we use Long.MAX_VALUE. Furthermore, i add a listener to deal with the exception thrown by the informer. -- This is an

[jira] [Updated] (FLINK-22627) Remove SlotManagerImpl

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

[GitHub] [flink] Samuel-Fiddis commented on pull request #15808: [FLINK-21229] add confluent schema registry ssl support

Samuel-Fiddis commented on pull request #15808: URL: https://github.com/apache/flink/pull/15808#issuecomment-849248037 I've updated and compiled the source code appending the following to the CachedSchemaCoderProvider class with the SchemaCoder get() method: import

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 958751f1cbe06cf9163c40e550bc553d6180a77b Azure:

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r640180553 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,213

[jira] [Updated] (FLINK-22017) Regions may never be scheduled when there are cross-region blocking edges

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

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r640179753 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,213

[jira] [Updated] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

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

[jira] [Updated] (FLINK-22069) Check Log Pollution for 1.14 release

[ https://issues.apache.org/jira/browse/FLINK-22069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22069: --- Labels: auto-deprioritized-critical pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

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

[jira] [Updated] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

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

[jira] [Updated] (FLINK-22459) FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)

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

[jira] [Updated] (FLINK-22414) Consider env.hadoop.conf.dir when looking for the hadoop configuration

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

[jira] [Updated] (FLINK-19442) Unaligned checkpoints 1.1

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

[jira] [Updated] (FLINK-22473) Kinesis connector options are not listed by its factory

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

[jira] [Updated] (FLINK-17133) Support CsvParser Features for CSV format via SQL DDL

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

[jira] [Updated] (FLINK-13815) Implement the SpaceAllocator

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

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 958751f1cbe06cf9163c40e550bc553d6180a77b Azure:

[jira] [Updated] (FLINK-22075) Incorrect null outputs in left join

[ https://issues.apache.org/jira/browse/FLINK-22075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22075: --- Labels: auto-deprioritized-critical auto-unassigned (was: auto-unassigned

[jira] [Updated] (FLINK-17200) Add connectors to ClickHouse

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

[jira] [Updated] (FLINK-22397) OrcFileSystemITCase fails on Azure

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

[jira] [Updated] (FLINK-17225) Support native k8s for scala shell

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

[jira] [Updated] (FLINK-22551) checkpoints: strange behaviour

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

[jira] [Updated] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

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

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r640184455 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,201

[jira] [Updated] (FLINK-22458) Failed when operating empty catalog table

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

[jira] [Updated] (FLINK-22446) Relocate dependencies in hive connector uber jar

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

[jira] [Updated] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

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

[jira] [Updated] (FLINK-22115) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released

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

[jira] [Updated] (FLINK-22328) Failed to send data to Kafka: Producer attempted an operation with an old epoch

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

[jira] [Updated] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

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

[jira] [Updated] (FLINK-22461) Resuming Savepoint (file, async, scale down) end-to-end test failed because of binding port failed

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

[jira] [Updated] (FLINK-22272) Some scenes can't drop table by hive catalog

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

[jira] [Updated] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

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

[jira] [Updated] (FLINK-22199) The JDBC connector does not support TIMESTAMP(6) WITH LOCAL TIME ZONE NOT NULL.

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

[jira] [Updated] (FLINK-22474) Display job configuration in web-ui

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

[jira] [Updated] (FLINK-22246) when use HiveCatalog create table , can't set Table owner property correctly

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

[jira] [Updated] (FLINK-22331) CLI Frontend (RestClient) doesn't work on Apple M1

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

[jira] [Updated] (FLINK-22322) Build hang when compiling Web UI

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

[jira] [Updated] (FLINK-22296) Introduce Preconditions-util into Python API

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

[jira] [Updated] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable

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

[jira] [Updated] (FLINK-22283) GraphiteReporter Metrics named xxx alredy exists

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

[jira] [Closed] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API

[ https://issues.apache.org/jira/browse/FLINK-20090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-20090. -- Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any

[jira] [Updated] (FLINK-18402) NullPointerException in org.apache.flink.api.common.typeutils.base.GenericArraySerializer.copy(GenericArraySerializer.java:96)

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

[jira] [Updated] (FLINK-14078) Introduce more JDBCDialect implementations

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

[jira] [Updated] (FLINK-22247) can not pass AddressList when connecting to rabbitmq

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

[jira] [Closed] (FLINK-8641) Move BootstrapTools#getTaskManagerShellCommand to flink-yarn

[ https://issues.apache.org/jira/browse/FLINK-8641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-8641. - Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any

[jira] [Updated] (FLINK-22238) Investigate angular native flamegraph library

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

[jira] [Updated] (FLINK-22330) Bumps checkstyle, junit, log4j version for security

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

[jira] [Updated] (FLINK-22209) Make StreamTask#triggerCheckpointAsync return void

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

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

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

[jira] [Updated] (FLINK-14482) Bump up rocksdb version

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

[jira] [Updated] (FLINK-22274) SQL parser fails to parse group by statements with brackets in views

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

[jira] [Updated] (FLINK-22280) Add XML output format for Flink Table

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

[jira] [Updated] (FLINK-13803) Introduce SpillableHeapKeyedStateBackend and all necessities

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

[jira] [Closed] (FLINK-16839) Connectors Kinesis metrics can be disabled

[ https://issues.apache.org/jira/browse/FLINK-16839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-16839. -- Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any

[jira] [Updated] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

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

[jira] [Updated] (FLINK-15674) Let Java and Scala Type Extraction go through the same stack

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

[jira] [Updated] (FLINK-15532) Enable strict capacity limit for memory usage for RocksDB

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

[jira] [Updated] (FLINK-15507) Activate local recovery for RocksDB backends by default

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

[jira] [Updated] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL

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

[jira] [Updated] (FLINK-22627) Remove SlotManagerImpl

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

[jira] [Updated] (FLINK-22644) Translate "Native Kubernetes" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #16009: [hotfix][docs] fix a few typos in TVF documentation

flinkbot edited a comment on pull request #16009: URL: https://github.com/apache/flink/pull/16009#issuecomment-849076051 ## CI report: * 3bcebda3993ad3a01e52aea7adcd4b8b42c1a679 Azure:

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352093#comment-17352093 ] Nicolas Ferrario commented on FLINK-18229: -- Hey [~xintongsong], what's the status of this

[GitHub] [flink] flinkbot edited a comment on pull request #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed

flinkbot edited a comment on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445 ## CI report: * 8be462efef265e62459453bde97db575da985e22 Azure:

[GitHub] [flink] afedulov commented on pull request #15991: [FLINK-22757][docs] Adding gcs documentation. Connecting flink to gcs.

afedulov commented on pull request #15991: URL: https://github.com/apache/flink/pull/15991#issuecomment-849101571 It does.  -- This is an automated message from the

[jira] [Updated] (FLINK-22774) Update Kinesis SQL connector's Guava to 27.0-jre

[ https://issues.apache.org/jira/browse/FLINK-22774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22774: - Component/s: Connectors / Kinesis > Update Kinesis SQL connector's Guava to 27.0-jre >

[jira] [Updated] (FLINK-22774) Update Kinesis SQL connector's Guava to 27.0-jre

[ https://issues.apache.org/jira/browse/FLINK-22774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22774: - Summary: Update Kinesis SQL connector's Guava to 27.0-jre (was: Package

[jira] [Closed] (FLINK-22774) Update Kinesis SQL connector's Guava to 27.0-jre

[ https://issues.apache.org/jira/browse/FLINK-22774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22774. Fix Version/s: 1.13.2 1.12.5 1.14.0 Resolution: Fixed

[GitHub] [flink] alpinegizmo commented on pull request #15991: [FLINK-22757][docs] Adding gcs documentation. Connecting flink to gcs.

alpinegizmo commented on pull request #15991: URL: https://github.com/apache/flink/pull/15991#issuecomment-849092771 @afedulov Can you confirm that GCS works for checkpointing? If so, I think the page should mention that use case. -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #16009: [hotfix][docs] fix a few typos in TVF documentation

flinkbot edited a comment on pull request #16009: URL: https://github.com/apache/flink/pull/16009#issuecomment-849076051 ## CI report: * 3bcebda3993ad3a01e52aea7adcd4b8b42c1a679 Azure:

  1   2   3   >