Issues 140 #144
Closed
Issues 140 #144
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Removed redundant code from SuroModule.
…d in in last commit
Support an optional filter on each sink in the routing map. The
routing map format is changed form
"where" : ["sink1", "sink2"]
to
"where" : [
{ "sink" : "sink1"},
{ "sink" : "sink2",
"filter" : { "type" : "regex",
"regex" : "abc" }
}
]
This change breaks backwards compatibility with the exisintg route map
definition
Per sink filter
- Added support of JSON format for message filtering
Automatically creating file queue directories for Queue4client
suro-tranquility's ZkExternalResource file is copied and pased from suro-kafka, its test class dependency is not making idea project file correctly
Removed duplicated metrics. Added default tag for empty routing key
FileBlockingQueue's default gc period changed to 1 minute from 1hour MessageSetReader's exception should truncate all messages Updated thrift gen files Added a few more test cases for FileBlockingQueue including multithreading HealthCheck is not closing TTransport because it's making server throw the following error: 2014-08-21 06:55:11,276 ERROR Thread-15 AbstractNonblockingServer$FrameBuffer - Read an invalid frame size of 0. Are you using TFramedTransport on the client side?
Added configuration SuroClient.enableOutPool, by default false SuroClient result status code is not OK, the server should be marked down When OutPool is disabled, ConnectionOutPool should not be created Unit tests fixed
Disable ConnectionOutPool
MessageSetReader will increase DROPPED_COUNT on the exception MesageRouter will increase DROPPED_COUNT on emptyRoutingKey QueuedSink with sinkId will increase DROPPED_COUNT with the tag, sinkId
AsyncSuroClient jobQueue is blocked on offer()
file queue size limit
we can safely ignore IndexOutOfBoundaryException
FileQueue with sizeLimit configuration
change get() to get(File file) , providing more useful info .
use suro File's lastModify/dateCreated time to generate upload path.
|
suro-pull-requests #111 FAILURE |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
fixed #140