[jira] [Comment Edited] (FLINK-18729) Make flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165593#comment-17165593 ] shengjk1 edited comment on FLINK-18729 at 7/27/20, 11:53 AM: - if no any

[jira] [Updated] (FLINK-18729) Flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: In streaming api, flink kafka producer can't auto discovery partition when the change of

[jira] [Updated] (FLINK-18729) Make flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Summary: Make flink streaming kafka producer auto discovery partition (was: Flink streaming kafka

[jira] [Updated] (FLINK-18729) Flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: Now, In streaming api, flink kafka producer can't auto discovery partition when the change

[jira] [Updated] (FLINK-18729) Flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: Now, flink streaming kafka producer can't auto discovery partition when the change of

[jira] [Updated] (FLINK-18729) Flink streaming kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: Now, flink streaming kafka producer can't auto discovery partition when the change of

[jira] [Updated] (FLINK-18729) Flink kafka producer auto discovery partition

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Summary: Flink kafka producer auto discovery partition (was: kafka) > Flink kafka producer auto

[jira] [Updated] (FLINK-18729) kafka

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Description: Now, flink kafka producer can't auto discovery partition when the change of kafka

[jira] [Commented] (FLINK-18729) kafka

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165593#comment-17165593 ] shengjk1 commented on FLINK-18729: -- if no any question, i will write code about it. > kafka > - >

[jira] [Updated] (FLINK-18729) kafka

[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-18729: - Component/s: Connectors / Kafka Affects Version/s: 1.10.0 1.10.1

[jira] [Created] (FLINK-18729) kafka

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

[jira] [Issue Comment Deleted] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-7289: Comment: was deleted (was: Thanks [~yunta] and [~mikekap]. I have solved it. As Mike Kaplinskiy said, i

[jira] [Comment Edited] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961652#comment-16961652 ] shengjk1 edited comment on FLINK-7289 at 10/29/19 3:55 AM: --- Thanks [~yunta] and

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961652#comment-16961652 ] shengjk1 commented on FLINK-7289: - Thanks [~yunta] and [~mikekap]. I have solved it. As Mike Kaplinskiy

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958725#comment-16958725 ] shengjk1 commented on FLINK-7289: - [~yunta] I don't know how to get the LOG file rockdb, this is my code

[jira] [Comment Edited] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956749#comment-16956749 ] shengjk1 edited comment on FLINK-7289 at 10/22/19 7:11 AM: ---  I also rebuild

[jira] [Comment Edited] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956749#comment-16956749 ] shengjk1 edited comment on FLINK-7289 at 10/22/19 7:10 AM: ---  I also rebuild

[jira] [Comment Edited] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956749#comment-16956749 ] shengjk1 edited comment on FLINK-7289 at 10/22/19 7:09 AM: ---  I also rebuild

[jira] [Comment Edited] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956749#comment-16956749 ] shengjk1 edited comment on FLINK-7289 at 10/22/19 7:09 AM: ---  I also rebuild

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956749#comment-16956749 ] shengjk1 commented on FLINK-7289: -  I also rebuild flink and use writeBufferManager. For one specific job

[jira] [Updated] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-7289: Affects Version/s: 1.7.2 1.8.2 1.9.0 > Memory allocation of

[jira] [Commented] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907048#comment-16907048 ] shengjk1 commented on FLINK-11608: -- Ok, I have appended an update commit [~jark] [~WangHW] > Translate

[jira] [Comment Edited] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905962#comment-16905962 ] shengjk1 edited comment on FLINK-11608 at 8/13/19 8:51 AM: --- Hi [~WangHW] ,

[jira] [Commented] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905962#comment-16905962 ] shengjk1 commented on FLINK-11608: -- Hi [~WangHW] , thanks for your comments. I also read [“Flink

[jira] [Commented] (FLINK-11789) Checkpoint directories are not cleaned up after job termination

[ https://issues.apache.org/jira/browse/FLINK-11789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785178#comment-16785178 ] shengjk1 commented on FLINK-11789: -- i agree  [~yunta] , I also think it would be worthy to discuss

[jira] [Commented] (FLINK-11789) Checkpoint directories are not cleaned up after job termination

[ https://issues.apache.org/jira/browse/FLINK-11789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781722#comment-16781722 ] shengjk1 commented on FLINK-11789: -- i think  delete checkpoints/JOB_ID}} should contains three

[jira] [Commented] (FLINK-11336) Flink HA didn't remove ZK metadata

[ https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781683#comment-16781683 ] shengjk1 commented on FLINK-11336: -- [~till.rohrmann]  Yay, i think too, thank you  > Flink HA didn't

[jira] [Commented] (FLINK-11336) Flink HA didn't remove ZK metadata

[ https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781618#comment-16781618 ] shengjk1 commented on FLINK-11336: -- hi, [~till.rohrmann]  I have other questions and suggestions:  1.

[jira] [Commented] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776504#comment-16776504 ] shengjk1 commented on FLINK-11725: -- 1.7.2已修复 > use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the

[jira] [Closed] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 closed FLINK-11725. Resolution: Fixed Fix Version/s: 1.7.2 > use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the

[jira] [Updated] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11725: - Environment: flink1.7.2 linux java8 kafka1.1 scala 2.1 CDH  was: flink1.7.1 linux java8

[jira] [Updated] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11725: - Description: I provide a simple example and used resource's picture for this issue  this application

[jira] [Comment Edited] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774999#comment-16774999 ] shengjk1 edited comment on FLINK-11725 at 2/25/19 2:54 AM: --- i think two ways 

[jira] [Updated] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11725: - Attachment: MainConnect4.java > use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources

[jira] [Updated] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11725: - Environment: flink1.7.1 linux java8 kafka1.1 was: flink1.7.2 linux java8 kafka1.1 > use

[jira] [Comment Edited] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774999#comment-16774999 ] shengjk1 edited comment on FLINK-11725 at 2/22/19 10:53 AM: i think two ways 

[jira] [Created] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

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:

[jira] [Commented] (FLINK-11725) use flink cli when {{-yn}} * {{-ys}} < {{-p}}, the applied resources are erratic

[ https://issues.apache.org/jira/browse/FLINK-11725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774999#comment-16774999 ] shengjk1 commented on FLINK-11725: -- i think two ways solve this issue: 1.Add judgment in

[jira] [Updated] (FLINK-11672) Add example for streaming operators's connect

[ https://issues.apache.org/jira/browse/FLINK-11672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11672: - Description: add example for streaming operators's connect such as

[jira] [Commented] (FLINK-11672) Add example for streaming operator connect

[ https://issues.apache.org/jira/browse/FLINK-11672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773601#comment-16773601 ] shengjk1 commented on FLINK-11672: -- hi, [~StephanEwen] ,Thanks for your attention, I mean to add

[jira] [Updated] (FLINK-11672) Add example for streaming operator connect

[ https://issues.apache.org/jira/browse/FLINK-11672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11672: - Description: add example for streaming operator connect in code (was: add example for streaming

[jira] [Updated] (FLINK-11672) Add example for streaming operator connect

[ https://issues.apache.org/jira/browse/FLINK-11672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11672: - Component/s: Examples > Add example for streaming operator connect >

[jira] [Created] (FLINK-11673) add example for streaming operators's broadcast

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:

[jira] [Created] (FLINK-11672) Add example for streaming operator connect

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

[jira] [Comment Edited] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770027#comment-16770027 ] shengjk1 edited comment on FLINK-11608 at 2/16/19 6:58 AM: --- hi [~jark]   I

[jira] [Commented] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770027#comment-16770027 ] shengjk1 commented on FLINK-11608: -- hi [~jark]   I want to know when and where I can create a PR for

[jira] [Assigned] (FLINK-11608) Translate the "Local Setup Tutorial" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 reassigned FLINK-11608: Assignee: shengjk1 > Translate the "Local Setup Tutorial" page into Chinese >

[jira] [Created] (FLINK-11469) fix Tuning Checkpoints and Large State doc

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

[jira] [Commented] (FLINK-11336) Flink HA didn't remove ZK metadata

[ https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749548#comment-16749548 ] shengjk1 commented on FLINK-11336: -- Yarn (per job or as a session) > Flink HA didn't remove ZK

[jira] [Comment Edited] (FLINK-11336) Flink HA didn't remove ZK metadata

[ https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749548#comment-16749548 ] shengjk1 edited comment on FLINK-11336 at 1/23/19 5:53 AM: --- Yarn (per job or

[jira] [Commented] (FLINK-11336) Flink HA didn't remove ZK metadata

[ https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747322#comment-16747322 ] shengjk1 commented on FLINK-11336: -- 1.No matter what form stop flink, such  as cancel,failed with no

[jira] [Commented] (FLINK-11336) Flink HA didn't remove ZK metadata

[ https://issues.apache.org/jira/browse/FLINK-11336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745782#comment-16745782 ] shengjk1 commented on FLINK-11336: -- Unfamiliar with batch and bounded streams,so Inconvenient

[jira] [Closed] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys)

[ https://issues.apache.org/jira/browse/FLINK-11376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 closed FLINK-11376. Resolution: Not A Problem > flink cli -yn -ys is not effect if (yn * ys) parallelism form

[jira] [Commented] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect

[ https://issues.apache.org/jira/browse/FLINK-11377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745724#comment-16745724 ] shengjk1 commented on FLINK-11377: -- yes thanks > AbstractYarnClusterDescriptor's

[jira] [Closed] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect

[ https://issues.apache.org/jira/browse/FLINK-11377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 closed FLINK-11377. Resolution: Not A Problem > AbstractYarnClusterDescriptor's validClusterSpecification is not final >

[jira] [Commented] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys)

[ https://issues.apache.org/jira/browse/FLINK-11376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745721#comment-16745721 ] shengjk1 commented on FLINK-11376: -- Hi,Till Rohrmann,thanks for you comment,I agree with your

[jira] [Updated] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys)

[ https://issues.apache.org/jira/browse/FLINK-11376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11376: - Attachment: Main222.java > flink cli -yn -ys is not effect if (yn * ys) parallelism form

[jira] [Updated] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys)

[ https://issues.apache.org/jira/browse/FLINK-11376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11376: - Attachment: (was: Main222.java) > flink cli -yn -ys is not effect if (yn * ys) parallelism form

[jira] [Updated] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect

[ https://issues.apache.org/jira/browse/FLINK-11377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11377: - Description: when cli  -yn -ys not effect ,AbstractYarnClusterDescriptor's validClusterSpecification

[jira] [Created] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys)

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:

[jira] [Created] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect

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:

[jira] [Created] (FLINK-11336) Flink HA didn't remove ZK metadata

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

[jira] [Commented] (FLINK-11257) FlinkKafkaConsumer should support assgin partition

[ https://issues.apache.org/jira/browse/FLINK-11257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732855#comment-16732855 ] shengjk1 commented on FLINK-11257: -- hi ,[~till.rohrmann],In order to ensure the compatibility of

[jira] [Updated] (FLINK-11257) FlinkKafkaConsumer should support assgin partition

[ https://issues.apache.org/jira/browse/FLINK-11257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengjk1 updated FLINK-11257: - Priority: Major (was: Minor) > FlinkKafkaConsumer should support assgin partition >

[jira] [Created] (FLINK-11257) FlinkKafkaConsumer should support assgin partition

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