[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644800#comment-17644800 ] zhanglu153 commented on FLINK-30075: [~luoyuxia] You can read the hadoop source code

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638033#comment-17638033 ] zhanglu153 edited comment on FLINK-30075 at 11/24/22 2:09 AM:

[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638033#comment-17638033 ] zhanglu153 commented on FLINK-30075: [~martijnvisser] When using hadoop 2.10.1 durin

[jira] [Created] (FLINK-30095) Flink's JobCluster ResourceManager should throw an exception when the failure number of starting worker reaches the maximum failure rate

zhanglu153 created FLINK-30095: -- Summary: Flink's JobCluster ResourceManager should throw an exception when the failure number of starting worker reaches the maximum failure rate Key: FLINK-30095 URL: https://issues

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635770#comment-17635770 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 6:05 AM:

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635734#comment-17635734 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 5:57 AM:

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635696#comment-17635696 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 5:47 AM:

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635635#comment-17635635 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 3:32 AM:

[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635770#comment-17635770 ] zhanglu153 commented on FLINK-30075: This error is related to the hadoop version and

[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635748#comment-17635748 ] zhanglu153 commented on FLINK-30075: 3. Why does the task not throw an exception whe

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: hadoop2.8.5 org.apache.hadoop.mapred.Master#getMasterPrincipal.png > Failed to load dat

[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635734#comment-17635734 ] zhanglu153 commented on FLINK-30075: 2.After the properties object in the Configurat

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: The error thrown when calling the getProps method after properties is set to null.png >

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: hadoop2.10.1 org.apache.hadoop.conf.Configuration#getProps.png > Failed to load data to

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: call the org.apache.hadoop.conf.Configuration#getProps method to create the Properties o

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635720#comment-17635720 ] zhanglu153 edited comment on FLINK-30075 at 11/18/22 7:47 AM:

[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635720#comment-17635720 ] zhanglu153 commented on FLINK-30075: 1.When is the properties object in the Configur

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: org.apache.hadoop.conf.Configuration#addDefaultResource.png > Failed to load data to the

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: hadoop2.10.1 org.apache.hadoop.yarn.conf.YarnConfiguration static code block.png > Fail

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: hadoop2.10.1 org.apache.hadoop.yarn.client.util.YarnClientUtils#getYarnConfWithRmHaId.pn

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: hadoop2.10.1 org.apache.hadoop.mapred.Master#getMasterPrincipal.png > Failed to load da

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: Set the properties object in the Configuration object of DFSClient#namenode proxy in the

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: hadoop2.10.1 org.apache.hadoop.security.SaslRpcClient#conf.png > Failed to load data to

[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635696#comment-17635696 ] zhanglu153 commented on FLINK-30075: {code:java} Couldn't set up IO streams: java.la

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: org.apache.flink.connectors.hive.read.HiveTableInputFormat#createInputSplits.png > Fail

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: hadoop2.8.5 org.apache.hadoop.security.SaslRpcClient#conf.png > Failed to load data to t

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: org.apache.hadoop.security.SaslRpcClient.png > Failed to load data to the cache after th

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: (was: org.apache.hadoop.security.SallRpcClient.png) > Failed to load data to the cac

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: org.apache.hadoop.security.SallRpcClient.png > Failed to load data to the cache after th

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: (was: SaslRpcClient中报错所在的代码.png) > Failed to load data to the cache after the hive l

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Attachment: SaslRpcClient中报错所在的代码.png > Failed to load data to the cache after the hive lookup join

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Description: When I test kafka and hive lookup join, only the connection between tm and zookeeper i

[jira] [Updated] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhanglu153 updated FLINK-30075: --- Description: When I test kafka and hive lookup join, only the connection between tm and zookeeper i

[jira] [Commented] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635635#comment-17635635 ] zhanglu153 commented on FLINK-30075: After the ChildFirstClassLoader is created, the

[jira] [Created] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

zhanglu153 created FLINK-30075: -- Summary: Failed to load data to the cache after the hive lookup join task is restarted Key: FLINK-30075 URL: https://issues.apache.org/jira/browse/FLINK-30075 Project: Fl