[GitHub] [flink] twalthr closed pull request #14309: [FLINK-20485][table] Improve performance of data views

twalthr closed pull request #14309: URL: https://github.com/apache/flink/pull/14309 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot commented on pull request #14328: [FLINK-19659][table-planner] Array type supports equals and not_equal…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14311: [FLINK-20490][table-planner-blink] Don't share inputs between FlinkPhysicalRel and ExecNode

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

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19659: - Description: Currently, Array type supports `equals` and `not_equals` when element types are th

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hailong wang updated FLINK-19659: - Description: Currently, Array type supports `equals` and `not_equals` when element types are th

[GitHub] [flink] flinkbot commented on pull request #14328: [FLINK-19659][table-planner] Array type supports equals and not_equal…

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

[GitHub] [flink-web] HuangXingBo commented on a change in pull request #397: Add 1.12 Release announcement.

HuangXingBo commented on a change in pull request #397: URL: https://github.com/apache/flink-web/pull/397#discussion_r538097233 ## File path: _posts/2020-12-04-release-1.12.0.md ## @@ -0,0 +1,332 @@ +--- +layout: post +title: "Apache Flink 1.12.0 Release Announcement" +date:

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19659: --- Labels: pull-request-available (was: ) > Array type supports equals and not_equals operator

[GitHub] [flink] wangxlong opened a new pull request #14328: [FLINK-19659][table-planner] Array type supports equals and not_equal…

wangxlong opened a new pull request #14328: URL: https://github.com/apache/flink/pull/14328 …s operator when element types are different but castable ## What is the purpose of the change Array type supports equals and not_equals operator when element types are different but ca

[GitHub] [flink-web] HuangXingBo commented on a change in pull request #397: Add 1.12 Release announcement.

HuangXingBo commented on a change in pull request #397: URL: https://github.com/apache/flink-web/pull/397#discussion_r538097233 ## File path: _posts/2020-12-04-release-1.12.0.md ## @@ -0,0 +1,332 @@ +--- +layout: post +title: "Apache Flink 1.12.0 Release Announcement" +date:

[GitHub] [flink-web] zhuzhurk commented on a change in pull request #397: Add 1.12 Release announcement.

zhuzhurk commented on a change in pull request #397: URL: https://github.com/apache/flink-web/pull/397#discussion_r538090393 ## File path: _posts/2020-12-04-release-1.12.0.md ## @@ -0,0 +1,332 @@ +--- +layout: post +title: "Apache Flink 1.12.0 Release Announcement" +date: 202

[jira] [Closed] (FLINK-20300) Create Flink 1.12 release notes

