Guowei Ma created FLINK-21779:
-
Summary:
testResourceCanBeAllocatedForDifferentJobWithDeclarationBeforeSlotFree fail
because of timeout
Key: FLINK-21779
URL: https://issues.apache.org/jira/browse/FLINK-21779
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:
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
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
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
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
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
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
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
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
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
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
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
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
14 matches
Mail list logo