[jira] [Updated] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26945: Fix Version/s: (was: 1.19.0) > Add DATE_SUB supported in SQL & Table API > ---

[jira] [Updated] (FLINK-26477) Finalize the window support in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-26477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26477: Fix Version/s: (was: 1.19.0) > Finalize the window support in Python DataStream API >

[jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system

[ https://issues.apache.org/jira/browse/FLINK-11868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-11868: Fix Version/s: (was: 1.19.0) > [filesystems] Introduce listStatusIterator API to file system >

[jira] [Updated] (FLINK-29941) Support SQL Client connects to SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-29941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29941: Fix Version/s: (was: 1.19.0) > Support SQL Client connects to SQL Gateway > --

[jira] [Updated] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure

[ https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29330: Fix Version/s: (was: 1.19.0) > Provide better logs of MiniCluster shutdown procedure > ---

[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 ] lincoln lee updated FLINK-21799: Fix Version/s: (was: 1.19.0) > Detect and fail explicitly on managed memory leaking >

[jira] [Updated] (FLINK-29031) FlinkKinesisConsumerTest.testSourceSynchronization failed with AssertionFailedError

[ https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29031: Fix Version/s: (was: 1.19.0) > FlinkKinesisConsumerTest.testSourceSynchronization failed with

[jira] [Updated] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType

[ https://issues.apache.org/jira/browse/FLINK-23869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23869: Fix Version/s: (was: 1.19.0) > Correct javadoc of ExecutionConfig#registerKryoType > -

[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 ] lincoln lee updated FLINK-17642: Fix Version/s: (was: 1.19.0) > Exception while reading broken ORC file is hidden > ---

[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 ] lincoln lee updated FLINK-22299: Fix Version/s: (was: 1.19.0) > should remind users to ignoreParseErrors option when parser fai

[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 ] lincoln lee updated FLINK-16531: Fix Version/s: (was: 1.19.0) > Add full integration tests for "GROUPING SETS" for streaming mo

[jira] [Updated] (FLINK-25346) FLIP-197: API stability graduation process

[ https://issues.apache.org/jira/browse/FLINK-25346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25346: Fix Version/s: (was: 1.19.0) > FLIP-197: API stability graduation process > --

[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 ] lincoln lee updated FLINK-21940: Fix Version/s: (was: 1.19.0) > Rowtime/proctime should be obtained from getTimestamp instead o

[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 ] lincoln lee updated FLINK-18022: Fix Version/s: (was: 1.19.0) > Add e2e test for new streaming file sink >

[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 ] lincoln lee updated FLINK-21409: Fix Version/s: (was: 1.19.0) > Add Avro to DataTypes & Serialization docs > --

[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 ] lincoln lee updated FLINK-16548: Fix Version/s: (was: 1.19.0) > Expose consistent environment variable to identify the componen

[jira] [Updated] (FLINK-27268) build sql query error in JdbcDynamicTableSource

[ https://issues.apache.org/jira/browse/FLINK-27268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27268: Fix Version/s: (was: 1.19.0) > build sql query error in JdbcDynamicTableSource > -

[jira] [Updated] (FLINK-30970) Fix SQL Client doc still uses old style output

[ https://issues.apache.org/jira/browse/FLINK-30970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30970: Fix Version/s: (was: 1.19.0) > Fix SQL Client doc still uses old style output > --

[jira] [Updated] (FLINK-28104) Drop the unused order parameter in FirstValueFunction/LastValueFunction

[ https://issues.apache.org/jira/browse/FLINK-28104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28104: Fix Version/s: (was: 1.19.0) > Drop the unused order parameter in FirstValueFunction/LastValue

[jira] [Updated] (FLINK-25043) Allow calls to public @VisibleForTesting from the same package

[ https://issues.apache.org/jira/browse/FLINK-25043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25043: Fix Version/s: (was: 1.19.0) > Allow calls to public @VisibleForTesting from the same package

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

[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16774: Fix Version/s: (was: 1.19.0) > expose HBaseUpsertSinkFunction hTableName and schema for other

[jira] [Updated] (FLINK-31116) Support taskmanager related parameters in session mode Support job granularity setting

[ https://issues.apache.org/jira/browse/FLINK-31116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31116: Fix Version/s: (was: 1.19.0) > Support taskmanager related parameters in session mode Support

[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 ] lincoln lee updated FLINK-20155: Fix Version/s: (was: 1.19.0) > java.lang.OutOfMemoryError: Direct buffer memory >

[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 ] lincoln lee updated FLINK-19774: Fix Version/s: (was: 1.19.0) > Introduce Sub Partition View Version for Approximate Local Reco

[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 ] lincoln lee updated FLINK-18981: Fix Version/s: (was: 1.19.0) > Support column comment for Hive tables > --

[jira] [Updated] (FLINK-32607) Kafka table source and json format support projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-32607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32607: Fix Version/s: (was: 1.19.0) > Kafka table source and json format support projection pushdown

[jira] [Updated] (FLINK-27079) Setup cron jobs

[ https://issues.apache.org/jira/browse/FLINK-27079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27079: Fix Version/s: (was: 1.19.0) > Setup cron jobs > --- > > Key: FLIN

[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 ] lincoln lee updated FLINK-18578: Fix Version/s: (was: 1.19.0) > Add rejecting checkpoint logic in source >

[jira] [Updated] (FLINK-32682) Introduce option for choosing time function evaluation methods

[ https://issues.apache.org/jira/browse/FLINK-32682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32682: Fix Version/s: (was: 1.19.0) > Introduce option for choosing time function evaluation methods

[jira] [Updated] (FLINK-27809) Clarify that cluster-id is mandatory for Kubernetes HA in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-27809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27809: Fix Version/s: (was: 1.19.0) > Clarify that cluster-id is mandatory for Kubernetes HA in stand

[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 ] lincoln lee updated FLINK-20834: Fix Version/s: (was: 1.19.0) > Add metrics for reporting the memory usage and CPU usage of the

[jira] [Updated] (FLINK-33950) Update max aggregate functions to new type system

[ https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33950: Fix Version/s: (was: 1.19.0) > Update max aggregate functions to new type system > ---

[jira] [Updated] (FLINK-25205) Optimize SinkUpsertMaterializer

[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25205: Fix Version/s: (was: 1.19.0) > Optimize SinkUpsertMaterializer > -

[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 ] lincoln lee updated FLINK-18624: Fix Version/s: (was: 1.19.0) > Document CREATE TEMPORARY TABLE > -

[jira] [Updated] (FLINK-33202) FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data

[ https://issues.apache.org/jira/browse/FLINK-33202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33202: Fix Version/s: (was: 1.19.0) > FLIP-327: Support switching from batch to stream mode to improv

[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 ] lincoln lee updated FLINK-17683: Fix Version/s: (was: 1.19.0) > Pojo with no-args constructor will be treated as ROW when retur

[jira] [Updated] (FLINK-25325) Migration Flink from Junit4 to Junit5

[ https://issues.apache.org/jira/browse/FLINK-25325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25325: Fix Version/s: (was: 1.19.0) > Migration Flink from Junit4 to Junit5 > ---

[jira] [Updated] (FLINK-26949) Add NVL supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26949: Fix Version/s: (was: 1.19.0) > Add NVL supported in SQL & Table API >

[jira] [Updated] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image

[ https://issues.apache.org/jira/browse/FLINK-24237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24237: Fix Version/s: (was: 1.19.0) > Consider disabling or lowering DNS caching timeout in docker im

[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 ] lincoln lee updated FLINK-20457: Fix Version/s: (was: 1.19.0) > Fix the handling of timestamp in DataStream.from_collection > -

[jira] [Updated] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels

[ https://issues.apache.org/jira/browse/FLINK-31267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31267: Fix Version/s: (was: 1.19.0) > Fine-Grained Resource Management supports table and sql levels

[jira] [Updated] (FLINK-33597) Can not use a nested column for a join condition

[ https://issues.apache.org/jira/browse/FLINK-33597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33597: Fix Version/s: (was: 1.19.0) > Can not use a nested column for a join condition >

[jira] [Updated] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34252: Fix Version/s: (was: 1.19.0) > WatermarkAssignerOperator should not emit WatermarkStatus.IDLE

[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 ] lincoln lee updated FLINK-19034: Fix Version/s: (was: 1.19.0) > Remove deprecated StreamExecutionEnvironment#set/getNumberOfExe

[jira] [Updated] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26760: Fix Version/s: (was: 1.19.0) > The new CSV source (file system source + CSV format) does not s

[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 ] lincoln lee updated FLINK-16800: Fix Version/s: (was: 1.19.0) > TypeMappingUtils#checkIfCompatible didn't deal with nested type

[jira] [Updated] (FLINK-24125) Rethink relationship between DeclarativeSlotPool and *Bridge

[ https://issues.apache.org/jira/browse/FLINK-24125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24125: Fix Version/s: (was: 1.19.0) > Rethink relationship between DeclarativeSlotPool and *Bridge >

[jira] [Updated] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart

[ https://issues.apache.org/jira/browse/FLINK-23849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23849: Fix Version/s: (was: 1.19.0) > Support react to the node decommissioning change state on yarn

[jira] [Updated] (FLINK-33561) Externalize Pulsar Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33561: Fix Version/s: (was: 1.19.0) > Externalize Pulsar Python connector code >

[jira] [Updated] (FLINK-26692) migrate TpcdsTestProgram.java to new source

[ https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26692: Fix Version/s: (was: 1.19.0) > migrate TpcdsTestProgram.java to new source > -

[jira] [Updated] (FLINK-28401) Remove snapshot repo from quickstarts for released versions

[ https://issues.apache.org/jira/browse/FLINK-28401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28401: Fix Version/s: (was: 1.19.0) > Remove snapshot repo from quickstarts for released versions > -

[jira] [Updated] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29459: Fix Version/s: (was: 1.19.0) > Sink v2 has bugs in supporting legacy v1 implementations with g

[jira] [Updated] (FLINK-31706) The default source parallelism should be the same as execution's default parallelism under adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-31706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31706: Fix Version/s: (was: 1.19.0) > The default source parallelism should be the same as execution'

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

[ https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22585: Fix Version/s: (was: 1.19.0) > Add deprecated message when "-m yarn-cluster" is used > ---

[jira] [Updated] (FLINK-24169) Flaky local YARN tests relying on log files

[ https://issues.apache.org/jira/browse/FLINK-24169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24169: Fix Version/s: (was: 1.19.0) > Flaky local YARN tests relying on log files > -

[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 ] lincoln lee updated FLINK-19613: Fix Version/s: (was: 1.19.0) > Create flink-connector-files-test-utils for formats testing > -

[jira] [Updated] (FLINK-31691) Add MAP_FROM_ENTRIES supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-31691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31691: Fix Version/s: (was: 1.19.0) > Add MAP_FROM_ENTRIES supported in SQL & Table API > ---

[jira] [Updated] (FLINK-31193) The option `table.exec.hive.native-agg-function.enabled` should work at job level when using it in SqlClient side

[ https://issues.apache.org/jira/browse/FLINK-31193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31193: Fix Version/s: (was: 1.19.0) > The option `table.exec.hive.native-agg-function.enabled` should

[jira] [Updated] (FLINK-34066) LagFunction throw NPE when input argument are not null

[ https://issues.apache.org/jira/browse/FLINK-34066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34066: Fix Version/s: (was: 1.19.0) > LagFunction throw NPE when input argument are not null > --

[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 ] lincoln lee updated FLINK-17405: Fix Version/s: (was: 1.19.0) > add test cases for cancel job in SQL client > -

[jira] [Updated] (FLINK-28399) Refactor CheckedThread to accept runnable via constructor

[ https://issues.apache.org/jira/browse/FLINK-28399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28399: Fix Version/s: (was: 1.19.0) > Refactor CheckedThread to accept runnable via constructor > ---

[jira] [Updated] (FLINK-30285) Inline checkstyle config into pom

[ https://issues.apache.org/jira/browse/FLINK-30285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30285: Fix Version/s: (was: 1.19.0) > Inline checkstyle config into pom > ---

[jira] [Updated] (FLINK-28893) Add conv function supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-28893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28893: Fix Version/s: (was: 1.19.0) > Add conv function supported in SQL & Table API > --

[jira] [Updated] (FLINK-33498) Do not allow manually triggering incremental checkpoints with full checkpoint configured

[ https://issues.apache.org/jira/browse/FLINK-33498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33498: Fix Version/s: (was: 1.19.0) > Do not allow manually triggering incremental checkpoints with f

[jira] [Updated] (FLINK-29656) Modify all join-related sql tests to make having statistics as the default choice

[ https://issues.apache.org/jira/browse/FLINK-29656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29656: Fix Version/s: (was: 1.19.0) > Modify all join-related sql tests to make having statistics as

[jira] [Updated] (FLINK-25612) Update the outdated illustration of ExecutionState in the documentation

[ https://issues.apache.org/jira/browse/FLINK-25612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25612: Fix Version/s: (was: 1.19.0) > Update the outdated illustration of ExecutionState in the docum

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

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

[jira] [Updated] (FLINK-34094) Document new AsyncScalarFunction

[ https://issues.apache.org/jira/browse/FLINK-34094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34094: Fix Version/s: (was: 1.19.0) > Document new AsyncScalarFunction >

[jira] [Updated] (FLINK-34421) Skip post-compile checks in compile.sh if fast profile is active

[ https://issues.apache.org/jira/browse/FLINK-34421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34421: Fix Version/s: (was: 1.19.0) > Skip post-compile checks in compile.sh if fast profile is activ

[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 ] lincoln lee updated FLINK-21578: Fix Version/s: (was: 1.19.0) > Closeable Sink Committer/GlobalCommitter were created to functi

[jira] [Updated] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24951: Fix Version/s: (was: 1.19.0) > Allow watch bookmarks to mitigate frequent watcher rebuilding >

[jira] [Updated] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-26664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26664: Fix Version/s: (was: 1.19.0) > Improve Python exception messages to be more Pythonic in PyFlin

[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 ] lincoln lee updated FLINK-19038: Fix Version/s: (was: 1.19.0) > It doesn't support to call Table.limit() continuously > ---

[jira] [Updated] (FLINK-29003) sqlServerDialect should support limit clause

[ https://issues.apache.org/jira/browse/FLINK-29003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29003: Fix Version/s: (was: 1.19.0) > sqlServerDialect should support limit clause >

[jira] [Updated] (FLINK-28538) Eagerly emit a watermark the first time we exceed Long.MIN_VALUE

[ https://issues.apache.org/jira/browse/FLINK-28538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28538: Fix Version/s: (was: 1.19.0) > Eagerly emit a watermark the first time we exceed Long.MIN_VALU

[jira] [Updated] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25322: Fix Version/s: (was: 1.19.0) > Support no-claim mode in changelog state backend >

[jira] [Updated] (FLINK-31261) Make AdaptiveScheduler aware of the (local) state size

[ https://issues.apache.org/jira/browse/FLINK-31261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31261: Fix Version/s: (was: 1.19.0) > Make AdaptiveScheduler aware of the (local) state size > --

[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 ] lincoln lee updated FLINK-21179: Fix Version/s: (was: 1.19.0) > Make sure that the open/close methods of the Python DataStream

[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 ] lincoln lee updated FLINK-18566: Fix Version/s: (was: 1.19.0) > Add Support for Azure Cognitive Search DataStream Connector > -

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

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

[jira] [Updated] (FLINK-22960) Temporal join TTL should use enableTimeToLive of state instead of timer

[ https://issues.apache.org/jira/browse/FLINK-22960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22960: Fix Version/s: (was: 1.19.0) > Temporal join TTL should use enableTimeToLive of state instead

[jira] [Updated] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb

[ https://issues.apache.org/jira/browse/FLINK-29775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29775: Fix Version/s: (was: 1.19.0) > [JUnit5 Migration] Module: flink-statebackend-rocksdb > ---

[jira] [Updated] (FLINK-34033) flink json supports raw type

[ https://issues.apache.org/jira/browse/FLINK-34033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34033: Fix Version/s: (was: 1.19.0) > flink json supports raw type > - >

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27237: Fix Version/s: (was: 1.19.0) > Partitioned table statement enhancement > -

[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 ] lincoln lee updated FLINK-21125: Fix Version/s: (was: 1.19.0) > Sum or Sum0 overflow quietly > > >

[jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks

[ https://issues.apache.org/jira/browse/FLINK-24680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24680: Fix Version/s: (was: 1.19.0) > Expose UserCodeClassLoader in OperatorCoordinator.Context for r

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23031: Fix Version/s: (was: 1.19.0) > Support to emit window result with periodic or non_periodic > -

[jira] [Updated] (FLINK-33626) Wrong style in flink ui

[ https://issues.apache.org/jira/browse/FLINK-33626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33626: Fix Version/s: (was: 1.19.0) > Wrong style in flink ui > --- > >

[jira] [Updated] (FLINK-24226) Improve error message when trying Presto S3 FS with recoverable writer

[ https://issues.apache.org/jira/browse/FLINK-24226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24226: Fix Version/s: (was: 1.19.0) > Improve error message when trying Presto S3 FS with recoverable

[jira] [Updated] (FLINK-29021) [Umbrella] Add docs for Hive Compatibility

[ https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29021: Fix Version/s: (was: 1.19.0) > [Umbrella] Add docs for Hive Compatibility > --

[jira] [Updated] (FLINK-32573) Translate "Custom Serialization for Managed State" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-32573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32573: Fix Version/s: (was: 1.19.0) > Translate "Custom Serialization for Managed State" page into Ch

[jira] [Updated] (FLINK-28061) create new tech blog for connector development based on Source API

[ https://issues.apache.org/jira/browse/FLINK-28061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28061: Fix Version/s: (was: 1.19.0) > create new tech blog for connector development based on Source

[jira] [Updated] (FLINK-29192) Add completeness test for built-in functions between Java and Python Table API

[ https://issues.apache.org/jira/browse/FLINK-29192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29192: Fix Version/s: (was: 1.19.0) > Add completeness test for built-in functions between Java and P

[jira] [Updated] (FLINK-32263) Add ELT support in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-32263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-32263: Fix Version/s: (was: 1.19.0) > Add ELT support in SQL & Table API > --

[jira] [Updated] (FLINK-25887) FLIP-193: Snapshots ownership follow ups

[ https://issues.apache.org/jira/browse/FLINK-25887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25887: Fix Version/s: (was: 1.19.0) > FLIP-193: Snapshots ownership follow ups >

[jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars

[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27492: Fix Version/s: (was: 1.19.0) > Flink table scala example does not including the scala-api jars

[jira] [Updated] (FLINK-29547) Select a[1] which is array type for parquet complex type throw ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-29547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29547: Fix Version/s: (was: 1.19.0) > Select a[1] which is array type for parquet complex type throw

[jira] [Updated] (FLINK-30821) The optimized exec plan generated by OverAggregateTest#testDiffPartitionKeysWithDiffOrderKeys2 in the case of all-blocking is not as expected

[ https://issues.apache.org/jira/browse/FLINK-30821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30821: Fix Version/s: (was: 1.19.0) > The optimized exec plan generated by > OverAggregateTest#testD

[jira] [Updated] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka/pulsar

[ https://issues.apache.org/jira/browse/FLINK-31006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31006: Fix Version/s: (was: 1.19.0) > job is not finished when using pipeline mode to run bounded sou

[jira] [Updated] (FLINK-26944) Add ADD_MONTHS supported in SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-26944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26944: Fix Version/s: (was: 1.19.0) > Add ADD_MONTHS supported in SQL and Table API > ---

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