[ https://issues.apache.org/jira/browse/FLINK-20300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20300. -- Fix Version/s: 1.12.1 Resolution: Fixed > Create Flink 1.12 release notes > ---

[jira] [Commented] (FLINK-20300) Create Flink 1.12 release notes

[ https://issues.apache.org/jira/browse/FLINK-20300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245700#comment-17245700 ] Robert Metzger commented on FLINK-20300: merged to master in https://github.com

[GitHub] [flink] rmetzger closed pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

rmetzger closed pull request #14195: URL: https://github.com/apache/flink/pull/14195 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

[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 ] Robert Metzger updated FLINK-16027: --- Fix Version/s: (was: 1.12.0) 1.13.0 > kafka connector's 'connector.to

[jira] [Updated] (FLINK-18159) Add support for trimming stack traces in user-facing components

[ https://issues.apache.org/jira/browse/FLINK-18159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18159: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add support for trimming stack

[jira] [Updated] (FLINK-15801) Timestamp extractor created from properties does not work for some physical fields

[ https://issues.apache.org/jira/browse/FLINK-15801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15801: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Timestamp extractor created fro

[jira] [Updated] (FLINK-14510) Remove the lazy vertex attaching mechanism from ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-14510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14510: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Remove the lazy vertex attachin

[jira] [Updated] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19698: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add close() method and onCheckp

[GitHub] [flink] rmetzger commented on pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

rmetzger commented on pull request #14195: URL: https://github.com/apache/flink/pull/14195#issuecomment-740422715 I addressed the remaining comments. I'm now merging the release notes! This is an automated message from the Ap

[GitHub] [flink] rmetzger commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

rmetzger commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r538081905 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,173 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes discuss imp

[GitHub] [flink] rmetzger commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

rmetzger commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r538081301 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,173 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes discuss imp

[GitHub] [flink] rmetzger commented on a change in pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

rmetzger commented on a change in pull request #14195: URL: https://github.com/apache/flink/pull/14195#discussion_r538080702 ## File path: docs/release-notes/flink-1.12.md ## @@ -0,0 +1,173 @@ +--- +title: "Release Notes - Flink 1.12" +--- + + + +These release notes discuss imp

[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10292: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Generate JobGraph in Standalone

[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 ] Robert Metzger updated FLINK-9407: -- Fix Version/s: (was: 1.12.0) 1.13.0 > Support orc rolling sink writer >

[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 ] Robert Metzger updated FLINK-11868: --- Fix Version/s: (was: 1.12.0) 1.13.0 > [filesystems] Introduce listSta

[jira] [Updated] (FLINK-10134) UTF-16 support for TextInputFormat

[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10134: --- Fix Version/s: (was: 1.12.0) 1.13.0 > UTF-16 support for TextInputFor

[jira] [Updated] (FLINK-12193) Send TM "can be released status" with RM heartbeat

[ https://issues.apache.org/jira/browse/FLINK-12193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12193: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Send TM "can be released status

[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 ] Robert Metzger updated FLINK-11499: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Extend StreamingFileSink BulkFo

[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 ] Robert Metzger updated FLINK-9879: -- Fix Version/s: (was: 1.12.0) 1.13.0 > Find sane defaults for (advanced)

[jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11937: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Resolve small file problem in R

[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 ] Robert Metzger updated FLINK-12273: --- Fix Version/s: (was: 1.12.0) 1.13.0 > The default value of Checkpoint

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12302: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Fixed the wrong finalStatus of

[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 ] Robert Metzger updated FLINK-12412: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Allow ListTypeInfo used for jav

[jira] [Updated] (FLINK-12520) Support to provide fully-qualified domain host name in TaskManagerMetricGroup

[ https://issues.apache.org/jira/browse/FLINK-12520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12520: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Support to provide fully-qualif

[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 ] Robert Metzger updated FLINK-12590: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Replace http links in documenta

[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 ] Robert Metzger updated FLINK-12692: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Support disk spilling in HeapKe

[jira] [Updated] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12884: --- Fix Version/s: (was: 1.12.0) 1.13.0 > FLIP-144: Native Kubernetes HA

[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 ] Robert Metzger updated FLINK-13809: --- Fix Version/s: (was: 1.12.0) 1.13.0 > The log directory of Flink Pyth

[jira] [Updated] (FLINK-13149) improve flink ui to make it easier to be used by other projects

[ https://issues.apache.org/jira/browse/FLINK-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13149: --- Fix Version/s: (was: 1.12.0) 1.13.0 > improve flink ui to make it eas

[jira] [Updated] (FLINK-13976) Make modern kafka E2E test runnable on Java 11

[ https://issues.apache.org/jira/browse/FLINK-13976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13976: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Make modern kafka E2E test runn

[jira] [Updated] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13418: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Avoid InfluxdbReporter to repor

[jira] [Updated] (FLINK-13692) Make CompletedCheckpointStore backwards compatible?

[ https://issues.apache.org/jira/browse/FLINK-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13692: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Make CompletedCheckpointStore b

[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 ] Robert Metzger updated FLINK-13698: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Rework threading model of Check

[jira] [Updated] (FLINK-14106) Make SlotManager pluggable

[ https://issues.apache.org/jira/browse/FLINK-14106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14106: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Make SlotManager pluggable > --

[jira] [Updated] (FLINK-13795) Web UI logs errors when selecting Checkpoint Tab for Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-13795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13795: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Web UI logs errors when selecti

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13910: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Many serializable classes have

[jira] [Updated] (FLINK-13719) Update Yarn E2E test docker image to run on Java 11

[ https://issues.apache.org/jira/browse/FLINK-13719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13719: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Update Yarn E2E test docker ima

[jira] [Updated] (FLINK-14191) Extend SlotManager to support dynamic slot allocation on pending task executors

[ https://issues.apache.org/jira/browse/FLINK-14191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14191: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Extend SlotManager to support d

[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 ] Robert Metzger updated FLINK-13876: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Remove ExecutionConfig field fr

[jira] [Updated] (FLINK-14187) FLIP-56 Dynamic Slot Allocation

[ https://issues.apache.org/jira/browse/FLINK-14187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14187: --- Fix Version/s: (was: 1.12.0) 1.13.0 > FLIP-56 Dynamic Slot Allocation

[jira] [Updated] (FLINK-14194) Clean-up of legacy mode.

[ https://issues.apache.org/jira/browse/FLINK-14194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14194: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Clean-up of legacy mode. >

[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 ] Robert Metzger updated FLINK-14032: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Make the cache size of RocksDBP

[jira] [Updated] (FLINK-14023) Support accessing job parameters in Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14023: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Support accessing job parameter

[jira] [Updated] (FLINK-14127) Better BackPressure Detection in WebUI

[ https://issues.apache.org/jira/browse/FLINK-14127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14127: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Better BackPressure Detection i

[jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14122: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Extend State Processor API to r

[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 ] Robert Metzger updated FLINK-14125: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Display memory and CPU usage in

[jira] [Updated] (FLINK-14820) Replace Time with Duration in FutureUtils

[ https://issues.apache.org/jira/browse/FLINK-14820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14820: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Replace Time with Duration in F

[jira] [Updated] (FLINK-14028) Support to configure the log level of the Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14028: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Support to configure the log le

[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 ] Robert Metzger updated FLINK-14340: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Specify an unique DFSClient nam

[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 ] Robert Metzger updated FLINK-14684: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add Pinterest to Chinese Powere

[jira] [Updated] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14159: --- Fix Version/s: (was: 1.12.0) 1.13.0 > flink rocksdb StreamCompression

[jira] [Updated] (FLINK-14971) Make all the non-IO operations in CheckpointCoordinator single-threaded

[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14971: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Make all the non-IO operations

[jira] [Updated] (FLINK-14190) Extend SlotManager to support dynamic slot allocation on registered TaskExecutors.

[ https://issues.apache.org/jira/browse/FLINK-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14190: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Extend SlotManager to support d

[jira] [Updated] (FLINK-14920) Set up environment to run performance e2e tests

[ https://issues.apache.org/jira/browse/FLINK-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14920: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Set up environment to run perfo

[jira] [Updated] (FLINK-14192) Enable the dynamic slot allocation feature.

[ https://issues.apache.org/jira/browse/FLINK-14192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14192: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Enable the dynamic slot allocat

[jira] [Updated] (FLINK-14193) Update RestAPI / Web UI

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14193: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Update RestAPI / Web UI > -

[jira] [Updated] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values

[ https://issues.apache.org/jira/browse/FLINK-14222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14222: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Optimize for Python UDFs with a

[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 ] Robert Metzger updated FLINK-14867: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Move TextInputFormat & TextOutp

[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 ] Robert Metzger updated FLINK-14479: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Strange exceptions found in log

[jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope

[ https://issues.apache.org/jira/browse/FLINK-14350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14350: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Introduce dedicated MetricScope

[jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface

[ https://issues.apache.org/jira/browse/FLINK-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14351: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Refactor MetricRegistry delimit

[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 ] Robert Metzger updated FLINK-14707: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Refactor checkpoint related met

[jira] [Updated] (FLINK-14919) Add performance e2e test suite for basic operations

[ https://issues.apache.org/jira/browse/FLINK-14919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14919: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add performance e2e test suite

[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 ] Robert Metzger updated FLINK-14379: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Supplement documentation about

[jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types

[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14383: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Support python UDFs with consta

[jira] [Updated] (FLINK-14393) add an option to enable/disable cancel job in web ui

[ https://issues.apache.org/jira/browse/FLINK-14393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14393: --- Fix Version/s: (was: 1.12.0) 1.13.0 > add an option to enable/disable

[jira] [Updated] (FLINK-14471) Hide error message when metric api failed

[ https://issues.apache.org/jira/browse/FLINK-14471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14471: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Hide error message when metric

[jira] [Updated] (FLINK-14410) Retrieve CharacterFilter once after registration

[ https://issues.apache.org/jira/browse/FLINK-14410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14410: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Retrieve CharacterFilter once a

[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 ] Robert Metzger updated FLINK-14500: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Support Flink Python User-Defin

[jira] [Updated] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

[ https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15325: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Input location preference which

[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 ] Robert Metzger updated FLINK-15018: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add event time page to Concepts

[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 ] Robert Metzger updated FLINK-15000: --- Fix Version/s: (was: 1.12.0) 1.13.0 > WebUI Metrics is very slow in l

[jira] [Updated] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15262: --- Fix Version/s: (was: 1.12.0) 1.13.0 > kafka connector doesn't read fr

[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 ] Robert Metzger updated FLINK-15471: --- Fix Version/s: (was: 1.12.0) 1.13.0 > HA e2e check for empty .out fil

[jira] [Updated] (FLINK-15122) Reusing record object in StreamTaskNetworkInput

[ https://issues.apache.org/jira/browse/FLINK-15122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15122: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Reusing record object in Stream

[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 ] Robert Metzger updated FLINK-15351: --- Fix Version/s: (was: 1.12.0) 1.13.0 > develop PostgresCatalog to conn

[jira] [Updated] (FLINK-14918) Add performance e2e test module and scripts

[ https://issues.apache.org/jira/browse/FLINK-14918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14918: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add performance e2e test module

[jira] [Updated] (FLINK-15586) BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem

[ https://issues.apache.org/jira/browse/FLINK-15586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15586: --- Fix Version/s: (was: 1.12.0) 1.13.0 > BucketingSink is ignoring plugi

[jira] [Updated] (FLINK-14920) Set up environment to run performance e2e tests

[ https://issues.apache.org/jira/browse/FLINK-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14920: --- Fix Version/s: (was: 1.12.0) > Set up environment to run performance e2e tests > ---

[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 ] Robert Metzger updated FLINK-15130: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Drop "RequiredParameters" and "

[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 ] Robert Metzger updated FLINK-14934: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Remove error log statement in E

[jira] [Updated] (FLINK-15710) Update BucketingSinkMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15710: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Update BucketingSinkMigrationTe

[jira] [Updated] (FLINK-15298) Wrong dependencies in the DataStream API tutorial (the wiki-edits example)

[ https://issues.apache.org/jira/browse/FLINK-15298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15298: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Wrong dependencies in the DataS

[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 ] Robert Metzger updated FLINK-15378: --- Fix Version/s: (was: 1.12.0) 1.13.0 > StreamFileSystemSink supported

[jira] [Updated] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14998: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Remove FileUtils#deletePathIfEm

[jira] [Updated] (FLINK-15717) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15717: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Update StatefulJobSavepointMigr

[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 ] Robert Metzger updated FLINK-15012: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Checkpoint directory not cleane

[jira] [Updated] (FLINK-15721) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15721: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Update StatefulJobWBroadcastSta

[jira] [Updated] (FLINK-15693) Stop receiving incoming RPC messages when RpcEndpoint is closing

[ https://issues.apache.org/jira/browse/FLINK-15693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15693: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Stop receiving incoming RPC mes

  1   2   3   4   5   6   7   8   >