[jira] [Updated] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector

[ https://issues.apache.org/jira/browse/FLINK-18563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18563: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add Support for Azure Cosmos DB Dat

[jira] [Updated] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector

[ https://issues.apache.org/jira/browse/FLINK-18566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18566: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add Support for Azure Cognitive Sea

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20656: - Fix Version/s: 1.18.0 (was: 1.17.0) > Update docs for new KafkaSource con

[jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log

[ https://issues.apache.org/jira/browse/FLINK-19846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19846: - Fix Version/s: 1.18.0 (was: 1.17.0) > Grammar mistakes in annotations and

[jira] [Updated] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector

[ https://issues.apache.org/jira/browse/FLINK-18564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18564: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add Support for Azure Event Hub Dat

[jira] [Updated] (FLINK-18753) Support local recovery for Unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18753: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support local recovery for Unaligne

[jira] [Updated] (FLINK-17987) KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error reading field

[ https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17987: - Fix Version/s: 1.18.0 (was: 1.17.0) > KafkaITCase.testStartFromGroupOffse

[jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18592: - Fix Version/s: 1.18.0 (was: 1.17.0) > StreamingFileSink fails due to trun

[jira] [Updated] (FLINK-18981) Support column comment for Hive tables

[ https://issues.apache.org/jira/browse/FLINK-18981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18981: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support column comment for Hive tab

[jira] [Updated] (FLINK-18627) Get unmatch filter method records to side output

[ https://issues.apache.org/jira/browse/FLINK-18627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18627: - Fix Version/s: 1.18.0 (was: 1.17.0) > Get unmatch filter method records t

[jira] [Updated] (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:all-tabpanel ] Xintong Song updated FLINK-20110: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support 'merge' method for first_va

[jira] [Updated] (FLINK-20484) Improve hive temporal table exception

[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20484: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve hive temporal table except

[jira] [Updated] (FLINK-20154) Improve error messages when using CLI with wrong target

[ https://issues.apache.org/jira/browse/FLINK-20154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20154: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve error messages when using C

[jira] [Updated] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate

[ https://issues.apache.org/jira/browse/FLINK-20305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20305: - Fix Version/s: 1.18.0 (was: 1.17.0) > Iterative job with maxWaitTimeMilli

[jira] [Updated] (FLINK-18567) Add Support for Azure Cognitive Search Table & SQL Connector

[ https://issues.apache.org/jira/browse/FLINK-18567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18567: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add Support for Azure Cognitive Sea

[jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC

[ https://issues.apache.org/jira/browse/FLINK-18734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18734: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add documentation for DynamoStreams

[jira] [Updated] (FLINK-18873) Make the WatermarkStrategy API more scala friendly

[ https://issues.apache.org/jira/browse/FLINK-18873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18873: - Fix Version/s: 1.18.0 (was: 1.17.0) > Make the WatermarkStrategy API more

[jira] [Updated] (FLINK-20920) Document how to connect to kerberized HMS

[ https://issues.apache.org/jira/browse/FLINK-20920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20920: - Fix Version/s: 1.18.0 (was: 1.17.0) > Document how to connect to kerberiz

[jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20687: - Fix Version/s: 1.18.0 (was: 1.17.0) > Missing 'yarn-application' target i

[jira] [Updated] (FLINK-20853) Add reader schema null check for AvroDeserializationSchema when recordClazz is GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-20853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20853: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add reader schema null check for Av

[jira] [Updated] (FLINK-19007) Automatically set presto staging directory to io.tmp.dirs

[ https://issues.apache.org/jira/browse/FLINK-19007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19007: - Fix Version/s: 1.18.0 (was: 1.17.0) > Automatically set presto staging di

[jira] [Updated] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-19482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19482: - Fix Version/s: 1.18.0 (was: 1.17.0) > OrcRowInputFormat does not define s

[jira] [Updated] (FLINK-19254) Invalid UTF-8 start byte exception

[ https://issues.apache.org/jira/browse/FLINK-19254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19254: - Fix Version/s: 1.18.0 (was: 1.17.0) > Invalid UTF-8 start byte exception

[jira] [Updated] (FLINK-18996) Avoid disorder for time interval join

[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18996: - Fix Version/s: 1.18.0 (was: 1.17.0) > Avoid disorder for time interval jo

[jira] [Updated] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish

[ https://issues.apache.org/jira/browse/FLINK-19425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19425: - Fix Version/s: 1.18.0 (was: 1.17.0) > Correct the usage of BulkWriter#flu

[jira] [Updated] (FLINK-19362) Remove confusing comment for `DOT` operator codegen

[ https://issues.apache.org/jira/browse/FLINK-19362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19362: - Fix Version/s: 1.18.0 (was: 1.17.0) > Remove confusing comment for `DOT`

[jira] [Updated] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

[ https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19432: - Fix Version/s: 1.18.0 (was: 1.17.0) > Whether to capture the updates whic

[jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs

[ https://issues.apache.org/jira/browse/FLINK-19263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19263: - Fix Version/s: 1.18.0 (was: 1.17.0) > Enforce alphabetical order in confi

[jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21375: - Fix Version/s: 1.18.0 (was: 1.17.0) > Refactor HybridMemorySegment >

[jira] [Updated] (FLINK-21408) Clarify which DataStream sources support Batch execution

[ https://issues.apache.org/jira/browse/FLINK-21408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21408: - Fix Version/s: 1.18.0 (was: 1.17.0) > Clarify which DataStream sources su

[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 ] Xintong Song updated FLINK-19659: - Fix Version/s: 1.18.0 (was: 1.17.0) > Array type supports equals and not_

[jira] [Updated] (FLINK-19935) Supports configure heap memory of sql-client to avoid OOM

[ https://issues.apache.org/jira/browse/FLINK-19935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19935: - Fix Version/s: 1.18.0 (was: 1.17.0) > Supports configure heap memory of s

[jira] [Updated] (FLINK-19895) Unify Life Cycle Management of ResultPartitionType Pipelined Family

[ https://issues.apache.org/jira/browse/FLINK-19895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19895: - Fix Version/s: 1.18.0 (was: 1.17.0) > Unify Life Cycle Management of Resu

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21022: - Fix Version/s: 1.18.0 (was: 1.17.0) > flink-connector-es add onSuccess ha

[jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down

[ https://issues.apache.org/jira/browse/FLINK-19819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19819: - Fix Version/s: 1.18.0 (was: 1.17.0) > SourceReaderBase supports limit pus

[jira] [Updated] (FLINK-19562) the /flink/docs/docker/run.sh cause an error with numeric username

[ https://issues.apache.org/jira/browse/FLINK-19562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19562: - Fix Version/s: 1.18.0 (was: 1.17.0) > the /flink/docs/docker/run.sh cause

[jira] [Updated] (FLINK-21409) Add Avro to DataTypes & Serialization docs

[ https://issues.apache.org/jira/browse/FLINK-21409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21409: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add Avro to DataTypes & Serializati

[jira] [Updated] (FLINK-19774) Introduce Sub Partition View Version for Approximate Local Recovery

[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19774: - Fix Version/s: 1.18.0 (was: 1.17.0) > Introduce Sub Partition View Versio

[jira] [Updated] (FLINK-19527) Update SQL Pages

[ https://issues.apache.org/jira/browse/FLINK-19527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19527: - Fix Version/s: 1.18.0 (was: 1.17.0) > Update SQL Pages >

[jira] [Updated] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

[ https://issues.apache.org/jira/browse/FLINK-19881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19881: - Fix Version/s: 1.18.0 (was: 1.17.0) > Optimize temporal join with upsert-

[jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing

[ https://issues.apache.org/jira/browse/FLINK-19613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19613: - Fix Version/s: 1.18.0 (was: 1.17.0) > Create flink-connector-files-test-u

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19722: - Fix Version/s: 1.18.0 (was: 1.17.0) > Pushdown Watermark to SourceProvide

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20457: - Fix Version/s: 1.18.0 (was: 1.17.0) > Fix the handling of timestamp in Da

[jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20190: - Fix Version/s: 1.18.0 (was: 1.17.0) > A New Window Trigger that can trigg

[jira] [Updated] (FLINK-20036) Join Has NoUniqueKey when using mini-batch

[ https://issues.apache.org/jira/browse/FLINK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20036: - Fix Version/s: 1.18.0 (was: 1.17.0) > Join Has NoUniqueKey when using min

[jira] [Updated] (FLINK-20155) java.lang.OutOfMemoryError: Direct buffer memory

[ https://issues.apache.org/jira/browse/FLINK-20155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20155: - Fix Version/s: 1.18.0 (was: 1.17.0) > java.lang.OutOfMemoryError: Direct

[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: 1.18.0 (was: 1.17.0) > Detect and fail explicitly on manag

[jira] [Updated] (FLINK-20767) add nested field support for SupportsFilterPushDown

[ https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20767: - Fix Version/s: 1.18.0 (was: 1.17.0) > add nested field support for Suppor

[jira] [Updated] (FLINK-20518) WebUI should escape characters in metric names

[ https://issues.apache.org/jira/browse/FLINK-20518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20518: - Fix Version/s: 1.18.0 (was: 1.17.0) > WebUI should escape characters in m

[jira] [Updated] (FLINK-21613) Parse Compute Column with `IN` expression throws NPE

[ https://issues.apache.org/jira/browse/FLINK-21613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21613: - Fix Version/s: 1.18.0 (was: 1.17.0) > Parse Compute Column with `IN` expr

[jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module

[ https://issues.apache.org/jira/browse/FLINK-20572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20572: - Fix Version/s: 1.18.0 (was: 1.17.0) > HiveCatalog should be a standalone

[jira] [Updated] (FLINK-20787) Improve the Table API to solve user friction

[ https://issues.apache.org/jira/browse/FLINK-20787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20787: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve the Table API to solve user

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22282: - Fix Version/s: 1.18.0 (was: 1.17.0) > Move creation of SplitEnumerator to

[jira] [Updated] (FLINK-20246) Add documentation on Python worker memory tuning in the memory tuning page

[ https://issues.apache.org/jira/browse/FLINK-20246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20246: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add documentation on Python worker

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20788: - Fix Version/s: 1.18.0 (was: 1.17.0) > It doesn't support to use cube/roll

[jira] [Updated] (FLINK-20578) Cannot create empty array using ARRAY[]

[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20578: - Fix Version/s: 1.18.0 (was: 1.17.0) > Cannot create empty array using ARR

[jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

[ https://issues.apache.org/jira/browse/FLINK-22334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22334: - Fix Version/s: 1.18.0 (was: 1.17.0) > Fail to translate the hive-sql in S

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

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21876: - Fix Version/s: 1.18.0 (was: 1.17.0) > Handle it properly when the returne

[jira] [Updated] (FLINK-22371) Chinese grammatical error

[ https://issues.apache.org/jira/browse/FLINK-22371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22371: - Fix Version/s: 1.18.0 (was: 1.17.0) > Chinese grammatical error > ---

[jira] [Updated] (FLINK-22607) Examples use deprecated AscendingTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-22607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22607: - Fix Version/s: 1.18.0 (was: 1.17.0) > Examples use deprecated AscendingTi

[jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent

[ https://issues.apache.org/jira/browse/FLINK-22418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22418: - Fix Version/s: 1.18.0 (was: 1.17.0) > The currently activated tab in the

[jira] [Updated] (FLINK-20952) Changelog json formats should support inherit options from JSON format

[ https://issues.apache.org/jira/browse/FLINK-20952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20952: - Fix Version/s: 1.18.0 (was: 1.17.0) > Changelog json formats should suppo

[jira] [Updated] (FLINK-20794) Support to select distinct columns in the Table API

[ https://issues.apache.org/jira/browse/FLINK-20794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20794: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support to select distinct columns

[jira] [Updated] (FLINK-20818) End to end test produce excessive amount of logs

[ https://issues.apache.org/jira/browse/FLINK-20818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20818: - Fix Version/s: 1.18.0 (was: 1.17.0) > End to end test produce excessive a

[jira] [Updated] (FLINK-21125) Sum or Sum0 overflow quietly

[ https://issues.apache.org/jira/browse/FLINK-21125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21125: - Fix Version/s: 1.18.0 (was: 1.17.0) > Sum or Sum0 overflow quietly >

[jira] [Updated] (FLINK-21053) Prevent potential RejectedExecutionExceptions in CheckpointCoordinator failing JM

[ https://issues.apache.org/jira/browse/FLINK-21053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21053: - Fix Version/s: 1.18.0 (was: 1.17.0) > Prevent potential RejectedExecution

[jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers

[ https://issues.apache.org/jira/browse/FLINK-20834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20834: - Fix Version/s: 1.18.0 (was: 1.17.0) > Add metrics for reporting the memor

[jira] [Updated] (FLINK-22299) should remind users to ignoreParseErrors option when parser failed

[ https://issues.apache.org/jira/browse/FLINK-22299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22299: - Fix Version/s: 1.18.0 (was: 1.17.0) > should remind users to ignoreParseE

[jira] [Updated] (FLINK-22909) Supports change log inputs for event time operators

[ https://issues.apache.org/jira/browse/FLINK-22909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22909: - Fix Version/s: 1.18.0 (was: 1.17.0) > Supports change log inputs for even

[jira] [Updated] (FLINK-22897) FlinkSQL1.12 Sink to Hive with diffrent parallelism will due to produce many small files

[ https://issues.apache.org/jira/browse/FLINK-22897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22897: - Fix Version/s: 1.18.0 (was: 1.17.0) > FlinkSQL1.12 Sink to Hive with diff

[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 ] Xintong Song updated FLINK-21302: - Fix Version/s: 1.18.0 (was: 1.17.0) > Fix NPE when use row_number() in ov

[jira] [Updated] (FLINK-21179) Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState

[ https://issues.apache.org/jira/browse/FLINK-21179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21179: - Fix Version/s: 1.18.0 (was: 1.17.0) > Make sure that the open/close metho

[jira] [Updated] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22457: - Fix Version/s: 1.18.0 (was: 1.17.0) > KafkaSourceLegacyITCase.testMultipl

[jira] [Updated] (FLINK-23403) Decrease default values for heartbeat timeout and interval

[ https://issues.apache.org/jira/browse/FLINK-23403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23403: - Fix Version/s: 1.18.0 (was: 1.17.0) > Decrease default values for heartbe

[jira] [Updated] (FLINK-21765) Remove implementation-specific MetricGroup parents

[ https://issues.apache.org/jira/browse/FLINK-21765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21765: - Fix Version/s: 1.18.0 (was: 1.17.0) > Remove implementation-specific Metr

[jira] [Updated] (FLINK-20865) Prevent potential resource deadlock in fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-20865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20865: - Fix Version/s: 1.18.0 (was: 1.17.0) > Prevent potential resource deadlock

[jira] [Updated] (FLINK-21783) Allow HeapBackend snapshotting customization

[ https://issues.apache.org/jira/browse/FLINK-21783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21783: - Fix Version/s: 1.18.0 (was: 1.17.0) > Allow HeapBackend snapshotting cust

[jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20849: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve JavaDoc and logging of new

[jira] [Updated] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

[ https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21578: - Fix Version/s: 1.18.0 (was: 1.17.0) > Closeable Sink Committer/GlobalComm

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21634: - Fix Version/s: 1.18.0 (was: 1.17.0) > ALTER TABLE statement enhancement >

[jira] [Updated] (FLINK-21184) Support temporary table/function for hive connector

[ https://issues.apache.org/jira/browse/FLINK-21184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21184: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support temporary table/function fo

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21711: - Fix Version/s: 1.18.0 (was: 1.17.0) > DataStreamSink doesn't allow settin

[jira] [Updated] (FLINK-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split

[ https://issues.apache.org/jira/browse/FLINK-22926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22926: - Fix Version/s: 1.18.0 (was: 1.17.0) > IDLE FLIP-27 source should go ACTIV

[jira] [Updated] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-23141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23141: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support KafkaSerializationSchema in

[jira] [Updated] (FLINK-21637) Wrong results when filtering by timestamp type

[ https://issues.apache.org/jira/browse/FLINK-21637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21637: - Fix Version/s: 1.18.0 (was: 1.17.0) > Wrong results when filtering by tim

[jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators

[ https://issues.apache.org/jira/browse/FLINK-23350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23350: - Fix Version/s: 1.18.0 (was: 1.17.0) > Write doc for change log disorder b

[jira] [Updated] (FLINK-21940) Rowtime/proctime should be obtained from getTimestamp instead of getLong

[ https://issues.apache.org/jira/browse/FLINK-21940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21940: - Fix Version/s: 1.18.0 (was: 1.17.0) > Rowtime/proctime should be obtained

[jira] [Updated] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

[ https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21871: - Fix Version/s: 1.18.0 (was: 1.17.0) > Support watermark for Hive and File

[jira] [Updated] (FLINK-22975) Specify port or range for k8s service

[ https://issues.apache.org/jira/browse/FLINK-22975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22975: - Fix Version/s: 1.18.0 (was: 1.17.0) > Specify port or range for k8s servi

[jira] [Updated] (FLINK-23412) Improve sourceSink description

[ https://issues.apache.org/jira/browse/FLINK-23412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23412: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve sourceSink description > --

[jira] [Updated] (FLINK-21784) Allow HeapBackend RestoreOperation customization

[ https://issues.apache.org/jira/browse/FLINK-21784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21784: - Fix Version/s: 1.18.0 (was: 1.17.0) > Allow HeapBackend RestoreOperation

[jira] [Updated] (FLINK-22553) Improve error reporting on TM connection failures

[ https://issues.apache.org/jira/browse/FLINK-22553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22553: - Fix Version/s: 1.18.0 (was: 1.17.0) > Improve error reporting on TM conne

[jira] [Updated] (FLINK-21649) Allow extension of CopyOnWrite state classes

[ https://issues.apache.org/jira/browse/FLINK-21649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21649: - Fix Version/s: 1.18.0 (was: 1.17.0) > Allow extension of CopyOnWrite stat

[jira] [Updated] (FLINK-23000) Allow downloading all Flink logs from the UI

[ https://issues.apache.org/jira/browse/FLINK-23000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23000: - Fix Version/s: 1.18.0 (was: 1.17.0) > Allow downloading all Flink logs fr

[jira] [Updated] (FLINK-23660) Hive Catalog support truncate table

[ https://issues.apache.org/jira/browse/FLINK-23660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23660: - Fix Version/s: 1.18.0 (was: 1.17.0) > Hive Catalog support truncate table

[jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend

[ https://issues.apache.org/jira/browse/FLINK-21648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21648: - Fix Version/s: 1.18.0 (was: 1.17.0) > FLIP-151: Incremental snapshots for

[jira] [Updated] (FLINK-22209) Make StreamTask#triggerCheckpointAsync return void

[ https://issues.apache.org/jira/browse/FLINK-22209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22209: - Fix Version/s: 1.18.0 (was: 1.17.0) > Make StreamTask#triggerCheckpointAs

[jira] [Updated] (FLINK-22223) Explicitly configure rest.address in distribution config

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-3: - Fix Version/s: 1.18.0 (was: 1.17.0) > Explicitly configure rest.address i

[jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs

[ https://issues.apache.org/jira/browse/FLINK-22235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22235: - Fix Version/s: 1.18.0 (was: 1.17.0) > Document stability concerns of flam

[jira] [Updated] (FLINK-22240) Sanity/phrasing pass for ExternalResourceUtils

[ https://issues.apache.org/jira/browse/FLINK-22240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22240: - Fix Version/s: 1.18.0 (was: 1.17.0) > Sanity/phrasing pass for ExternalRe

<    2   3   4   5   6   7   8   9   10   11   >