小编Kul*_*gar的帖子

当我最近开始混音时Windows Azure,我遇到了一种情况,即Block Blob&之间的哪一个Page Blob.我目前正在将一些text,csv或dat文件上传到blob存储,然后MapReduce使用我的C#程序为它做一个程序.是的,我已经经历了一些物品,如走了第一条,第二条.

但无法从他们那里得到一个明确的想法.缩短,Block Blob vs Page Blob.任何帮助,将不胜感激.

我运行了服务logstash configtest,但给出的错误是:

logstash:无法识别的服务

我能够单独运行logstash服务,但不能运行"configtest".在etc/logstash/conf.d /我创建了logstash.conf文件,其中包含如下所示的代码: -

附加信息:-

service logstash status
? logstash.service - logstash
   Loaded: loaded (/etc/systemd/system/logstash.service; disabled)
   Active: active (running) since Mon 2016-12-26 12:40:58 PST; 6s ago
 Main PID: 3512 (java)
   CGroup: /system.slice/logstash.service
           ??3512 /usr/bin/java -XX:+UseParNewGC -XX:+UseConcMarkSweepGC -XX:CMSInitiatingOccupancyFraction=75 -XX:+UseCMSInitiatingOccupancyOnly -XX...

Dec 26 12:40:58 Mr systemd[1]: Started logstash.

使用configtest运行时的服务: -

root@Mr:/# service logstash configtest
logstash: unrecognized service

我在debian8机器上运行这个,希望我能从你们那里得到一个很好的解决方案.

# This input block will listen on port 10514 for logs to come in.
# host should be an IP on the …

我使用ELK堆栈来分析我的日志文件.我上周测试过,一切正常.

今天,我测试但是当我键入" http:// localhost:9200/iot_log/_count "(iot_log是我的索引模式)时出现此错误:

{"error":{"root_cause":[{"type":"index_not_found_exception","reason":"no such index","resource.type":"index_or_alias","resource.id":"iot_log", "index_uuid":" na ","index":"iot_log"}],"type":"index_not_found_exception","reason":"no such index","resource.type":"index_or_alias","resource.id ":"iot_log","index_uuid":" na ","index":"iot_log"},"状态":404}

我真的搜索了论坛,但我还没有找到解决方案,我想知道这个问题的原因是什么,我该如何纠正呢？

我有一个java应用程序,我正在使用它Flink Api.所以基本上我正在尝试用代码做的是创建两个记录很少的数据集,然后将它们作为两个表和必要的字段注册.

 DataSet<Company> comp = env.fromElements(
                new Company("Aux", 1),
                new Company("Comp2", 2),
                new Company("Comp3", 3));

        DataSet<Employee> emp = env.fromElements(
                new Employee("Kula", 1),
                new Employee("Ish", 1),
                new Employee("Kula", 3));


        tEnv.registerDataSet("Employee", emp, "name, empId");
        tEnv.registerDataSet("Company", comp, "cName, empId");

然后我尝试使用以下方法连接这两个表Table API:

Table anotherJoin = tEnv.sql("SELECT Employee.name, Employee.empId, Company.cName FROM " +
                "Employee RIGHT JOIN Company on Employee.empId = Company.empId");

而我只是在控制台上打印结果.这在我的机器上完美地工作.我创建了一个fat-jar使用maven-shade-pluginwith依赖项,我正在尝试在AWS中执行它Lambda.

因此,当我尝试在那里执行它时,我会被抛出以下异常(我只发布前几行):

reference.conf @ file:/var/task/reference.conf:804:无法将替换解析为值:$ {akka.stream.materializer}:com.typesafe.config.ConfigException $ UnresolvedSubstitution com.typesafe.config.ConfigException $ …

我正在开发一个Windows Phone 8.1通用应用程序,并希望找到处理页面导航的最佳方法,而不会在后面的代码中有大量逻辑.我希望尽可能整洁地将代码保留在我的视图中.为响应按钮点击,导航到新页面的MVVM方式是什么？

我目前必须从ViewModel向视图发送一条RelayComnmand消息,其中包含要导航到的页面的详细信息.这意味着后面的代码必须按如下方式连接:

    public MainPage()
    {
      InitializeComponent();
      Messenger.Default.Register<OpenArticleMessage>(this, (article) => ReceiveOpenArticleMessage(article));
...
}

    private object ReceiveOpenArticleMessage(OpenArticleMessage article)
    {
     Frame.Navigate(typeof(ArticleView));
   }

虽然它确实有效,但这似乎并不是最好的方法.如何直接从ViewModel进行页面导航？我在我的项目中使用MVVM-Light.

我很不清楚sql_last_value当我这样发表我的陈述时会发生什么：

statement => "SELECT * from mytable where id > :sql_last_value"

我可以稍微理解使用它背后的原因，它不浏览整个 db 表来更新字段，而是只更新新添加的记录。如果我错了纠正我。

所以我想要做的是，使用以下方式创建索引logstash：

input {
    jdbc {
        jdbc_connection_string => "jdbc:mysql://hostmachine:3306/db" 
        jdbc_user => "root"
        jdbc_password => "root"
        jdbc_validate_connection => true
        jdbc_driver_library => "/path/mysql_jar/mysql-connector-java-5.1.39-bin.jar"
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        schedule => "* * * * *"
        statement => "SELECT * from mytable where id > :sql_last_value"
        use_column_value => true
        tracking_column => id
        jdbc_paging_enabled => "true"
        jdbc_page_size => "50000"
    }
}

output {
    elasticsearch {
        #protocol => http
        index …

实际上我有弹性搜索5.1.1并尝试使用以下命令下载kopf插件,我得到了这样的错误..你能帮我解决这个问题吗？

C:\ Users\896323\Downloads\elasticsearch-5.1.1\elasticsearch-5.1.1\bin> plugin install lmenezes/elasticsearch-kopf/2.1.1用于管理已安装的elasticsearch插件的工具

命令

• list - 列出已安装的elasticsearch插件
• 安装 - 安装插件
• 删除 - 从elasticsearch中删除插件

非选项参数:命令

选项说明------ -----------

• -h, - help显示帮助
• -s, - silent显示最小输出
• -v, - verbose显示详细输出

错误:未知插件lmenezes/elasticsearch-kopf/2.1.1

我最近一直在研究WSO2 Message Broker(Ver:3.1.0),以便使用JMeterjms客户端发布和使用消息.所以我有我的发布者Java程序,我正在发布消息,我试图每秒发布4000条消息.如有必要,我可以提供代码段.

我通过 在无头模式下运行JMeter命令jmeter -n -t C:\Users\ctsadmin\Downloads\wso2MB\apache-jmeter-2.13\bin\GamesSubscriber.jmx -l C:\Users\ctsadmin\Downloads\wso2MB\apache-jmeter-2.13\bin\mytest_results.jtl来消耗这些消息.我也VisualVm打开了窗口,看看测试的内存消耗.在前15分钟,根据下面的图像,发布和消费已经确定,但在那之后,突然之间的VisualVm节目大肆宣传并耗尽内存.我附上了VisualVM下面的截图.

我已检查heap dump的的WSO2 MB使用JProfiler为好.附上了它的截图.

可能是什么问题？我应该做出哪些改变？像增加heap尺寸的东西？任何帮助都会受到重视.

编辑:我特此附加日志文件和堆转储.

我有一个 python 脚本，它以 json 形式获取集群运行状况并向我发送邮件。问题是 json 没有很好地打印出来。这些是我已经尝试过的方法：

1. 简单 --> json.dumps(health)
2. json.dumps(health, indent=4, sort_keys=True)

但是gmail中的输出还是没有格式化的，有点像这样

{ "active_primary_shards": 25, "active_shards": 50, "active_shards_percent_as_number": 100.0, "cluster_name": "number_of_pending_tasks": 0, "relocating_shards": 0, "status": "green", "task_max_waiting_in_queue_millis": 0, "timed_out": false, "unassigned_shards": 0 }

邮件已发送至 gmail

我目前正在使用最新版本MySQL(版本8.0.2),我正在尝试创建一个read-only View.

这是我的查询的样子:

CREATE VIEW Emp_Salary3 AS
SELECT Empid, Ename, Date_Joined, Salary, Dcode 
FROM Employees
WHERE Salary < 35000
WITH READ ONLY;

但后来我得到的回应是:

错误代码:1064.您的SQL语法有错误; 检查与MySQL服务器版本对应的手册,以便在第5行的"READ ONLY"附近使用正确的语法

因此我也检查了手册,它没有任何READ-ONLY选项.有没有解决这个问题？

任何帮助都可以得到赞赏.