visualskyrim

ansible-playbook -i <inventory-file> deploy_authorized_keys.yml --ask-become-pass --ask-pass --extra-vars='pubkey="<pubkey-for-super-user>”’

visualskyrim

---
- hosts: all
  become: true
  become_user: "super-user"
  tasks:
  - name: make direcotry
    file:
      path: "/home/<super-user>/.ssh"
      state: directory
  - name: create empty file

visualskyrim

[defaults]
host_key_checking = False

visualskyrim

ansible-playbook -i <inventory-file> deploy_authorized_keys.yml --ask-pass --extra-vars='pubkey="<pubkey>"'

visualskyrim

---
- hosts: all
  tasks:
  - name: make direcotry
    file:
      path: "/home/<username>/.ssh"
      state: directory
  - name: create empty file
    file:
      path: "/home/<username>/.ssh/authorized_keys"

visualskyrim

import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.CheckpointingMode;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.CheckpointConfig;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink;
import org.apache.flink.streaming.connectors.fs.bucketing.DateTimeBucketer;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08;
import org.apache.flink.streaming.util.serialization.SimpleStringSchema;

visualskyrim

input {
    kafka {
        group_id => "flink-test"
        topics => ["flink-test"]
        bootstrap_servers => "localhost:9092"
    }
}
output {
  stdout {}
}

visualskyrim

from kafka import KafkaProducer
from kafka.errors import KafkaError
import json
import time

producer = KafkaProducer(bootstrap_servers=['localhost:9092'], value_serializer=lambda m: json.dumps(m).encode('ascii'))
# Asynchronous by default
future = producer.send('flink-test', b'raw_bytes')

# Block for 'synchronous' sends

visualskyrim

  it("should render a text box with no string inside if search string is not provided by store", () => {
    const testState = {
      showBox: {
        search: ""
      }
    };
    const store = createMockStore(testState)
    const component = shallowWithStore(<ConnectedShowBox />, store);
    expect(component).to.be.a('object');
    

visualskyrim

describe('ConnectedShowBox', () => {
  it("should render a text box with empty string inside if string is not provided by store", () => {
    const testState = {
      searchBox: {}
    };
    const store = createMockStore(testState)
    const component = shallowWithStore(<ConnectedShowBox />, store);
    expect(component).to.be.a('object');
    expect(component.dive().find("").prop("value")).to.equal("")
  });