[jira] [Created] (FLINK-21779) testResourceCanBeAllocatedForDifferentJobWithDeclarationBeforeSlotFree fail because of timeout

2021-03-14 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21779: - Summary: testResourceCanBeAllocatedForDifferentJobWithDeclarationBeforeSlotFree fail because of timeout Key: FLINK-21779 URL: https://issues.apache.org/jira/browse/FLINK-21779

[jira] [Created] (FLINK-21780) SourceStreamTaskTest hangs (no output for 900 seconds)

2021-03-14 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21780: - Summary: SourceStreamTaskTest hangs (no output for 900 seconds) Key: FLINK-21780 URL: https://issues.apache.org/jira/browse/FLINK-21780 Project: Flink Issue Type:

[jira] [Created] (FLINK-21781) Lookup Table based on rowkey ranges

2021-03-14 Thread Felipe Lolas (Jira)
Felipe Lolas created FLINK-21781: Summary: Lookup Table based on rowkey ranges Key: FLINK-21781 URL: https://issues.apache.org/jira/browse/FLINK-21781 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21782) Lookup Table based on rowkey ranges

2021-03-14 Thread Felipe Lolas (Jira)
Felipe Lolas created FLINK-21782: Summary: Lookup Table based on rowkey ranges Key: FLINK-21782 URL: https://issues.apache.org/jira/browse/FLINK-21782 Project: Flink Issue Type: Improvement

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

2021-03-14 Thread Thomas Weise
Hi Nicholas, Thanks for the reply. I had implemented a small PoC. It switches a configurable sequence of sources with predefined bounds. I'm using the unmodified MockSource for illustration. It does not require a "Switchable" interface. I looked at the code you shared and the delegation and signal

[jira] [Created] (FLINK-21783) Allow extension of HeapBackend SnapshotStrategy

2021-03-14 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21783: - Summary: Allow extension of HeapBackend SnapshotStrategy Key: FLINK-21783 URL: https://issues.apache.org/jira/browse/FLINK-21783 Project: Flink Iss

[jira] [Created] (FLINK-21784) Allow extension of HeapBackend RestoreOperation

2021-03-14 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21784: - Summary: Allow extension of HeapBackend RestoreOperation Key: FLINK-21784 URL: https://issues.apache.org/jira/browse/FLINK-21784 Project: Flink Iss

Re: [DISCUSS] FLIP-154: SQL Implicit Type Coercion

2021-03-14 Thread Jingsong Li
Thanks Danny for your update, the FLIP page looks very good now. Flink already has some implicit casting rules in LogicalTypeCasts[1]. The biggest difference is that the previous implicit casting is strictly limited to the safety, "Implicit casts are used for safe type widening and type generaliza

[jira] [Created] (FLINK-21785) Support StreamExecCorrelate json serde

2021-03-14 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-21785: --- Summary: Support StreamExecCorrelate json serde Key: FLINK-21785 URL: https://issues.apache.org/jira/browse/FLINK-21785 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21786) sample Job execution failed

2021-03-14 Thread Bhagi (Jira)
Bhagi created FLINK-21786: - Summary: sample Job execution failed Key: FLINK-21786 URL: https://issues.apache.org/jira/browse/FLINK-21786 Project: Flink Issue Type: Bug Components: Deploymen

[jira] [Created] (FLINK-21787) The method $(String) is undefined for the type TableExample

2021-03-14 Thread wangbin (Jira)
wangbin created FLINK-21787: --- Summary: The method $(String) is undefined for the type TableExample Key: FLINK-21787 URL: https://issues.apache.org/jira/browse/FLINK-21787 Project: Flink Issue Type

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

2021-03-14 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21788: --- Summary: Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle Key: FLINK-21788 URL: https://issues.apache.org/jira/browse/FLINK-21788

[jira] [Created] (FLINK-21789) Make FileChannelManagerImpl#getNextPathNum select data directory fairly

2021-03-14 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21789: --- Summary: Make FileChannelManagerImpl#getNextPathNum select data directory fairly Key: FLINK-21789 URL: https://issues.apache.org/jira/browse/FLINK-21789 Project: Flink

[jira] [Created] (FLINK-21790) Shuffle data directories to make data directory section of different TaskManagers fairer

2021-03-14 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-21790: --- Summary: Shuffle data directories to make data directory section of different TaskManagers fairer Key: FLINK-21790 URL: https://issues.apache.org/jira/browse/FLINK-21790