Skip to content

Commit

Permalink
PIG-5317: Upgrade old dependencies: commons-lang, hsqldb, commons-log…
Browse files Browse the repository at this point in the history
…ging (nkollar via rohini)

git-svn-id: https://svn.apache.org/repos/asf/pig/trunk@1819863 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information
r0hini committed Jan 2, 2018
1 parent d35635c commit a499d84
Show file tree
Hide file tree
Showing 31 changed files with 64 additions and 96 deletions.
2 changes: 2 additions & 0 deletions CHANGES.txt
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,8 @@ PIG-5282: Upgade to Java 8 (satishsaley via rohini)

IMPROVEMENTS

PIG-5317: Upgrade old dependencies: commons-lang, hsqldb, commons-logging (nkollar via rohini)

PIG-5322: ConstantCalculator optimizer is not applied for split (rohini)

PIG-5316: Initialize mapred.task.id property for PoS jobs (nkollar via szita)
Expand Down
6 changes: 3 additions & 3 deletions build.xml
Original file line number Diff line number Diff line change
Expand Up @@ -772,7 +772,7 @@
<fileset dir="${ivy.lib.dir}" includes="commons-cli-*.jar"/>
<fileset dir="${ivy.lib.dir}" includes="commons-configuration-*.jar"/>
<fileset dir="${ivy.lib.dir}" includes="commons-collections-*.jar"/>
<fileset dir="${ivy.lib.dir}" includes="commons-lang-*.jar"/>
<fileset dir="${ivy.lib.dir}" includes="commons-lang3-*.jar"/>
<fileset dir="${ivy.lib.dir}" includes="commons-codec-*.jar"/>
<fileset dir="${ivy.lib.dir}" includes="commons-io-*.jar"/>
<fileset dir="${ivy.lib.dir}" includes="commons-logging-*.jar"/>
Expand Down Expand Up @@ -1079,7 +1079,7 @@
<fileset dir="${test.build.classes}">
<include name="**/org/apache/pig/test/**"/>
</fileset>
<zipfileset src="${ivy.lib.dir}/commons-lang-${commons-lang.version}.jar" />
<zipfileset src="${ivy.lib.dir}/commons-lang3-${commons-lang3.version}.jar" />
</jar>
</target>

Expand All @@ -1094,7 +1094,7 @@
<include name="**/org/apache/pig/pigunit/**"/>
<include name="**/org/apache/pig/test/Util.**"/>
</fileset>
<zipfileset src="${ivy.lib.dir}/commons-lang-${commons-lang.version}.jar" />
<zipfileset src="${ivy.lib.dir}/commons-lang3-${commons-lang3.version}.jar" />
</jar>
</target>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;

