File tree Expand file tree Collapse file tree 1 file changed +11
-4
lines changed
flume-ng-core/src/main/java/org/apache/flume/formatter/output Expand file tree Collapse file tree 1 file changed +11
-4
lines changed Original file line number Diff line number Diff line change 25
25
import org .joda .time .LocalDateTime ;
26
26
import org .joda .time .format .DateTimeFormat ;
27
27
import org .joda .time .format .DateTimeFormatter ;
28
+ import org .slf4j .Logger ;
29
+ import org .slf4j .LoggerFactory ;
28
30
29
31
/**
30
32
*
31
33
*/
32
34
public class RollTimePathManager extends DefaultPathManager {
33
35
34
- private final DateTimeFormatter formatter = DateTimeFormat .forPattern ("yyyyMMddHHmmss" );
36
+ private static final Logger logger = LoggerFactory
37
+ .getLogger (RollTimePathManager .class );
38
+ private final DateTimeFormatter formatter = DateTimeFormat .forPattern ("yyyy-MM-dd" );
35
39
private String lastRoll ;
36
40
37
41
public RollTimePathManager (Context context ) {
@@ -46,13 +50,16 @@ public File nextFile() {
46
50
getFileIndex ().set (0 );
47
51
lastRoll = date ;
48
52
}
49
- sb .append (getPrefix ()).append (date ).append ("-" );
50
- sb .append (getFileIndex ().incrementAndGet ());
53
+ sb .append (getPrefix ());//.append("-");
54
+ int i = getFileIndex ().incrementAndGet ();
55
+ if ( i > 1 ) {
56
+ sb .append (date );
57
+ sb .append ("-" +(i -1 ));
58
+ }
51
59
if (getExtension ().length () > 0 ) {
52
60
sb .append ("." ).append (getExtension ());
53
61
}
54
62
currentFile = new File (getBaseDirectory (), sb .toString ());
55
-
56
63
return currentFile ;
57
64
}
58
65
You can’t perform that action at this time.
0 commit comments