[jira] [Updated] (FLINK-22868) Update training exercises for 1.13

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

[jira] [Updated] (FLINK-22054) Using a shared watcher for ConfigMap watching

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

[jira] [Updated] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

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

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

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

[jira] [Updated] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. th

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

[jira] [Updated] (FLINK-11374) See more failover and can filter by time range

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

[jira] [Updated] (FLINK-22532) Improve the support for remote functions in the DataStream integration

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

[jira] [Updated] (FLINK-11442) Upgrade OSS SDK Version

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

[jira] [Updated] (FLINK-11407) Allow providing reason messages for TypeSerializerSchemaCompatibility.incompatible()

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

[jira] [Updated] (FLINK-11372) Incorrect delegation of compatibility checks to new snapshots in CollectionSerializerConfigSnapshot

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

[jira] [Updated] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates

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

[jira] [Updated] (FLINK-11313) [checkpoint] Introduce LZ4 compression for keyed state in full checkpoints and savepoints

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

[jira] [Updated] (FLINK-22710) ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed

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

[jira] [Updated] (FLINK-22605) Python UDF should only be created once regardless of how many times it is invoked

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

[jira] [Updated] (FLINK-22004) Translate Flink Roadmap to Chinese.

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

[jira] [Updated] (FLINK-22388) KafkaITCase.testMetricsAndEndOfStream times out on topic creation

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

[jira] [Updated] (FLINK-21716)  Support higher precision for Data Type TIME(p)

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

[jira] [Updated] (FLINK-11286) Support to send StreamStatus.IDLE for non-source operators

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

[jira] [Updated] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka

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

[jira] [Updated] (FLINK-22311) Flink JDBC XA connector need to set maxRetries to 0 to properly working

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

[jira] [Updated] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

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

[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-21153) yarn-per-job deployment target ignores yarn options

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

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

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

[jira] [Updated] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP

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

[jira] [Updated] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

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

[jira] [Updated] (FLINK-22705) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to fail to download the tar

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

[jira] [Updated] (FLINK-22631) Metrics are incorrect when task finished

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

[jira] [Updated] (FLINK-21877) Add E2E test for upsert-kafka connector

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

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

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

[GitHub] [flink] mans2singh commented on pull request #16103: [hotfix][docs] Corrected timezone name and column alignment

mans2singh commented on pull request #16103: URL: https://github.com/apache/flink/pull/16103#issuecomment-864306254 Thanks @leonardBang @wuchong @tisonkun @Airblader for your time. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Updated] (FLINK-11401) Allow compression on ParquetBulkWriter

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

[jira] [Updated] (FLINK-20574) Throttle number of remote invocation requests on startup or restores with large backlogs

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

[GitHub] [flink] mayuehappy commented on pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

mayuehappy commented on pull request #16171: URL: https://github.com/apache/flink/pull/16171#issuecomment-864336463 @rkhachatryan Thx very much for your patience, I have updated the commit, PTAL -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] Aitozi opened a new pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

Aitozi opened a new pull request #16207: URL: https://github.com/apache/flink/pull/16207 …dic or non_periodic ## What is the purpose of the change As describe in issue, this pr is to support sql window to late/early trigger the emit periodic or non_periodic ## Brief

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23031: --- Labels: pull-request-available (was: ) > Support to emit window result with periodic or non

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

[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365839#comment-17365839 ] JING ZHANG commented on FLINK-22719: [~twalthr] Sorry for late response. FLINK-22719

[GitHub] [flink] flinkbot commented on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot commented on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864348261 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 pro

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365841#comment-17365841 ] Aitozi commented on FLINK-23031: I have made a implementation , could you help take a lo

[GitHub] [flink] flinkbot commented on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot commented on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 41f6378376a0aecec273853b4aaeaf8d09ddeb59 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

[ https://issues.apache.org/jira/browse/FLINK-22719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365839#comment-17365839 ] JING ZHANG edited comment on FLINK-22719 at 6/19/21, 4:02 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 773bfcf7c143eea72b1c5284d6dd3dfe19c90c85 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 41f6378376a0aecec273853b4aaeaf8d09ddeb59 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22715) Implement streaming window assigner tablefunction operator

[ https://issues.apache.org/jira/browse/FLINK-22715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-22715: --- Labels: (was: auto-unassigned) > Implement streaming window assigner tablefunction operator >

[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&focusedCommentId=17365845#comment-17365845 ] JING ZHANG commented on FLINK-22781: [~flink-jira-bot] I'm still working on this. [~

[GitHub] [flink] flinkbot edited a comment on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

flinkbot edited a comment on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-861345742 ## CI report: * 4c138e0498036924cada4f7cc5e9acd46d76000b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 41f6378376a0aecec273853b4aaeaf8d09ddeb59 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365856#comment-17365856 ] Cooper Luan commented on FLINK-22955: - it's ok to implement LookupFunction like Jdbc

[jira] [Comment Edited] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365856#comment-17365856 ] Cooper Luan edited comment on FLINK-22955 at 6/19/21, 6:30 AM: ---

[jira] [Comment Edited] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365856#comment-17365856 ] Cooper Luan edited comment on FLINK-22955 at 6/19/21, 6:31 AM: ---

[jira] [Comment Edited] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365856#comment-17365856 ] Cooper Luan edited comment on FLINK-22955 at 6/19/21, 6:33 AM: ---

[GitHub] [flink] dannycranmer commented on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

dannycranmer commented on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864364989 @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 spec

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 773bfcf7c143eea72b1c5284d6dd3dfe19c90c85 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

<    1   2   3   4