11589

Build # 11589

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/c5a08c66af543a01ee1ec598354ee5a89847b09c">c5a08c66a<a href="https://github.com/apache/carbondata/commit/c5a08c66af543a01ee1ec598354ee5a89847b09c">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/6408588c2cd696bda04673313843956dd8634b95">6408588c2</a>">6408588c2</a><a href="https://github.com/apache/carbondata/commit/c5a08c66af543a01ee1ec598354ee5a89847b09c"> into df71291ec">df71291ec</a>

Run Details

197 of 197 new or added lines in 13 files covered. (100.0%)

64157 of 81994 relevant lines covered (78.25%)

1.04 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

76.47

/core/src/main/java/org/apache/carbondata/core/dictionary/service/AbstractDictionaryServer.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.carbondata.core.dictionary.service;

import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Enumeration;
import java.util.List;

import org.apache.commons.lang3.SystemUtils;
import org.apache.log4j.Logger;

public abstract class AbstractDictionaryServer {

  public String findLocalIpAddress(Logger LOGGER) {
    try {
      String defaultIpOverride = System.getenv("SPARK_LOCAL_IP");
      if (defaultIpOverride != null) {
        return defaultIpOverride;
      } else {
        InetAddress address = InetAddress.getLocalHost();
        if (address.isLoopbackAddress()) {
          // Address resolves to something like 127.0.1.1, which happens on Debian; try to find
          // a better address using the local network interfaces
          // getNetworkInterfaces returns ifs in reverse order compared to ifconfig output order
          // on unix-like system. On windows, it returns in index order.
          // It's more proper to pick ip address following system output order.
          Enumeration<NetworkInterface> activeNetworkIFs = NetworkInterface.getNetworkInterfaces();
          List<NetworkInterface> reOrderedNetworkIFs = new ArrayList<NetworkInterface>();
          while (activeNetworkIFs.hasMoreElements()) {
            reOrderedNetworkIFs.add(activeNetworkIFs.nextElement());
          }

          if (!SystemUtils.IS_OS_WINDOWS) {
            Collections.reverse(reOrderedNetworkIFs);
          }

          for (NetworkInterface ni : reOrderedNetworkIFs) {
            Enumeration<InetAddress> inetAddresses = ni.getInetAddresses();
            while (inetAddresses.hasMoreElements()) {
              InetAddress addr = inetAddresses.nextElement();
              if (!addr.isLinkLocalAddress() && !addr.isLoopbackAddress()
                  && addr instanceof Inet4Address) {
                // We've found an address that looks reasonable!
                LOGGER.warn("Your hostname, " + InetAddress.getLocalHost().getHostName()
                    + " resolves to a loopback address: " + address.getHostAddress() + "; using "
                    + addr.getHostAddress() + " instead (on interface " + ni.getName() + ")");
                LOGGER.warn("Set SPARK_LOCAL_IP if you need to bind to another address");
                return addr.getHostAddress();
              }
            }
            LOGGER.warn("Your hostname, " + InetAddress.getLocalHost().getHostName()
                + " resolves to a loopback address: " + address.getHostAddress()
                + ", but we couldn't find any external IP address!");
            LOGGER.warn("Set SPARK_LOCAL_IP if you need to bind to another address");
          }
        }
        return address.getHostAddress();
      }
    } catch (UnknownHostException e) {
      LOGGER.error("do not get local host address:" + e.getMessage(), e);
      throw new RuntimeException(e);
    } catch (SocketException e) {
      LOGGER.error("do not get net work interface:" + e.getMessage(), e);
      throw new RuntimeException(e);
    }
  }
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17
18	package org.apache.carbondata.core.dictionary.service;
19
20	import java.net.Inet4Address;
21	import java.net.InetAddress;
22	import java.net.NetworkInterface;
23	import java.net.SocketException;
24	import java.net.UnknownHostException;
25	import java.util.ArrayList;
26	import java.util.Collections;
27	import java.util.Enumeration;
28	import java.util.List;
29
30	import org.apache.commons.lang3.SystemUtils;
31	import org.apache.log4j.Logger;
32
33	public abstract class AbstractDictionaryServer {	2✔
34
35	public String findLocalIpAddress(Logger LOGGER) {
36	try {
37	String defaultIpOverride = System.getenv("SPARK_LOCAL_IP");	2✔
38	if (defaultIpOverride != null) {	2✔
39	return defaultIpOverride;	×
40	} else {
41	InetAddress address = InetAddress.getLocalHost();	2✔
42	if (address.isLoopbackAddress()) {	2✔
43	// Address resolves to something like 127.0.1.1, which happens on Debian; try to find
44	// a better address using the local network interfaces
45	// getNetworkInterfaces returns ifs in reverse order compared to ifconfig output order
46	// on unix-like system. On windows, it returns in index order.
47	// It's more proper to pick ip address following system output order.
48	Enumeration<NetworkInterface> activeNetworkIFs = NetworkInterface.getNetworkInterfaces();	2✔
49	List<NetworkInterface> reOrderedNetworkIFs = new ArrayList<NetworkInterface>();	2✔
50	while (activeNetworkIFs.hasMoreElements()) {	2✔
51	reOrderedNetworkIFs.add(activeNetworkIFs.nextElement());	2✔
52	}
53
54	if (!SystemUtils.IS_OS_WINDOWS) {	2✔
55	Collections.reverse(reOrderedNetworkIFs);	2✔
56	}
57
58	for (NetworkInterface ni : reOrderedNetworkIFs) {	2✔
59	Enumeration<InetAddress> inetAddresses = ni.getInetAddresses();	2✔
60	while (inetAddresses.hasMoreElements()) {	2✔
61	InetAddress addr = inetAddresses.nextElement();	2✔
62	if (!addr.isLinkLocalAddress() && !addr.isLoopbackAddress()	2✔
63	&& addr instanceof Inet4Address) {
64	// We've found an address that looks reasonable!
65	LOGGER.warn("Your hostname, " + InetAddress.getLocalHost().getHostName()	2✔
66	+ " resolves to a loopback address: " + address.getHostAddress() + "; using "	2✔
67	+ addr.getHostAddress() + " instead (on interface " + ni.getName() + ")");	2✔
68	LOGGER.warn("Set SPARK_LOCAL_IP if you need to bind to another address");	2✔
69	return addr.getHostAddress();	2✔
70	}
71	}	2✔
72	LOGGER.warn("Your hostname, " + InetAddress.getLocalHost().getHostName()	2✔
73	+ " resolves to a loopback address: " + address.getHostAddress()	2✔
74	+ ", but we couldn't find any external IP address!");
75	LOGGER.warn("Set SPARK_LOCAL_IP if you need to bind to another address");	2✔
76	}	2✔
77	}
78	return address.getHostAddress();	×
79	}
80	} catch (UnknownHostException e) {	×
81	LOGGER.error("do not get local host address:" + e.getMessage(), e);	×
82	throw new RuntimeException(e);	×
83	} catch (SocketException e) {	×
84	LOGGER.error("do not get net work interface:" + e.getMessage(), e);	×
85	throw new RuntimeException(e);	×
86	}
87	}
88	}

apache / carbondata / 11589

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous