[jira] [Updated] (FLINK-17535) Treat min/max as part of the hierarchy of config option

[ https://issues.apache.org/jira/browse/FLINK-17535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17535: - Fix Version/s: (was: 1.14.0) 1.15.0 > Treat min/max as part of the

[jira] [Updated] (FLINK-15645) enable COPY TO/FROM in Postgres JDBC source/sink for faster batch processing

[ https://issues.apache.org/jira/browse/FLINK-15645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15645: - Fix Version/s: (was: 1.14.0) 1.15.0 > enable COPY TO/FROM in Postgres

[jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved

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

[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: (was: 1.14.0) 1.15.0 > Group by on event time should

[jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner

[ https://issues.apache.org/jira/browse/FLINK-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16143: - Fix Version/s: (was: 1.14.0) 1.15.0 > Turn on more date time functions

[jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables

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

[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: (was: 1.14.0) 1.15.0 > Translate "Filesystem SQL

[jira] [Updated] (FLINK-17405) add test cases for cancel job in SQL client

[ https://issues.apache.org/jira/browse/FLINK-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17405: - Fix Version/s: (was: 1.14.0) 1.15.0 > add test cases for cancel job in

[jira] [Updated] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

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

[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: (was: 1.14.0) 1.15.0 > Refactor orc shim to create a

[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: (was: 1.14.0) 1.15.0 > It doesn't support to call

[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: (was: 1.14.0) 1.15.0 > Some configuration args do not

[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: (was: 1.14.0) 1.15.0 > Add Support for Azure Cognitive

[jira] [Updated] (FLINK-18201) Support create_function in Python Table API

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

[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: (was: 1.14.0) 1.15.0 > Document CREATE TEMPORARY TABLE >

[jira] [Updated] (FLINK-18442) Move `testSessionWindowsWithContinuousEventTimeTrigger` to `ContinuousEventTimeTriggerTest`

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

[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: (was: 1.14.0) 1.15.0 > Add Support for Azure Cosmos DB

[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: (was: 1.14.0) 1.15.0 > Add Support for Azure Event Hub

[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: (was: 1.14.0) 1.15.0 > Add e2e test for new streaming

[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: (was: 1.14.0) 1.15.0 > Add Support for Azure Event Grid

[jira] [Updated] (FLINK-18229) Pending worker requests should be properly cleared

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

[jira] [Updated] (FLINK-18202) Introduce Protobuf format

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

[jira] [Updated] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs

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

[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: (was: 1.14.0) 1.15.0 > Get unmatch filter method records

[jira] [Updated] (FLINK-18405) Add watermark support for unaligned checkpoints

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

[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: (was: 1.14.0) 1.15.0 > Enforce alphabetical order in

[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: (was: 1.14.0) 1.15.0 > Support column comment for Hive

[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: (was: 1.14.0) 1.15.0 > Expose Metric Groups to Split

[jira] [Updated] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

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

[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: (was: 1.14.0) 1.15.0 > Add rejecting checkpoint logic in

[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: (was: 1.14.0) 1.15.0 > Support local recovery for

[jira] [Updated] (FLINK-19103) The PushPartitionIntoTableSourceScanRule will lead a performance problem when there are still many partitions after pruning

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

[jira] [Updated] (FLINK-18231) flink kafka connector exists same qualified class name, whch will cause conflicts when user has all the versions of flink-kafka-connector

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

[jira] [Updated] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink

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

[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: (was: 1.14.0) 1.15.0 > Introduce Sub Partition View

[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: (was: 1.14.0) 1.15.0 > Add documentation for

[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: (was: 1.14.0) 1.15.0 > Whether to capture the updates

[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: (was: 1.14.0) 1.15.0 > Grammar mistakes in annotations

[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: (was: 1.14.0) 1.15.0 > Make the WatermarkStrategy API

[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: (was: 1.14.0) 1.15.0 > Correct the usage of

[jira] [Updated] (FLINK-19085) Remove deprecated methods for writing CSV and Text files from DataStream

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

[jira] [Updated] (FLINK-18556) Drop the unused options in TableConfig

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

[jira] [Updated] (FLINK-18213) refactor kafka sql connector to use just one shade to compatible 0.10.0.2 +

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

[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: (was: 1.14.0) 1.15.0 > Remove confusing comment for `DOT`

[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: (was: 1.14.0) 1.15.0 > Add Support for Azure Cognitive

[jira] [Updated] (FLINK-18954) Add documentation for connectors in Python DataStream API.

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

[jira] [Updated] (FLINK-19743) Add Source metrics definitions

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

[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: (was: 1.14.0) 1.15.0 > Supports configure heap memory of

[jira] [Updated] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

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

[jira] [Updated] (FLINK-19647) Support the limit push down for the hbase connector

[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19647: - Fix Version/s: (was: 1.14.0) 1.15.0 > Support the limit push down 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: (was: 1.14.0) 1.15.0 > Remove deprecated

[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: (was: 1.14.0) 1.15.0 > Array type supports equals and

[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: (was: 1.14.0) 1.15.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: (was: 1.14.0) 1.15.0 > Pushdown Watermark to

[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: (was: 1.14.0) 1.15.0 > Introduce avro.ignore-parse-errors

[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: (was: 1.14.0) 1.15.0 > Automatically set presto staging

[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: (was: 1.14.0) 1.15.0 > SourceReaderBase supports limit

[jira] [Updated] (FLINK-19230) Support Python UDAF on blink batch planner

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

[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: (was: 1.14.0) 1.15.0 > Unify Life Cycle Management of

[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: (was: 1.14.0) 1.15.0 > Add documentation on Python worker

[jira] [Updated] (FLINK-19845) Migrate all FileSystemFormatFactory implementations

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

[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: (was: 1.14.0) 1.15.0 > Join Has NoUniqueKey when using

[jira] [Updated] (FLINK-19965) Refactor HiveMapredSplitReader to adapt to the new hive source

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

[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: (was: 1.14.0) 1.15.0 > Support 'merge' method for

[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: (was: 1.14.0) 1.15.0 > A New Window Trigger that can

[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: (was: 1.14.0) 1.15.0 > Update SQL Pages >

[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: (was: 1.14.0) 1.15.0 > WebUI should escape characters in

[jira] [Updated] (FLINK-19967) Clean legacy classes for Parquet and Orc

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

[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: (was: 1.14.0) 1.15.0 > Optimize temporal join with

[jira] [Updated] (FLINK-20280) Support batch mode for Python DataStream API

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

[jira] [Updated] (FLINK-20188) Add Documentation for new File Source

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

[jira] [Updated] (FLINK-20726) Introduce Pulsar connector

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

[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: (was: 1.14.0) 1.15.0 > add nested field support for

[jira] [Updated] (FLINK-20787) Improve the Table API to make it usable

[ 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: (was: 1.14.0) 1.15.0 > Improve the Table API to make it

[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: (was: 1.14.0) 1.15.0 > Improve error messages when using

[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: (was: 1.14.0) 1.15.0 > Update docs for new KafkaSource

[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: (was: 1.14.0) 1.15.0 > Support to select distinct columns

[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: (was: 1.14.0) 1.15.0 > HiveCatalog should be a standalone

[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: (was: 1.14.0) 1.15.0 > Improve JavaDoc and logging of new

[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: (was: 1.14.0) 1.15.0 > Cannot create empty array using

[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: (was: 1.14.0) 1.15.0 > Add metrics for reporting the

[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: (was: 1.14.0) 1.15.0 > Missing 'yarn-application' target

[jira] [Updated] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

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

[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: (was: 1.14.0) 1.15.0 > It doesn't support to use

[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: (was: 1.14.0) 1.15.0 > Improve hive temporal table

[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: (was: 1.14.0) 1.15.0 > Prevent potential resource

[jira] [Updated] (FLINK-20896) Support SupportsAggregatePushDown for JDBC TableSource

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

[jira] [Updated] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27

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

[jira] [Updated] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

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

[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: (was: 1.14.0) 1.15.0 > ALTER TABLE statement enhancement

[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: (was: 1.14.0) 1.15.0 > Document how to connect to

[jira] [Updated] (FLINK-20946) Optimize Python ValueState Implementation In PyFlink

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

[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: (was: 1.14.0) 1.15.0 > Changelog json formats should

[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: (was: 1.14.0) 1.15.0 > Clarify which DataStream sources

[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: (was: 1.14.0) 1.15.0 > Add reader schema null check for

[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: (was: 1.14.0) 1.15.0 > Support temporary table/function

[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: (was: 1.14.0) 1.15.0 > Make sure that the open/close

[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: (was: 1.14.0) 1.15.0 > Prevent potential

[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: (was: 1.14.0) 1.15.0 > Refactor HybridMemorySegment >

[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: (was: 1.14.0) 1.15.0 > flink-connector-es add onSuccess

<    1   2   3   4   5   6   7   8   9   >