[jira] [Created] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

hiliuxg created FLINK-16585: --- Summary: Table program cannot be compiled.Cannot determine simple type name "com" Key: FLINK-16585 URL: https://issues.apache.org/jira/browse/FLINK-16585 Project: Flink

[jira] [Comment Edited] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004012#comment-17004012 ] hiliuxg edited comment on FLINK-15388 at 12/27/19 8:35 AM: --- Hi [~xintongsong]

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004012#comment-17004012 ] hiliuxg commented on FLINK-15388: - That error log was a colleague who asked for the job status every 10

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Attachment: tm.png > The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. >

[jira] [Commented] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003926#comment-17003926 ] hiliuxg commented on FLINK-15415: - Hi [~yunta]: Sorry, I don’t know if you can create a new question

[jira] [Commented] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003916#comment-17003916 ] hiliuxg commented on FLINK-15415: - Hi [~Benchao Li]: Thank you for following my question . I used the

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Attachment: 236log.7z > The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. >

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Attachment: 236log.7z > The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. >

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003911#comment-17003911 ] hiliuxg commented on FLINK-15388: - Hi [~xintongsong]: I ping taskmanager on the machine where the

[jira] [Comment Edited] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003869#comment-17003869 ] hiliuxg edited comment on FLINK-15388 at 12/27/19 5:42 AM: --- Hi [~xintongsong]:

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003869#comment-17003869 ] hiliuxg commented on FLINK-15388: - Hi [~xintongsong]: The problem reappears, the network is ok, the CPU

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Attachment: metrics.png > The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. >

[jira] [Comment Edited] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003854#comment-17003854 ] hiliuxg edited comment on FLINK-15415 at 12/27/19 3:23 AM: --- !flink-pid.png!

[jira] [Updated] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15415: Description:  The Flink node has been running for 1 month, and it is found that the machine's memory is

[jira] [Updated] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15415: Description:  The Flink node has been running for 1 month, and it is found that the machine's memory is

[jira] [Commented] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003854#comment-17003854 ] hiliuxg commented on FLINK-15415: - !flink-pid.png! !flink-pid-2.png! !flink-3.png!   > Flink machine

[jira] [Updated] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15415: Attachment: flink-3.png > Flink machine node memory is consumed quickly, but the heap has not changed >

[jira] [Updated] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15415: Attachment: flink-pid.png > Flink machine node memory is consumed quickly, but the heap has not changed >

[jira] [Updated] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

[ https://issues.apache.org/jira/browse/FLINK-15415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15415: Attachment: flink-pid-2.png > Flink machine node memory is consumed quickly, but the heap has not changed

[jira] [Created] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

hiliuxg created FLINK-15415: --- Summary: Flink machine node memory is consumed quickly, but the heap has not changed Key: FLINK-15415 URL: https://issues.apache.org/jira/browse/FLINK-15415 Project: Flink

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003419#comment-17003419 ] hiliuxg commented on FLINK-15388: - Hi [~xintongsong]  Is it possible for flink to manually assign a job

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Attachment: metrics.png > The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. >

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003289#comment-17003289 ] hiliuxg commented on FLINK-15388: - Hi [~xintongsong] Is it possible that TM is too busy, causing akka

[jira] [Comment Edited] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003173#comment-17003173 ] hiliuxg edited comment on FLINK-15388 at 12/25/19 9:43 AM: --- hi [~xintongsong]

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003173#comment-17003173 ] hiliuxg commented on FLINK-15388: - [~xintongsong] Thank you so much for taking the time to help me

[jira] [Issue Comment Deleted] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Comment: was deleted (was: Hi Xintong Song: the complete log file can be download by link

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003128#comment-17003128 ] hiliuxg commented on FLINK-15388: - Hi Xintong Song: the complete log file can be download by link

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003129#comment-17003129 ] hiliuxg commented on FLINK-15388: - Hi Xintong Song: the complete log file can be download by link

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003093#comment-17003093 ] hiliuxg commented on FLINK-15388: - Hi Xintong Song : There is also a error log ,Does not is related to

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003090#comment-17003090 ] hiliuxg commented on FLINK-15388: - Hi,Xintong Song: Thanks for your patience，the related logs has

[jira] [Commented] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003064#comment-17003064 ] hiliuxg commented on FLINK-15388: - Hi xintong Song, The TM is not failed also the heap is not full .

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Description: the taskmanager's slot was removed , there was not full gc or oom , what's the problem ?

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Environment: model : standalone,not yarn version :  flink 1.8.0 configration :  jobmanager.heap.size:

[jira] [Updated] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

[ https://issues.apache.org/jira/browse/FLINK-15388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hiliuxg updated FLINK-15388: Environment: model : standalone,not yarn version :  flink 1.8.0 configration :  jobmanager.heap.size:

[jira] [Created] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed.

hiliuxg created FLINK-15388: --- Summary: The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. Key: FLINK-15388 URL: https://issues.apache.org/jira/browse/FLINK-15388 Project: Flink

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16904324#comment-16904324 ] hiliuxg commented on FLINK-10114: - Hi,[~yanghua] , My implement is made with  Bucketing Sink and Hadoop

[jira] [Comment Edited] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16904323#comment-16904323 ] hiliuxg edited comment on FLINK-10114 at 8/10/19 5:04 AM: -- Hi,[~kien_truong]. I

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16904323#comment-16904323 ] hiliuxg commented on FLINK-10114: - I try , But the StreamingFileSink base api hard to implement the orc

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903704#comment-16903704 ] hiliuxg commented on FLINK-10114: - I have  already  implemented this feature . It can guarantee