Exception in thread "pipeline.main" java.nio.BufferOverflowException

Using 2.4.0 with a Redis input, suddenly this morning I am getting:

Exception in thread "pipeline.main" java.nio.BufferOverflowException
at java.nio.HeapByteBuffer.put(HeapByteBuffer.java:189)
at org.jruby.util.io.ChannelStream.bufferedWrite(ChannelStream.java:1100)
at org.jruby.util.io.ChannelStream.fwrite(ChannelStream.java:1277)
at org.jruby.RubyIO.fwrite(RubyIO.java:1560)
at org.jruby.RubyIO.write(RubyIO.java:1431)
at org.jruby.RubyIO$INVOKER$i$1$0$write.call(RubyIO$INVOKER$i$1$0$write.gen)
at org.jruby.RubyClass.finvoke(RubyClass.java:743)
at org.jruby.runtime.Helpers.invoke(Helpers.java:505)
at org.jruby.RubyBasicObject.callMethod(RubyBasicObject.java:364)
at org.jruby.RubyIO.write(RubyIO.java:2509)
at org.jruby.RubyIO.putsSingle(RubyIO.java:2497)
at org.jruby.RubyIO.puts1(RubyIO.java:2426)
at org.jruby.RubyIO.puts(RubyIO.java:2399)
at org.jruby.RubyIO$INVOKER$i$puts.call(RubyIO$INVOKER$i$puts.gen)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:168)
at org.jruby.ast.CallOneArgNode.interpret(CallOneArgNode.java:57)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.ast.IfNode.interpret(IfNode.java:116)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:112)
at org.jruby.runtime.Interpreted19Block.evalBlockBody(Interpreted19Block.java:206)
at org.jruby.runtime.Interpreted19Block.yield(Interpreted19Block.java:157)
at org.jruby.runtime.Block.yield(Block.java:142)
at org.jruby.ext.thread.Mutex.synchronize(Mutex.java:149)
at org.jruby.ext.thread.Mutex$INVOKER$i$0$0$synchronize.call(Mutex$INVOKER$i$0$0$synchronize.gen)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:143)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:154)
at org.jruby.ast.CallNoArgBlockNode.interpret(CallNoArgBlockNode.java:64)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:182)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:203)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:168)
at org.jruby.runtime.callsite.ShiftLeftCallSite.call(ShiftLeftCallSite.java:24)
at org.jruby.ast.CallOneArgNode.interpret(CallOneArgNode.java:57)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:182)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:203)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:168)
at org.jruby.runtime.callsite.ShiftLeftCallSite.call(ShiftLeftCallSite.java:24)
at org.jruby.ast.CallOneArgNode.interpret(CallOneArgNode.java:57)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.IfNode.interpret(IfNode.java:116)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:112)
at org.jruby.runtime.Interpreted19Block.evalBlockBody(Interpreted19Block.java:206)
at org.jruby.runtime.Interpreted19Block.yield(Interpreted19Block.java:157)
at org.jruby.runtime.Block.yield(Block.java:142)
at org.jruby.RubyHash$13.visit(RubyHash.java:1355)
at org.jruby.RubyHash.visitLimited(RubyHash.java:648)
at org.jruby.RubyHash.visitAll(RubyHash.java:634)
at org.jruby.RubyHash.iteratorVisitAll(RubyHash.java:1306)
at org.jruby.RubyHash.each_pairCommon(RubyHash.java:1351)
at org.jruby.RubyHash.each19(RubyHash.java:1342)
at org.jruby.RubyHash.each19(RubyHash.java:1342)
at org.jruby.RubyHash$INVOKER$i$0$0$each19.call(RubyHash$INVOKER$i$0$0$each19.gen)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:143)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:154)
at org.jruby.ast.CallNoArgBlockNode.interpret(CallNoArgBlockNode.java:64)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:112)
at org.jruby.runtime.Interpreted19Block.evalBlockBody(Interpreted19Block.java:206)
at org.jruby.runtime.Interpreted19Block.yield(Interpreted19Block.java:157)
at org.jruby.runtime.Block.yield(Block.java:142)
at org.jruby.ext.thread.Mutex.synchronize(Mutex.java:149)
at org.jruby.ext.thread.Mutex$INVOKER$i$0$0$synchronize.call(Mutex$INVOKER$i$0$0$synchronize.gen)
at org.jruby.runtime.callsite.CachingCallSite.callBlock(CachingCallSite.java:143)
at org.jruby.runtime.callsite.CachingCallSite.callIter(CachingCallSite.java:154)
at org.jruby.ast.CallNoArgBlockNode.interpret(CallNoArgBlockNode.java:64)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:182)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:203)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:168)
at org.jruby.ast.FCallOneArgNode.interpret(FCallOneArgNode.java:36)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:225)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:219)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:202)
at org.jruby.ast.FCallTwoArgNode.interpret(FCallTwoArgNode.java:38)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_METHOD(ASTInterpreter.java:74)
at org.jruby.internal.runtime.methods.InterpretedMethod.call(InterpretedMethod.java:268)
at org.jruby.internal.runtime.methods.DefaultMethod.call(DefaultMethod.java:235)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:236)
at org.jruby.ast.FCallThreeArgNode.interpret(FCallThreeArgNode.java:40)
at org.jruby.ast.IfNode.interpret(IfNode.java:116)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:112)
at org.jruby.runtime.Interpreted19Block.evalBlockBody(Interpreted19Block.java:206)
at org.jruby.runtime.Interpreted19Block.yield(Interpreted19Block.java:194)
at org.jruby.runtime.Interpreted19Block.call(Interpreted19Block.java:125)
at org.jruby.runtime.Block.call(Block.java:101)
at org.jruby.RubyProc.call(RubyProc.java:300)
at org.jruby.internal.runtime.methods.ProcMethod.call(ProcMethod.java:64)
at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:218)
at org.jruby.internal.runtime.methods.DynamicMethod.call(DynamicMethod.java:214)
at org.jruby.runtime.callsite.CachingCallSite.cacheAndCall(CachingCallSite.java:346)
at org.jruby.runtime.callsite.CachingCallSite.call(CachingCallSite.java:204)
at org.jruby.ast.CallTwoArgNode.interpret(CallTwoArgNode.java:59)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.ast.RescueBodyNode.interpret(RescueBodyNode.java:108)
at org.jruby.ast.RescueNode.handleException(RescueNode.java:174)
at org.jruby.ast.RescueNode.interpret(RescueNode.java:120)
at org.jruby.ast.BeginNode.interpret(BeginNode.java:83)
at org.jruby.ast.NewlineNode.interpret(NewlineNode.java:105)
at org.jruby.ast.BlockNode.interpret(BlockNode.java:71)
at org.jruby.evaluator.ASTInterpreter.INTERPRET_BLOCK(ASTInterpreter.java:112)
at org.jruby.runtime.Interpreted19Block.evalBlockBody(Interpreted19Block.java:206)
at org.jruby.runtime.Interpreted19Block.yield(Interpreted19Block.java:194)
at org.jruby.runtime.Interpreted19Block.call(Interpreted19Block.java:125)
at org.jruby.runtime.Block.call(Block.java:101)
at org.jruby.RubyProc.call(RubyProc.java:300)
at org.jruby.RubyProc.call(RubyProc.java:230)
at org.jruby.internal.runtime.RubyRunnable.run(RubyRunnable.java:99)
at java.lang.Thread.run(Thread.java:745)
HeapByteBuffer.java:189:in `put': java.nio.BufferOverflowException
from ChannelStream.java:1100:in`bufferedWrite'
from ChannelStream.java:1277:in `fwrite'
from RubyIO.java:1560:in`fwrite'
from RubyIO.java:1431:in `write'
from RubyIO$INVOKER$i$1$0$write.gen:-1:in`call'
from RubyClass.java:743:in `finvoke'
from Helpers.java:505:in`invoke'
from RubyBasicObject.java:364:in `callMethod'
from RubyIO.java:2509:in`write'
from RubyIO.java:2497:in `putsSingle'
from RubyIO.java:2426:in`puts1'
from RubyIO.java:2399:in `puts'
from RubyIO$INVOKER$i$puts.gen:-1:in`call'
from CachingCallSite.java:168:in `call'
from CallOneArgNode.java:57:in`interpret'
from NewlineNode.java:105:in `interpret'
from BlockNode.java:71:in`interpret'
from IfNode.java:116:in `interpret'
from NewlineNode.java:105:in`interpret'
from ASTInterpreter.java:112:in `INTERPRET_BLOCK'
from Interpreted19Block.java:206:in`evalBlockBody'
from Interpreted19Block.java:157:in `yield'
from Block.java:142:in`yield'
from Mutex.java:149:in `synchronize'
from Mutex$INVOKER$i$0$0$synchronize.gen:-1:in`call'
from CachingCallSite.java:143:in `callBlock'
from CachingCallSite.java:154:in`callIter'
from CallNoArgBlockNode.java:64:in `interpret'
from NewlineNode.java:105:in`interpret'
from ASTInterpreter.java:74:in `INTERPRET_METHOD'
from InterpretedMethod.java:182:in`call'
from DefaultMethod.java:203:in `call'
from CachingCallSite.java:168:in`call'
from ShiftLeftCallSite.java:24:in `call'
from CallOneArgNode.java:57:in`interpret'
from NewlineNode.java:105:in `interpret'
from ASTInterpreter.java:74:in`INTERPRET_METHOD'
from InterpretedMethod.java:182:in `call'
from DefaultMethod.java:203:in`call'
from CachingCallSite.java:168:in `call'
from ShiftLeftCallSite.java:24:in`call'
from CallOneArgNode.java:57:in `interpret'
from NewlineNode.java:105:in`interpret'
from IfNode.java:116:in `interpret'
from NewlineNode.java:105:in`interpret'
from BlockNode.java:71:in `interpret'
from ASTInterpreter.java:112:in`INTERPRET_BLOCK'
from Interpreted19Block.java:206:in `evalBlockBody'
from Interpreted19Block.java:157:in`yield'
from Block.java:142:in `yield'
from RubyHash.java:1355:in`visit'
from RubyHash.java:648:in `visitLimited'
from RubyHash.java:634:in`visitAll'
from RubyHash.java:1306:in `iteratorVisitAll'
from RubyHash.java:1351:in`each_pairCommon'
from RubyHash.java:1342:in `each19'
from RubyHash$INVOKER$i$0$0$each19.gen:-1:in`call'
from CachingCallSite.java:143:in `callBlock'
from CachingCallSite.java:154:in`callIter'
from CallNoArgBlockNode.java:64:in `interpret'
from NewlineNode.java:105:in`interpret'
from ASTInterpreter.java:112:in `INTERPRET_BLOCK'
from Interpreted19Block.java:206:in`evalBlockBody'
from Interpreted19Block.java:157:in `yield'
from Block.java:142:in`yield'
from RubyHash.java:1355:in `visit'
from RubyHash.java:648:in`visitLimited'
from RubyHash.java:634:in `visitAll'
from RubyHash.java:1306:in`iteratorVisitAll'
from RubyHash.java:1351:in `each_pairCommon'
from RubyHash.java:1342:in`each19'
from RubyHash$INVOKER$i$0$0$each19.gen:-1:in `call'
from CachingCallSite.java:143:in`callBlock'
from CachingCallSite.java:154:in `callIter'
from CallNoArgBlockNode.java:64:in`interpret'
from NewlineNode.java:105:in `interpret'
from ASTInterpreter.java:112:in`INTERPRET_BLOCK'
from Interpreted19Block.java:206:in `evalBlockBody'
from Interpreted19Block.java:157:in`yield'
from Block.java:142:in `yield'
from Mutex.java:149:in`synchronize'
from Mutex$INVOKER$i$0$0$synchronize.gen:-1:in `call'
from CachingCallSite.java:143:in`callBlock'
from CachingCallSite.java:154:in `callIter'
from CallNoArgBlockNode.java:64:in`interpret'
from NewlineNode.java:105:in `interpret'
from BlockNode.java:71:in`interpret'
from ASTInterpreter.java:74:in `INTERPRET_METHOD'
from InterpretedMethod.java:182:in`call'
from DefaultMethod.java:203:in `call'
from CachingCallSite.java:168:in`call'
from FCallOneArgNode.java:36:in `interpret'
from NewlineNode.java:105:in`interpret'
from BlockNode.java:71:in `interpret'
from ASTInterpreter.java:74:in`INTERPRET_METHOD'
from InterpretedMethod.java:225:in `call'
from DefaultMethod.java:219:in`call'
from CachingCallSite.java:202:in `call'
from FCallTwoArgNode.java:38:in`interpret'
from NewlineNode.java:105:in `interpret'
from BlockNode.java:71:in`interpret'
from ASTInterpreter.java:74:in `INTERPRET_METHOD'
from InterpretedMethod.java:268:in`call'
from DefaultMethod.java:235:in `call'
from CachingCallSite.java:236:in`call'
from FCallThreeArgNode.java:40:in `interpret'
from IfNode.java:116:in`interpret'
from NewlineNode.java:105:in `interpret'
from BlockNode.java:71:in`interpret'
from ASTInterpreter.java:112:in `INTERPRET_BLOCK'
from Interpreted19Block.java:206:in`evalBlockBody'
from Interpreted19Block.java:194:in `yield'
from Interpreted19Block.java:125:in`call'
from Block.java:101:in `call'
from RubyProc.java:300:in`call'
from ProcMethod.java:64:in `call'
from DynamicMethod.java:218:in`call'
from DynamicMethod.java:214:in `call'
from CachingCallSite.java:346:in`cacheAndCall'
from CachingCallSite.java:204:in `call'
from CallTwoArgNode.java:59:in`interpret'
from NewlineNode.java:105:in `interpret'
from BlockNode.java:71:in`interpret'
from BlockNode.java:71:in `interpret'
from RescueBodyNode.java:108:in`interpret'
from RescueNode.java:174:in `handleException'
from RescueNode.java:120:in`interpret'
from EnsureNode.java:96:in `interpret'
from ASTInterpreter.java:74:in`INTERPRET_METHOD'
from InterpretedMethod.java:139:in `call'
from DefaultMethod.java:187:in`call'
from CachingCallSite.java:306:in `cacheAndCall'
from CachingCallSite.java:136:in`call'
from CallNoArgNode.java:60:in `interpret'
from ReturnNode.java:92:in`interpret'
from NewlineNode.java:105:in `interpret'
from BlockNode.java:71:in`interpret'
from ASTInterpreter.java:112:in `INTERPRET_BLOCK'
from Interpreted19Block.java:206:in`evalBlockBody'
from Interpreted19Block.java:194:in `yield'
from Interpreted19Block.java:125:in`call'
from Block.java:101:in `call'
from RubyProc.java:300:in`call'
from RubyProc.java:281:in `call19'
from RubyProc$INVOKER$i$0$0$call19.gen:-1:in`call'
from DynamicMethod.java:202:in `call'
from DynamicMethod.java:198:in`call'
from CachingCallSite.java:306:in `cacheAndCall'
from CachingCallSite.java:136:in`call'
from CallNoArgNode.java:60:in `interpret'
from NewlineNode.java:105:in`interpret'
from ASTInterpreter.java:112:in `INTERPRET_BLOCK'
from Interpreted19Block.java:206:in`evalBlockBody'
from Interpreted19Block.java:194:in `yield'
from Interpreted19Block.java:125:in`call'
from Block.java:101:in `call'
from RubyProc.java:300:in`call'
from RubyProc.java:281:in `call19'
from RubyProc$INVOKER$i$0$0$call19.gen:-1:in`call'
from DynamicMethod.java:202:in `call'
from DynamicMethod.java:198:in`call'
from CachingCallSite.java:306:in `cacheAndCall'
from CachingCallSite.java:136:in`call'
from CallSpecialArgNode.java:65:in `interpret'
from DAsgnNode.java:110:in`interpret'
from NewlineNode.java:105:in `interpret'
from BlockNode.java:71:in`interpret'
from RescueNode.java:221:in `executeBody'
from RescueNode.java:116:in`interpret'
from BeginNode.java:83:in `interpret'
from NewlineNode.java:105:in`interpret'
from ASTInterpreter.java:112:in `INTERPRET_BLOCK'
from Interpreted19Block.java:206:in`evalBlockBody'
from Interpreted19Block.java:194:in `yield'
from Interpreted19Block.java:125:in`call'
from Block.java:101:in `call'
from RubyProc.java:300:in`call'
from RubyProc.java:230:in `call'
from RubyRunnable.java:99:in`run'
from Thread.java:745:in `run'