[jira] [Commented] (FLINK-32783) Release Testing: Improve parallel download of RocksDB incremental state

[ https://issues.apache.org/jira/browse/FLINK-32783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761982#comment-17761982 ] Konstantin Knauf commented on FLINK-32783: -- I don't think we need to test it af

[jira] [Commented] (FLINK-32782) Release Testing: Disable WAL in RocksDBWriteBatchWrapper by default

[ https://issues.apache.org/jira/browse/FLINK-32782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761981#comment-17761981 ] Konstantin Knauf commented on FLINK-32782: -- I don't think we need to test it af

[jira] [Commented] (FLINK-21450) Add local recovery support to adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751793#comment-17751793 ] Konstantin Knauf commented on FLINK-21450: -- [~roman] I think, we still need to

[jira] [Commented] (FLINK-15736) Support Java 17 (LTS)

[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749535#comment-17749535 ] Konstantin Knauf commented on FLINK-15736: -- How do users usually learn about su

[jira] [Assigned] (FLINK-32706) Add SPLIT(STRING) support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-32706: Assignee: Hanyu Zheng > Add SPLIT(STRING) support in SQL & Table API > --

[jira] [Commented] (FLINK-28045) [umbrella] Deprecate SourceFunction API

[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747334#comment-17747334 ] Konstantin Knauf commented on FLINK-28045: -- [~airblader] What we still need to

[jira] [Commented] (FLINK-32402) FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747331#comment-17747331 ] Konstantin Knauf commented on FLINK-32402: -- [~zjureel] Great. There is a PR tha

[jira] [Commented] (FLINK-31634) FLIP-301: Hybrid Shuffle supports Remote Storage

[ https://issues.apache.org/jira/browse/FLINK-31634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747330#comment-17747330 ] Konstantin Knauf commented on FLINK-31634: -- Thanks, [~tanyuxin]. > FLIP-301: H

[jira] [Assigned] (FLINK-31889) Add documentation for implementing/loading enrichers

[ https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-31889: Assignee: Konstantin Knauf (was: Panagiotis Garefalakis) > Add documentation for

[jira] [Assigned] (FLINK-31889) Add documentation for implementing/loading enrichers

[ https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-31889: Assignee: Panagiotis Garefalakis (was: Konstantin Knauf) > Add documentation for

[jira] [Assigned] (FLINK-31889) Add documentation for implementing/loading enrichers

[ https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-31889: Assignee: Panagiotis Garefalakis > Add documentation for implementing/loading enr

[jira] [Commented] (FLINK-15736) Support Java 17 (LTS)

[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746950#comment-17746950 ] Konstantin Knauf commented on FLINK-15736: -- [~chesnay]Do we need any user-facin

[jira] [Updated] (FLINK-29344) Make Adaptive Scheduler supports Fine-Grained Resource Management

[ https://issues.apache.org/jira/browse/FLINK-29344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-29344: - Fix Version/s: (was: 1.18.0) > Make Adaptive Scheduler supports Fine-Grained Resourc

[jira] [Commented] (FLINK-29344) Make Adaptive Scheduler supports Fine-Grained Resource Management

[ https://issues.apache.org/jira/browse/FLINK-29344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746947#comment-17746947 ] Konstantin Knauf commented on FLINK-29344: -- Since the feature freeze has passed

[jira] [Created] (FLINK-32671) Document Externalized Declarative Resource Management

Konstantin Knauf created FLINK-32671: Summary: Document Externalized Declarative Resource Management Key: FLINK-32671 URL: https://issues.apache.org/jira/browse/FLINK-32671 Project: Flink

[jira] [Assigned] (FLINK-31316) FLIP-291: Externalized Declarative Resource Management

[ https://issues.apache.org/jira/browse/FLINK-31316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-31316: Assignee: David Morávek (was: Konstantin Knauf) > FLIP-291: Externalized Declara

[jira] [Assigned] (FLINK-31316) FLIP-291: Externalized Declarative Resource Management

[ https://issues.apache.org/jira/browse/FLINK-31316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-31316: Assignee: Konstantin Knauf (was: David Morávek) > FLIP-291: Externalized Declara

[jira] [Commented] (FLINK-32486) FLIP-324: Introduce Runtime Filter for Flink Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-32486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746942#comment-17746942 ] Konstantin Knauf commented on FLINK-32486: -- [~wanglijie] Tan Is there user faci

[jira] [Commented] (FLINK-32548) Make watermark alignment ready for production use

[ https://issues.apache.org/jira/browse/FLINK-32548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746938#comment-17746938 ] Konstantin Knauf commented on FLINK-32548: -- [~fanrui] In the documentation (ht

[jira] [Commented] (FLINK-31634) FLIP-301: Hybrid Shuffle supports Remote Storage

[ https://issues.apache.org/jira/browse/FLINK-31634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746941#comment-17746941 ] Konstantin Knauf commented on FLINK-31634: -- [~tanyuxin] Is there user facing do

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746936#comment-17746936 ] Konstantin Knauf commented on FLINK-31275: -- I will mark this as "Not finished"

[jira] [Commented] (FLINK-32402) FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746935#comment-17746935 ] Konstantin Knauf commented on FLINK-32402: -- [~zjureel]Does this feature require

[jira] [Commented] (FLINK-32427) FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

[ https://issues.apache.org/jira/browse/FLINK-32427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746934#comment-17746934 ] Konstantin Knauf commented on FLINK-32427: -- What is the status of this feature

[jira] [Updated] (FLINK-32472) FLIP-308: Support Time Travel

[ https://issues.apache.org/jira/browse/FLINK-32472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-32472: - Fix Version/s: 1.18.0 > FLIP-308: Support Time Travel > - >

[jira] [Commented] (FLINK-32472) FLIP-308: Support Time Travel

[ https://issues.apache.org/jira/browse/FLINK-32472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746927#comment-17746927 ] Konstantin Knauf commented on FLINK-32472: -- [~hackergin] I will mark this featu

[jira] [Commented] (FLINK-32515) FLIP-303: Support REPLACE TABLE AS SELECT statement

[ https://issues.apache.org/jira/browse/FLINK-32515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746925#comment-17746925 ] Konstantin Knauf commented on FLINK-32515: -- [~luoyuxia] I will mark this featur

[jira] [Updated] (FLINK-32515) FLIP-303: Support REPLACE TABLE AS SELECT statement

[ https://issues.apache.org/jira/browse/FLINK-32515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-32515: - Fix Version/s: 1.18.0 > FLIP-303: Support REPLACE TABLE AS SELECT statement > --

[jira] [Commented] (FLINK-31487) Add targetColumns to DynamicTableSink#Context

[ https://issues.apache.org/jira/browse/FLINK-31487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746922#comment-17746922 ] Konstantin Knauf commented on FLINK-31487: -- [~lincoln.86xy] Is this feature alr

[jira] [Commented] (FLINK-31833) Support fusion codegen for multiple operators

[ https://issues.apache.org/jira/browse/FLINK-31833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746921#comment-17746921 ] Konstantin Knauf commented on FLINK-31833: -- [~lsy] Does this feature provide a

[jira] [Updated] (FLINK-26372) Allow to configure Changelog Storage per program

[ https://issues.apache.org/jira/browse/FLINK-26372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26372: - Fix Version/s: (was: 1.18.0) > Allow to configure Changelog Storage per program > --

[jira] [Commented] (FLINK-26372) Allow to configure Changelog Storage per program

[ https://issues.apache.org/jira/browse/FLINK-26372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746920#comment-17746920 ] Konstantin Knauf commented on FLINK-26372: -- I will mark this as "Not finished"

[jira] [Commented] (FLINK-30235) Comprehensive benchmarks on changelog checkpointing

[ https://issues.apache.org/jira/browse/FLINK-30235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746918#comment-17746918 ] Konstantin Knauf commented on FLINK-30235: -- I will mark this as "Not finished"

[jira] [Updated] (FLINK-29844) FLIP-263: Improve resolving schema compatibility

[ https://issues.apache.org/jira/browse/FLINK-29844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-29844: - Fix Version/s: (was: 1.18.0) > FLIP-263: Improve resolving schema compatibility > --

[jira] [Commented] (FLINK-29844) FLIP-263: Improve resolving schema compatibility

[ https://issues.apache.org/jira/browse/FLINK-29844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746917#comment-17746917 ] Konstantin Knauf commented on FLINK-29844: -- I will mark this as "Not finished"

[jira] [Commented] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746916#comment-17746916 ] Konstantin Knauf commented on FLINK-32070: -- I will mark this as Won't Do in Fli

[jira] [Updated] (FLINK-32070) FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-32070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-32070: - Fix Version/s: (was: 1.18.0) > FLIP-306 Unified File Merging Mechanism for Checkpoin

[jira] [Assigned] (FLINK-29344) Make Adaptive Scheduler supports Fine-Grained Resource Management

[ https://issues.apache.org/jira/browse/FLINK-29344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-29344: Assignee: Chesnay Schepler > Make Adaptive Scheduler supports Fine-Grained Resour

[jira] [Created] (FLINK-32468) Replace Akka by Pekko

Konstantin Knauf created FLINK-32468: Summary: Replace Akka by Pekko Key: FLINK-32468 URL: https://issues.apache.org/jira/browse/FLINK-32468 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-29281) Replace Akka by gRPC-based RPC implementation

[ https://issues.apache.org/jira/browse/FLINK-29281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-29281: - Summary: Replace Akka by gRPC-based RPC implementation (was: Replace Akka) > Replace Ak

[jira] [Commented] (FLINK-31609) Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail

[ https://issues.apache.org/jira/browse/FLINK-31609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713474#comment-17713474 ] Konstantin Knauf commented on FLINK-31609: -- [~ferenc-csaky] Hi Ferenc, do you o

[jira] [Created] (FLINK-30116) Don't Show Env Vars in Web UI

Konstantin Knauf created FLINK-30116: Summary: Don't Show Env Vars in Web UI Key: FLINK-30116 URL: https://issues.apache.org/jira/browse/FLINK-30116 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-29850) Flink Table Store quick start guide does not work

[ https://issues.apache.org/jira/browse/FLINK-29850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627911#comment-17627911 ] Konstantin Knauf commented on FLINK-29850: -- I can reproduce this. > Flink Tabl

[jira] [Commented] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624685#comment-17624685 ] Konstantin Knauf commented on FLINK-16073: -- [~fuping.wang] Done > Translate "S

[jira] [Assigned] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-16073: Assignee: fuping.wang > Translate "State & Fault Tolerance" pages into Chinese >

[jira] [Commented] (FLINK-27748) AdaptiveScheduler should support operator fixed parallelism

[ https://issues.apache.org/jira/browse/FLINK-27748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17599355#comment-17599355 ] Konstantin Knauf commented on FLINK-27748: -- [~long jiang] Better late than neve

[jira] [Commented] (FLINK-19589) Support per-connector FileSystem configuration

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579681#comment-17579681 ] Konstantin Knauf commented on FLINK-19589: -- In terms of the scope of this ticke

[jira] [Commented] (FLINK-28045) [umbrella] Deprecate SourceFunction API

[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1761#comment-1761 ] Konstantin Knauf commented on FLINK-28045: -- Are all of these subtasks considere

[jira] [Commented] (FLINK-28051) Introduce stable Source API alternative to ExternallyInducedSource

[ https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1759#comment-1759 ] Konstantin Knauf commented on FLINK-28051: -- Is it confirmed an alternative is n

[jira] [Commented] (FLINK-27748) AdaptiveScheduler should support operator fixed parallelism

[ https://issues.apache.org/jira/browse/FLINK-27748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543896#comment-17543896 ] Konstantin Knauf commented on FLINK-27748: -- IIRC the adaptive scheduler (or at

[jira] [Comment Edited] (FLINK-26281) Test Elasticsearch connector End2End

[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510356#comment-17510356 ] Konstantin Knauf edited comment on FLINK-26281 at 3/22/22, 9:20 AM: --

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510356#comment-17510356 ] Konstantin Knauf commented on FLINK-26281: -- I've done a couple of tests with ES

[jira] [Commented] (FLINK-26759) Legacy source support waiting for recordWriter to be available

[ https://issues.apache.org/jira/browse/FLINK-26759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510328#comment-17510328 ] Konstantin Knauf commented on FLINK-26759: -- I am very much with [~martijnvisser

[jira] [Updated] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15550: - Fix Version/s: 1.14.5 (was: 1.14.3) > testCancelTaskExceptionAfte

[jira] [Updated] (FLINK-26049) The tolerable-failed-checkpoints logic is invalid when checkpoint trigger failed

[ https://issues.apache.org/jira/browse/FLINK-26049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26049: - Fix Version/s: 1.14.5 (was: 1.14.4) > The tolerable-failed-checkp

[jira] [Updated] (FLINK-26223) Making ZK-related logs available in tests

[ https://issues.apache.org/jira/browse/FLINK-26223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26223: - Fix Version/s: 1.14.5 (was: 1.14.4) > Making ZK-related logs avai

[jira] [Updated] (FLINK-26285) ZooKeeperStateHandleStore does not handle not existing nodes properly in getAllAndLock

[ https://issues.apache.org/jira/browse/FLINK-26285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26285: - Fix Version/s: 1.14.5 (was: 1.14.4) > ZooKeeperStateHandleStore d

[jira] [Updated] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-23944: - Fix Version/s: 1.14.5 (was: 1.14.4) > PulsarSourceITCase.testTask

[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26524: - Fix Version/s: 1.14.5 (was: 1.14.4) > Elasticsearch (v5.3.3) sink

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501330#comment-17501330 ] Konstantin Knauf commented on FLINK-26281: -- [~alexanderpreuss] Is it important

[jira] [Updated] (FLINK-25682) Check in script to verify cheksums and signatures for Apache Flink Releases

[ https://issues.apache.org/jira/browse/FLINK-25682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25682: - Description: For each flink, flink-shaded and flink-ml release, multiple community memeb

[jira] [Comment Edited] (FLINK-26273) Test checkpoints restore modes & formats

[ https://issues.apache.org/jira/browse/FLINK-26273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497438#comment-17497438 ] Konstantin Knauf edited comment on FLINK-26273 at 3/2/22, 12:45 PM: --

[jira] [Resolved] (FLINK-26273) Test checkpoints restore modes & formats

[ https://issues.apache.org/jira/browse/FLINK-26273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf resolved FLINK-26273. -- Resolution: Done > Test checkpoints restore modes & formats >

[jira] [Created] (FLINK-26446) Update Feature Radar in Apache Flink Roadmap

Konstantin Knauf created FLINK-26446: Summary: Update Feature Radar in Apache Flink Roadmap Key: FLINK-26446 URL: https://issues.apache.org/jira/browse/FLINK-26446 Project: Flink Issue T

[jira] [Updated] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name

[ https://issues.apache.org/jira/browse/FLINK-24376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24376: - Fix Version/s: (was: 1.14.4) > Operator name in OperatorCoordinator should not use c

[jira] [Updated] (FLINK-24735) SQL client crashes with `Cannot add expression of different type to set`

[ https://issues.apache.org/jira/browse/FLINK-24735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24735: - Fix Version/s: (was: 1.14.4) > SQL client crashes with `Cannot add expression of dif

[jira] [Updated] (FLINK-25227) Comparing the equality of the same (boxed) numeric values returns false

[ https://issues.apache.org/jira/browse/FLINK-25227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25227: - Fix Version/s: (was: 1.14.4) > Comparing the equality of the same (boxed) numeric va

[jira] [Updated] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured

[ https://issues.apache.org/jira/browse/FLINK-23955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-23955: - Fix Version/s: (was: 1.14.4) > submit flink sql job error when flink HA on yarn is c

[jira] [Updated] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25444: - Fix Version/s: (was: 1.14.4) > ClosureCleaner rejects ExecutionConfig as not be Seri

[jira] [Updated] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25771: - Fix Version/s: (was: 1.14.4) > CassandraConnectorITCase.testRetrialAndDropTables tim

[jira] [Updated] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26018: - Fix Version/s: (was: 1.14.4) > Unnecessary late events when using the new KafkaSourc

[jira] [Updated] (FLINK-21302) Fix NPE when use row_number() in over agg

[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21302: - Fix Version/s: (was: 1.14.4) > Fix NPE when use row_number() in over agg > -

[jira] [Updated] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24491: - Fix Version/s: (was: 1.14.4) > ExecutionGraphInfo may not be archived when the dispa

[jira] [Updated] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

[ https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24483: - Fix Version/s: (was: 1.14.4) > Document what is Public API and what compatibility gu

[jira] [Commented] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497959#comment-17497959 ] Konstantin Knauf commented on FLINK-26354: -- >From my perspective consistency wi

[jira] [Commented] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

[ https://issues.apache.org/jira/browse/FLINK-26354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497509#comment-17497509 ] Konstantin Knauf commented on FLINK-26354: -- In the discussion linked I don't un

[jira] [Comment Edited] (FLINK-26273) Test checkpoints restore modes & formats

[ https://issues.apache.org/jira/browse/FLINK-26273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497438#comment-17497438 ] Konstantin Knauf edited comment on FLINK-26273 at 2/24/22, 2:38 PM: --

[jira] [Commented] (FLINK-26273) Test checkpoints restore modes & formats

[ https://issues.apache.org/jira/browse/FLINK-26273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497438#comment-17497438 ] Konstantin Knauf commented on FLINK-26273: -- [~dwysakowicz] Looks very good. Her

[jira] [Comment Edited] (FLINK-26273) Test checkpoints restore modes & formats

[ https://issues.apache.org/jira/browse/FLINK-26273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497438#comment-17497438 ] Konstantin Knauf edited comment on FLINK-26273 at 2/24/22, 2:37 PM: --

[jira] [Commented] (FLINK-26254) KafkaSink might violate order of sequence numbers and risk exactly-once processing

[ https://issues.apache.org/jira/browse/FLINK-26254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497409#comment-17497409 ] Konstantin Knauf commented on FLINK-26254: -- Important: this only happened with

[jira] [Created] (FLINK-26354) "-restoreMode" should be "--restoreMode" and should have a shorthand

Konstantin Knauf created FLINK-26354: Summary: "-restoreMode" should be "--restoreMode" and should have a shorthand Key: FLINK-26354 URL: https://issues.apache.org/jira/browse/FLINK-26354 Project:

[jira] [Created] (FLINK-26353) "flink stop --help" does not list "--type" option

Konstantin Knauf created FLINK-26353: Summary: "flink stop --help" does not list "--type" option Key: FLINK-26353 URL: https://issues.apache.org/jira/browse/FLINK-26353 Project: Flink Is

[jira] [Closed] (FLINK-21884) Reduce TaskManager failure detection time

[ https://issues.apache.org/jira/browse/FLINK-21884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf closed FLINK-21884. Resolution: Fixed Solved in https://issues.apache.org/jira/browse/FLINK-25277.  > Reduce

[jira] [Updated] (FLINK-24607) SourceCoordinator may miss to close SplitEnumerator when failover frequently

[ https://issues.apache.org/jira/browse/FLINK-24607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24607: - Component/s: Connectors / Common > SourceCoordinator may miss to close SplitEnumerator w

[jira] [Updated] (FLINK-24607) SourceCoordinator may miss to close SplitEnumerator when failover frequently

[ https://issues.apache.org/jira/browse/FLINK-24607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24607: - Component/s: (was: Runtime / Coordination) > SourceCoordinator may miss to close Spl

[jira] [Updated] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-23843: - Component/s: Connectors / Common (was: Runtime / Coordination) > Ex

[jira] [Assigned] (FLINK-26281) Test Elasticsearch connector End2End

[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-26281: Assignee: Konstantin Knauf > Test Elasticsearch connector End2End > -

[jira] [Assigned] (FLINK-26273) Test checkpoints restore modes & formats

[ https://issues.apache.org/jira/browse/FLINK-26273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-26273: Assignee: Konstantin Knauf > Test checkpoints restore modes & formats > -

[jira] [Commented] (FLINK-26254) KafkaSink might violate order of sequence numbers and risk exactly-once processing

[ https://issues.apache.org/jira/browse/FLINK-26254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494641#comment-17494641 ] Konstantin Knauf commented on FLINK-26254: -- This also happens with a higher che

[jira] [Updated] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26018: - Fix Version/s: (was: 1.15.0) > Unnecessary late events when using the new KafkaSourc

[jira] [Updated] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26018: - Fix Version/s: 1.15.0 > Unnecessary late events when using the new KafkaSource > ---

[jira] [Updated] (FLINK-26018) Unnecessary late events when using the new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26018: - Fix Version/s: 1.15.0 1.14.4 > Unnecessary late events when using the

[jira] [Updated] (FLINK-25883) The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large

[ https://issues.apache.org/jira/browse/FLINK-25883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25883: - Fix Version/s: 1.13.7 (was: 1.13.6) > The value of DEFAULT_BUNDLE

[jira] [Updated] (FLINK-25785) Update com.h2database:h2 to 2.0.210

[ https://issues.apache.org/jira/browse/FLINK-25785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25785: - Fix Version/s: 1.13.7 (was: 1.13.6) > Update com.h2database:h2 to

[jira] [Updated] (FLINK-26039) Incorrect value getter in map unnest table function

[ https://issues.apache.org/jira/browse/FLINK-26039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26039: - Fix Version/s: 1.13.7 (was: 1.13.6) > Incorrect value getter in m

[jira] [Updated] (FLINK-24607) SourceCoordinator may miss to close SplitEnumerator when failover frequently

[ https://issues.apache.org/jira/browse/FLINK-24607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24607: - Fix Version/s: 1.13.7 (was: 1.13.6) > SourceCoordinator may miss

[jira] [Updated] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25771: - Fix Version/s: 1.13.7 (was: 1.13.6) > CassandraConnectorITCase.te

[jira] [Resolved] (FLINK-25532) Provide Flink SQL CLI as Docker image

[ https://issues.apache.org/jira/browse/FLINK-25532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf resolved FLINK-25532. -- Resolution: Fixed Fixed via Documentation. > Provide Flink SQL CLI as Docker image >

[jira] [Updated] (FLINK-25532) Provide Flink SQL CLI as Docker image

[ https://issues.apache.org/jira/browse/FLINK-25532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25532: - Fix Version/s: 1.15.0 > Provide Flink SQL CLI as Docker image >

[jira] [Assigned] (FLINK-25532) Provide Flink SQL CLI as Docker image

[ https://issues.apache.org/jira/browse/FLINK-25532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-25532: Assignee: Konstantin Knauf > Provide Flink SQL CLI as Docker image >

[jira] [Commented] (FLINK-25532) Provide Flink SQL CLI as Docker image

[ https://issues.apache.org/jira/browse/FLINK-25532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490816#comment-17490816 ] Konstantin Knauf commented on FLINK-25532: -- I overlooked the passthrough comman

  1   2   3   4   5   6   7   8   9   10   >