shengjk1 created FLINK-18729:
Summary: kafka
Key: FLINK-18729
URL: https://issues.apache.org/jira/browse/FLINK-18729
Project: Flink
Issue Type: Improvement
Reporter: shengjk1
--
shengjk1 created FLINK-11725:
Summary: use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the
applied resources are erratic
Key: FLINK-11725
URL: https://issues.apache.org/jira/browse/FLINK-11725
Project: F
shengjk1 created FLINK-11673:
Summary: add example for streaming operators's broadcast
Key: FLINK-11673
URL: https://issues.apache.org/jira/browse/FLINK-11673
Project: Flink
Issue Type: Improveme
shengjk1 created FLINK-11672:
Summary: Add example for streaming operator connect
Key: FLINK-11672
URL: https://issues.apache.org/jira/browse/FLINK-11672
Project: Flink
Issue Type: Improvement
shengjk1 created FLINK-11469:
Summary: fix Tuning Checkpoints and Large State doc
Key: FLINK-11469
URL: https://issues.apache.org/jira/browse/FLINK-11469
Project: Flink
Issue Type: Improvement
shengjk1 created FLINK-11377:
Summary: AbstractYarnClusterDescriptor's validClusterSpecification
is not final application resources from yarn if cli -yn -ys not effect
Key: FLINK-11377
URL: https://issues.apache.o
shengjk1 created FLINK-11376:
Summary: flink cli -yn -ys is not effect if (yn *
ys)https://issues.apache.org/jira/browse/FLINK-11376
Project: Flink
Issue Type: Bug
Affects Versions: 1.7.1
Environment: java: jdk1.
shengjk1 created FLINK-11336:
Summary: Flink HA didn't remove ZK metadata
Key: FLINK-11336
URL: https://issues.apache.org/jira/browse/FLINK-11336
Project: Flink
Issue Type: Improvement
shengjk1 created FLINK-11257:
Summary: FlinkKafkaConsumer should support assgin partition
Key: FLINK-11257
URL: https://issues.apache.org/jira/browse/FLINK-11257
Project: Flink
Issue Type: New F