[jira] [Created] (FLINK-22640) DataGen SQL Connector does not support defining fields min/max option of decimal type field

2021-05-11 Thread lincoln lee (Jira)
lincoln lee created FLINK-22640: --- Summary: DataGen SQL Connector does not support defining fields min/max option of decimal type field Key: FLINK-22640 URL: https://issues.apache.org/jira/browse/FLINK-22640

[jira] [Created] (FLINK-22630) Different com.squareup.okhttp3:okhttp dependency versions might lead to version conflicts with io.fabric8:kubernetes-server-mock

2021-05-11 Thread Matthias (Jira)
Matthias created FLINK-22630: Summary: Different com.squareup.okhttp3:okhttp dependency versions might lead to version conflicts with io.fabric8:kubernetes-server-mock Key: FLINK-22630 URL:

[jira] [Created] (FLINK-22631) Metrics are incorrect when task finished

2021-05-11 Thread Li (Jira)
Li created FLINK-22631: -- Summary: Metrics are incorrect when task finished Key: FLINK-22631 URL: https://issues.apache.org/jira/browse/FLINK-22631 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-22639) ClassLoaderUtil cannot print classpath of FlinkUserCodeClassLoader

2021-05-11 Thread Adrian Zhong (Jira)
Adrian Zhong created FLINK-22639: Summary: ClassLoaderUtil cannot print classpath of FlinkUserCodeClassLoader Key: FLINK-22639 URL: https://issues.apache.org/jira/browse/FLINK-22639 Project: Flink

[jira] [Created] (FLINK-22629) table api sql ask

2021-05-11 Thread Leo (Jira)
Leo created FLINK-22629: --- Summary: table api sql ask Key: FLINK-22629 URL: https://issues.apache.org/jira/browse/FLINK-22629 Project: Flink Issue Type: Bug Reporter: Leo

Re: Task Local Recovery with mountable disks in the cloud

2021-05-11 Thread Yang Wang
Just a side input, not only the persistent volume could help with keeping the local state for the TaskManager pod, but also the ephemeral storage. Ephemeral storage is bound to the lifecycle of TaskManager pod. And it could be shared between different restarts of TaskManager container. Best,

[jira] [Created] (FLINK-22625) FileSinkMigrationITCase unstable

2021-05-11 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22625: Summary: FileSinkMigrationITCase unstable Key: FLINK-22625 URL: https://issues.apache.org/jira/browse/FLINK-22625 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure

2021-05-11 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22626: Summary: KafkaITCase.testTimestamps fails on Azure Key: FLINK-22626 URL: https://issues.apache.org/jira/browse/FLINK-22626 Project: Flink Issue

[jira] [Created] (FLINK-22627) Remove SlotManagerImpl

2021-05-11 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-22627: -- Summary: Remove SlotManagerImpl Key: FLINK-22627 URL: https://issues.apache.org/jira/browse/FLINK-22627 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-22628) Modify web page display problem

2021-05-11 Thread quyanghaoren (Jira)
quyanghaoren created FLINK-22628: Summary: Modify web page display problem Key: FLINK-22628 URL: https://issues.apache.org/jira/browse/FLINK-22628 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22637) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed

2021-05-11 Thread Matthias (Jira)
Matthias created FLINK-22637: Summary: UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue failed Key: FLINK-22637 URL: https://issues.apache.org/jira/browse/FLINK-22637 Project: Flink

[jira] [Created] (FLINK-22638) Keep channels blocked on alignment timeout

2021-05-11 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22638: Summary: Keep channels blocked on alignment timeout Key: FLINK-22638 URL: https://issues.apache.org/jira/browse/FLINK-22638 Project: Flink Issue

[jira] [Created] (FLINK-22636) Group job specific ZooKeeper HA services under common jobs/ zNode

2021-05-11 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22636: - Summary: Group job specific ZooKeeper HA services under common jobs/ zNode Key: FLINK-22636 URL: https://issues.apache.org/jira/browse/FLINK-22636 Project: Flink

[jira] [Created] (FLINK-22632) CatalogFunctionImpl.isGeneric should use ContextClassLoader

2021-05-11 Thread Zhong Zhuang (Jira)
Zhong Zhuang created FLINK-22632: Summary: CatalogFunctionImpl.isGeneric should use ContextClassLoader Key: FLINK-22632 URL: https://issues.apache.org/jira/browse/FLINK-22632 Project: Flink

[jira] [Created] (FLINK-22635) Checkpoint history lost across parallelism changes

2021-05-11 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22635: Summary: Checkpoint history lost across parallelism changes Key: FLINK-22635 URL: https://issues.apache.org/jira/browse/FLINK-22635 Project: Flink

[jira] [Created] (FLINK-22633) Add a Harness example to flink-statefun-playground

2021-05-11 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-22633: Summary: Add a Harness example to flink-statefun-playground Key: FLINK-22633 URL: https://issues.apache.org/jira/browse/FLINK-22633 Project: Flink Issue

[jira] [Created] (FLINK-22634) tableEnvironment executeSql

2021-05-11 Thread Leo (Jira)
Leo created FLINK-22634: --- Summary: tableEnvironment executeSql Key: FLINK-22634 URL: https://issues.apache.org/jira/browse/FLINK-22634 Project: Flink Issue Type: Bug Reporter: Leo