{"action":"created","issue":{"url":"https://api.github.com/repos/mardambey/mypipe/issues/25","labels_url":"https://api.github.com/repos/mardambey/mypipe/issues/25/labels{/name}","comments_url":"https://api.github.com/repos/mardambey/mypipe/issues/25/comments","events_url":"https://api.github.com/repos/mardambey/mypipe/issues/25/events","html_url":"https://github.com/mardambey/mypipe/issues/25","id":104559450,"number":25,"title":"Specific schema format","user":{"login":"eugenemiretsky","id":1828811,"avatar_url":"https://avatars.githubusercontent.com/u/1828811?v=3","gravatar_id":"","url":"https://api.github.com/users/eugenemiretsky","html_url":"https://github.com/eugenemiretsky","followers_url":"https://api.github.com/users/eugenemiretsky/followers","following_url":"https://api.github.com/users/eugenemiretsky/following{/other_user}","gists_url":"https://api.github.com/users/eugenemiretsky/gists{/gist_id}","starred_url":"https://api.github.com/users/eugenemiretsky/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/eugenemiretsky/subscriptions","organizations_url":"https://api.github.com/users/eugenemiretsky/orgs","repos_url":"https://api.github.com/users/eugenemiretsky/repos","events_url":"https://api.github.com/users/eugenemiretsky/events{/privacy}","received_events_url":"https://api.github.com/users/eugenemiretsky/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-09-02T19:56:29Z","updated_at":"2015-10-05T15:57:19Z","closed_at":null,"body":"Hi! \r\n\r\nCouldn't find documentation for the format of  Specific Avro schemas.\r\n From what I can tell from the code,\r\n1)  The schema name is  s\"${db}_${table}_${mtype}\" (type being update/insert/delete).\r\n2)  For inserts the  schema  is expected to just have all the columns\r\n3)  For updates the schema is expected to have old_<column_name>  and  new_<column_name> \r\n\r\nIs there something I'm missing?\r\n\r\nAlso, for most updates only 1 column gets updated, it seems somewhat inefficient to send all the new & old values for each column. "},"comment":{"url":"https://api.github.com/repos/mardambey/mypipe/issues/comments/145579665","html_url":"https://github.com/mardambey/mypipe/issues/25#issuecomment-145579665","issue_url":"https://api.github.com/repos/mardambey/mypipe/issues/25","id":145579665,"user":{"login":"bbnsumanth","id":8859414,"avatar_url":"https://avatars.githubusercontent.com/u/8859414?v=3","gravatar_id":"","url":"https://api.github.com/users/bbnsumanth","html_url":"https://github.com/bbnsumanth","followers_url":"https://api.github.com/users/bbnsumanth/followers","following_url":"https://api.github.com/users/bbnsumanth/following{/other_user}","gists_url":"https://api.github.com/users/bbnsumanth/gists{/gist_id}","starred_url":"https://api.github.com/users/bbnsumanth/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/bbnsumanth/subscriptions","organizations_url":"https://api.github.com/users/bbnsumanth/orgs","repos_url":"https://api.github.com/users/bbnsumanth/repos","events_url":"https://api.github.com/users/bbnsumanth/events{/privacy}","received_events_url":"https://api.github.com/users/bbnsumanth/received_events","type":"User","site_admin":false},"created_at":"2015-10-05T15:57:19Z","updated_at":"2015-10-05T15:57:19Z","body":"Hi,i'm trying to run mypipe,but i'm getting the following error.can u please hellp me to fix that.\r\nThanks in advance :)\r\njava.util.NoSuchElementException: key not found: 127.0.0.1\r\n\tat scala.collection.MapLike$class.default(MapLike.scala:228)\r\n\tat scala.collection.AbstractMap.default(Map.scala:59)\r\n\tat scala.collection.MapLike$class.apply(MapLike.scala:141)\r\n\tat scala.collection.AbstractMap.apply(Map.scala:59)\r\n\tat mypipe.runner.PipeRunnerUtil$$anonfun$createPipes$1$$anonfun$3.apply(PipeRunner.scala:76)\r\n\tat mypipe.runner.PipeRunnerUtil$$anonfun$createPipes$1$$anonfun$3.apply(PipeRunner.scala:75)\r\n\tat scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)\r\n\tat scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)\r\n\tat scala.collection.Iterator$class.foreach(Iterator.scala:742)\r\n\tat scala.collection.AbstractIterator.foreach(Iterator.scala:1194)\r\n\tat scala.collection.IterableLike$class.foreach(IterableLike.scala:72)\r\n\tat scala.collection.AbstractIterable.foreach(Iterable.scala:54)\r\n\tat scala.collection.TraversableLike$class.map(TraversableLike.scala:245)\r\n\tat scala.collection.AbstractTraversable.map(Traversable.scala:104)\r\n\tat mypipe.runner.PipeRunnerUtil$$anonfun$createPipes$1.apply(PipeRunner.scala:75)\r\n\tat mypipe.runner.PipeRunnerUtil$$anonfun$createPipes$1.apply(PipeRunner.scala:63)\r\n\tat scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)\r\n\tat scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:245)\r\n\tat scala.collection.Iterator$class.foreach(Iterator.scala:742)\r\n\tat scala.collection.AbstractIterator.foreach(Iterator.scala:1194)\r\n\tat scala.collection.IterableLike$class.foreach(IterableLike.scala:72)\r\n\tat scala.collection.AbstractIterable.foreach(Iterable.scala:54)\r\n\tat scala.collection.TraversableLike$class.map(TraversableLike.scala:245)\r\n\tat scala.collection.AbstractTraversable.map(Traversable.scala:104)\r\n\tat mypipe.runner.PipeRunnerUtil$.createPipes(PipeRunner.scala:63)\r\n\tat mypipe.runner.PipeRunner$.pipes$lzycompute(PipeRunner.scala:22)\r\n\tat mypipe.runner.PipeRunner$.pipes(PipeRunner.scala:22)\r\n\tat mypipe.runner.PipeRunner$.delayedEndpoint$mypipe$runner$PipeRunner$1(PipeRunner.scala:24)\r\n\tat mypipe.runner.PipeRunner$delayedInit$body.apply(PipeRunner.scala:13)\r\n\tat scala.Function0$class.apply$mcV$sp(Function0.scala:34)\r\n\tat scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12)\r\n\tat scala.App$$anonfun$main$1.apply(App.scala:76)\r\n\tat scala.App$$anonfun$main$1.apply(App.scala:76)\r\n\tat scala.collection.immutable.List.foreach(List.scala:381)\r\n\tat scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)\r\n\tat scala.App$class.main(App.scala:76)\r\n\tat mypipe.runner.PipeRunner$.main(PipeRunner.scala:13)\r\n\tat mypipe.runner.PipeRunner.main(PipeRunner.scala)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\r\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r\n\tat java.lang.reflect.Method.invoke(Method.java:497)\r\n[trace] Stack trace suppressed: run last runner/compile:runMain for the full output.\r\njava.lang.RuntimeException: Nonzero exit code: 1\r\n\tat scala.sys.package$.error(package.scala:27)\r\n"}}