[jira] [Updated] (FLINK-16218) Chinese character is garbled when reading from MySQL using JDBC source

[ https://issues.apache.org/jira/browse/FLINK-16218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16218: Fix Version/s: (was: 1.11.2) 1.11.3 > Chinese character is garbled when reading fro

[jira] [Updated] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

[ https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16585: Fix Version/s: (was: 1.11.2) 1.11.3 > Table program cannot be compiled.Cannot deter

[jira] [Updated] (FLINK-16324) Checkpoint tasks progress would display 100% in web UI even not all tasks finished

[ https://issues.apache.org/jira/browse/FLINK-16324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16324: Fix Version/s: (was: 1.11.2) 1.11.3 > Checkpoint tasks progress would display 100%

[jira] [Updated] (FLINK-15788) Various Kubernetes integration improvements

[ https://issues.apache.org/jira/browse/FLINK-15788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15788: Fix Version/s: (was: 1.11.2) 1.11.3 > Various Kubernetes integration improvements >

[jira] [Updated] (FLINK-15524) Some links in Chinese documents points to English documents by mistake

[ https://issues.apache.org/jira/browse/FLINK-15524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15524: Fix Version/s: (was: 1.11.2) 1.11.3 > Some links in Chinese documents points to Eng

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15471: Fix Version/s: (was: 1.11.2) 1.11.3 > HA e2e check for empty .out files does not pr

[jira] [Updated] (FLINK-15298) Wrong dependencies in the DataStream API tutorial (the wiki-edits example)

[ https://issues.apache.org/jira/browse/FLINK-15298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15298: Fix Version/s: (was: 1.11.2) 1.11.3 > Wrong dependencies in the DataStream API tuto

[jira] [Updated] (FLINK-19125) Avoid memory fragmentation when running flink docker image

[ https://issues.apache.org/jira/browse/FLINK-19125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19125: Fix Version/s: (was: 1.11.2) 1.11.3 > Avoid memory fragmentation when running flink

[jira] [Updated] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14159: Fix Version/s: (was: 1.11.2) 1.11.3 > flink rocksdb StreamCompressionDecorator not

[jira] [Updated] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset'

[ https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15262: Fix Version/s: (was: 1.11.2) 1.11.3 > kafka connector doesn't read from beginning i

[jira] [Closed] (FLINK-12148) Give precedence to specified local jar when same mainClass is included in both lib and specified jar

[ https://issues.apache.org/jira/browse/FLINK-12148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-12148. --- Resolution: Fixed Closing it for now since there was no update from the initial reporter and 1.8 is already

[jira] [Reopened] (FLINK-12148) Give precedence to specified local jar when same mainClass is included in both lib and specified jar

[ https://issues.apache.org/jira/browse/FLINK-12148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-12148: - > Give precedence to specified local jar when same mainClass is included in > both lib and specified jar >

[jira] [Closed] (FLINK-12148) Give precedence to specified local jar when same mainClass is included in both lib and specified jar

[ https://issues.apache.org/jira/browse/FLINK-12148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-12148. --- Resolution: Won't Fix > Give precedence to specified local jar when same mainClass is included in > both li

[jira] [Updated] (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 ] Zhu Zhu updated FLINK-18276: Fix Version/s: (was: 1.11.2) 1.11.3 > NullPointerException (and potential leak) whe

[jira] [Updated] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18196: Fix Version/s: (was: 1.11.2) 1.11.3 > flink throws `NullPointerException` when exec

[jira] [Updated] (FLINK-17964) Hivemodule does not support map type

[ https://issues.apache.org/jira/browse/FLINK-17964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17964: Fix Version/s: 1.10.3 > Hivemodule does not support map type > > >

[jira] [Updated] (FLINK-17964) Hivemodule does not support map type

[ https://issues.apache.org/jira/browse/FLINK-17964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17964: Fix Version/s: (was: 1.11.2) 1.11.3 > Hivemodule does not support map type > --

[jira] [Updated] (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 ] Zhu Zhu updated FLINK-17742: Fix Version/s: (was: 1.11.2) 1.11.3 > Blob file not removed after task was cancelle

[jira] [Updated] (FLINK-17691) FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-17691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17691: Fix Version/s: (was: 1.11.2) 1.11.3 > FlinkKafkaProducer011 transactional.id too lo

[jira] [Updated] (FLINK-17677) FLINK_LOG_PREFIX recommended in docs is not always available

[ https://issues.apache.org/jira/browse/FLINK-17677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17677: Fix Version/s: (was: 1.11.2) 1.11.3 > FLINK_LOG_PREFIX recommended in docs is not a

[jira] [Updated] (FLINK-17458) TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers

[ https://issues.apache.org/jira/browse/FLINK-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17458: Fix Version/s: (was: 1.11.2) 1.11.3 > TaskExecutorSubmissionTest#testFailingSchedul

[jira] [Updated] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the Table

[ https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16622: Fix Version/s: (was: 1.11.2) 1.11.3 > Type ARRAY of table field 'id' does not match

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

[jira] [Updated] (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 ] Zhu Zhu updated FLINK-17329: Fix Version/s: (was: 1.11.2) 1.11.3 > Quickstarts Scala nightly e2e test failed on

[jira] [Updated] (FLINK-16612) Submit job through the rest api, job name will be lost

[ https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16612: Fix Version/s: (was: 1.11.2) 1.11.3 > Submit job through the rest api, job name wil

[jira] [Updated] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

[ https://issues.apache.org/jira/browse/FLINK-18347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18347: Fix Version/s: (was: 1.11.2) 1.11.3 > kinesis connector throw Error java.lang.NoSuc

[jira] [Updated] (FLINK-18376) java.lang.ArrayIndexOutOfBoundsException in RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-18376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18376: Fix Version/s: (was: 1.11.2) 1.11.3 1.10.3 1.1

[jira] [Updated] (FLINK-18438) TaskManager start failed

[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18438: Fix Version/s: (was: 1.11.2) 1.11.3 > TaskManager start failed > --

[jira] [Updated] (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 ] Zhu Zhu updated FLINK-18365: Fix Version/s: (was: 1.11.2) 1.11.3 1.12.0 > The same sql in a b

[jira] [Updated] (FLINK-18479) can not commit partition when set partition time

[ https://issues.apache.org/jira/browse/FLINK-18479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18479: Fix Version/s: (was: 1.11.2) 1.11.3 1.12.0 > can not commit part

[jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18592: Fix Version/s: (was: 1.11.2) 1.11.3 > StreamingFileSink fails due to truncating HDF

[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 ] Zhu Zhu updated FLINK-18624: Affects Version/s: 1.11.0 > Document CREATE TEMPORARY TABLE > --- > >

[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 ] Zhu Zhu updated FLINK-18624: Fix Version/s: 1.12.0 > Document CREATE TEMPORARY TABLE > --- > >

[jira] [Updated] (FLINK-18633) Download miniconda is instable

[ https://issues.apache.org/jira/browse/FLINK-18633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18633: Fix Version/s: (was: 1.11.2) 1.11.3 > Download miniconda is instable >

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

[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 ] Zhu Zhu updated FLINK-18624: Affects Version/s: (was: 1.11.0) > Document CREATE TEMPORARY TABLE > --- >

[jira] [Updated] (FLINK-18640) Flink jdbc not support postgresql with schema

[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18640: Fix Version/s: (was: 1.11.2) 1.11.3 > Flink jdbc not support postgresql with schema

[jira] [Updated] (FLINK-18654) Correct missleading documentation in "Partitioned Scan" section of JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18654: Fix Version/s: (was: 1.11.2) 1.11.3 > Correct missleading documentation in "Partiti

[jira] [Updated] (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 ] Zhu Zhu updated FLINK-18460: Fix Version/s: (was: 1.11.2) 1.11.3 > If the Python UDFs are called before calling

[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 ] Zhu Zhu updated FLINK-18734: Fix Version/s: (was: 1.11.2) 1.11.3 > Add documentation for DynamoStreams Consumer

[jira] [Commented] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191450#comment-17191450 ] Zhu Zhu commented on FLINK-18206: - Hi [~twalthr], is this issue fixed? > The timestamp

[jira] [Updated] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18206: Fix Version/s: (was: 1.11.2) 1.11.3 1.10.3 1.1

[jira] [Updated] (FLINK-19061) HiveCatalog fails to get partition column stats if partition value contains special characters

[ https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19061: Fix Version/s: (was: 1.11.2) 1.11.3 > HiveCatalog fails to get partition column sta

[jira] [Updated] (FLINK-19094) Revise the description of watermark strategy in Flink Table document

[ https://issues.apache.org/jira/browse/FLINK-19094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19094: Fix Version/s: (was: 1.11.2) 1.11.3 > Revise the description of watermark strategy

[jira] [Updated] (FLINK-19061) HiveCatalog fails to get partition column stats if partition value contains special characters

[ https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19061: Affects Version/s: 1.11.0 > HiveCatalog fails to get partition column stats if partition value contains >

[jira] [Commented] (FLINK-19061) HiveCatalog fails to get partition column stats if partition value contains special characters

[ https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191453#comment-17191453 ] Zhu Zhu commented on FLINK-19061: - [~lzljs3620320] I can see the fix is merged into mast

[jira] [Updated] (FLINK-18881) Modify the Access Broken Link

[ https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18881: Fix Version/s: (was: 1.11.2) 1.11.3 > Modify the Access Broken Link > -

[jira] [Updated] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

[ https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19027: Fix Version/s: (was: 1.11.2) 1.11.3 > UnalignedCheckpointITCase.shouldPerformUnalig

[jira] [Updated] (FLINK-18881) Modify the Access Broken Link

[ https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18881: Fix Version/s: (was: 1.11.3) 1.11.2 > Modify the Access Broken Link > -

[jira] [Closed] (FLINK-18881) Modify the Access Broken Link

[ https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-18881. --- Resolution: Fixed I can access the link [Rides and Fares Exercise|https://github.com/apache/flink-training/

[jira] [Updated] (FLINK-18880) Allow to configure the heap memory used by the gateway server

[ https://issues.apache.org/jira/browse/FLINK-18880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18880: Fix Version/s: (was: 1.11.2) 1.11.3 > Allow to configure the heap memory used by th

[jira] [Updated] (FLINK-18836) Python UDTF doesn't work well when the return type isn't generator

[ https://issues.apache.org/jira/browse/FLINK-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18836: Fix Version/s: (was: 1.11.2) 1.11.3 > Python UDTF doesn't work well when the return

[jira] [Updated] (FLINK-18833) Improve the Python documentation about sql

[ https://issues.apache.org/jira/browse/FLINK-18833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18833: Fix Version/s: (was: 1.11.2) 1.11.3 > Improve the Python documentation about sql >

[jira] [Updated] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

[ https://issues.apache.org/jira/browse/FLINK-18828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18828: Fix Version/s: (was: 1.11.2) 1.11.3 > Terminate jobmanager process with zero exit c

[jira] [Updated] (FLINK-18715) add cpu usage metric of jobmanager/taskmanager

[ https://issues.apache.org/jira/browse/FLINK-18715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18715: Fix Version/s: (was: 1.11.2) 1.11.3 > add cpu usage metric of jobmanager/taskmanag

[jira] [Updated] (FLINK-18775) Rework PyFlink Documentation

[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18775: Fix Version/s: (was: 1.11.2) 1.11.3 > Rework PyFlink Documentation > --

[jira] [Updated] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path

[ https://issues.apache.org/jira/browse/FLINK-18785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18785: Fix Version/s: (was: 1.11.2) 1.11.3 > flink goes into dead lock leader election whe

[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 ] Zhu Zhu updated FLINK-18706: Fix Version/s: (was: 1.11.2) 1.11.3 > Stop with savepoint cannot guarantee exactly-

[jira] [Updated] (FLINK-18701) NOT NULL constraint is not guaranteed when aggregation split is enabled

[ https://issues.apache.org/jira/browse/FLINK-18701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18701: Fix Version/s: (was: 1.11.2) 1.11.3 > NOT NULL constraint is not guaranteed when ag

[jira] [Updated] (FLINK-18549) flink 1.11 can not commit partition automatically

[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18549: Release Note: (was: my hadoop version is 2.6-cdh 5.8 , I upgrade it to hadoop 3.1.2 ，it is successed) >

[jira] [Updated] (FLINK-18549) flink 1.11 can not commit partition automatically

[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18549: Fix Version/s: (was: 1.11.2) > flink 1.11 can not commit partition automatically > ---

[jira] [Commented] (FLINK-18549) flink 1.11 can not commit partition automatically

[ https://issues.apache.org/jira/browse/FLINK-18549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191463#comment-17191463 ] Zhu Zhu commented on FLINK-18549: - This is what [~zhangjun] had commented when closing t

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191470#comment-17191470 ] Zhu Zhu commented on FLINK-18934: - I think this ticket still needs some time to figure o

[jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18934: Fix Version/s: (was: 1.11.2) 1.11.3 > Idle stream does not advance watermark in con

[jira] [Commented] (FLINK-14942) State Processing API: add an option to make deep copy

[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191481#comment-17191481 ] Zhu Zhu commented on FLINK-14942: - Hi [~sjwiesman][~qinjunjerry], just to confirm whethe

[jira] [Commented] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191487#comment-17191487 ] Zhu Zhu commented on FLINK-19109: - Hi [~roman_khachatryan], do you think we can get the

[jira] [Commented] (FLINK-19061) HiveCatalog fails to get partition column stats if partition value contains special characters

[ https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191489#comment-17191489 ] Zhu Zhu commented on FLINK-19061: - Thanks for the updates [~lzljs3620320] > HiveCatalog

[jira] [Updated] (FLINK-12148) Give precedence to specified local jar when same mainClass is included in both lib and specified jar

[ https://issues.apache.org/jira/browse/FLINK-12148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-12148: Fix Version/s: (was: 1.10.3) (was: 1.11.2) (was: 1.12.0)

[jira] [Updated] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18206: Fix Version/s: 1.11.3 1.10.3 > The timestamp is displayed incorrectly > --

[jira] [Commented] (FLINK-18206) The timestamp is displayed incorrectly

[ https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191497#comment-17191497 ] Zhu Zhu commented on FLINK-18206: - Thanks for the updates [~twalthr] > The timestamp i

[jira] [Commented] (FLINK-19109) Split Reader eats chained periodic watermarks

[ https://issues.apache.org/jira/browse/FLINK-19109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191537#comment-17191537 ] Zhu Zhu commented on FLINK-19109: - Thanks for the updates! [~roman_khachatryan] > Split

[jira] [Closed] (FLINK-14606) Simplify params of Execution#processFail

[ https://issues.apache.org/jira/browse/FLINK-14606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-14606. --- Resolution: Won't Do Closed because the value of {{inCallback}} and {{releasePartitions}} are not exactly a

[jira] [Commented] (FLINK-19703) A result partition is not untracked after its producer task failed in TaskManager

[ https://issues.apache.org/jira/browse/FLINK-19703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219608#comment-17219608 ] Zhu Zhu commented on FLINK-19703: - [~chesnay] It can happen in code path {{JobMaster#up

[jira] [Commented] (FLINK-19703) A result partition is not untracked after its producer task failed in TaskManager

[ https://issues.apache.org/jira/browse/FLINK-19703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219622#comment-17219622 ] Zhu Zhu commented on FLINK-19703: - The problem can be exposed by reworking ExecutionPart

[jira] [Created] (FLINK-19806) Job may try to leave SUSPENDED state in ExecutionGraph#failJob()

Zhu Zhu created FLINK-19806: --- Summary: Job may try to leave SUSPENDED state in ExecutionGraph#failJob() Key: FLINK-19806 URL: https://issues.apache.org/jira/browse/FLINK-19806 Project: Flink Issue

[jira] [Commented] (FLINK-19853) BulkSlotProviderImplTest.testFailedBulkSlotAllocationReleasesAllocatedSlot failed in azure

[ https://issues.apache.org/jira/browse/FLINK-19853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224519#comment-17224519 ] Zhu Zhu commented on FLINK-19853: - The failure cause is the concurrency of the released

[jira] [Comment Edited] (FLINK-19853) BulkSlotProviderImplTest.testFailedBulkSlotAllocationReleasesAllocatedSlot failed in azure

[ https://issues.apache.org/jira/browse/FLINK-19853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224519#comment-17224519 ] Zhu Zhu edited comment on FLINK-19853 at 11/2/20, 9:11 AM: --- Th

[jira] [Created] (FLINK-19919) Remove legacy scheduling in ExecutionGraph components

Zhu Zhu created FLINK-19919: --- Summary: Remove legacy scheduling in ExecutionGraph components Key: FLINK-19919 URL: https://issues.apache.org/jira/browse/FLINK-19919 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-19920) Remove legacy FailoverStrategy

Zhu Zhu created FLINK-19920: --- Summary: Remove legacy FailoverStrategy Key: FLINK-19920 URL: https://issues.apache.org/jira/browse/FLINK-19920 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-19921) Remove legacy RestartStrategy

Zhu Zhu created FLINK-19921: --- Summary: Remove legacy RestartStrategy Key: FLINK-19921 URL: https://issues.apache.org/jira/browse/FLINK-19921 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-19922) Remove SlotProvider from SchedulerNG

Zhu Zhu created FLINK-19922: --- Summary: Remove SlotProvider from SchedulerNG Key: FLINK-19922 URL: https://issues.apache.org/jira/browse/FLINK-19922 Project: Flink Issue Type: Sub-task Com

[jira] [Assigned] (FLINK-19919) Remove legacy scheduling in ExecutionGraph components

[ https://issues.apache.org/jira/browse/FLINK-19919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19919: --- Assignee: Zhu Zhu > Remove legacy scheduling in ExecutionGraph components > ---

[jira] [Assigned] (FLINK-19920) Remove legacy FailoverStrategy

[ https://issues.apache.org/jira/browse/FLINK-19920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19920: --- Assignee: Zhu Zhu > Remove legacy FailoverStrategy > -- > >

[jira] [Assigned] (FLINK-19921) Remove legacy RestartStrategy

[ https://issues.apache.org/jira/browse/FLINK-19921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19921: --- Assignee: Zhu Zhu > Remove legacy RestartStrategy > - > >

[jira] [Closed] (FLINK-19703) A result partition is not untracked after its producer task failed in TaskManager

[ https://issues.apache.org/jira/browse/FLINK-19703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19703. --- Resolution: Fixed Fixed via: dc50a2a84100441e6003df57e2ad667d275e5e3c ed33697c1b8d74eb511cf88ec8e40792c128ad

[jira] [Commented] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

[ https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224723#comment-17224723 ] Zhu Zhu commented on FLINK-15325: - I'd like to resume this discussion because it has bee

[jira] [Commented] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

[ https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226074#comment-17226074 ] Zhu Zhu commented on FLINK-15325: - Maybe a better option is to ignore the input location

[jira] [Created] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

Zhu Zhu created FLINK-19994: --- Summary: All vertices in an DataSet iteration job will be eagerly scheduled Key: FLINK-19994 URL: https://issues.apache.org/jira/browse/FLINK-19994 Project: Flink Iss

[jira] [Commented] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

[ https://issues.apache.org/jira/browse/FLINK-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226604#comment-17226604 ] Zhu Zhu commented on FLINK-19994: - cc [~trohrmann][~azagrebin] WDYT? Correct me if I mi

[jira] [Comment Edited] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

[ https://issues.apache.org/jira/browse/FLINK-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226604#comment-17226604 ] Zhu Zhu edited comment on FLINK-19994 at 11/5/20, 9:33 AM: --- cc

[jira] [Commented] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

[ https://issues.apache.org/jira/browse/FLINK-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226799#comment-17226799 ] Zhu Zhu commented on FLINK-19994: - [~azagrebin] {{computeStronglyConnectedComponents}} d

[jira] [Assigned] (FLINK-19994) All vertices in an DataSet iteration job will be eagerly scheduled

[ https://issues.apache.org/jira/browse/FLINK-19994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-19994: --- Assignee: Zhu Zhu > All vertices in an DataSet iteration job will be eagerly scheduled > --

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227153#comment-17227153 ] Zhu Zhu commented on FLINK-19964: - We recently noticed the issue FLINK-19994 that pipeli

[jira] [Commented] (FLINK-14942) State Processing API: add an option to make deep copy

[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17191931#comment-17191931 ] Zhu Zhu commented on FLINK-14942: - [~qinjunjerry] from what I know, shallow copy is not

[jira] [Updated] (FLINK-14942) State Processing API: add an option to make deep copy

[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14942: Fix Version/s: (was: 1.11.2) > State Processing API: add an option to make deep copy > ---

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17191975#comment-17191975 ] Zhu Zhu commented on FLINK-17329: - Another instance: https://dev.azure.com/apache-flink

[jira] [Updated] (FLINK-19094) Revise the description of watermark strategy in Flink Table document

[ https://issues.apache.org/jira/browse/FLINK-19094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19094: Fix Version/s: (was: 1.11.3) 1.11.2 > Revise the description of watermark strategy

[jira] [Updated] (FLINK-19148) Table crashed in Flink Table API & SQL Docs

[ https://issues.apache.org/jira/browse/FLINK-19148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19148: Fix Version/s: (was: 1.11.3) 1.11.2 > Table crashed in Flink Table API & SQL Docs

[jira] [Closed] (FLINK-19166) StreamingFileWriter should register Listener before the initialization of buckets

[ https://issues.apache.org/jira/browse/FLINK-19166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-19166. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed via master: 03fd81937a77d4952a49d53891880b0489485c0c re

[jira] [Updated] (FLINK-17016) Integrate pipelined region scheduling

[ https://issues.apache.org/jira/browse/FLINK-17016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17016: Summary: Integrate pipelined region scheduling (was: Enable PipelinedRegionSchedulingStrategy) > Integra

<    8   9   10   11   12   13   14   15   16   17   >