import org.apache.commons.lang.math.RandomUtils;
import org.apache.commons.lang3.RandomUtils;
import org.apache.pig.data.Tuple;
import org.apache.pig.data.TupleFactory;
import org.apache.pig.piggybank.evaluation.xml.XPathAll;
Expand Down Expand Up @@ -356,7 +356,7 @@ private String expandXml() {

final StringBuilder sb = new StringBuilder();

final int max = RandomUtils.nextInt(100);
final int max = RandomUtils.nextInt(0, 100);

for (int i = 0; i < max; i++) {
sb.append("<expansion>This is an expansion of the xml to simulate random sized xml" + i + "</expansion>");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;

import org.apache.commons.lang.math.RandomUtils;
import org.apache.commons.lang3.RandomUtils;
import org.apache.pig.data.Tuple;
import org.apache.pig.data.TupleFactory;
import org.apache.pig.piggybank.evaluation.xml.XPath;
Expand Down Expand Up @@ -314,7 +314,7 @@ private String expandXml() {

final StringBuilder sb = new StringBuilder();

final int max = RandomUtils.nextInt(100);
final int max = RandomUtils.nextInt(0, 100);

for(int i = 0; i < max; i++) {
sb.append("<expansion>This is an expansion of the xml to simulate random sized xml" + i + "</expansion>");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
import java.util.Iterator;
import java.util.Properties;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.pig.ExecType;
import org.apache.pig.PigServer;
import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRConfiguration;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,10 +30,12 @@
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Date;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;

import org.apache.pig.ExecType;
import org.apache.pig.PigServer;
import org.apache.pig.backend.executionengine.ExecException;
import org.apache.pig.backend.executionengine.ExecJob;
import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRConfiguration;
import org.apache.pig.test.MiniGenericCluster;
Expand All @@ -56,15 +58,13 @@ public class TestDBStorage {
private String driver = "org.hsqldb.jdbcDriver";
// private String url = "jdbc:hsqldb:mem:.";
private String TMP_DIR;
private String dblocation;
private String url;
private String dbUrl = "jdbc:hsqldb:hsql://localhost/" + "batchtest";
private String dbUrl = "jdbc:hsqldb:hsql://localhost/batchtest";
private String user = "sa";
private String password = "";

private static final String INPUT_FILE = "datafile.txt";

public TestDBStorage() throws ExecException, IOException {
public TestDBStorage() throws IOException {
// Initialise Pig server
cluster = MiniGenericCluster.buildCluster();
pigServer = new PigServer(ExecType.MAPREDUCE, cluster.getProperties());
Expand All @@ -74,15 +74,13 @@ public TestDBStorage() throws ExecException, IOException {
.setProperty(MRConfiguration.REDUCE_MAX_ATTEMPTS, "1");
System.out.println("Pig server initialized successfully");
TMP_DIR = System.getProperty("user.dir") + "/build/test/";
dblocation = TMP_DIR + "batchtest";
url = "jdbc:hsqldb:file:" + dblocation
+ ";hsqldb.default_table_type=cached;hsqldb.cache_rows=100";
// Initialise DBServer
dbServer = new Server();
dbServer.setDatabaseName(0, "batchtest");
// dbServer.setDatabasePath(0, "mem:test;sql.enforce_strict_size=true");
dbServer.setDatabasePath(0,
"file:" + TMP_DIR + "batchtest;sql.enforce_strict_size=true");
"file:" + TMP_DIR + "batchtest;"+
"hsqldb.default_table_type=cached;hsqldb.cache_rows=100;sql.enforce_strict_size=true");
dbServer.setLogWriter(null);
dbServer.setErrWriter(null);
dbServer.start();
Expand All @@ -98,7 +96,6 @@ public TestDBStorage() throws ExecException, IOException {

private void createFile() throws IOException {
PrintWriter w = new PrintWriter(new FileWriter(INPUT_FILE));
w = new PrintWriter(new FileWriter(INPUT_FILE));
w.println("100\tapple\t1.0\t2008-01-01");
w.println("100\torange\t2.0\t2008-02-01");
w.println("100\tbanana\t1.1\t2008-03-01");
Expand All @@ -111,7 +108,7 @@ private void createTable() throws IOException {
Connection con = null;
String sql = "create table ttt (id integer, name varchar(32), ratio double, dt date)";
try {
con = DriverManager.getConnection(url, user, password);
con = DriverManager.getConnection(dbUrl, user, password);
} catch (SQLException sqe) {
throw new IOException("Unable to obtain a connection to the database",
sqe);
Expand Down Expand Up @@ -159,11 +156,11 @@ public boolean accept(File dir, String name) {
}

@Test
public void testWriteToDB() throws IOException {
public void testWriteToDB() throws IOException, InterruptedException, ParseException {
String insertQuery = "insert into ttt (id, name, ratio, dt) values (?,?,?,?)";
pigServer.setBatchOn();
String dbStore = "org.apache.pig.piggybank.storage.DBStorage('" + driver
+ "', '" + Util.encodeEscape(url) + "', '" + insertQuery + "');";
+ "', '" + Util.encodeEscape(dbUrl) + "', '" + insertQuery + "');";
pigServer.registerQuery("A = LOAD '" + INPUT_FILE
+ "' as (id:int, fruit:chararray, ratio:double, dt : datetime);");
pigServer.registerQuery("STORE A INTO 'dummy' USING " + dbStore);
Expand All @@ -179,7 +176,7 @@ public void testWriteToDB() throws IOException {
Connection con = null;
String selectQuery = "select id, name, ratio, dt from ttt order by name";
try {
con = DriverManager.getConnection(url, user, password);
con = DriverManager.getConnection(dbUrl, user, password);
} catch (SQLException sqe) {
throw new IOException(
"Unable to obtain database connection for data verification", sqe);
Expand All @@ -189,10 +186,14 @@ public void testWriteToDB() throws IOException {
ResultSet rs = ps.executeQuery();

int expId = 100;
String[] expNames = { "apple", "banana", "orange" };
double[] expRatios = { 1.0, 1.1, 2.0 };
Date [] expDates = {new Date(2008,01,01),new Date(2008,02,01),new Date(2008,03,01)};
for (int i = 0; i < 4 && rs.next(); i++) {
String[] expNames = {"apple", "banana", "orange"};
double[] expRatios = {1.0, 1.1, 2.0};
DateFormat df = new SimpleDateFormat("yyyy-MM-dd");
Date[] expDates = {new Date(df.parse("2008-01-01").getTime()),
new Date(df.parse("2008-03-01").getTime()),
new Date(df.parse("2008-02-01").getTime())};
for (int i = 0; i < 4; i++) {
rs.next();
//Need to check for nulls explicitly.
if ( i == 0) {
//Id
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,7 @@
import java.io.IOException;
import java.util.Iterator;

import junit.framework.TestCase;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.StringUtils;

import org.apache.pig.ExecType;
import org.apache.pig.data.Tuple;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@

import org.junit.Assert;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.StringUtils;

import org.apache.pig.ExecType;
import org.apache.pig.data.Tuple;
Expand Down
4 changes: 1 addition & 3 deletions ivy.xml
Original file line number Diff line number Diff line change
Expand Up @@ -224,8 +224,6 @@
<dependency org="org.fusesource.jansi" name="jansi" rev="${jansi.version}"
conf="compile->master"/>
<dependency org="joda-time" name="joda-time" rev="${joda-time.version}" conf="compile->master"/>
<dependency org="commons-lang" name="commons-lang" rev="${commons-lang.version}"
conf="compile->master"/>
<dependency org="com.google.guava" name="guava" rev="${guava.version}" conf="compile->master" />
<dependency org="org.python" name="jython-standalone" rev="${jython.version}" conf="compile->master"/>
<dependency org="rhino" name="js" rev="${rhino.version}" conf="compile->master"/>
Expand Down Expand Up @@ -364,7 +362,7 @@
</dependency>

<!-- for piggybank -->
<dependency org="hsqldb" name="hsqldb" rev="${hsqldb.version}"
<dependency org="org.hsqldb" name="hsqldb" rev="${hsqldb.version}"
conf="test->default" />
<dependency org="org.apache.hive" name="hive-exec" rev="${hive.version}" conf="compile->master" changing="true">
<artifact name="hive-exec" m:classifier="core" />
Expand Down
5 changes: 2 additions & 3 deletions ivy/libraries.properties
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,7 @@ commons-cli.version=1.2
commons-codec.version=1.4
commons-io.version=2.3
commons-el.version=1.0
commons-logging.version=1.1.1
commons-lang.version=2.6
commons-logging.version=1.2
commons-configuration.version=1.6
commons-collections.version=3.2.1
commons-collections4.version=4.0
Expand All @@ -40,7 +39,7 @@ hadoop-common.version=2.7.3
hadoop-hdfs.version=2.7.3
hadoop-mapreduce.version=2.7.3
hbase1.version=1.2.4
hsqldb.version=1.8.0.10
hsqldb.version=2.4.0
hive.version=1.2.1
httpcomponents.version=4.4
jackson.version=1.9.13
Expand Down
9 changes: 2 additions & 7 deletions ivy/pig-template.xml
Original file line number Diff line number Diff line change
Expand Up @@ -33,11 +33,6 @@
<artifactId>commons-codec</artifactId>
<version>1.4</version>
</dependency>
<dependency>
<groupId>commons-net</groupId>
<artifactId>commons-net</artifactId>
<version>3.1</version>
</dependency>
<dependency>
<groupId>commons-el</groupId>
<artifactId>commons-el</artifactId>
Expand All @@ -59,9 +54,9 @@
<version>4.11</version>
</dependency>
<dependency>
<groupId>hsqldb</groupId>
<groupId>org.hsqldb</groupId>
<artifactId>hsqldb</artifactId>
<version>1.8.0.10</version>
<version>2.4.0</version>
</dependency>
<dependency>
<groupId>jline</groupId>
Expand Down
12 changes: 6 additions & 6 deletions ivy/piggybank-template.xml
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,9 @@
<version>@version</version>
<dependencies>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.6</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
Expand All @@ -36,7 +36,7 @@
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.1.1</version>
<version>1.2</version>
</dependency>
<dependency>
<groupId>commons-el</groupId>
Expand Down Expand Up @@ -92,9 +92,9 @@
<scope>test</scope>
</dependency>
<dependency>
<groupId>hsqldb</groupId>
<groupId>org.hsqldb</groupId>
<artifactId>hsqldb</artifactId>
<version>1.8.0.10</version>
<version>2.4.0</version>
<scope>test</scope>
</dependency>
</dependencies>
Expand Down
8 changes: 4 additions & 4 deletions ivy/pigunit-template.xml
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,9 @@
<version>@version</version>
<dependencies>
<dependency>
<groupId>commons-lang</groupId>
<artifactId>commons-lang</artifactId>
<version>2.6</version>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.6</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
Expand All @@ -36,7 +36,7 @@
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.1.1</version>
<version>1.2</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
Expand Down
1 change: 0 additions & 1 deletion src/org/apache/pig/PigServer.java
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,6 @@
import java.util.concurrent.atomic.AtomicInteger;

import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@
import org.apache.accumulo.core.util.Pair;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.ParseException;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import org.apache.commons.cli.Option;
import org.apache.commons.cli.Options;
import org.apache.commons.cli.ParseException;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.StringUtils;

public class AccumuloStorageOptions {
public static final Option CASTER_OPTION = new Option(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import java.util.Timer;
import java.util.TimerTask;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import java.util.List;
import java.util.Set;

import org.apache.commons.lang.ArrayUtils;
import org.apache.commons.lang3.ArrayUtils;
import org.apache.pig.PigException;
import org.apache.pig.backend.executionengine.ExecException;
import org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator;
Expand Down
2 changes: 1 addition & 1 deletion src/org/apache/pig/tools/grunt/GruntParser.java
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@
import jline.console.ConsoleReader;

import org.apache.commons.io.output.NullOutputStream;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.fs.FileSystem;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import java.util.List;
import java.util.Map;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.mapred.JobClient;
Expand Down
Loading

0 comments on commit a499d84

Please sign in to comment.