小编hve*_*iga的帖子

zgc我正在测试 11中包含的新垃圾收集器java，因为它承诺非常低的延迟。我们的应用程序是一个实时服务，每秒创建和销毁许多对象，并且它在多线程环境中使用akka.

当zgc通过传递选项-XX:+UnlockExperimentalVMOptions -XX:+UseZGC和启用gc日志来启用时，我们可以在日志中看到许多类似于以下的消息：

[2020-05-20T18:05:36.563+0000][63.851s][info ][gc] Allocation Stall (Main-akka.remote.default-remote-dispatcher-6) 11332.231ms
[2020-05-20T18:05:36.563+0000][63.851s][info ][gc] Allocation Stall (Main-akka.remote.default-remote-dispatcher-26) 9898.046ms
[2020-05-20T18:05:36.563+0000][63.851s][info ][gc] Allocation Stall (Main-io-blocking-dispatcher-52) 12133.240ms
[2020-05-20T18:05:36.563+0000][63.851s][info ][gc] Allocation Stall (Main-akka.actor.default-dispatcher-54) 9002.299ms
[2020-05-20T18:05:36.563+0000][63.850s][info ][gc] Allocation Stall (Main-io-blocking-dispatcher-50) 12134.218ms
[2020-05-20T18:05:36.563+0000][63.850s][info ][gc] Allocation Stall (Main-akka.actor.default-dispatcher-46) 12132.540ms
[2020-05-20T18:05:36.563+0000][63.851s][info ][gc] Allocation Stall (Main-akka.actor.default-dispatcher-56) 8072.664ms

几秒钟后，JVM 退出，没有给出任何原因。我们正在奔跑openjdk-java-11。关于如何开展这项工作有什么建议吗？

我是Akka/Scala世界的新手.我试图找出当演员收到消息时总是执行某些事情的最佳方式,即使它没有匹配.我知道这receive是PartialFunction但我很想知道是否有更好的方法来做到这一点:

def receive: Receive = {
  case string: String => { 
    functionIWantToCall()
    println(string)
  }
  case obj: MyClass => {
    functionIWantToCall()
    doSomethingElse()
  }
  case _ => functionIWantToCall()
}

我非常确定在Scala中有更好的方法来执行此操作,而不是functionIWantToCall()在每个案例中调用.有人可以建议一些东西:)？

我有一个大型数据集,我试图用Apache Spark运行(大约5TB).我注意到,当作业开始时,它会非常快速地检索数据,并且作业的第一阶段(map转换)非常快速地完成.

但是,在处理了大约500GB的数据之后,这种map转换开始变慢,一些任务需要几分钟甚至几小时才能完成.

我正在使用10台机器,122 GB和16CPU,我正在为每个工作节点分配所有资源.我想过增加机器的数量,但还有其他的东西我可能会丢失吗？

我尝试了一小部分数据集(30 GB),似乎工作正常.

我想知道如何在Spring DSL中使用camel-zipfile中的ZipSplitter.我一直在尝试基于这篇文章的不同方法使用Apache Camel UnZippedMessageProcessor解压缩文件,但我无法弄清楚如何在Spring中做.另外,我还没有找到任何关于此的例子.

我有这样的事情:

<bean id="zipSplitter" class="org.apache.camel.dataformat.zipfile.ZipSplitter" />

...

<split streaming="true" parallelProcessing="true">
    <?????>
    <convertBodyTo type="java.lang.String" />
    <to uri="file:foo" />
</split>

谢谢您的帮助!

我正在将这段代码用于我需要为朋友设计的小程序.问题是无法让它发挥作用.

我正在设计一个使用蔬菜和水果清单的程序.例如我的列表是:

smallist = [["apple", 2], ["banana", 3], ["strawberry",1]]
item = input("Please give the name of the fruit\n\n")

smallist.index(item)
print (smallist)

问题是当我尝试找到让我们说苹果的索引时.我只是说苹果不存在.

smallist.index(item)
ValueError: 'apple' is not in list

我无法弄清楚为什么它不会向我展示苹果的价值,在这种情况下它将是2

我想改变片段onTabSelected.

因为此刻,如果你滑动过渡工作正常.但是如果单击Tab,则片段不会切换.将Tab被强调,但内容保持不变.

问题出在我的onTabSelected方法上.我需要一个关于如何切换到Fragments的建议onTabSelected.

不幸的是我不能延伸MainActivity到我FragmentActivity,因为ActionBar在那种情况下我将无法使用(我需要扩展ActionBarActivity).

onTabSelected片段:

@Override
public void onTabSelected(ActionBar.Tab tab, FragmentTransaction fragmentTransaction) {
  int position = tab.getPosition();

  switch (position) {
    case 0:
        break;
    case 1:
        break;
    case 2:
        break;
  }
}

MainActivity的一部分在这里很重要:

public class MainActivity extends ActionBarActivity implements ActionBar.TabListener {

    private ViewPager viewPager;
    private TabsPagerAdapter mAdapter;
    private ActionBar actionBar;

    // Tab titles
    private String[] tabs = { "Novice", "?lanki", "O Tribuni" }; …

我试图提出一种解决方案，将收到的传入字符串拆分为多个字符串。我一直在研究，在以前的Akka-Streams版本中似乎有一个Transformer可以扩展以进行这种转换的类。

在我使用的版本（RC2）中，有Stages，但我不确定如何实现拆分模式。

Source.actorPublisher[String](MyActor.props).
.XXXXX(_.split("\n"))
.map(...)
.to(Sink(...))

我正在寻找XXXXX允许我输入a String并返回一个序列的组件String，并将每个组件发送到流程的其余部分。

我正在使用相对较新的Facebook图形API.我正在获取使用该应用的朋友列表和他们的个人资料照片.

我不知道如何修改我发送的参数,以便返回的图片很大.当前返回的默认值是小的.

我正在使用newMyFriendsRequest.

我发送它的parms看起来像这样......

Bundle parameters = new Bundle();
parameters.putString("fields", "picture,name");

request.setParameters(parameters);
request.executeAsync();

不知道如何将parm添加到该请求,以便返回给我的图片很大.

有人可以帮忙吗？