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