$ git diff
diff --git a/src/fluent/message.hpp b/src/fluent/message.hpp
index a71c6a3..a184c5d 100644
--- a/src/fluent/message.hpp
+++ b/src/fluent/message.hpp
@@ -149,7 +149,7 @@ namespace fluent {
       std::vector<Object*> array_;
     public:
       Array() {}
-      ~Array() {}
+      ~Array();
       Map *retain_map();
       Array *retain_array();
       void push(const std::string &val);
diff --git a/src/message.cc b/src/message.cc
index 4d1b705..c3e04d8 100644
--- a/src/message.cc
+++ b/src/message.cc
@@ -265,6 +265,12 @@ namespace fluent {
     return map;
   }

+  Message::Array::~Array() {
+    for (auto it = this->array_.begin(); it != this->array_.end(); it++) {
+      delete *it;
+    }
+  }
+
   void Message::Array::push(const std::string &val) {
     Object *v = new String(val);
     this->array_.push_back(v);

diff --git a/Libraries/libfluent/src/emitter.cc b/Libraries/libfluent/src/emitter.cc
index 28fb5fb..e533b81 100644
--- a/Libraries/libfluent/src/emitter.cc
+++ b/Libraries/libfluent/src/emitter.cc
@@ -212,7 +212,7 @@ namespace fluent {
     Message *root;
     while (nullptr != (root = this->queue_.bulk_pop())) {
       for(Message *msg = root; msg; msg = msg->next()) {
-        int rc;
+        int rc = 0;
         switch(this->format_) {
           case MsgPack: {
             msgpack::sbuffer buf;


diff --git a/Libraries/libfluent/tools/fluent-bench.cc b/Libraries/libfluent/tools/fluent-bench.cc
index dcc98c8..6ab8ef6 100644
--- a/Libraries/libfluent/tools/fluent-bench.cc
+++ b/Libraries/libfluent/tools/fluent-bench.cc
@@ -46,7 +46,7 @@ int main(int argc, char *argv[]) {

   int wait = 1000000 / mps;
   time_t last_ts = time(nullptr);
-  size_t msg_count = 0;
+  int msg_count = 0;

   std::cout << "wait: " << wait << "usec" << std::endl;