r0c

org.apache.flink.table.api.TableException: Exception in close
	at org.apache.flink.table.filesystem.FileSystemOutputFormat.close(FileSystemOutputFormat.java:131)
	at org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction.close(OutputFormatSinkFunction.java:97)
	at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:635)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$afterInvoke$1(StreamTask.java:515)
	at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:513)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:478)

r0c

mysql-connector-java-5.1.48.jar
slf4j-log4j12-1.7.15.jar
log4j-1.2.17.jar
flink-table_2.11-1.10.0.jar
flink-table-blink_2.11-1.10.0.jar
flink-dist_2.11-1.10.0.jar
flink-jdbc_2.11-1.10.0.jar
flink-sql-connector-elasticsearch6_2.11-1.10.0.jar
flink-sql-connector-kafka_2.11-1.10.0.jar
flink-json-1.10.0.jar

r0c

{
"@context": "https://w3id.org/openbadges/v2",
"id": "https://www.joybusinessacademy.com/revocation-list-testnet.json",
"type": "RevocationList",
"issuer": "https://www.joybusinessacademy.com/about-us",
"revokedAssertions": [
{
"id": "urn:uuid:93019408-acd8-4420-be5e-0400d643954a",
"revocationReason": "Honor code violation"
},

r0c

#!/bin/bash
#
# terraform-app
#
# This to terraform the servers for the Galleon App

# By storing the date now, we can calculate the duration of provisioning at the
# end of this script.
start_seconds="$(date +%s)"

r0c

Identity added: /tmp/ansible_tower_whfkyB/ad_hoc_credential (/tmp/ansible_tower_whfkyB/ad_hoc_credential) 10.99.1.148 | SUCCESS | rc=0 >>

[2017-01-11T22:38:51,053][TRACE][o.e.i.b.request          ] [request] Adjusted breaker by [16440] bytes, now [16440]

[2017-01-11T22:38:51,053][TRACE][o.e.i.b.request          ] [request] Adjusted breaker by [-16440] bytes, now [0]

[2017-01-11T22:38:51,055][TRACE][o.e.i.b.in_flight_requests] [in_flight_requests] Adjusted breaker by [485] bytes, now [485]

[2017-01-11T22:38:51,055][TRACE][o.e.t.TaskManager        ] [ip-10-99-1-148] register 4918 [netty] [internal:discovery/zen/fd/ping] []

r0c

[2017-01-11T21:37:18,111][INFO ][o.e.n.Node               ] [ip-10-99-1-148] initializing ...

[2017-01-11T21:37:18,189][INFO ][o.e.e.NodeEnvironment    ] [ip-10-99-1-148] using [1] data paths, mounts [[/es_data/data (/dev/md127)]], net usable_space [37.1gb], net total_space [39.2gb], spins? [possibly], types [ext4]

[2017-01-11T21:37:18,190][INFO ][o.e.e.NodeEnvironment    ] [ip-10-99-1-148] heap size [1.9gb], compressed ordinary object pointers [true]

[2017-01-11T21:37:18,199][INFO ][o.e.n.Node               ] [ip-10-99-1-148] version[5.0.2], pid[2951], build[f6b4951/2016-11-24T10:07:18.101Z], OS[Linux/3.10.0-327.28.3.el7.x86_64/amd64], JVM[Oracle Corporation/Java HotSpot(TM) 64-Bit Server VM/1.8.0_102/25.102-b14]

[2017-01-11T21:37:19,141][INFO ][c.f.s.SearchGuardPlugin  ] Node [ip-10-99-1-148] is a transportClient: false/tribeNode: false/tribeNodeClient: false

r0c

#!/usr/bin/env python
import random


def getL(list, n, maxlenoverall):
    if n == 0:
        return 1
    maxlen = 1 

    for i in range(n):