[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636390#comment-17636390 ] nobleyd commented on FLINK-28695: - [~pnowojski] Hi, we have the same problem, and adjusting

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635285#comment-17635285 ] nobleyd commented on FLINK-28695: - We also encounter this problem in production, and task failures will

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626171#comment-17626171 ] nobleyd commented on FLINK-27341: - Hi, this issue is not resolve in flink1.16, whilte I think it is

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17585171#comment-17585171 ] nobleyd commented on FLINK-27341: - Hi, I want to known which release will fix this issue, is there any

[jira] [Created] (FLINK-28577) 1.15.1 web ui console report error about checkpoint size

nobleyd created FLINK-28577: --- Summary: 1.15.1 web ui console report error about checkpoint size Key: FLINK-28577 URL: https://issues.apache.org/jira/browse/FLINK-28577 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24758) filesystem sink: partition.time-extractor.kind support "yyyyMMdd"

[ https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441689#comment-17441689 ] nobleyd commented on FLINK-24758: - It is better if make it configurable for the user. For example, a new

[jira] [Commented] (FLINK-10740) FLIP-27: Refactor Source Interface

[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402793#comment-17402793 ] nobleyd commented on FLINK-10740: - Since the source split output is created in

[jira] [Commented] (FLINK-21507) Reinterpreting stream as keyed breaks the upstream partitioning

[ https://issues.apache.org/jira/browse/FLINK-21507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311268#comment-17311268 ] nobleyd commented on FLINK-21507: - Hi, [~izeigerman]. I don't know what is the original purpose for you

[jira] [Commented] (FLINK-11536) cannot start standalone cluster - failed to bind to /0.0.0.0:6123

[ https://issues.apache.org/jira/browse/FLINK-11536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294328#comment-17294328 ] nobleyd commented on FLINK-11536: - [~yunta] Hi. I also met this problem, but my taskmanager is not

[jira] [Commented] (FLINK-21507) Given a sequence of multiple custom stream partitioning operations only last transformation in sequence is applied while others are dropped

[ https://issues.apache.org/jira/browse/FLINK-21507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291418#comment-17291418 ] nobleyd commented on FLINK-21507: - {quote}I see that only last partitioning operation

[jira] [Commented] (FLINK-18799) improve slot allocation to make resource balance among machines.

[ https://issues.apache.org/jira/browse/FLINK-18799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169765#comment-17169765 ] nobleyd commented on FLINK-18799: - [~zhuzh] Maybe some detail is not clear and make you confused. I do

[jira] [Updated] (FLINK-18799) improve slot allocation to make resource balance among machines.

[ https://issues.apache.org/jira/browse/FLINK-18799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nobleyd updated FLINK-18799: Description:   I have a completed job, and each vertex may have different parallelism, and what troubles

[jira] [Created] (FLINK-18799) improve slot allocation to make resource balance among machines.

nobleyd created FLINK-18799: --- Summary: improve slot allocation to make resource balance among machines. Key: FLINK-18799 URL: https://issues.apache.org/jira/browse/FLINK-18799 Project: Flink

[jira] [Closed] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10

[ https://issues.apache.org/jira/browse/FLINK-17479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nobleyd closed FLINK-17479. --- Release Note: JDK issue Resolution: Fixed > Occasional checkpoint failure due to null pointer

[jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108317#comment-17108317 ] nobleyd commented on FLINK-17493: - [~xintongsong] Yes, it comes to direct memory OOM. > Possible direct

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107341#comment-17107341 ] nobleyd commented on FLINK-17487: - [~rmetzger] No, if I cancel the job, the checkpoints will be retained

[jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107331#comment-17107331 ] nobleyd commented on FLINK-17493: - [~xintongsong], I readjusted the affected version, which was

[jira] [Updated] (FLINK-17493) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nobleyd updated FLINK-17493: Attachment: image-2020-05-14-21-58-59-152.png > Possible direct memory leak in cassandra sink >

[jira] [Updated] (FLINK-17493) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nobleyd updated FLINK-17493: Affects Version/s: (was: 1.9.3) 1.9.0 > Possible direct memory leak in

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103613#comment-17103613 ] nobleyd commented on FLINK-17487: - I think the only two case that the checkpoints should be deleted is

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103612#comment-17103612 ] nobleyd commented on FLINK-17487: - Someone may say if I need to restart the job using an older

[jira] [Commented] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10

[ https://issues.apache.org/jira/browse/FLINK-17479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103610#comment-17103610 ] nobleyd commented on FLINK-17479: - [~klion26] In fact, this is exactly what I feel strange. I don't

[jira] [Issue Comment Deleted] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10

[ https://issues.apache.org/jira/browse/FLINK-17479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nobleyd updated FLINK-17479: Comment: was deleted (was: [~klion26]   In fact, this is exactly what I feel strange. I don't know the

[jira] [Commented] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10

[ https://issues.apache.org/jira/browse/FLINK-17479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103607#comment-17103607 ] nobleyd commented on FLINK-17479: - [~klion26]   In fact, this is exactly what I feel strange. I don't

[jira] [Closed] (FLINK-17492) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nobleyd closed FLINK-17492. --- Resolution: Duplicate > Possible direct memory leak in cassandra sink >

[jira] [Created] (FLINK-17494) Possible direct memory leak in cassandra sink

nobleyd created FLINK-17494: --- Summary: Possible direct memory leak in cassandra sink Key: FLINK-17494 URL: https://issues.apache.org/jira/browse/FLINK-17494 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17493) Possible direct memory leak in cassandra sink

nobleyd created FLINK-17493: --- Summary: Possible direct memory leak in cassandra sink Key: FLINK-17493 URL: https://issues.apache.org/jira/browse/FLINK-17493 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17492) Possible direct memory leak in cassandra sink

nobleyd created FLINK-17492: --- Summary: Possible direct memory leak in cassandra sink Key: FLINK-17492 URL: https://issues.apache.org/jira/browse/FLINK-17492 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17487) Do not delete old checkpoints when stop the job.

nobleyd created FLINK-17487: --- Summary: Do not delete old checkpoints when stop the job. Key: FLINK-17487 URL: https://issues.apache.org/jira/browse/FLINK-17487 Project: Flink Issue Type:

[jira] [Created] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10

nobleyd created FLINK-17479: --- Summary: Occasional checkpoint failure due to null pointer exception in Flink version 1.10 Key: FLINK-17479 URL: https://issues.apache.org/jira/browse/FLINK-17479 Project: