Stephan Ewen created FLINK-19499:
Summary: Expose Metric Groups to Split Assigners
Key: FLINK-19499
URL: https://issues.apache.org/jira/browse/FLINK-19499
Project: Flink
Issue Type:
Stephan Ewen created FLINK-19498:
Summary: Port LocatableInputSplitAssigner to new File Source API
Key: FLINK-19498
URL: https://issues.apache.org/jira/browse/FLINK-19498
Project: Flink
Hi Team,
I am trying Flink 1.11 by using the official doc and examples. Here is my code.
While executing I am getting this error.
Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could
not find a suitable table factory for
Hi Teng
As Aljoscha said, this should not be a problem as some parts are processing
records while some are still restoring in the whole graph.
For the 2nd question "Are the initializations in 4) causing the checkpoint to
take longer to complete", the answer is yes.
As the stream task turns
