[jira] [Closed] (FLINK-25375) Update Log4j to 2.17.0

[ https://issues.apache.org/jira/browse/FLINK-25375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf closed FLINK-25375. > Update Log4j to 2.17.0 > -- > > Key: FLINK-25375 >

[jira] [Commented] (FLINK-25375) Update Log4j to 2.17.0

[ https://issues.apache.org/jira/browse/FLINK-25375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465307#comment-17465307 ] Konstantin Knauf commented on FLINK-25375: -- release-1.14: 49971b8a527b81b5e0016

[jira] [Resolved] (FLINK-25375) Update Log4j to 2.17.0

[ https://issues.apache.org/jira/browse/FLINK-25375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf resolved FLINK-25375. -- Resolution: Fixed > Update Log4j to 2.17.0 > -- > >

[GitHub] [flink] knaufk merged pull request #18167: [FLINK-25375] [BP-1.14] Update log4j2 dependency to 2.17.0 to address

knaufk merged pull request #18167: URL: https://github.com/apache/flink/pull/18167 -- 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: issues-unsubscr

[GitHub] [flink] knaufk merged pull request #18166: [FLINK-25375] [BP-1.12] Update log4j2 dependency to 2.17.0 to address

knaufk merged pull request #18166: URL: https://github.com/apache/flink/pull/18166 -- 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: issues-unsubscr

[GitHub] [flink] knaufk merged pull request #18168: [FLINK-25375] [BP-1.13] Update log4j2 dependency to 2.17.0 to address

knaufk merged pull request #18168: URL: https://github.com/apache/flink/pull/18168 -- 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: issues-unsubscr

[jira] [Commented] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465294#comment-17465294 ] Yuan Mei commented on FLINK-25423: -- Thanks Seth! > Enable loading state backend via co

[jira] [Updated] (FLINK-5865) Throw original exception in states

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

[jira] [Updated] (FLINK-5914) remove aggregateResultType from streaming.api.datastream.aggregate

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

[jira] [Updated] (FLINK-5230) Safety nets against leaving dysfunctional JobManagers

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

[jira] [Updated] (FLINK-5944) Flink should support reading Snappy Files

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

[jira] [Updated] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

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

[jira] [Updated] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality

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

[jira] [Updated] (FLINK-11209) Provide more complete guidance for the log usage documentation

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

[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-deprioritized-minor auto-unassigned (was: auto-depr

[jira] [Updated] (FLINK-11184) Rework TableSource and TableSink interfaces

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

[jira] [Updated] (FLINK-5319) ClassCastException when reusing an inherited method reference as KeySelector for different classes

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

[jira] [Updated] (FLINK-11157) Web UI should show timestamps relative to server time zone

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

[jira] [Updated] (FLINK-5178) allow BlobCache to use a distributed file system irrespective of the HA mode

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

[jira] [Updated] (FLINK-5284) Make output of bucketing sink compatible with other processing framework like mapreduce

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

[jira] [Updated] (FLINK-11221) Support delimited identifiers in TableAPI

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

[jira] [Updated] (FLINK-6027) Ignore the exception thrown by the subsuming of old completed checkpoints

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

[jira] [Updated] (FLINK-5735) Non-overlapping sliding window is not deterministic

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

[jira] [Updated] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

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

[jira] [Updated] (FLINK-11172) Remove the max retention time in StreamQueryConfig

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

[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-deprioritized-minor auto-unassigned pull-request-ava

[jira] [Updated] (FLINK-11276) Sliding Window Optimization

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

[jira] [Updated] (FLINK-11258) Add badge to the README

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

[jira] [Created] (FLINK-25443) Embedded statefulfunction jakson /java8 date time issue

Ashok created FLINK-25443: - Summary: Embedded statefulfunction jakson /java8 date time issue Key: FLINK-25443 URL: https://issues.apache.org/jira/browse/FLINK-25443 Project: Flink Issue Type: Bug

[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-deprioritized-minor auto-unassigned pull-request-ava

[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: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[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-deprioritized-minor auto-unassigned (was: auto-depr

[jira] [Updated] (FLINK-6081) Offset/Fetch support for SQL Streaming

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

[jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

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

[jira] [Updated] (FLINK-24349) Support customized Calalogs via JDBC

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

[jira] [Updated] (FLINK-6131) Add side inputs for DataStream API

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

[jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream

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

[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-deprioritized-minor auto-unassigned pull-request-ava

[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-deprioritized-minor auto-unassigned pull-request-ava

[jira] [Updated] (FLINK-6166) Broken quickstart for snapshots

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

[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-deprioritized-minor auto-unassigned (was: auto-depr

[jira] [Updated] (FLINK-11425) Support of “Hash Teams” in Hybrid Hash Join

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

[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-deprioritized-major auto-unassigned pull-request-available stale-minor (was: a

[jira] [Updated] (FLINK-19380) Add support for a gRPC transport for the RequestReply protocol.

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

[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: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[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 auto-deprioritized-minor (was: auto-deprioritized-major

[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-deprioritized-major auto-unassigned stale-minor usability (was: auto-depriorit

[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-deprioritized-minor auto-unassigned pull-request-ava

[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-deprioritized-major auto-unassigned stale-minor (was: auto-deprioritized-major

[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-deprioritized-major auto-unassigned stale-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-11454) Support MergedStream operation

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

[jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system

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

[jira] [Updated] (FLINK-21117) KafkaProducerExactlyOnceITCase fails with "Exceeded checkpoint tolerable failure threshold."

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