[jira] [Updated] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348

[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-24392: --- Description: The Presto s3 filesystem implementation currently shipped with Flink doesn't

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-925446816 Hi, @MartijnVisser @Airblader @twalthr @zhuzhurk @JingsongLi , I made some changes based on your suggestions. Could you help me to review it ? Thank you so much

[GitHub] [flink] flinkbot edited a comment on pull request #17379: Update kafka.md

flinkbot edited a comment on pull request #17379: URL: https://github.com/apache/flink/pull/17379#issuecomment-929802829 ## CI report: * af61c2cdd87041b08acd0d52ec63bf39b50bd89a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17379: Update kafka.md

flinkbot edited a comment on pull request #17379: URL: https://github.com/apache/flink/pull/17379#issuecomment-929802829 ## CI report: * af61c2cdd87041b08acd0d52ec63bf39b50bd89a Azure:

[jira] [Updated] (FLINK-24401) TM cannot exit after Metaspace OOM

[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] future updated FLINK-24401: --- Description: Hi masters, from the code and log, we can see that OOM will terminateJVM directly, but

[jira] [Updated] (FLINK-24401) TM cannot exit after Metaspace OOM

[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] future updated FLINK-24401: --- Attachment: image-2021-09-29-12-00-28-510.png > TM cannot exit after Metaspace OOM >

[jira] [Updated] (FLINK-24401) TM cannot exit after Metaspace OOM

[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] future updated FLINK-24401: --- Attachment: image-2021-09-29-12-00-44-812.png > TM cannot exit after Metaspace OOM >

[jira] [Updated] (FLINK-24401) TM cannot exit after Metaspace OOM

[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] future updated FLINK-24401: --- Attachment: (was: image-2021-09-29-11-47-47-157.png) > TM cannot exit after Metaspace OOM >

[jira] [Updated] (FLINK-24401) TM cannot exit after Metaspace OOM

[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] future updated FLINK-24401: --- Attachment: (was: image-2021-09-29-11-45-48-098.png) > TM cannot exit after Metaspace OOM >

[jira] [Commented] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest?

[ https://issues.apache.org/jira/browse/FLINK-24400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421917#comment-17421917 ] jacky jia commented on FLINK-24400: --- I have found the original pull request

[jira] [Created] (FLINK-24401) TM cannot exit after Metaspace OOM

future created FLINK-24401: -- Summary: TM cannot exit after Metaspace OOM Key: FLINK-24401 URL: https://issues.apache.org/jira/browse/FLINK-24401 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest?

[ https://issues.apache.org/jira/browse/FLINK-24400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jacky jia updated FLINK-24400: -- Priority: Minor (was: Not a Priority) > does elasticsearch connector can suport

[jira] [Updated] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest?

[ https://issues.apache.org/jira/browse/FLINK-24400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jacky jia updated FLINK-24400: -- Issue Type: Improvement (was: Technical Debt) > does elasticsearch connector can suport

[GitHub] [flink] flinkbot commented on pull request #17379: Update kafka.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed

flinkbot edited a comment on pull request #17370: URL: https://github.com/apache/flink/pull/17370#issuecomment-929030266 ## CI report: * dcd53f6a0fe2cb509e9593cdfc935d1945812d31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed

flinkbot edited a comment on pull request #17371: URL: https://github.com/apache/flink/pull/17371#issuecomment-929030407 ## CI report: * eb7ba466c81412f77297fd09956c4058b4ef2571 Azure:

[jira] [Commented] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest?

[ https://issues.apache.org/jira/browse/FLINK-24400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421913#comment-17421913 ] jacky jia commented on FLINK-24400: --- I think it is easy to support, but may be it has some unsafe

[jira] [Created] (FLINK-24400) does elasticsearch connector can suport UpdateByQueryRequest?

jacky jia created FLINK-24400: - Summary: does elasticsearch connector can suport UpdateByQueryRequest? Key: FLINK-24400 URL: https://issues.apache.org/jira/browse/FLINK-24400 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #17379: Update kafka.md

flinkbot commented on pull request #17379: URL: https://github.com/apache/flink/pull/17379#issuecomment-929793876 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] flinkbot edited a comment on pull request #17371: [BP-1.13][FLINK-24380][k8s] Terminate the pod if it failed

flinkbot edited a comment on pull request #17371: URL: https://github.com/apache/flink/pull/17371#issuecomment-929030407 ## CI report: * eb7ba466c81412f77297fd09956c4058b4ef2571 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17370: [BP-1.14][FLINK-24380][k8s] Terminate the pod if it failed

flinkbot edited a comment on pull request #17370: URL: https://github.com/apache/flink/pull/17370#issuecomment-929030266 ## CI report: * dcd53f6a0fe2cb509e9593cdfc935d1945812d31 Azure:

[GitHub] [flink] BradyYue opened a new pull request #17379: Update kafka.md

BradyYue opened a new pull request #17379: URL: https://github.com/apache/flink/pull/17379 java and scala exeample code :  WatermarkStrategy.forBoundedOutOfOrderness(Duration.ofSeconds(20)) More than is point ## What is the purpose of the change *(For example: This

[jira] [Commented] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421902#comment-17421902 ] Caizhi Weng commented on FLINK-20110: - Hi [~hailong wang] are you still working on this PR? If

[jira] [Updated] (FLINK-15130) Drop "RequiredParameters" and "Options"

[ https://issues.apache.org/jira/browse/FLINK-15130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15130: - Fix Version/s: (was: 1.14.0) 1.15.0 > Drop "RequiredParameters" and

[jira] [Updated] (FLINK-15351) develop PostgresCatalog to connect Flink with Postgres tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15351: - Fix Version/s: (was: 1.14.0) 1.15.0 > develop PostgresCatalog to connect

[jira] [Updated] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test

[ https://issues.apache.org/jira/browse/FLINK-15183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15183: - Fix Version/s: (was: 1.14.0) 1.15.0 > Use SQL-CLI to TPC-DS E2E test >

[jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking

[ https://issues.apache.org/jira/browse/FLINK-21799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21799: - Fix Version/s: (was: 1.14.0) 1.15.0 > Detect and fail explicitly on

[jira] [Updated] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used

[ https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22585: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add deprecated message when "-m

[jira] [Updated] (FLINK-20103) Improve test coverage with chaos testing & side-by-side tests

[ https://issues.apache.org/jira/browse/FLINK-20103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20103: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve test coverage with chaos

[jira] [Updated] (FLINK-24281) Migrate all existing tests to new Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-24281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24281: - Fix Version/s: (was: 1.14.1) 1.14.0 > Migrate all existing tests to new

[jira] [Updated] (FLINK-23607) Cleanup unnecessary dependencies in dstl pom.xml

[ https://issues.apache.org/jira/browse/FLINK-23607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23607: - Fix Version/s: (was: 1.14.1) 1.14.0 > Cleanup unnecessary dependencies

[jira] [Updated] (FLINK-21769) Encapsulate component meta data

[ https://issues.apache.org/jira/browse/FLINK-21769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21769: - Fix Version/s: (was: 1.14.0) 1.15.0 > Encapsulate component meta data >

[jira] [Updated] (FLINK-24315) Cannot rebuild watcher thread while the K8S API server is unavailable

[ https://issues.apache.org/jira/browse/FLINK-24315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24315: - Fix Version/s: (was: 1.14.0) 1.14.1 > Cannot rebuild watcher thread

[jira] [Updated] (FLINK-24353) Bash scripts do not respect dynamic configurations when calculating memory sizes

[ https://issues.apache.org/jira/browse/FLINK-24353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24353: - Fix Version/s: (was: 1.14.0) 1.14.1 > Bash scripts do not respect

[jira] [Updated] (FLINK-23798) Avoid using reflection to get filter when partition filter is enabled

[ https://issues.apache.org/jira/browse/FLINK-23798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23798: - Fix Version/s: (was: 1.14.0) 1.15.0 > Avoid using reflection to get

[jira] [Updated] (FLINK-24159) document of entropy injection may mislead users

[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24159: - Fix Version/s: (was: 1.14.1) 1.14.0 > document of entropy injection may

[jira] [Updated] (FLINK-24159) document of entropy injection may mislead users

[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24159: - Fix Version/s: (was: 1.14.0) 1.14.1 > document of entropy injection may

[GitHub] [flink] iyupeng commented on pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

iyupeng commented on pull request #17344: URL: https://github.com/apache/flink/pull/17344#issuecomment-929774236 @wuchong @godfreyhe Please take a look, thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-9407: Fix Version/s: (was: 1.14.0) 1.15.0 > Support orc rolling sink writer >

[jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode

[ https://issues.apache.org/jira/browse/FLINK-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13735: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support session window with blink

[jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14340: - Fix Version/s: (was: 1.14.0) 1.15.0 > Specify an unique DFSClient name

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

[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14032: - Fix Version/s: (was: 1.14.0) 1.15.0 > Make the cache size of

[jira] [Updated] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-11499: - Fix Version/s: (was: 1.14.0) 1.15.0 > Extend StreamingFileSink

[jira] [Updated] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12358: - Fix Version/s: (was: 1.14.0) 1.15.0 > Verify whether rest documenation

[jira] [Updated] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS

[ https://issues.apache.org/jira/browse/FLINK-12491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12491: - Fix Version/s: (was: 1.14.0) 1.15.0 > Incorrect documentation for

[jira] [Updated] (FLINK-13809) The log directory of Flink Python API is unwritable if it is installed via "sudo"

[ https://issues.apache.org/jira/browse/FLINK-13809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13809: - Fix Version/s: (was: 1.14.0) 1.15.0 > The log directory of Flink Python

[jira] [Updated] (FLINK-14684) Add Pinterest to Chinese Powered By page

[ https://issues.apache.org/jira/browse/FLINK-14684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14684: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add Pinterest to Chinese Powered

[jira] [Updated] (FLINK-14125) Display memory and CPU usage in the overview page

[ https://issues.apache.org/jira/browse/FLINK-14125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14125: - Fix Version/s: (was: 1.14.0) 1.15.0 > Display memory and CPU usage in

[jira] [Updated] (FLINK-12412) Allow ListTypeInfo used for java.util.List and MapTypeInfo used for java.util.Map

[ https://issues.apache.org/jira/browse/FLINK-12412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12412: - Fix Version/s: (was: 1.14.0) 1.15.0 > Allow ListTypeInfo used for

[jira] [Updated] (FLINK-14707) Refactor checkpoint related methods within Environment

[ https://issues.apache.org/jira/browse/FLINK-14707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14707: - Fix Version/s: (was: 1.14.0) 1.15.0 > Refactor checkpoint related

[jira] [Updated] (FLINK-14690) Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL Client

[ https://issues.apache.org/jira/browse/FLINK-14690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14690: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support 'DESCRIBE CATALOG

[jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13015: - Fix Version/s: (was: 1.14.0) 1.15.0 > Create validators, strategies and

[jira] [Updated] (FLINK-14479) Strange exceptions found in log file after executing `test_udf.py`

[ https://issues.apache.org/jira/browse/FLINK-14479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14479: - Fix Version/s: (was: 1.14.0) 1.15.0 > Strange exceptions found in log

[jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters

[ https://issues.apache.org/jira/browse/FLINK-9879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-9879: Fix Version/s: (was: 1.14.0) 1.15.0 > Find sane defaults for (advanced) SSL

[jira] [Updated] (FLINK-14934) Remove error log statement in ES connector

[ https://issues.apache.org/jira/browse/FLINK-14934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14934: - Fix Version/s: (was: 1.14.0) 1.15.0 > Remove error log statement in ES

[jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client

[ https://issues.apache.org/jira/browse/FLINK-14879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14879: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support 'DESCRIBE DATABSE

[jira] [Updated] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-10230: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support 'SHOW CREATE VIEW' syntax

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15471: - Fix Version/s: (was: 1.14.0) 1.15.0 > HA e2e check for empty .out files

[jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft()

[ https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15740: - Fix Version/s: (was: 1.14.0) 1.15.0 > Remove Deadline#timeLeft() >

[jira] [Updated] (FLINK-15922) Show "Warn - received late message for checkpoint" only when checkpoint actually expired

[ https://issues.apache.org/jira/browse/FLINK-15922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15922: - Fix Version/s: (was: 1.14.0) 1.15.0 > Show "Warn - received late message

[jira] [Updated] (FLINK-15018) Add event time page to Concepts

[ https://issues.apache.org/jira/browse/FLINK-15018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15018: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add event time page to Concepts >

[jira] [Updated] (FLINK-17372) SlotManager should expose total required resources

[ https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17372: - Fix Version/s: (was: 1.14.0) 1.15.0 > SlotManager should expose total

[jira] [Updated] (FLINK-15859) Unify identifiers in the interface methods of CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-15859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15859: - Fix Version/s: (was: 1.14.0) 1.15.0 > Unify identifiers in the interface

[jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16023: - Fix Version/s: (was: 1.14.0) 1.15.0 > jdbc connector's 'connector.table'

[jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure.

[ https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12273: - Fix Version/s: (was: 1.14.0) 1.15.0 > The default value of

[jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column

[ https://issues.apache.org/jira/browse/FLINK-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15553: - Fix Version/s: (was: 1.14.0) 1.15.0 > Create table ddl support comment

[jira] [Updated] (FLINK-15585) Improve function identifier string in plan digest

[ https://issues.apache.org/jira/browse/FLINK-15585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15585: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve function identifier string

[jira] [Updated] (FLINK-13698) Rework threading model of CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-13698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13698: - Fix Version/s: (was: 1.14.0) 1.15.0 > Rework threading model of

[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 ] Xintong Song updated FLINK-11868: - Fix Version/s: (was: 1.14.0) 1.15.0 > [filesystems] Introduce

[jira] [Updated] (FLINK-16701) Elasticsearch sink support alias for indices.

[ https://issues.apache.org/jira/browse/FLINK-16701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16701: - Fix Version/s: (was: 1.14.0) 1.15.0 > Elasticsearch sink support alias

[jira] [Updated] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16027: - Fix Version/s: (was: 1.14.0) 1.15.0 > kafka connector's

[jira] [Updated] (FLINK-15973) Optimize the execution plan where it refers the Python UDF result field in the where clause

[ https://issues.apache.org/jira/browse/FLINK-15973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15973: - Fix Version/s: (was: 1.14.0) 1.15.0 > Optimize the execution plan where

[jira] [Updated] (FLINK-15860) Store temporary functions as CatalogFunctions in FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-15860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15860: - Fix Version/s: (was: 1.14.0) 1.15.0 > Store temporary functions as

[jira] [Updated] (FLINK-14379) Supplement documentation about raw state

[ https://issues.apache.org/jira/browse/FLINK-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14379: - Fix Version/s: (was: 1.14.0) 1.15.0 > Supplement documentation about raw

[jira] [Updated] (FLINK-12590) Replace http links in documentation

[ https://issues.apache.org/jira/browse/FLINK-12590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12590: - Fix Version/s: (was: 1.14.0) 1.15.0 > Replace http links in

[jira] [Updated] (FLINK-17784) Better detection for parquet and orc in hive

[ https://issues.apache.org/jira/browse/FLINK-17784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17784: - Fix Version/s: (was: 1.14.0) 1.15.0 > Better detection for parquet and

[jira] [Updated] (FLINK-16024) support filter pushdown in jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16024: - Fix Version/s: (was: 1.14.0) 1.15.0 > support filter pushdown in jdbc

[jira] [Updated] (FLINK-13876) Remove ExecutionConfig field from PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-13876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13876: - Fix Version/s: (was: 1.14.0) 1.15.0 > Remove ExecutionConfig field from

[jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14500: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support Flink Python User-Defined

[jira] [Updated] (FLINK-15003) Improve hive test performance

[ https://issues.apache.org/jira/browse/FLINK-15003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15003: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve hive test performance >

[jira] [Updated] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector

[ https://issues.apache.org/jira/browse/FLINK-17589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17589: - Fix Version/s: (was: 1.14.0) 1.15.0 > Extend StreamingFileSink to

[jira] [Updated] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode

[ https://issues.apache.org/jira/browse/FLINK-16531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16531: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add full integration tests for

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

[ https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15378: - Fix Version/s: (was: 1.14.0) 1.15.0 > StreamFileSystemSink supported

[jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm

[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16548: - Fix Version/s: (was: 1.14.0) 1.15.0 > Expose consistent environment

[jira] [Updated] (FLINK-16323) Support to join a static table in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-16323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16323: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support to join a static table in

[jira] [Updated] (FLINK-15000) WebUI Metrics is very slow in large parallelism

[ https://issues.apache.org/jira/browse/FLINK-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15000: - Fix Version/s: (was: 1.14.0) 1.15.0 > WebUI Metrics is very slow in

[jira] [Updated] (FLINK-15460) planner dependencies won't be necessary for JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15460: - Fix Version/s: (was: 1.14.0) 1.15.0 > planner dependencies won't be

[jira] [Updated] (FLINK-14867) Move TextInputFormat & TextOutputFormat to flink-core

[ https://issues.apache.org/jira/browse/FLINK-14867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14867: - Fix Version/s: (was: 1.14.0) 1.15.0 > Move TextInputFormat &

[jira] [Updated] (FLINK-16775) expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system

[ https://issues.apache.org/jira/browse/FLINK-16775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16775: - Fix Version/s: (was: 1.14.0) 1.15.0 > expose

[jira] [Updated] (FLINK-15012) Checkpoint directory not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15012: - Fix Version/s: (was: 1.14.0) 1.15.0 > Checkpoint directory not cleaned

[jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI

[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16609: - Fix Version/s: (was: 1.14.0) 1.15.0 > Promotes the column name

[jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status

[ https://issues.apache.org/jira/browse/FLINK-17362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17362: - Fix Version/s: (was: 1.14.0) 1.15.0 > Improve table examples to reflect

[jira] [Updated] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing

[ https://issues.apache.org/jira/browse/FLINK-17011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17011: - Fix Version/s: (was: 1.14.0) 1.15.0 > Introduce builder to create

[jira] [Updated] (FLINK-15845) Add java-based StreamingFileSink test using s3

[ https://issues.apache.org/jira/browse/FLINK-15845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15845: - Fix Version/s: (was: 1.14.0) 1.15.0 > Add java-based StreamingFileSink

[jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16774: - Fix Version/s: (was: 1.14.0) 1.15.0 > expose HBaseUpsertSinkFunction

[jira] [Updated] (FLINK-16799) add hive partition limit when read from hive

[ https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16799: - Fix Version/s: (was: 1.14.0) 1.15.0 > add hive partition limit when read

[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden

[ https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17642: - Fix Version/s: (was: 1.14.0) 1.15.0 > Exception while reading broken ORC

[jira] [Updated] (FLINK-17755) Support side-output of expiring states with TTL.

[ https://issues.apache.org/jira/browse/FLINK-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17755: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support side-output of expiring

[jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16762: - Fix Version/s: (was: 1.14.0) 1.15.0 > Relocation Beam dependency of

[jira] [Updated] (FLINK-16952) Parquet file system format support filter pushdown

[ https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16952: - Fix Version/s: (was: 1.14.0) 1.15.0 > Parquet file system format

  1   2   3   4   5   6   7   8   9   >