|
@@ -130,7 +130,7 @@ def build_version(version_tuple):
|
|
|
def build_tuple(version_string):
|
|
|
return [int(x) for x in version_string.split('.')]
|
|
|
|
|
|
-def start_node(version, release_dir, data_dir, tcp_port=DEFAULT_TRANSPORT_TCP_PORT, http_port=DEFAULT_HTTP_TCP_PORT, cluster_name=None):
|
|
|
+def start_node(version, release_dir, data_dir, repo_dir, tcp_port=DEFAULT_TRANSPORT_TCP_PORT, http_port=DEFAULT_HTTP_TCP_PORT, cluster_name=None):
|
|
|
logging.info('Starting node from %s on port %s/%s, data_dir %s' % (release_dir, tcp_port, http_port, data_dir))
|
|
|
if cluster_name is None:
|
|
|
cluster_name = 'bwc_index_' + version
|
|
@@ -143,7 +143,8 @@ def start_node(version, release_dir, data_dir, tcp_port=DEFAULT_TRANSPORT_TCP_PO
|
|
|
'-Des.network.host=localhost',
|
|
|
'-Des.discovery.zen.ping.multicast.enabled=false',
|
|
|
'-Des.transport.tcp.port=%s' % tcp_port,
|
|
|
- '-Des.http.port=%s' % http_port
|
|
|
+ '-Des.http.port=%s' % http_port,
|
|
|
+ '-Des.path.repo=%s' % repo_dir
|
|
|
]
|
|
|
if version.startswith('0.') or version.startswith('1.0.0.Beta') :
|
|
|
cmd.append('-f') # version before 1.0 start in background automatically
|
|
@@ -329,7 +330,7 @@ def parse_config():
|
|
|
help='Recreate all existing backwards compatibility indexes')
|
|
|
parser.add_argument('--releases-dir', '-d', default='backwards', metavar='DIR',
|
|
|
help='The directory containing elasticsearch releases')
|
|
|
- parser.add_argument('--output-dir', '-o', default='src/test/resources/org/elasticsearch/bwcompat',
|
|
|
+ parser.add_argument('--output-dir', '-o', default='core/src/test/resources/org/elasticsearch/bwcompat',
|
|
|
help='The directory to write the zipped index into')
|
|
|
parser.add_argument('--tcp-port', default=DEFAULT_TRANSPORT_TCP_PORT, type=int,
|
|
|
help='The port to use as the minimum port for TCP communication')
|
|
@@ -364,7 +365,7 @@ def create_bwc_index(cfg, version):
|
|
|
node = None
|
|
|
|
|
|
try:
|
|
|
- node = start_node(version, release_dir, data_dir, cfg.tcp_port, cfg.http_port)
|
|
|
+ node = start_node(version, release_dir, data_dir, repo_dir, cfg.tcp_port, cfg.http_port)
|
|
|
client = create_client(cfg.http_port)
|
|
|
index_name = 'index-%s' % version.lower()
|
|
|
generate_index(client, version, index_name)
|