Review Board 1.7.22


FLUME-1975. Use TThreadedSelectServer in ThriftSource if it is available

Review Request #10364 - Created April 9, 2013 and submitted

Hari Shreedharan
FLUME-1975
Reviewers
Flume
flume-git
Use reflection to figure out which server to use.
Ran unit tests in both hadoop-1 and hadoop-2 profiles. Use the test logs to verify that TThreadPoolServer is used in Hadoop-1 profile, but no log in Hadoop-2 profile.
pom.xml
Revision 9aff211 New Change
[20] 70 lines
[+20]
71
      </activation>
71
      </activation>
72
      <properties>
72
      <properties>
73
        <hadoop.version>1.0.1</hadoop.version>
73
        <hadoop.version>1.0.1</hadoop.version>
74
        <hbase.version>0.92.1</hbase.version>
74
        <hbase.version>0.92.1</hbase.version>
75
        <hadoop.common.artifact.id>hadoop-core</hadoop.common.artifact.id>
75
        <hadoop.common.artifact.id>hadoop-core</hadoop.common.artifact.id>

    
   
76
        <thrift.version>0.7.0</thrift.version>
76
      </properties>
77
      </properties>
77
      <dependencyManagement>
78
      <dependencyManagement>
78
        <dependencies>
79
        <dependencies>
79
          <dependency>
80
          <dependency>
80
            <groupId>org.apache.hadoop</groupId>
81
            <groupId>org.apache.hadoop</groupId>
[+20] [20] 19 lines
[+20]
100
      </activation>
101
      </activation>
101
      <properties>
102
      <properties>
102
        <hadoop.version>2.0.0-alpha</hadoop.version>
103
        <hadoop.version>2.0.0-alpha</hadoop.version>
103
        <hbase.version>0.94.2</hbase.version>
104
        <hbase.version>0.94.2</hbase.version>
104
        <hadoop.common.artifact.id>hadoop-common</hadoop.common.artifact.id>
105
        <hadoop.common.artifact.id>hadoop-common</hadoop.common.artifact.id>

    
   
106
        <thrift.version>0.8.0</thrift.version>
105
      </properties>
107
      </properties>
106
      <dependencyManagement>
108
      <dependencyManagement>
107
        <dependencies>
109
        <dependencies>
108
          <dependency>
110
          <dependency>
109
            <groupId>org.apache.hadoop</groupId>
111
            <groupId>org.apache.hadoop</groupId>
[+20] [20] 613 lines
[+20]
723
      </dependency>
725
      </dependency>
724

    
   
726

   
725
      <dependency>
727
      <dependency>
726
        <groupId>org.apache.thrift</groupId>
728
        <groupId>org.apache.thrift</groupId>
727
        <artifactId>libthrift</artifactId>
729
        <artifactId>libthrift</artifactId>
728
        <version>0.7.0</version>
730
        <version>${thrift.version}</version>
729
        <exclusions>
731
        <exclusions>
730
          <exclusion>
732
          <exclusion>
731
            <groupId>javax.servlet</groupId>
733
            <groupId>javax.servlet</groupId>
732
            <artifactId>servlet-api</artifactId>
734
            <artifactId>servlet-api</artifactId>
733
          </exclusion>
735
          </exclusion>
[+20] [20] 335 lines
flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java
Revision 5856e90 New Change
 
  1. pom.xml: Loading...
  2. flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java: Loading...