[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: (was: 1.14.0) 1.14.1 1.15.0 > TypeMappi

[jira] [Closed] (FLINK-17168) TPC-DS end-to-end test failed on travis due to failed to download data generator

[ https://issues.apache.org/jira/browse/FLINK-17168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-17168. Fix Version/s: (was: 1.14.0) Resolution: Abandoned Closing this as it has been inactive

[jira] [Closed] (FLINK-17329) Quickstarts Scala nightly e2e test failed on travis

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

[jira] [Updated] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable

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

[jira] [Closed] (FLINK-17742) Blob file not removed after task was cancelled in standalone mode

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

[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: (was: 1.14.0) 1.14.1 1.15.0 > Pojo with

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

[jira] [Updated] (FLINK-17855) UDF with parameter Array(Row) can not work

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

[jira] [Closed] (FLINK-18060) Add notice for heap-based state backend of state access reference problem

[ https://issues.apache.org/jira/browse/FLINK-18060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18060. Fix Version/s: (was: 1.14.0) Resolution: Abandoned Closing this as it has been inactive

[jira] [Closed] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18211. Fix Version/s: (was: 1.14.0) Resolution: Abandoned Closing this as it has been inactive

[jira] [Closed] (FLINK-18334) Exclude .dumpstream files that only contain JAVA_TOOL_OPTIONS logging

[ https://issues.apache.org/jira/browse/FLINK-18334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18334. Fix Version/s: (was: 1.14.0) Resolution: Abandoned Closing this as it has been inactive

[jira] [Closed] (FLINK-18276) NullPointerException (and potential leak) when closing KafkaConsumer after exception in reassignPartitions

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

[jira] [Closed] (FLINK-18365) The same sql in a batch env and a streaming env has different value.

[ https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18365. Fix Version/s: (was: 1.14.0) Resolution: Abandoned Closing this as it has been inactive

[jira] [Closed] (FLINK-18503) bug occurs when `HeapReducingState#add` method handles null

[ https://issues.apache.org/jira/browse/FLINK-18503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18503. Fix Version/s: (was: 1.14.0) Resolution: Abandoned Closing this as it has been inactive

[jira] [Closed] (FLINK-18460) If the Python UDFs are called before calling the Python Dependency Management API, the Python Dependency Management would not will not take effect.

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

[jira] [Updated] (FLINK-18777) Supports schema registry catalog

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

[jira] [Updated] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

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

[jira] [Updated] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

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

[GitHub] [flink] RocMarshal commented on a change in pull request #15902: [FLINK-19028][docs] Translate the "application_parameters.md" into Chinese

RocMarshal commented on a change in pull request #15902: URL: https://github.com/apache/flink/pull/15902#discussion_r718095851 ## File path: docs/content.zh/docs/dev/datastream/application_parameters.md ## @@ -24,28 +24,27 @@ specific language governing permissions and limitati

[jira] [Updated] (FLINK-19370) FileSourceTextLinesITCase.testContinuousTextFileSource failed as results mismatch

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

[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: (was: 1.14.0) 1.14.1 1.15.0 > Invalid U

[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: (was: 1.14.0) (was: 1.11.0) 1.14.1

[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: (was: 1.14.0) 1.14.1 1.15.0 > the /flin

[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: (was: 1.14.0) 1.14.1 1.15.0 > Iterative

[jira] [Updated] (FLINK-19670) Query on a view of temporal join throws ParseException

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

[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: (was: 1.12.6) (was: 1.14.0) 1.14.1

[jira] [Updated] (FLINK-20474) flink cep results of doc is not right

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

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

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

[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: (was: 1.14.0) 1.14.1 1.15.0 > Sum or Su

[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: (was: 1.14.0) 1.14.1 1.15.0 > End to en

[jira] [Updated] (FLINK-20643) flink-connector-elasticsearch7 causes Direct buffer memory OOM

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

[jira] [Updated] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

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

[jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager

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

[jira] [Updated] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

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

[jira] [Updated] (FLINK-21438) Broken links in content.zh/docs/concepts/flink-architecture.md

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

[jira] [Updated] (FLINK-21340) CheckForbiddenMethodsUsage is not run and fails

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

[jira] [Updated] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

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

[jira] [Updated] (FLINK-21582) COALESCE not works when cast a variable return null

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

[jira] [Updated] (FLINK-21726) Fix checkpoint stuck

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

[jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync

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

[jira] [Updated] (FLINK-21789) Make FileChannelManagerImpl#getNextPathNum select data directories fairly

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

[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: (was: 1.14.0) 1.14.1 1.15.0 > Parse Com

[jira] [Updated] (FLINK-21898) JobRetrievalITCase crash

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

[jira] [Updated] (FLINK-22065) Improve the error message when input invalid command in the sql client

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

[jira] [Updated] (FLINK-21962) SQL Group Windows do not work on Flink 1.11

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

[jira] [Updated] (FLINK-22306) KafkaITCase.testCollectingSchema failed on AZP

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

[jira] [Updated] (FLINK-22701) "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg

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

[jira] [Updated] (FLINK-22567) OrcFsStreamingSinkITCase crashes JVM

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

[jira] [Updated] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

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

[jira] [Updated] (FLINK-22572) JsonFsStreamSinkITCase.testPart fails running in a timeout

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

[jira] [Updated] (FLINK-22558) testcontainers fail to start ResourceReaper

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

[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: (was: 1.14.0) 1.14.1 1.15.0 > Fail to t

[jira] [Updated] (FLINK-23310) Correct the `ModifyKindSetTrait` for `GroupWindowAggregate` when the input is an update stream

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

[jira] [Updated] (FLINK-22842) Streaming File Sink end-to-end test fail due to not finish after 900s

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

[jira] [Updated] (FLINK-22834) KafkaITCase.testBigRecordJob times out on azure

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

[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 ] Xintong Song updated FLINK-23869: - Fix Version/s: (was: 1.12.6) (was: 1.14.0) 1.14.1

[jira] [Updated] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

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

[jira] [Updated] (FLINK-22892) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails

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

[jira] [Updated] (FLINK-22742) Lookup join condition with process time throws org.codehaus.commons.compiler.CompileException

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

[jira] [Updated] (FLINK-22311) Flink JDBC XA connector need to set maxRetries to 0 to properly working

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

[jira] [Updated] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

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

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

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

[jira] [Updated] (FLINK-24380) Flink should handle the state transition of the pod from Pending to Failed

[ https://issues.apache.org/jira/browse/FLINK-24380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24380: - Fix Version/s: (was: 1.14.0) 1.14.1 > Flink should handle the state trans

[jira] [Updated] (FLINK-23528) stop-with-savepoint can fail with FlinkKinesisConsumer

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

[jira] [Updated] (FLINK-23493) python tests hang on Azure

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

[jira] [Updated] (FLINK-23946) Application mode fails fatally when being shut down

[ https://issues.apache.org/jira/browse/FLINK-23946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23946: - Fix Version/s: (was: 1.14.0) 1.14.1 > Application mode fails fatally when

[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: (was: 1.14.0) 1.14.1 > FlinkKafkaProducerITCase.testRecove

[GitHub] [flink] flinkbot edited a comment on pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

flinkbot edited a comment on pull request #17360: URL: https://github.com/apache/flink/pull/17360#issuecomment-927544424 ## CI report: * 1e11514b73a035cad03c582c00e5a156ec7ab115 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17377: [hotfix][docs] Move out the time zone page from streaming concepts section

flinkbot edited a comment on pull request #17377: URL: https://github.com/apache/flink/pull/17377#issuecomment-929395259 ## CI report: * 806c45e5ba19bc365c30b8a05766b289539f0887 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: (was: 1.14.0) 1.14.1 1.15.0 > Kubernete

[GitHub] [flink] flinkbot edited a comment on pull request #17378: [hotfix][docs] Move out the time zone page from streaming concepts section #17377

flinkbot edited a comment on pull request #17378: URL: https://github.com/apache/flink/pull/17378#issuecomment-929395351 ## CI report: * 5b412eca858465e486bce5ad080a1bb23e573c8d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21556) StreamingKafkaITCase hangs on azure

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

[jira] [Updated] (FLINK-21853) Running HA per-job cluster (rocks, non-incremental) end-to-end test could not finished in 900 seconds

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

[jira] [Updated] (FLINK-24273) Relocate io.fabric8 dependency

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

[jira] [Updated] (FLINK-24117) Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver

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

[jira] [Updated] (FLINK-23902) Support Hive version 2.3.8

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

[jira] [Updated] (FLINK-23589) Support Avro Microsecond precision

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

[jira] [Updated] (FLINK-23942) Python documentation redirects to shared pages should activate python tabs

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

[jira] [Updated] (FLINK-23427) Translate the page of "Blocking Shuffle" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23427: - Fix Version/s: (was: 1.14.0) 1.15.0 > Translate the page of "Blocking Shu

[jira] [Updated] (FLINK-23928) Test the buffer debloating

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

[jira] [Updated] (FLINK-23825) Test SQL Client manually

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

[jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions

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

[jira] [Updated] (FLINK-23855) Table API & SQL Configuration Not displayed on flink dashboard

[ https://issues.apache.org/jira/browse/FLINK-23855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23855: - Fix Version/s: (was: 1.14.0) 1.15.0 > Table API & SQL Configuration Not d

[jira] [Updated] (FLINK-23533) Split InputSelection into public and internal parts

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

[jira] [Updated] (FLINK-23842) Add log messages for reader registrations and split requests.

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

[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 ] Xintong Song updated FLINK-22960: - Fix Version/s: (was: 1.14.0) 1.15.0 > Temporal join TTL should use enable

[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: (was: 1.14.0) 1.15.0 > Chinese grammatical error > ---

[jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable

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

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

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

[jira] [Updated] (FLINK-23254) Upgrade Test Framework to JUnit 5

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

[jira] [Updated] (FLINK-21796) SQLClientKafkaITCase.testKafka fails to download Kafka

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

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

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

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

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

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

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

[jira] [Updated] (FLINK-22336) [umbrella] Enhance testing for built-in functions

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

[jira] [Updated] (FLINK-23887) Check thread pollution for 1.14

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

[jira] [Updated] (FLINK-23914) Make connector testing framework more verbose on test failure

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

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

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

[jira] [Updated] (FLINK-23752) Add document for using HiveSource API

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

[jira] [Updated] (FLINK-23086) Add getRuntimeExecutionMode to StreamExecutionEnvironment

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

<    1   2   3   4   5   6   7   8   9   >