You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2017/02/08 21:31:23 UTC
[1/2] storm git commit: STORM-2350: Storm-HDFS's
listFilesByModificationTime is broken
Repository: storm
Updated Branches:
refs/heads/1.x-branch 2a7e6dc05 -> c417c8ee2
STORM-2350: Storm-HDFS's listFilesByModificationTime is broken
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/bb5c6b84
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/bb5c6b84
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/bb5c6b84
Branch: refs/heads/1.x-branch
Commit: bb5c6b84876da10d842889bb1729ccfab02af7b5
Parents: 2a7e6dc
Author: Tibor Kiss <ti...@gmail.com>
Authored: Tue Feb 7 06:11:32 2017 +0100
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Feb 8 16:27:34 2017 -0500
----------------------------------------------------------------------
.../java/org/apache/storm/hdfs/common/ModifTimeComparator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/bb5c6b84/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/ModifTimeComparator.java
----------------------------------------------------------------------
diff --git a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/ModifTimeComparator.java b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/ModifTimeComparator.java
index de5613e..0558b3f 100644
--- a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/ModifTimeComparator.java
+++ b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/ModifTimeComparator.java
@@ -27,6 +27,6 @@ public class ModifTimeComparator
implements Comparator<FileStatus> {
@Override
public int compare(FileStatus o1, FileStatus o2) {
- return new Long(o1.getModificationTime()).compareTo( o1.getModificationTime() );
+ return new Long(o1.getModificationTime()).compareTo( o2.getModificationTime() );
}
}
[2/2] storm git commit: add STORM-2350 to changelog
Posted by pt...@apache.org.
add STORM-2350 to changelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/c417c8ee
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c417c8ee
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c417c8ee
Branch: refs/heads/1.x-branch
Commit: c417c8ee28384b392ddcbd96366047037164280d
Parents: bb5c6b8
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Feb 8 16:28:06 2017 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Feb 8 16:28:06 2017 -0500
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/c417c8ee/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 2e0cb4b..ff46285 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
\ufeff## 1.1.0
+ * STORM-2350: Storm-HDFS's listFilesByModificationTime is broken
* STORM-2270 Kafka spout should consume from latest when ZK partition commit offset bigger than the latest offset
* STORM-1464: storm-hdfs support for multiple output files and partitioning
* STORM-2320: DRPC client printer class reusable for local and remote DRPC