flume-sink报错 java.lang.IllegalStateException: close() called when transaction is OPEN - you must either commit or rollback first
2017-02-10 15:49
1826 查看
1. 确认代码无误(根据情况修改,表示若获得不了数据不会自动commit或者rollback):
http://grokbase.com/t/flume/user/12be2xfgg5/custom-sink-close-called-when-transaction-is-open-error
2. 确认flume启动给足了内存:
查看flume-ng文件:
JAVA_OPTS="-Xmx1024m" #设置大一点,默认是20M
可参考:http://blog.csdn.net/panguoyuan/article/details/39555239
Event event = channel.take(); if (event == null) { return Status.BACKOFF; } I changed it to: if (event == null) { transaction.commit(); return Status.BACKOFF; }
http://grokbase.com/t/flume/user/12be2xfgg5/custom-sink-close-called-when-transaction-is-open-error
2. 确认flume启动给足了内存:
查看flume-ng文件:
JAVA_OPTS="-Xmx1024m" #设置大一点,默认是20M
可参考:http://blog.csdn.net/panguoyuan/article/details/39555239
相关文章推荐
- Glide异常:java.lang.IllegaliArgumentException:You must not call setTag() on a view Glide is targeting
- java.lang.IllegalArgumentException: You must not call setTag() on a view Glide is targeting
- java.lang.IllegalArgumentException: You must not call setTag() on a view Glide is targeting
- RMAN-06496: must use the TO clause when the database is mounted or open
- HTTP Status 500 - Could not open JDBC Connection for transaction; nested exception is java.lang.NoCl
- Could not open JPA EntityManager for transaction; nested exception is java.lang.NullPointerException
- java.lang.IllegalArgumentException: You must not call setTag() on a view Glide is targeting
- 解决Could not open Hibernate Session for transaction; nested exception is java.lang.NoClassDefFoundEr
- 解决"There is already an open DataReader associated with this Command which must be closed first." exception in EF 中
- Tomcat的异常 之 java.lang.IllegalArgumentException: Document base *** does not exist or is not a readabl
- java.lang.IllegalArgumentException: Document base (文件夹路) does not exist or is not a readable directo
- java.lang.IllegalArgumentException: Document base *** does not exist or is not a readable
- vs2005下出现“Session state can only be used when enableSessionState is set to true, either in a configuration file or in the Page directive”的解决方法
- java.lang.IllegalArgumentException: Document base XXXXX does not exist or is not a readable directory
- LINQ: There is already an open DataReader associated with this Command which must be closed first
- MySql: There is already an open DataReader associated with this Command which must be closed first.2/16
- 使用水晶报表11.5 问题 is already open. Do you want to close it?
- Could not open Hibernate Session for transaction . or java.net.SocketException: Broken pipe
- java.lang.IllegalArgumentException: sessionFactory or hibernateTemplate is required 错误解决方法
- java.lang.IllegalArgumentException: Document base *** does not exist or is not a readable