小编Roc*_*cel的帖子

我有很多用户向Play控制台报告此崩溃.我测试了它,它有时只出现.崩溃发生在我在ParseApplication类中的这一行中,它扩展了Application类,应该在其他所有之前调用它？

这是它崩溃的线:

 Parse.initialize(this, "XXXXXXXXXXXXXXXXXXXXXXXXXXXX", "XXXXXXXXXXXXXXXXXXXXXXXXX");

这是崩溃

java.lang.RuntimeException: Unable to create application com.hour.chat.ParseApplication: java.util.ConcurrentModificationException
at android.app.ActivityThread.handleBindApplication(ActivityThread.java:4411)
at android.app.ActivityThread.access$1500(ActivityThread.java:145)
at android.app.ActivityThread$H.handleMessage(ActivityThread.java:1266)
at android.os.Handler.dispatchMessage(Handler.java:102)
at android.os.Looper.loop(Looper.java:136)
at android.app.ActivityThread.main(ActivityThread.java:5081)
at java.lang.reflect.Method.invokeNative(Native Method)
at java.lang.reflect.Method.invoke(Method.java:515)
at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:781)
at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:597)
at dalvik.system.NativeStart.main(Native Method)
Caused by: java.util.ConcurrentModificationException
at java.util.LinkedList$LinkIterator.next(LinkedList.java:124)
at com.parse.ParseObject.mergeREST(ParseObject.java:928)
at com.parse.ParseUser.mergeREST(ParseUser.java:285)
at com.parse.OfflineStore$13$2.then(OfflineStore.java:765)
at com.parse.OfflineStore$13$2.then(OfflineStore.java:762)
at com.parse.Task$10.run(Task.java:448)
at com.parse.Task$ImmediateExecutor.execute(Task.java:673)
at com.parse.Task.completeImmediately(Task.java:444)
at com.parse.Task.continueWith(Task.java:318)
at com.parse.Task.continueWith(Task.java:329)
at com.parse.Task$8.then(Task.java:381)
at com.parse.Task$8.then(Task.java:373)
at com.parse.Task$11.run(Task.java:481)
at com.parse.Task$ImmediateExecutor.execute(Task.java:673)
at com.parse.Task.completeAfterTask(Task.java:477)
at com.parse.Task.continueWithTask(Task.java:353)
at com.parse.Task.onSuccess(Task.java:373)
at com.parse.Task.onSuccess(Task.java:393)
at com.parse.OfflineStore$13.then(OfflineStore.java:762)
at com.parse.OfflineStore$13.then(OfflineStore.java:721) …

我们正在使用kafka streams的windows join来加入2个流,我们想知道:

• 为什么KS在内部主题上增加+ 24小时？例如,我们有一个1小时的窗口,但内部主题保留了25小时.我们可以将其配置为不添加24h吗？
• KS似乎在窗口中保留了两个流的数据 - 内部主题和状态存储(rocksdb) - 有没有办法只保留连接左侧的流？

[UPDATE]

例如,我们像这样创建JoinWindow:

JoinWindows.of(300000).before(600000).until(3600000)

虽然我可以看到内部主题(对于JOINTHIS和OUTEROTHER)已经创建了

Configs:retention.ms=90000000

现在刚刚在我的机器上的空代理(使用汇合的cli工具)上测试了这个

我正在尝试将 Rocks DB 与 TTL 结合使用。我初始化rocks db的方式如下：

 options.setCreateIfMissing(true)
   .setWriteBufferSize(8 * SizeUnit.KB)
   .setMaxWriteBufferNumber(3) 
   .setCompressionType(CompressionType.LZ4_COMPRESSION)
   .setKeepLogFileNum(1);

db = TtlDB.open(options, this.dbpath, 10, false);

我已将 TTL 设置为 10 秒。但是，10 秒后键值对不会被删除。这里发生了什么事？