[jira] [Created] (FLINK-19499) Expose Metric Groups to Split Assigners

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: Improveme

[jira] [Created] (FLINK-19498) Port LocatableInputSplitAssigner to new File Source API

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 Issue

Flink table error in 1.11 "Could not find a suitable table factory "

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 'org.apache.flink.table.factories.TableSourceFacto

Re: CheckpointedFunction initialization during checkpoint

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 into