[
https://issues.apache.org/jira/browse/FLINK-23310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23310:
Fix Version/s: 1.16.0
> Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is
>
[
https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22585:
Fix Version/s: 1.16.0
> Add deprecated message when "-m yarn-cluster" is used
>
[
https://issues.apache.org/jira/browse/FLINK-23921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23921:
Fix Version/s: 1.16.0
> WindowJoinITCase.testInnerJoinWithIsNotDistinctFromOnWTF is not stable
>
[
https://issues.apache.org/jira/browse/FLINK-19935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-19935:
Fix Version/s: 1.16.0
> Supports configure heap memory of sql-client to avoid OOM
>
[
https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21307:
Fix Version/s: 1.16.0
> Revisit activation model of FlinkSecurityManager
>
[
https://issues.apache.org/jira/browse/FLINK-23867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23867:
Fix Version/s: 1.16.0
> FlinkKafkaInternalProducerITCase.testCommitTransactionAfterClosed fails with
>
[
https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-18202:
Fix Version/s: 1.16.0
> Introduce Protobuf format
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-18624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-18624:
Fix Version/s: 1.16.0
> Document CREATE TEMPORARY TABLE
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-14222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-14222:
Fix Version/s: 1.16.0
> Optimize for Python UDFs with all parameters are constant values
>
[
https://issues.apache.org/jira/browse/FLINK-24547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24547:
Fix Version/s: 1.16.0
> A function named row_kind() can get row_kind
>
[
https://issues.apache.org/jira/browse/FLINK-22235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22235:
Fix Version/s: 1.16.0
> Document stability concerns of flamegraphs for heavier jobs
>
[
https://issues.apache.org/jira/browse/FLINK-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-15729:
Fix Version/s: 1.16.0
> Table planner dependency instructions for executing in IDE can be improved
>
[
https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20091:
Fix Version/s: 1.16.0
> Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema
>
[
https://issues.apache.org/jira/browse/FLINK-26144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26144:
Fix Version/s: 1.16.0
> SavepointFormatITCase did NOT fail with changelog.enabled randomized
>
[
https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20849:
Fix Version/s: 1.16.0
> Improve JavaDoc and logging of new KafkaSource
>
[
https://issues.apache.org/jira/browse/FLINK-19527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-19527:
Fix Version/s: 1.16.0
> Update SQL Pages
>
>
> Key: FLINK-19527
>
[
https://issues.apache.org/jira/browse/FLINK-24865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24865:
Fix Version/s: 1.16.0
> Support MATCH_RECOGNIZE in Batch mode
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22065:
Fix Version/s: 1.16.0
> Improve the error message when input invalid command in the sql client
>
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-18634:
Fix Version/s: 1.16.0
> FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout
>
[
https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-17987:
Fix Version/s: 1.16.0
> KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error
>
[
https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20687:
Fix Version/s: 1.16.0
> Missing 'yarn-application' target in CLI help message
>
[
https://issues.apache.org/jira/browse/FLINK-21953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21953:
Fix Version/s: 1.16.0
> Add documentation on batch mode support of Python DataStream API
>
[
https://issues.apache.org/jira/browse/FLINK-22607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22607:
Fix Version/s: 1.16.0
> Examples use deprecated AscendingTimestampExtractor
>
[
https://issues.apache.org/jira/browse/FLINK-20280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20280:
Fix Version/s: 1.16.0
> Support batch mode for Python DataStream API
>
[
https://issues.apache.org/jira/browse/FLINK-23778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23778:
Fix Version/s: 1.16.0
> UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue hangs on Azure
>
[
https://issues.apache.org/jira/browse/FLINK-24259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24259:
Fix Version/s: 1.16.0
> Exception message when Kafka topic is null in FlinkKafkaConsumer
>
[
https://issues.apache.org/jira/browse/FLINK-18627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-18627:
Fix Version/s: 1.16.0
> Get unmatch filter method records to side output
>
[
https://issues.apache.org/jira/browse/FLINK-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-17405:
Fix Version/s: 1.16.0
> add test cases for cancel job in SQL client
>
[
https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-2:
Fix Version/s: 1.16.0
> Global config is logged twice by the client for batch jobs
>
[
https://issues.apache.org/jira/browse/FLINK-24078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24078:
Fix Version/s: 1.16.0
> Remove brackets around variables
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-23533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23533:
Fix Version/s: 1.16.0
> Split InputSelection into public and internal parts
>
[
https://issues.apache.org/jira/browse/FLINK-24854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24854:
Fix Version/s: 1.16.0
> StateHandleSerializationTest unit test error
>
[
https://issues.apache.org/jira/browse/FLINK-14028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-14028:
Fix Version/s: 1.16.0
> Support to configure the log level of the Python user-defined functions
>
[
https://issues.apache.org/jira/browse/FLINK-21769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21769:
Fix Version/s: 1.16.0
> Encapsulate component meta data
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-23942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23942:
Fix Version/s: 1.16.0
> Python documentation redirects to shared pages should activate python tabs
>
[
https://issues.apache.org/jira/browse/FLINK-24721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24721:
Fix Version/s: 1.16.0
> Update the based on the Maven official indication
>
[
https://issues.apache.org/jira/browse/FLINK-22344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22344:
Fix Version/s: 1.16.0
> KafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue times out
>
[
https://issues.apache.org/jira/browse/FLINK-22520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22520:
Fix Version/s: 1.16.0
> KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs
>
[
https://issues.apache.org/jira/browse/FLINK-15130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-15130:
Fix Version/s: 1.16.0
> Drop "RequiredParameters" and "Options"
> ---
[
https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-16023:
Fix Version/s: 1.16.0
> jdbc connector's 'connector.table' property should be optional rather than
>
[
https://issues.apache.org/jira/browse/FLINK-22834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22834:
Fix Version/s: 1.16.0
> KafkaITCase.testBigRecordJob times out on azure
>
[
https://issues.apache.org/jira/browse/FLINK-22742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22742:
Fix Version/s: 1.16.0
> Lookup join condition with process time throws
>
[
https://issues.apache.org/jira/browse/FLINK-19263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-19263:
Fix Version/s: 1.16.0
> Enforce alphabetical order in configuration option docs
>
[
https://issues.apache.org/jira/browse/FLINK-23350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23350:
Fix Version/s: 1.16.0
> Write doc for change log disorder by special operators
>
[
https://issues.apache.org/jira/browse/FLINK-22209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22209:
Fix Version/s: 1.16.0
> Make StreamTask#triggerCheckpointAsync return void
>
[
https://issues.apache.org/jira/browse/FLINK-25291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25291:
Fix Version/s: 1.16.0
> Add failure cases in DataStream source and sink suite of connector testing
>
[
https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-16799:
Fix Version/s: 1.16.0
> add hive partition limit when read from hive
>
[
https://issues.apache.org/jira/browse/FLINK-25587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25587:
Fix Version/s: 1.16.0
> HiveCatalogITCase crashed on Azure with exit code 239
>
[
https://issues.apache.org/jira/browse/FLINK-26369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26369:
Fix Version/s: 1.16.0
> Translate the part zh-page mixed with not be translated.
>
[
https://issues.apache.org/jira/browse/FLINK-24590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24590:
Fix Version/s: 1.16.0
> Consider removing timeout from FlinkMatchers#futureWillCompleteExceptionally
>
[
https://issues.apache.org/jira/browse/FLINK-23694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23694:
Fix Version/s: 1.16.0
> KafkaWriterITCase hangs on azure
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-14690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-14690:
Fix Version/s: 1.16.0
> Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL
>
[
https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-17372:
Fix Version/s: 1.16.0
> SlotManager should expose total required resources
>
[
https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-18578:
Fix Version/s: 1.16.0
> Add rejecting checkpoint logic in source
>
[
https://issues.apache.org/jira/browse/FLINK-20787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20787:
Fix Version/s: 1.16.0
> Improve the Table API to solve user friction
>
[
https://issues.apache.org/jira/browse/FLINK-20474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20474:
Fix Version/s: 1.16.0
> flink cep results of doc is not right
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-15378:
Fix Version/s: 1.16.0
> StreamFileSystemSink supported mutil hdfs plugins.
>
[
https://issues.apache.org/jira/browse/FLINK-18213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-18213:
Fix Version/s: 1.16.0
> refactor kafka sql connector to use just one shade to compatible 0.10.0.2 +
>
[
https://issues.apache.org/jira/browse/FLINK-20572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20572:
Fix Version/s: 1.16.0
> HiveCatalog should be a standalone module
>
[
https://issues.apache.org/jira/browse/FLINK-25316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25316:
Fix Version/s: 1.16.0
> BlobServer can get stuck during shutdown
>
[
https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24483:
Fix Version/s: 1.16.0
> Document what is Public API and what compatibility guarantees Flink is
>
[
https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-3:
Fix Version/s: 1.16.0
> Explicitly configure rest.address in distribution config
>
[
https://issues.apache.org/jira/browse/FLINK-22299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22299:
Fix Version/s: 1.16.0
> should remind users to ignoreParseErrors option when parser failed
>
[
https://issues.apache.org/jira/browse/FLINK-21898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21898:
Fix Version/s: 1.16.0
> JobRetrievalITCase crash
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-20305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20305:
Fix Version/s: 1.16.0
> Iterative job with maxWaitTimeMillis does not terminate
>
[
https://issues.apache.org/jira/browse/FLINK-23390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23390:
Fix Version/s: 1.16.0
> FlinkKafkaInternalProducerITCase.testResumeTransactionAfterClosed
>
[
https://issues.apache.org/jira/browse/FLINK-21940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21940:
Fix Version/s: 1.16.0
> Rowtime/proctime should be obtained from getTimestamp instead of getLong
>
[
https://issues.apache.org/jira/browse/FLINK-21179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21179:
Fix Version/s: 1.16.0
> Make sure that the open/close methods of the Python DataStream Function are
>
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-16024:
Fix Version/s: 1.16.0
> support filter pushdown in jdbc connector
>
[
https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20190:
Fix Version/s: 1.16.0
> A New Window Trigger that can trigger window operation both by event time
>
[
https://issues.apache.org/jira/browse/FLINK-20896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20896:
Fix Version/s: 1.16.0
> Support SupportsAggregatePushDown for JDBC TableSource
>
[
https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23740:
Fix Version/s: 1.16.0
> SQL Full Outer Join bug
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-19499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-19499:
Fix Version/s: 1.16.0
> Expose Metric Groups to Split Assigners
> ---
[
https://issues.apache.org/jira/browse/FLINK-24095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24095:
Fix Version/s: 1.16.0
> Elasticsearch7DynamicSinkITCase.testWritingDocuments fails due to socket
>
[
https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20726:
Fix Version/s: 1.16.0
> Introduce Pulsar connector
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-16548:
Fix Version/s: 1.16.0
> Expose consistent environment variable to identify the component name and
>
[
https://issues.apache.org/jira/browse/FLINK-26931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26931:
Fix Version/s: 1.16.0
> Pulsar sink's producer name should be unique
>
[
https://issues.apache.org/jira/browse/FLINK-15183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-15183:
Fix Version/s: 1.16.0
> Use SQL-CLI to TPC-DS E2E test
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-25040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25040:
Fix Version/s: 1.16.0
> FlinkKafkaInternalProducerITCase.testInitTransactionId failed on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-25353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-25353:
Fix Version/s: 1.16.0
> Add tests to ensure API graduation process is honoured
>
[
https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-20767:
Fix Version/s: 1.16.0
> add nested field support for SupportsFilterPushDown
>
[
https://issues.apache.org/jira/browse/FLINK-24636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24636:
Fix Version/s: 1.16.0
> Move cluster deletion operation cache into ResourceManager
>
[
https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-14340:
Fix Version/s: 1.16.0
> Specify an unique DFSClient name for Hadoop FileSystem
>
[
https://issues.apache.org/jira/browse/FLINK-22237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22237:
Fix Version/s: 1.16.0
> Flamegraph component calls draw method from template
>
[
https://issues.apache.org/jira/browse/FLINK-26446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-26446:
Fix Version/s: 1.16.0
> Update Feature Radar in Apache Flink Roadmap
>
[
https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24306:
Fix Version/s: 1.16.0
> group by index throw SqlValidatorException
>
[
https://issues.apache.org/jira/browse/FLINK-22230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22230:
Fix Version/s: 1.16.0
> Misleading TaskExecutorResourceUtils log messages
>
[
https://issues.apache.org/jira/browse/FLINK-23997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23997:
Fix Version/s: 1.16.0
> Improvement for SQL windowing table-valued function
>
[
https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-12273:
Fix Version/s: 1.16.0
> The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE,
>
[
https://issues.apache.org/jira/browse/FLINK-22336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22336:
Fix Version/s: 1.16.0
> [umbrella] Enhance testing for built-in functions
>
[
https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-11499:
Fix Version/s: 1.16.0
> Extend StreamingFileSink BulkFormats to support arbitrary roll policies
>
[
https://issues.apache.org/jira/browse/FLINK-21408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21408:
Fix Version/s: 1.16.0
> Clarify which DataStream sources support Batch execution
>
[
https://issues.apache.org/jira/browse/FLINK-19482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-19482:
Fix Version/s: 1.16.0
> OrcRowInputFormat does not define serialVersionUID
>
[
https://issues.apache.org/jira/browse/FLINK-24140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24140:
Fix Version/s: 1.16.0
> Enhance the ITCase for FLIP-147
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-17755:
Fix Version/s: 1.16.0
> Support side-output of expiring states with TTL.
>
[
https://issues.apache.org/jira/browse/FLINK-23869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-23869:
Fix Version/s: 1.16.0
> Correct javadoc of ExecutionConfig#registerKryoType
>
[
https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21559:
Fix Version/s: 1.16.0
> Python DataStreamTests::test_process_function failed on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-22960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-22960:
Fix Version/s: 1.16.0
> Temporal join TTL should use enableTimeToLive of state instead of timer
>
[
https://issues.apache.org/jira/browse/FLINK-24542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24542:
Fix Version/s: 1.16.0
> Expose the freshness metrics for kafka connector
>
[
https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-17337:
Fix Version/s: 1.16.0
> Send UPDATE messages instead of INSERT and DELETE in streaming join operator
>
601 - 700 of 2914 matches
Mail list logo
