[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: 1.18.0 (was: 1.17.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: 1.18.0 (was: 1.17.0) > Support to join a static table in

[jira] [Updated] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector

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

[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: 1.18.0 (was: 1.17.0) > jdbc connector's 'connector.table'

[jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result

[ https://issues.apache.org/jira/browse/FLINK-16466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16466: - Fix Version/s: 1.18.0 (was: 1.17.0) > Group by on event time should

[jira] [Updated] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese

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

[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: 1.18.0 (was: 1.17.0) > Promotes the column name

[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: 1.18.0 (was: 1.17.0) > Introduce builder to create

[jira] [Updated] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

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

[jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source

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

[jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE

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

[jira] [Updated] (FLINK-16126) Translate all connector related pages into Chinese

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

[jira] [Updated] (FLINK-18986) KubernetesSessionCli creates RestClusterClient for detached deployments

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

[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: 1.18.0 (was: 1.17.0) > Add full integration tests for

[jira] [Updated] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries

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

[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: 1.18.0 (was: 1.17.0) > add hive partition limit when read

[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: 1.18.0 (was: 1.17.0) > Relocation Beam dependency of

[jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types

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

[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: 1.18.0 (was: 1.17.0) > Parquet file system format

[jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously

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

[jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive

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

[jira] [Updated] (FLINK-18742) Some configuration args do not take effect at client

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

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17337: - Fix Version/s: 1.18.0 (was: 1.17.0) > Send UPDATE messages instead of

[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: 1.18.0 (was: 1.17.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: 1.18.0 (was: 1.17.0) > Support side-output of expiring

[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: 1.18.0 (was: 1.17.0) > Better detection for parquet and

[jira] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners

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

[jira] [Updated] (FLINK-17683) Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction， but not when it is a field of case class.

[ https://issues.apache.org/jira/browse/FLINK-17683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17683: - Fix Version/s: 1.18.0 (was: 1.17.0) > Pojo with no-args constructor will

[jira] [Updated] (FLINK-18022) Add e2e test for new streaming file sink

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

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20091: - Fix Version/s: 1.18.0 (was: 1.17.0) > Introduce avro.ignore-parse-errors

[jira] [Updated] (FLINK-17826) Add missing custom query support on new jdbc connector

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

[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

[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

[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

[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

[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

[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

[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) >

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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 &

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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`

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

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