Why does jobmanager running needs slot ?

2018-02-04 Thread mingleizhang
I find some codes in flink does not make sense to me. Like in some classes below: JobMasterGateway.java has a offerSlots method which means Offers the given slots to the job manager. I was wondering why a jobmanager running should need slots ? TaskExecutor.java has a offerSlotsToJobManager met

[jira] [Created] (FLINK-8556) Add proxy usage to Kinesis Connector to acces its endpoint

2018-02-04 Thread Ph.Duveau (JIRA)
Ph.Duveau created FLINK-8556: Summary: Add proxy usage to Kinesis Connector to acces its endpoint Key: FLINK-8556 URL: https://issues.apache.org/jira/browse/FLINK-8556 Project: Flink Issue Type: