小编hve*_*iga的帖子

你能否告诉我Apache Spark和AKKA之间的区别,我知道这两个框架都意味着编程分布式和并行计算,但我没有看到它们之间的链接或区别.

此外,我想得到适合他们每个人的用例.

我正在尝试使用Log4j2将spring日志打印到文件和控制台中.我想这是我的Log4j2配置中的一个问题.我无法让它发挥作用.我在log4j2.xml文件中有这个配置:

<?xml version="1.0" encoding="UTF-8"?>
<configuration name="defaultConfiguration" status="warn" strict="true" monitorInterval="5">
    <properties>
        <property name="patternlayout">%d{ISO8601} [%t] %-5level %logger{36} - %msg%n%throwable{full}</property>
        <property name="filename">${env:MY_ROOT}/logs/mylog.log</property>
        <property name="filenamePattern">${env:MY_ROOT}/logs/mylog-%d{yyyy-dd-MM}-%i.log.gz</property>
    </properties>
    <appenders>
        <appender name="Console" type="Console" target="SYSTEM_OUT">
            <layout type="PatternLayout" pattern="${patternlayout}" />
        </appender>
        <appender name="File" type="RollingFile" fileName="${filename}" filePattern="${filenamePattern}" bufferedIO="true" immediateFlush="true"
        append="true">
            <layout type="PatternLayout" pattern="${patternlayout}" />
            <Policies>
                <TimeBasedTriggeringPolicy />
                <SizeBasedTriggeringPolicy size="50 MB" />
            </Policies>
            <DefaultRolloverStrategy max="30" />
        </appender>
        <appender name="AsynchFile" type="asynch" blocking="true" bufferSize="128">
            <appender-ref ref="File" />
        </appender>
    </appenders>
    <loggers>
        <root level="info">
            <appender-ref ref="Console" />
            <appender-ref ref="AsynchFile" />
        </root>
        <logger name="org.springframework.beans"> …

我在一个独立的集群中运行Spark.与Master和2个工作节点在同一节点上的python驱动程序应用程序.业务逻辑是由在Worker节点上创建的执行程序运行的python代码.

如果其中一个遗嘱执行人死亡,我最终会陷入困境.如果我强行杀死Worker 0上的一个后端进程,Master输出:

16/06/07 16:20:35 ERROR TaskSchedulerImpl: Lost executor 1 on sparkslave0: Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.
16/06/07 16:20:35 WARN TaskSetManager: Lost task 2.0 in stage 0.0 (TID 2, sparkslave0): ExecutorLostFailure (executor 1 exited caused by one of the running tasks) Reason: Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.
16/06/07 16:20:35 INFO DAGScheduler: Executor …

我想知道是否有任何方法来检查字符串是否存在于另一个字符串中(即包含函数).我已经看过http://forge.puppetlabs.com/puppetlabs/stdlib,但我还没有找到这个特定的功能.也许这可以通过正则表达式来实现,但我不确定该怎么做.有人可以帮我这个吗？

我刚刚将Eclipse升级到Kepler,并认为我会尝试使用内置RSE替代JCraft SFTP插件,以便通过SSH进行远程同步.我已经勾选了Review/Synchronize导出了我的项目,在Synchronize面板中我可以看到我要导出的文件.

如果我右键单击一个文件,我会得到一个"Put"选项来发送文件,但如果我右键单击一个文件夹,则该选项不存在.

如何"放"一个文件夹？在地狱里我没办法单独做每个文件.

我启动ncat控制台,然后提交简单的示例应用程序network_wordcount.py.

当我通过ncat控制台输入单词时,我看到以下输出:

...
15/01/20 16:55:19 INFO scheduler.JobScheduler: Added jobs for time 1421769319000 ms
15/01/20 16:55:19 INFO storage.MemoryStore: ensureFreeSpace(12) called with curMem=65052, maxMem=280248975
15/01/20 16:55:19 INFO storage.MemoryStore: Block input-0-1421769319200 stored as bytes in memory (estimated size 12.0 B, free 267.2 MB)
15/01/20 16:55:19 INFO storage.BlockManagerInfo: Added input-0-1421769319200 in memory on localhost:34754 (size: 12.0 B, free: 267.2 MB)
15/01/20 16:55:19 INFO storage.BlockManagerMaster: Updated info of block input-0-1421769319200 
15/01/20 16:55:19 WARN storage.BlockManager: Block input-0-1421769319200 replicated to only 0 peer(s) instead of 1 peers …

例如我有这样的5点,

(1,1) (2,-1) (3,2) (4,-2) (5,2)

现在,

• 1)我想要一个函数在Matlab中插入这些点.
• 2)我想绘制这个函数.
• 3)从输入读取一个数字并将F(x)写入输出.

我怎样才能做到这一点？？

我试图使用Log4j2的新RoutingAppender基于MDC(Log4j2中的ThreadContext)路由不同的日志.我想做的是以下内容:

• 如果MDC映射有$ contextId - >追加到$ contextId appender(特定日志)
• 如果MDC没有$ contextId - >追加到主appender(通用日志)

我想在标记中使用通配符模式实现此目的,然后使用for contextId($ {ctx:contextId})中的key参数进行过滤,并使用默认(不带键参数)作为主appender,但是我没有知道哪个值是那个通配符.

任何帮助表示赞赏,也许我正在走错路.我一直在阅读关于过滤器但似乎没有按我的意愿工作.

谢谢!

我们正在尝试使用Apache Camel2.16.3将一些数据推送到第三方HTTP端点。我们正在使用HTTP4组件。我们将uri，方法和查询参数设置为消息中的标头。但是，端点包含一个下划线（_），并且我们得到了如下异常：

引起原因：java.lang.IllegalArgumentException：无效的uri：https ://x_y.something.com/somePath?q_one = XXXX & q_two =YYYYY。如果要转发/桥接http端点，请在端点上启用bridgeEndpoint选项：端点[https4：// placeholder？throwExceptionOnFailure = false]

我一直在研究，看起来这_是URI中不应该存在的内容。该网站实际上说https://x_y.something.com/somePath无效但https://xy.something.com/somePath有效。

由于我无法更改第三方端点，是否可以以某种方式转义下划线？如果没有，是否还有其他解决方案，或者我们需要放弃Apache Camel吗？

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。关于如何开展这项工作有什么建议吗？