This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 5171352 [hotfix][javadocs] Replace odd single quotes
5171352 is described below
commit 5171352c283def8eaae3b63d808c3fe3cac5c74b
Author: Xingcan Cui <[email protected]>
AuthorDate: Wed Oct 17 16:26:23 2018 -0400
[hotfix][javadocs] Replace odd single quotes
---
docs/_includes/generated/akka_configuration.html | 2 +-
.../apache/flink/batch/connectors/cassandra/example/BatchExample.java | 2 +-
.../flink/batch/connectors/cassandra/example/BatchPojoExample.java | 2 +-
.../connectors/cassandra/example/CassandraPojoSinkExample.java | 2 +-
.../connectors/cassandra/example/CassandraTupleSinkExample.java | 2 +-
.../cassandra/example/CassandraTupleWriteAheadSinkExample.java | 2 +-
.../src/main/java/org/apache/flink/configuration/AkkaOptions.java | 2 +-
7 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/docs/_includes/generated/akka_configuration.html
b/docs/_includes/generated/akka_configuration.html
index f5a2a5d..7872101 100644
--- a/docs/_includes/generated/akka_configuration.html
+++ b/docs/_includes/generated/akka_configuration.html
@@ -60,7 +60,7 @@
<tr>
<td><h5>akka.log.lifecycle.events</h5></td>
<td style="word-wrap: break-word;">false</td>
- <td>Turns on the Akka’s remote logging of events. Set this value
to ‘true’ in case of debugging.</td>
+ <td>Turns on the Akka’s remote logging of events. Set this value
to 'true' in case of debugging.</td>
</tr>
<tr>
<td><h5>akka.lookup.timeout</h5></td>
diff --git
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java
index 205e437..563f095 100644
---
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java
+++
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchExample.java
@@ -35,7 +35,7 @@ import java.util.ArrayList;
* This is an example showing the to use the Cassandra Input-/OutputFormats in
the Batch API.
*
* <p>The example assumes that a table exists in a local cassandra database,
according to the following queries:
- * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class':
'SimpleStrategy', 'replication_factor': ‘1’};
+ * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class':
'SimpleStrategy', 'replication_factor': '1'};
* CREATE TABLE IF NOT EXISTS test.batches (number int, strings text, PRIMARY
KEY(number, strings));
*/
public class BatchExample {
diff --git
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchPojoExample.java
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchPojoExample.java
index abac357..d5e0742 100644
---
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchPojoExample.java
+++
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/example/BatchPojoExample.java
@@ -37,7 +37,7 @@ import java.util.stream.IntStream;
* This is an example showing the to use the {@link
CassandraPojoInputFormat}/{@link CassandraPojoOutputFormat} in the Batch API.
*
* <p>The example assumes that a table exists in a local cassandra database,
according to the following queries:
- * CREATE KEYSPACE IF NOT EXISTS flink WITH replication = {'class':
'SimpleStrategy', 'replication_factor': ‘1’};
+ * CREATE KEYSPACE IF NOT EXISTS flink WITH replication = {'class':
'SimpleStrategy', 'replication_factor': '1'};
* CREATE TABLE IF NOT EXISTS flink.batches (id text, counter int, batch_id
int, PRIMARY KEY(id, counter, batchId));
*/
public class BatchPojoExample {
diff --git
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraPojoSinkExample.java
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraPojoSinkExample.java
index 89e2d9e..6ee615d 100644
---
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraPojoSinkExample.java
+++
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraPojoSinkExample.java
@@ -34,7 +34,7 @@ import java.util.ArrayList;
* <p>Pojo's have to be annotated with datastax annotations to work with this
sink.
*
* <p>The example assumes that a table exists in a local cassandra database,
according to the following queries:
- * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class':
'SimpleStrategy', 'replication_factor': ‘1’};
+ * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class':
'SimpleStrategy', 'replication_factor': '1'};
* CREATE TABLE IF NOT EXISTS test.message(body txt PRIMARY KEY)
*/
public class CassandraPojoSinkExample {
diff --git
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java
index 72013d5..82daae1 100644
---
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java
+++
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java
@@ -32,7 +32,7 @@ import java.util.ArrayList;
* This is an example showing the to use the Tuple Cassandra Sink in the
Streaming API.
*
* <p>The example assumes that a table exists in a local cassandra database,
according to the following queries:
- * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class':
'SimpleStrategy', 'replication_factor': ‘1’};
+ * CREATE KEYSPACE IF NOT EXISTS test WITH replication = {'class':
'SimpleStrategy', 'replication_factor': '1'};
* CREATE TABLE IF NOT EXISTS test.writetuple(element1 text PRIMARY KEY,
element2 int)
*/
public class CassandraTupleSinkExample {
diff --git
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleWriteAheadSinkExample.java
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleWriteAheadSinkExample.java
index 8cab311..d761f2a 100644
---
a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleWriteAheadSinkExample.java
+++
b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleWriteAheadSinkExample.java
@@ -37,7 +37,7 @@ import java.util.UUID;
* This is an example showing the to use the Cassandra Sink (with write-ahead
log) in the Streaming API.
*
* <p>The example assumes that a table exists in a local cassandra database,
according to the following queries:
- * CREATE KEYSPACE IF NOT EXISTS example WITH replication = {'class':
'SimpleStrategy', 'replication_factor': ‘1’};
+ * CREATE KEYSPACE IF NOT EXISTS example WITH replication = {'class':
'SimpleStrategy', 'replication_factor': '1'};
* CREATE TABLE example.values (id text, count int, PRIMARY KEY(id));
*
* <p>Important things to note are that checkpointing is enabled, a
StateBackend is set and the enableWriteAheadLog() call
diff --git
a/flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java
b/flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java
index 02234b9..ba63e85 100644
--- a/flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java
+++ b/flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java
@@ -160,7 +160,7 @@ public class AkkaOptions {
public static final ConfigOption<Boolean> LOG_LIFECYCLE_EVENTS =
ConfigOptions
.key("akka.log.lifecycle.events")
.defaultValue(false)
- .withDescription("Turns on the Akka’s remote logging of events.
Set this value to ‘true’ in case of debugging.");
+ .withDescription("Turns on the Akka’s remote logging of events.
Set this value to 'true' in case of debugging.");
/**
* Timeout for all blocking calls that look up remote actors.
