[GitHub] [flink] flinkbot edited a comment on pull request #16306: [FLINK-23158] Add source transformations to the list when adding sources

flinkbot edited a comment on pull request #16306: URL: https://github.com/apache/flink/pull/16306#issuecomment-869338082 ## CI report: * 66ed8fc72a4301a4b23b06e255bfb658fc5d3928 Azure:

[jira] [Commented] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer

[ https://issues.apache.org/jira/browse/FLINK-22956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370406#comment-17370406 ] Jingsong Lee commented on FLINK-22956: -- Hi [~nicholasjiang]  Over Funcs has some logic that

[GitHub] [flink] flinkbot commented on pull request #16306: [FLINK-23158] Add source transformations to the list when adding sources

flinkbot commented on pull request #16306: URL: https://github.com/apache/flink/pull/16306#issuecomment-869338082 ## CI report: * 66ed8fc72a4301a4b23b06e255bfb658fc5d3928 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] RocMarshal edited a comment on pull request #16300: [Hotfix][docs] Fixed typos.

RocMarshal edited a comment on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869337797 @tisonkun Thank you for your reply. I found this problem during the investigation of version upgrade. It’s probably that `ScalaVersion = "_2.11" ` was discussed

[GitHub] [flink] flinkbot edited a comment on pull request #16305: [FLINK-22157][table-planner-blink] Fix join & select a portion of composite primary key will cause ArrayIndexOutOfBoundsException

flinkbot edited a comment on pull request #16305: URL: https://github.com/apache/flink/pull/16305#issuecomment-869301608 ## CI report: * 8932007479d6238b414b568b8f51d8f1cae69b70 Azure:

[GitHub] [flink-benchmarks] zhuzhurk commented on a change in pull request #17: [FLINK-23078] Fix SchedulerBenchmarkExecutorBase#teardown

zhuzhurk commented on a change in pull request #17: URL: https://github.com/apache/flink-benchmarks/pull/17#discussion_r659465800 ## File path: src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkBase.java ## @@ -55,4 +58,10 @@ public static void

[GitHub] [flink] RocMarshal commented on pull request #16300: [Hotfix][docs] Fixed typos.

RocMarshal commented on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869337797 @tisonkun Thank you for your reply. I found this problem during the investigation of version upgrade. It’s probably that `ScalaVersion = "_2.11" ` was discussed carefully

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * 43550b885f3b52e7db0f82cbbf84c4086b66456c UNKNOWN * 087283320d89633e8c0cb08a331a0c0fe135549e Azure:

[GitHub] [flink] flinkbot commented on pull request #16306: [FLINK-23158] Add source transformations to the list when adding sources

flinkbot commented on pull request #16306: URL: https://github.com/apache/flink/pull/16306#issuecomment-869334047 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-23158) Source transformation is not added to the StreamExecutionEnvironment explicitly

[ https://issues.apache.org/jira/browse/FLINK-23158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23158: --- Labels: pull-request-available (was: ) > Source transformation is not added to the

[GitHub] [flink] gaoyunhaii opened a new pull request #16306: [FLINK-23158] Add source transformations to the list when adding sources

gaoyunhaii opened a new pull request #16306: URL: https://github.com/apache/flink/pull/16306 ## What is the purpose of the change This PR explicitly adds the source transformation to the list of the env to avoid exception thrown for source only jobs. ## Brief change log

[GitHub] [flink] flinkbot edited a comment on pull request #16305: [FLINK-22157][table-planner-blink] Fix join & select a portion of composite primary key will cause ArrayIndexOutOfBoundsException

flinkbot edited a comment on pull request #16305: URL: https://github.com/apache/flink/pull/16305#issuecomment-869301608 ## CI report: * 8932007479d6238b414b568b8f51d8f1cae69b70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16305: [FLINK-22157][table-planner-blink] Fix join & select a portion of composite primary key will cause ArrayIndexOutOfBoundsException

flinkbot edited a comment on pull request #16305: URL: https://github.com/apache/flink/pull/16305#issuecomment-869301608 ## CI report: * 8932007479d6238b414b568b8f51d8f1cae69b70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

flinkbot edited a comment on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788701462 ## CI report: * 43550b885f3b52e7db0f82cbbf84c4086b66456c UNKNOWN * 087283320d89633e8c0cb08a331a0c0fe135549e Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-22458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370398#comment-17370398 ] chrismartin edited comment on FLINK-22458 at 6/28/21, 3:15 AM: --- i have the

[GitHub] [flink] becketqin commented on a change in pull request #16115: [FLINK-22766][connector/kafka] Report offsets and Kafka consumer metrics in Flink metric group

becketqin commented on a change in pull request #16115: URL: https://github.com/apache/flink/pull/16115#discussion_r659446873 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java ## @@

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

[ https://issues.apache.org/jira/browse/FLINK-22458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370398#comment-17370398 ] chrismartin commented on FLINK-22458: - i have same problem, did you resolve it ? > Failed when

[jira] [Comment Edited] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370397#comment-17370397 ] Jark Wu edited comment on FLINK-22781 at 6/28/21, 3:09 AM: --- If we don't

[jira] [Commented] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370397#comment-17370397 ] Jark Wu commented on FLINK-22781: - If we don't consider backward-compatibility, I think using just

[jira] [Commented] (FLINK-20784) .staging_xxx does not exist, when insert into hive

[ https://issues.apache.org/jira/browse/FLINK-20784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370396#comment-17370396 ] chrismartin commented on FLINK-20784: - I have the same problem in 1.12.1, how did you fix it, which

[GitHub] [flink] flinkbot commented on pull request #16305: [FLINK-22157][table-planner-blink] Fix join & select a portion of composite primary key will cause ArrayIndexOutOfBoundsException

flinkbot commented on pull request #16305: URL: https://github.com/apache/flink/pull/16305#issuecomment-869301608 ## CI report: * 8932007479d6238b414b568b8f51d8f1cae69b70 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] Zakelly edited a comment on pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

Zakelly edited a comment on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-869297752 > I've updated the PR, PTAL @Myasuka and @curcur (@Zakelly do you have any other concerns?) I have no more concerns :) -- This is an automated message from the

[GitHub] [flink] Zakelly commented on pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

Zakelly commented on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-869297752 > I've updated the PR, PTAL @Myasuka and @curcur (@Zakelly do you have any other concerns?) I have no more concerns :) -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370393#comment-17370393 ] Jingsong Lee commented on FLINK-22781: -- Hi Jing, Thanks for the summarization. First of all, I

[jira] [Updated] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22621: - Priority: Major (was: Minor) > HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on

[jira] [Commented] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370392#comment-17370392 ] Xintong Song commented on FLINK-22621: --

[jira] [Updated] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22621: - Labels: (was: auto-deprioritized-major) > HBaseConnectorITCase.testTableSourceSinkWithDDL

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370391#comment-17370391 ] Xintong Song commented on FLINK-23052: --

[GitHub] [flink] flinkbot commented on pull request #16305: [FLINK-22157][table-planner-blink] Fix join & select a portion of composite primary key will cause ArrayIndexOutOfBoundsException

flinkbot commented on pull request #16305: URL: https://github.com/apache/flink/pull/16305#issuecomment-869293785 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-21229) Support ssl connection with schema registry format

[ https://issues.apache.org/jira/browse/FLINK-21229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-21229: - Fix Version/s: (was: 1.12.6) 1.12.5 > Support ssl connection with schema

[GitHub] [flink] TsReaper opened a new pull request #16305: [FLINK-22157][table-planner-blink] Fix join & select a portion of composite primary key will cause ArrayIndexOutOfBoundsException

TsReaper opened a new pull request #16305: URL: https://github.com/apache/flink/pull/16305 (This PR is picked from #15540.) ## What is the purpose of the change `FlinkRelMdUniqueKeys#getTableUniqueKeys` currently does not consider the case when projections are pushed down and

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370387#comment-17370387 ] Xintong Song commented on FLINK-23052: --

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370386#comment-17370386 ] Xintong Song commented on FLINK-22545: --

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370385#comment-17370385 ] Xintong Song commented on FLINK-23052: --

[jira] [Closed] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22970. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in - master: aef798d7c85b397a96bd20b2ecec9ab105177551

[GitHub] [flink] wuchong merged pull request #16141: [FLINK-22970][docs] The documentation for `TO_TIMESTAMP` UDF has an incorrect description

wuchong merged pull request #16141: URL: https://github.com/apache/flink/pull/16141 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-22891) FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370383#comment-17370383 ] Xintong Song commented on FLINK-22891: --

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370382#comment-17370382 ] Xintong Song commented on FLINK-23052: --

[jira] [Created] (FLINK-23164) JobMasterTest.testMultipleStartsWork unstable on azure

Xintong Song created FLINK-23164: Summary: JobMasterTest.testMultipleStartsWork unstable on azure Key: FLINK-23164 URL: https://issues.apache.org/jira/browse/FLINK-23164 Project: Flink Issue

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370381#comment-17370381 ] Xintong Song commented on FLINK-23052: --

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370380#comment-17370380 ] Xintong Song commented on FLINK-20495: --

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370379#comment-17370379 ] Xintong Song commented on FLINK-23052: --

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370378#comment-17370378 ] Xintong Song commented on FLINK-22457: --

[GitHub] [flink] leonardBang commented on pull request #16141: [FLINK-22970][docs] The documentation for `TO_TIMESTAMP` UDF has an incorrect description

leonardBang commented on pull request #16141: URL: https://github.com/apache/flink/pull/16141#issuecomment-869277732 cc @wuchong Please help merge this one -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370377#comment-17370377 ] Xintong Song commented on FLINK-23052: --

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370376#comment-17370376 ] Xintong Song commented on FLINK-22198: --

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370375#comment-17370375 ] Xintong Song commented on FLINK-23052: --

[GitHub] [flink] RocMarshal commented on pull request #16300: [Hotfix][docs] Fixed typos.

RocMarshal commented on pull request #16300: URL: https://github.com/apache/flink/pull/16300#issuecomment-869276692 > https://github.com/apache/flink/blob/2a7e7d7e92f0610502e59f6104391a83dc8b5692/flink-yarn/pom.xml#L44-L54 > > @RocMarshal nope. Our codebase is in the pattern

[jira] [Commented] (FLINK-12403) Translate "How to use logging" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370373#comment-17370373 ] wuguihu commented on FLINK-12403: - Hi，[~jark] , can you assign this issue to me? I'd like to working on

[GitHub] [flink] wanglijie95 commented on pull request #16274: [FLINK-23093] Limit default io pool size to 8 for Mini Cluster.

wanglijie95 commented on pull request #16274: URL: https://github.com/apache/flink/pull/16274#issuecomment-869260910 Hi @StephanEwen , please help for the review, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-22578) deployment configuration page miss content navigate menu

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

[jira] [Updated] (FLINK-22723) multi-field-dynamic index is not supported by elasticsearch connector

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

[jira] [Updated] (FLINK-21394) FLIP-164: Improve Schema Handling in Catalogs

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

[jira] [Updated] (FLINK-22527) Give friendly hint when click FlameGraph without rest.flamegraph.enabled

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

[jira] [Updated] (FLINK-20946) Optimize Python ValueState Implementation In PyFlink

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

[jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend

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

[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 stale-major (was:

[jira] [Updated] (FLINK-22589) There are quite a few Python classes doesn't appear in the Python docs

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

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

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

[jira] [Updated] (FLINK-20935) can't write flink configuration to tmp file and add it to local resource in yarn session mode

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

[jira] [Updated] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

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

[jira] [Updated] (FLINK-21962) SQL Group Windows do not work on Flink 1.11

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

[jira] [Updated] (FLINK-22701) "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg

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

[jira] [Updated] (FLINK-21444) Lookup joins should deal with intermediate table scans correctly

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

[jira] [Updated] (FLINK-22764) Disable Values Source node in streaming plan optimization

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

[jira] [Updated] (FLINK-22787) Fix parse error when input statement has inline comments

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

[jira] [Updated] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs

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

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

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

[jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents

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

[jira] [Updated] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating)

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

[jira] [Updated] (FLINK-19033) Cleanups of DataStream API

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

[jira] [Updated] (FLINK-20920) Document how to connect to kerberized HMS

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

[jira] [Updated] (FLINK-19230) Support Python UDAF on blink batch planner

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

[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

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

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

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

[jira] [Updated] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job"

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

[jira] [Updated] (FLINK-22729) Truncated Messages in Python workers

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

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

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

[jira] [Updated] (FLINK-21065) Passing configuration from TableEnvironmentImpl to MiniCluster is not supported

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

[jira] [Updated] (FLINK-22531) Improve the support for finite streaming jobs with async operations.

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

[jira] [Updated] (FLINK-20929) Add automated deployment of nightly docker images

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

[jira] [Updated] (FLINK-22727) SerializableAvroSchema cannot handle large schema

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

[GitHub] [flink] flinkbot edited a comment on pull request #16304: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

flinkbot edited a comment on pull request #16304: URL: https://github.com/apache/flink/pull/16304#issuecomment-869200661 ## CI report: * e1b712ae652bd439c03d94b97015a39b7666d3d4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16304: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

flinkbot edited a comment on pull request #16304: URL: https://github.com/apache/flink/pull/16304#issuecomment-869200661 ## CI report: * e1b712ae652bd439c03d94b97015a39b7666d3d4 Azure:

[GitHub] [flink] flinkbot commented on pull request #16304: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

flinkbot commented on pull request #16304: URL: https://github.com/apache/flink/pull/16304#issuecomment-869200661 ## CI report: * e1b712ae652bd439c03d94b97015a39b7666d3d4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16304: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

flinkbot commented on pull request #16304: URL: https://github.com/apache/flink/pull/16304#issuecomment-869197551 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] hapihu opened a new pull request #16304: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

hapihu opened a new pull request #16304: URL: https://github.com/apache/flink/pull/16304 Translate Task Lifecycle document into Chinese -- 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] yiduwangkai commented on pull request #13339: [FLINK-19157][jdbc] Added Phoenix dialect

yiduwangkai commented on pull request #13339: URL: https://github.com/apache/flink/pull/13339#issuecomment-869183602 @wuchong zhouzach is busy, i can help to continue this work， is that ok? -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Comment Edited] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370232#comment-17370232 ] godfrey he edited comment on FLINK-23135 at 6/27/21, 2:46 PM: --

[jira] [Comment Edited] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370232#comment-17370232 ] godfrey he edited comment on FLINK-23135 at 6/27/21, 2:46 PM: --

[jira] [Comment Edited] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370232#comment-17370232 ] godfrey he edited comment on FLINK-23135 at 6/27/21, 2:44 PM: --

[jira] [Commented] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370232#comment-17370232 ] godfrey he commented on FLINK-23135: [~zhengjiewen] The reason is:

[jira] [Updated] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-23135: --- Fix Version/s: 1.12.5 > Flink SQL Error while applying rule AggregateReduceGroupingRule >

[GitHub] [flink] flinkbot edited a comment on pull request #16303: [FLINK-23009][kinesis] Include guava failureaccess in jar

flinkbot edited a comment on pull request #16303: URL: https://github.com/apache/flink/pull/16303#issuecomment-869138760 ## CI report: * 41f0a6cd2e7f3623388a4a6e3032eca9efa8d7a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16274: [FLINK-23093] Limit default io pool size to 8 for Mini Cluster.

flinkbot edited a comment on pull request #16274: URL: https://github.com/apache/flink/pull/16274#issuecomment-867441605 ## CI report: * f11971105620910117d3f215818ed9ff50b0a50c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16302: [FLINK-23163][Kubernetes]Add debug log to flink kubeclient

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

[jira] [Updated] (FLINK-23163) Add debug ability for kubernetes client

[ https://issues.apache.org/jira/browse/FLINK-23163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-23163: --- Description: add option to enable http client debug log (was: # set user agent to http client # add

[jira] [Commented] (FLINK-12438) Translate "Task Lifecycle" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370202#comment-17370202 ] wuguihu commented on FLINK-12438: - Hi Jark Wu, can you assign this issue to me? I'd like to working on

[GitHub] [flink] flinkbot edited a comment on pull request #16303: [FLINK-23009][kinesis] Include guava failureaccess in jar

flinkbot edited a comment on pull request #16303: URL: https://github.com/apache/flink/pull/16303#issuecomment-869138760 ## CI report: * 41f0a6cd2e7f3623388a4a6e3032eca9efa8d7a7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16274: [FLINK-23093] Limit default io pool size to 8 for Mini Cluster.

flinkbot edited a comment on pull request #16274: URL: https://github.com/apache/flink/pull/16274#issuecomment-867441605 ## CI report: * Unknown: [CANCELED](TBD) * f11971105620910117d3f215818ed9ff50b0a50c Azure:

  1   2   >