8248

Build # 8248

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/833a528528f127d8fd5b903afe0df5c68b62bfb7">833a52852<a href="https://github.com/apache/carbondata/commit/833a528528f127d8fd5b903afe0df5c68b62bfb7">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/63ba06a7e4ed82870a381053cae48e1059b6024a">63ba06a7e</a>">63ba06a7e</a><a href="https://github.com/apache/carbondata/commit/833a528528f127d8fd5b903afe0df5c68b62bfb7"> into 884ac915b">884ac915b</a>

Run Details

59 of 59 new or added lines in 6 files covered. (100.0%)

57543 of 71334 relevant lines covered (80.67%)

1.07 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.carbondata.common.logging.LogService;

import org.apache.commons.lang3.SystemUtils;

public abstract class AbstractDictionaryServer {

  public String findLocalIpAddress(LogService 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());
      throw new RuntimeException(e.getMessage());
    } catch (SocketException e) {
      LOGGER.error("do not get net work interface:" + e.getMessage());
      throw new RuntimeException(e.getMessage());
    }
  }
}

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.carbondata.common.logging.LogService;
31
32	import org.apache.commons.lang3.SystemUtils;
33
34	public abstract class AbstractDictionaryServer {	2✔
35
36	public String findLocalIpAddress(LogService LOGGER) {
37	try {
38	String defaultIpOverride = System.getenv("SPARK_LOCAL_IP");	2✔
39	if (defaultIpOverride != null) {	2✔
40	return defaultIpOverride;	×
41	} else {
42	InetAddress address = InetAddress.getLocalHost();	2✔
43	if (address.isLoopbackAddress()) {	2✔
44	// Address resolves to something like 127.0.1.1, which happens on Debian; try to find
45	// a better address using the local network interfaces
46	// getNetworkInterfaces returns ifs in reverse order compared to ifconfig output order
47	// on unix-like system. On windows, it returns in index order.
48	// It's more proper to pick ip address following system output order.
49	Enumeration<NetworkInterface> activeNetworkIFs = NetworkInterface.getNetworkInterfaces();	2✔
50	List<NetworkInterface> reOrderedNetworkIFs = new ArrayList<NetworkInterface>();	2✔
51	while (activeNetworkIFs.hasMoreElements()) {	2✔
52	reOrderedNetworkIFs.add(activeNetworkIFs.nextElement());	2✔
53	}
54
55	if (!SystemUtils.IS_OS_WINDOWS) {	2✔
56	Collections.reverse(reOrderedNetworkIFs);	2✔
57	}
58
59	for (NetworkInterface ni : reOrderedNetworkIFs) {	2✔
60	Enumeration<InetAddress> inetAddresses = ni.getInetAddresses();	2✔
61	while (inetAddresses.hasMoreElements()) {	2✔
62	InetAddress addr = inetAddresses.nextElement();	2✔
63	if (!addr.isLinkLocalAddress() && !addr.isLoopbackAddress()	2✔
64	&& addr instanceof Inet4Address) {
65	// We've found an address that looks reasonable!
66	LOGGER.warn("Your hostname, " + InetAddress.getLocalHost().getHostName()	2✔
67	+ " resolves to a loopback address: " + address.getHostAddress() + "; using "	2✔
68	+ addr.getHostAddress() + " instead (on interface " + ni.getName() + ")");	2✔
69	LOGGER.warn("Set SPARK_LOCAL_IP if you need to bind to another address");	2✔
70	return addr.getHostAddress();	2✔
71	}
72	}	2✔
73	LOGGER.warn("Your hostname, " + InetAddress.getLocalHost().getHostName()	2✔
74	+ " resolves to a loopback address: " + address.getHostAddress()	2✔
75	+ ", but we couldn't find any external IP address!");
76	LOGGER.warn("Set SPARK_LOCAL_IP if you need to bind to another address");	2✔
77	}	2✔
78	}
79	return address.getHostAddress();	×
80	}
81	} catch (UnknownHostException e) {	×
82	LOGGER.error("do not get local host address:" + e.getMessage());	×
83	throw new RuntimeException(e.getMessage());	×
84	} catch (SocketException e) {	×
85	LOGGER.error("do not get net work interface:" + e.getMessage());	×
86	throw new RuntimeException(e.getMessage());	×
87	}
88	}
89	}

apache / carbondata / 8248

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