[jira] [Closed] (FLINK-19953) Translation in docs/ops/memory/mem_setup.zh.md

[ https://issues.apache.org/jira/browse/FLINK-19953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-19953. Resolution: Fixed Merged via * master: b88859fb960b1ade9d79222440bd9bc836775e34 > Translation

[jira] [Commented] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227266#comment-17227266 ] Xintong Song commented on FLINK-19816: -- Thanks for the discussion, [~stevenz3wu] & [~trohrmann].

[jira] [Commented] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227250#comment-17227250 ] Xintong Song commented on FLINK-19698: -- Hi [~becket_qin], I find the fix for this issue has been

[jira] [Commented] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227416#comment-17227416 ] Xintong Song commented on FLINK-19698: -- [~sewen], Do you mean this issue on 1.11 is blocked on the

[jira] [Commented] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227425#comment-17227425 ] Xintong Song commented on FLINK-19816: -- Alright, thanks for the explaination. > Flink restored

[jira] [Comment Edited] (FLINK-19816) Flink restored from a wrong checkpoint (a very old one and not the last completed one)

[ https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227425#comment-17227425 ] Xintong Song edited comment on FLINK-19816 at 11/6/20, 2:12 PM: Alright,

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255569#comment-17255569 ] Xintong Song commented on FLINK-20632: -- True, it's hard to explain to users that the official

[jira] [Commented] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255570#comment-17255570 ] Xintong Song commented on FLINK-20781: -- [~becket_qin], Thanks for the reply. +1 on putting a

[jira] [Commented] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255521#comment-17255521 ] Xintong Song commented on FLINK-20781: -- [~becket_qin], Any chance that `null` check is also needed

[jira] [Updated] (FLINK-20781) UnalignedCheckpointITCase failure caused by NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20781: - Priority: Critical (was: Blocker) > UnalignedCheckpointITCase failure caused by

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255545#comment-17255545 ] Xintong Song commented on FLINK-20632: -- {quote}While it would solve the issue I do somewhat like

[jira] [Commented] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254761#comment-17254761 ] Xintong Song commented on FLINK-20461: -- [~hpeter], Is this related to the Azure environment? If

[jira] [Closed] (FLINK-20664) Support setting service account for TaskManager pod

[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20664. Resolution: Fixed Fixed via * master (1.13): 4e5448cc332090d7bd2664f60278534d945e1211 *

[jira] [Updated] (FLINK-20764) BatchGroupedReduceOperator does not emit results for singleton inputs

[ https://issues.apache.org/jira/browse/FLINK-20764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20764: - Fix Version/s: 1.13.0 > BatchGroupedReduceOperator does not emit results for singleton inputs >

[jira] [Updated] (FLINK-20764) BatchGroupedReduceOperator does not emit results for singleton inputs

[ https://issues.apache.org/jira/browse/FLINK-20764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20764: - Affects Version/s: 1.12.0 > BatchGroupedReduceOperator does not emit results for singleton

[jira] [Closed] (FLINK-20764) BatchGroupedReduceOperator does not emit results for singleton inputs

[ https://issues.apache.org/jira/browse/FLINK-20764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20764. Resolution: Fixed Fixed via: * master (1.13): b474d2872f4a82d838ac23252254253df4ca2309 *

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256378#comment-17256378 ] Xintong Song commented on FLINK-20811: -- Thanks for offering the effort, [~nicholasjiang].

[jira] [Created] (FLINK-20811) Support HTTP paths for yarn ship files/archives

Xintong Song created FLINK-20811: Summary: Support HTTP paths for yarn ship files/archives Key: FLINK-20811 URL: https://issues.apache.org/jira/browse/FLINK-20811 Project: Flink Issue Type:

[jira] [Closed] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20505. Resolution: Won't Do As discussed, we will not support HTTP paths for the shared libs. Instead,

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256483#comment-17256483 ] Xintong Song edited comment on FLINK-20811 at 12/30/20, 11:57 AM: --

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256483#comment-17256483 ] Xintong Song commented on FLINK-20811: -- [~ZhenqiuHuang] and I had a offline discussion earlier

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256929#comment-17256929 ] Xintong Song commented on FLINK-20632: -- The docker guys are still not responding to our 1.12.0

[jira] [Comment Edited] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256929#comment-17256929 ] Xintong Song edited comment on FLINK-20632 at 12/31/20, 10:26 AM: -- The

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258652#comment-17258652 ] Xintong Song commented on FLINK-10868: -- Thanks for the updates, [~hpeter]. Just to manage

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17259639#comment-17259639 ] Xintong Song commented on FLINK-20632: -- Thanks [~rmetzger], I got the following error when trying

[jira] [Updated] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20632: - Priority: Blocker (was: Critical) > Missing docker images for 1.12 release >

[jira] [Assigned] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20811: Assignee: Xintong Song > Support HTTP paths for yarn ship files/archives >

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17259623#comment-17259623 ] Xintong Song commented on FLINK-20811: -- First of all, I think we can at least have the Kubernetes

[jira] [Assigned] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20811: Assignee: (was: Xintong Song) > Support HTTP paths for yarn ship files/archives >

[jira] [Closed] (FLINK-20860) Allow streaming operators to use managed memory

[ https://issues.apache.org/jira/browse/FLINK-20860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20860. Resolution: Done Merged via * master (1.13): ed354d9c93b38d843269c29b291271ba8400c7d9 > Allow

[jira] [Assigned] (FLINK-20864) Apply exact matching rules in fulfilling resource requirement with slot resource

[ https://issues.apache.org/jira/browse/FLINK-20864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20864: Assignee: Yangze Guo > Apply exact matching rules in fulfilling resource requirement

[jira] [Updated] (FLINK-15660) Redundant AllocationID verification for allocateSlot in TaskSlotTable

[ https://issues.apache.org/jira/browse/FLINK-15660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15660: - Fix Version/s: 1.13.0 > Redundant AllocationID verification for allocateSlot in TaskSlotTable >

[jira] [Closed] (FLINK-20837) Refactor dynamic SlotID

[ https://issues.apache.org/jira/browse/FLINK-20837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20837. Resolution: Done Merged via * master (1.13): 8dc257dcd3907cd42c15bd1748e4e1954e15696c > Refactor

[jira] [Closed] (FLINK-15660) Redundant AllocationID verification for allocateSlot in TaskSlotTable

[ https://issues.apache.org/jira/browse/FLINK-15660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-15660. Resolution: Fixed Subsumed by FLINK-20837. Fixed via * master (1.13):

[jira] [Updated] (FLINK-20836) Register TaskManager with total and default slot resource profile in SlotManager

[ https://issues.apache.org/jira/browse/FLINK-20836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20836: - Component/s: Runtime / Coordination > Register TaskManager with total and default slot resource

[jira] [Closed] (FLINK-20836) Register TaskManager with total and default slot resource profile in SlotManager

[ https://issues.apache.org/jira/browse/FLINK-20836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20836. Resolution: Done Merged via * master (1.13): 435ebfa82c3b67bfe722833b61d604915ac9ab6d > Register

[jira] [Created] (FLINK-20906) Update copy right year to 2021 for NOTICE files

Xintong Song created FLINK-20906: Summary: Update copy right year to 2021 for NOTICE files Key: FLINK-20906 URL: https://issues.apache.org/jira/browse/FLINK-20906 Project: Flink Issue Type:

[jira] [Updated] (FLINK-20906) Update copyright year to 2021 for NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20906: - Summary: Update copyright year to 2021 for NOTICE files (was: Update copy right year to 2021

[jira] [Commented] (FLINK-20906) Update copyright year to 2021 for NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262328#comment-17262328 ] Xintong Song commented on FLINK-20906: -- [~chesnay], Thanks for the reminder. IIUC, we should do

[jira] [Commented] (FLINK-20906) Update copyright year to 2021 for NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262331#comment-17262331 ] Xintong Song commented on FLINK-20906: -- I found many NOTICE files in `flink-shaded` still have the

[jira] [Assigned] (FLINK-20905) Format the description of 'kubernetes.container.image' option

[ https://issues.apache.org/jira/browse/FLINK-20905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20905: Assignee: Ruguo Yu > Format the description of 'kubernetes.container.image' option >

[jira] [Closed] (FLINK-20906) Update copyright year to 2021 for NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20906. Resolution: Done Merged via * master (1.13): 67d167ccd45046fc5ed222ac1f1e3ba5e6ec434b *

[jira] [Updated] (FLINK-20793) Fix NamesTest due to code style refactor

[ https://issues.apache.org/jira/browse/FLINK-20793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20793: - Fix Version/s: (was: 1.12.2) 1.12.1 > Fix NamesTest due to code style

[jira] [Updated] (FLINK-20756) PythonCalcSplitConditionRule is not working as expected

[ https://issues.apache.org/jira/browse/FLINK-20756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20756: - Fix Version/s: (was: 1.12.2) 1.12.1 > PythonCalcSplitConditionRule is

[jira] [Updated] (FLINK-20822) Don't check whether a function is generic in hive catalog

[ https://issues.apache.org/jira/browse/FLINK-20822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20822: - Fix Version/s: (was: 1.12.2) 1.12.1 > Don't check whether a function is

[jira] [Updated] (FLINK-20615) Local recovery and sticky scheduling end-to-end test timeout with "IOException: Stream Closed"

[ https://issues.apache.org/jira/browse/FLINK-20615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20615: - Fix Version/s: (was: 1.12.2) 1.12.1 > Local recovery and sticky

[jira] [Commented] (FLINK-20906) Update copyright year to 2021 for NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262530#comment-17262530 ] Xintong Song commented on FLINK-20906: -- [~chesnay], I've opened a PR for `flink-shaded`. Please

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261846#comment-17261846 ] Xintong Song commented on FLINK-20632: -- Thanks for driving the efforts, [~rmetzger]. I'm

[jira] [Closed] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-21024. Resolution: Fixed Fixed via * master (1.13): 1678b607ec16d58c595b40758192ed1d555b37d8 *

[jira] [Updated] (FLINK-21024) Dynamic properties get exposed to job's main method if user parameters are passed

[ https://issues.apache.org/jira/browse/FLINK-21024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21024: - Fix Version/s: 1.12.2 1.13.0 > Dynamic properties get exposed to job's main

[jira] [Closed] (FLINK-20960) Add warning in 1.12 release notes about potential corrupt data stream with unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20960. Resolution: Fixed Fixed via * master (1.13): 5905c7deb9040052cc5396156972e9dc8676c28a *

[jira] [Assigned] (FLINK-20835) Implement FineGrainedSlotManager

[ https://issues.apache.org/jira/browse/FLINK-20835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20835: Assignee: Yangze Guo > Implement FineGrainedSlotManager >

[jira] [Commented] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264790#comment-17264790 ] Xintong Song commented on FLINK-16267: -- Hi [~YordanPavlov], This ticket is closed because Flink by

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271746#comment-17271746 ] Xintong Song commented on FLINK-20632: -- I tried sign the images for 1.12.1, but couldn't find a way

[jira] [Commented] (FLINK-21144) KubernetesResourceManagerDriver#tryResetPodCreationCoolDown causes fatal error

[ https://issues.apache.org/jira/browse/FLINK-21144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271981#comment-17271981 ] Xintong Song commented on FLINK-21144: -- Nice catch! This escaped our tests because we use a fully

[jira] [Assigned] (FLINK-21144) KubernetesResourceManagerDriver#tryResetPodCreationCoolDown causes fatal error

[ https://issues.apache.org/jira/browse/FLINK-21144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21144: Assignee: Xintong Song > KubernetesResourceManagerDriver#tryResetPodCreationCoolDown

[jira] [Commented] (FLINK-21143) 【runtime】flink job use the lib jars instead of the `yarn.provided.lib.dirs` config jars

[ https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272011#comment-17272011 ] Xintong Song commented on FLINK-21143: -- Hi [~zhisheng], Could you share how is

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

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

[jira] [Updated] (FLINK-18640) Fix PostgresDialect doesn't quote the identifiers

[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18640: - Fix Version/s: (was: 1.10.3) 1.10.4 > Fix PostgresDialect doesn't quote

[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 ] Xintong Song updated FLINK-18460: - Fix Version/s: (was: 1.10.3) 1.10.4 > If the Python UDFs are called

[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 ] Xintong Song updated FLINK-18347: - Fix Version/s: (was: 1.10.3) 1.10.4 > kinesis connector throw Error

[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 ] Xintong Song updated FLINK-18276: - Fix Version/s: (was: 1.10.3) 1.10.4 > NullPointerException (and

[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 ] Xintong Song updated FLINK-18592: - Fix Version/s: (was: 1.10.3) 1.10.4 > StreamingFileSink fails due to

[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.10.3) 1.10.4 > Stop with savepoint cannot

[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 ] Xintong Song updated FLINK-17964: - Fix Version/s: (was: 1.10.3) 1.10.4 > Hivemodule does not support map

[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 ] Xintong Song updated FLINK-17642: - Fix Version/s: (was: 1.10.3) 1.10.4 > Exception while reading broken ORC

[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 ] Xintong Song updated FLINK-17742: - Fix Version/s: (was: 1.10.3) 1.10.4 > Blob file not removed after task

[jira] [Updated] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable

[ https://issues.apache.org/jira/browse/FLINK-17310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-17310: - Fix Version/s: (was: 1.10.3) 1.10.4 > Test blink planner failed to

[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 ] Xintong Song updated FLINK-16324: - Fix Version/s: (was: 1.10.3) 1.10.4 > Checkpoint tasks progress would

[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 ] Xintong Song updated FLINK-17329: - Fix Version/s: (was: 1.10.3) 1.10.4 > Quickstarts Scala nightly e2e test

[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 ] Xintong Song updated FLINK-16612: - Fix Version/s: (was: 1.10.3) 1.10.4 > Submit job through the rest api,

[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 ] Xintong Song updated FLINK-14159: - Fix Version/s: (was: 1.10.3) 1.10.4 > flink rocksdb

[jira] [Updated] (FLINK-15801) Timestamp extractor created from properties does not work for some physical fields

[ https://issues.apache.org/jira/browse/FLINK-15801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15801: - Fix Version/s: (was: 1.10.3) 1.10.4 > Timestamp extractor created from

[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 ] Xintong Song updated FLINK-15298: - Fix Version/s: (was: 1.10.3) 1.10.4 > Wrong dependencies in the

[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 ] Xintong Song updated FLINK-15471: - Fix Version/s: (was: 1.10.3) 1.10.4 > HA e2e check for empty .out files

[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 ] Xintong Song updated FLINK-15524: - Fix Version/s: (was: 1.10.3) 1.10.4 > Some links in Chinese documents

[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 ] Xintong Song updated FLINK-15262: - Fix Version/s: (was: 1.10.3) 1.10.4 > kafka connector doesn't read from

[jira] [Updated] (FLINK-15018) Add event time page to Concepts

[ https://issues.apache.org/jira/browse/FLINK-15018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15018: - Fix Version/s: (was: 1.10.3) 1.10.4 > Add event time page to Concepts >

[jira] [Created] (FLINK-21016) Upload missing packages to PyPI for release 1.12.1

Xintong Song created FLINK-21016: Summary: Upload missing packages to PyPI for release 1.12.1 Key: FLINK-21016 URL: https://issues.apache.org/jira/browse/FLINK-21016 Project: Flink Issue

[jira] [Updated] (FLINK-21016) Upload missing packages to PyPI for release 1.12.1

[ https://issues.apache.org/jira/browse/FLINK-21016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21016: - Description: Due to the PyPI project space limit, the following 1.12.1 packages are missing on

[jira] [Updated] (FLINK-20991) Create 1.12.1 official image

[ https://issues.apache.org/jira/browse/FLINK-20991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20991: - Affects Version/s: 1.12.1 > Create 1.12.1 official image > > >

[jira] [Updated] (FLINK-20747) ClassCastException when using MAX aggregate function

[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20747: - Fix Version/s: (was: 1.12.1) 1.12.2 > ClassCastException when using MAX

[jira] [Updated] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19925: - Fix Version/s: (was: 1.12.1) 1.12.2 > Errors$NativeIoException:

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

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

[jira] [Updated] (FLINK-20379) New Kafka Connector does not support DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20379: - Fix Version/s: (was: 1.12.1) 1.12.2 > New Kafka Connector does not

[jira] [Updated] (FLINK-20465) Fail globally when not resuming from the latest checkpoint in regional failover

[ https://issues.apache.org/jira/browse/FLINK-20465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20465: - Fix Version/s: (was: 1.12.1) 1.12.2 > Fail globally when not resuming

[jira] [Updated] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20714: - Fix Version/s: (was: 1.12.1) 1.12.2 > Hive delegation token is not

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

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

[jira] [Updated] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20359: - Fix Version/s: (was: 1.12.1) 1.12.2 > Support adding Owner Reference to

[jira] [Updated] (FLINK-20761) Cannot read hive table/partition whose location path contains comma

[ https://issues.apache.org/jira/browse/FLINK-20761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20761: - Fix Version/s: (was: 1.12.1) 1.12.2 > Cannot read hive table/partition

[jira] [Updated] (FLINK-20529) Publish Dockerfiles for release 1.12.0

[ https://issues.apache.org/jira/browse/FLINK-20529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20529: - Fix Version/s: (was: 1.12.1) 1.12.2 > Publish Dockerfiles for release

[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.1) 1.12.2 > Fix the handling of timestamp in

[jira] [Updated] (FLINK-20960) Add warning in 1.12 release notes about potential corrupt data stream with unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20960: - Fix Version/s: (was: 1.12.1) 1.12.2 > Add warning in 1.12 release notes

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20576: - Fix Version/s: (was: 1.12.1) 1.12.2 > Flink Temporal Join Hive Dim Error

[jira] [Updated] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

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

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20656: - Fix Version/s: (was: 1.12.1) 1.12.2 > Update docs for new KafkaSource

[jira] [Updated] (FLINK-20553) Add end-to-end test case for new Kafka source

[ https://issues.apache.org/jira/browse/FLINK-20553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20553: - Fix Version/s: (was: 1.12.1) 1.12.2 > Add end-to-end test case for new

[jira] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20655: - Fix Version/s: (was: 1.12.1) 1.12.2 > Add E2E tests to the new

[jira] [Updated] (FLINK-20565) Fix typo in EXPLAIN Statements docs.

[ https://issues.apache.org/jira/browse/FLINK-20565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20565: - Fix Version/s: (was: 1.12.1) 1.12.2 > Fix typo in EXPLAIN Statements

[jira] [Updated] (FLINK-20536) Update migration tests in master to cover migration from release-1.12

[ https://issues.apache.org/jira/browse/FLINK-20536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20536: - Fix Version/s: (was: 1.12.1) 1.12.2 > Update migration tests in master

<    5   6   7   8   9   10   11   12   13   14   >