[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=17644800#comment-17644800 ] zhanglu153 commented on FLINK-30075: [~luoyuxia] You can read the hadoop source code. In the method

[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=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=17638033#comment-17638033 ] zhanglu153 commented on FLINK-30075: [~martijnvisser] When using hadoop 2.10.1 during testing, an

[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:

[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=17635770#comment-17635770 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 6:05 AM: -- This error

[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=17635734#comment-17635734 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 5:57 AM: -- 2.After the

[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=17635696#comment-17635696 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 5:47 AM: -- {code:java}

[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=17635635#comment-17635635 ] zhanglu153 edited comment on FLINK-30075 at 11/19/22 3:32 AM: -- After the

[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=17635770#comment-17635770 ] zhanglu153 commented on FLINK-30075: This error is related to the hadoop version and the operation

[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=17635748#comment-17635748 ] zhanglu153 commented on FLINK-30075: 3. Why does the task not throw an exception when using

[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

[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=17635734#comment-17635734 ] zhanglu153 commented on FLINK-30075: 2.After the properties object in the Configuration object of

[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

[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=17635720#comment-17635720 ] zhanglu153 edited comment on FLINK-30075 at 11/18/22 7:47 AM: -- 1.When is

[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=17635720#comment-17635720 ] zhanglu153 commented on FLINK-30075: 1.When is the properties object in the Configuration object of

[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

[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 >

[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

[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

[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

[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=17635696#comment-17635696 ] zhanglu153 commented on FLINK-30075: {code:java} Couldn't set up IO streams:

[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 >

[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

[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

[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

[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

[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

[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

[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

[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=17635635#comment-17635635 ] zhanglu153 commented on FLINK-30075: After the ChildFirstClassLoader is created, the default will be

[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: