Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1524#discussion_r53014234
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -176,6 +184,8 @@ abstract class ApplicationMasterBase {
[
https://issues.apache.org/jira/browse/FLINK-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148628#comment-15148628
]
ASF GitHub Bot commented on FLINK-3396:
---
Github user uce commented on the pull request:
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1633#issuecomment-184694713
Travis has passed. Did you have another look at this @tillrohrmann?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Chesnay Schepler created FLINK-3416:
---
Summary: [py] .bat files fail when path contains spaces
Key: FLINK-3416
URL: https://issues.apache.org/jira/browse/FLINK-3416
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148622#comment-15148622
]
Robert Metzger commented on FLINK-3115:
---
[~smarthi], can you give us an update on the progress with
Stephan Ewen created FLINK-3415:
---
Summary: TimestampExctractor accepts negative watermarks
Key: FLINK-3415
URL: https://issues.apache.org/jira/browse/FLINK-3415
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3304.
---
Resolution: Fixed
Fix Version/s: 1.0.0
Resolved in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1635
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148612#comment-15148612
]
ASF GitHub Bot commented on FLINK-3304:
---
Github user kl0u commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148609#comment-15148609
]
ASF GitHub Bot commented on FLINK-3304:
---
Github user rmetzger commented on the pull request:
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1635#issuecomment-184688675
Thanks a lot @rmetzger !
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1635#issuecomment-184688215
Merging ...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1641#discussion_r53010068
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/StreamTransformation.java
---
@@ -202,6 +203,29 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-3315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148596#comment-15148596
]
ASF GitHub Bot commented on FLINK-3315:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148586#comment-15148586
]
ASF GitHub Bot commented on FLINK-3299:
---
Github user gyfora commented on the pull request:
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1642#issuecomment-184683583
In general the DbStateBackend should not misbehave under the current
assumptions. What Ufuk means is that the DbStateBackend does not make any
assumption about the job
[
https://issues.apache.org/jira/browse/FLINK-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148560#comment-15148560
]
ASF GitHub Bot commented on FLINK-3299:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1642#issuecomment-184677192
What would that corner case be?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148558#comment-15148558
]
ASF GitHub Bot commented on FLINK-3299:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1642
[FLINK-3299] Remove ApplicationID from Environment
As per discussion in the issue, we decided to remove the the
`ApplicationID`.
Replaces the app ID in RocksDB and DB backend with job ID. I've
[
https://issues.apache.org/jira/browse/FLINK-3315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148548#comment-15148548
]
ASF GitHub Bot commented on FLINK-3315:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1641
[FLINK-3315] Fix Slot Sharing in Streaming API
This changes slot sharing settings to single method
slotSharingGroup(String) on DataStream.
Operations inherit the slot sharing group of
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148547#comment-15148547
]
ASF GitHub Bot commented on FLINK-3226:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1634#issuecomment-184672115
Merged, please close @twalthr
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1639#issuecomment-184672051
Merged, please close @twalthr
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
[
https://issues.apache.org/jira/browse/FLINK-3412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148498#comment-15148498
]
Stefano Baghino commented on FLINK-3412:
I like the approach suggested by [~till.rohrmann], I've
[
https://issues.apache.org/jira/browse/FLINK-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148495#comment-15148495
]
ASF GitHub Bot commented on FLINK-3396:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1633#discussion_r53000913
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1073,57 +1073,73 @@ class JobManager(
// execute
[
https://issues.apache.org/jira/browse/FLINK-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148485#comment-15148485
]
ASF GitHub Bot commented on FLINK-3396:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1633#discussion_r52999704
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1079,6 +1079,9 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148480#comment-15148480
]
ASF GitHub Bot commented on FLINK-3396:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1633#discussion_r52998947
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1073,57 +1073,73 @@ class JobManager(
// execute
[
https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148479#comment-15148479
]
ASF GitHub Bot commented on FLINK-3296:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1563#issuecomment-184642511
I renamed the method to `writeUsingOutputFormat` and rebased to current
master.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148478#comment-15148478
]
ASF GitHub Bot commented on FLINK-3396:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1633#discussion_r52998567
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1073,57 +1073,73 @@ class JobManager(
//
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52998526
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraExactlyOnceSink.java
---
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148477#comment-15148477
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148470#comment-15148470
]
Robert Metzger commented on FLINK-3412:
---
+1 I ran into this issue as well.
> Remove implicit
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148469#comment-15148469
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148468#comment-15148468
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52997627
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraExactlyOnceSink.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52997588
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraExactlyOnceSink.java
---
[
https://issues.apache.org/jira/browse/FLINK-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148466#comment-15148466
]
ASF GitHub Bot commented on FLINK-3396:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1633#discussion_r52997375
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1073,57 +1073,73 @@ class JobManager(
// execute
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148456#comment-15148456
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52995595
--- Diff: docs/apis/streaming/fault_tolerance.md ---
@@ -176,6 +176,11 @@ state updates) of Flink coupled with bundled sinks:
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148455#comment-15148455
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148453#comment-15148453
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52995525
--- Diff: docs/apis/streaming/fault_tolerance.md ---
@@ -176,6 +176,11 @@ state updates) of Flink coupled with bundled sinks:
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148450#comment-15148450
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Till Rohrmann created FLINK-3414:
Summary: Add Scala API for CEP's pattern definition
Key: FLINK-3414
URL: https://issues.apache.org/jira/browse/FLINK-3414
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148451#comment-15148451
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52995438
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52995374
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraExactlyOnceSink.java
---
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148448#comment-15148448
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148447#comment-15148447
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52995123
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraExactlyOnceSink.java
---
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-184624521
The `testDetachedPerJobYarnCluster()` YARN test is failing with
```
10:33:26,969 INFO org.apache.flink.client.CliFrontend
-
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148442#comment-15148442
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52994814
--- Diff: docs/apis/streaming/fault_tolerance.md ---
@@ -176,6 +176,11 @@ state updates) of Flink coupled with bundled sinks:
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148439#comment-15148439
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52994610
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,195 @@
+/**
+ *
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52994409
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148437#comment-15148437
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148435#comment-15148435
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52994316
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java
---
@@
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52994189
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraExactlyOnceSink.java
---
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148433#comment-15148433
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148432#comment-15148432
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52994037
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraExactlyOnceSink.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52993965
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraExactlyOnceSink.java
---
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148430#comment-15148430
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148424#comment-15148424
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52993497
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,195 @@
+/**
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148423#comment-15148423
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52993461
--- Diff: docs/apis/streaming/connectors/cassandra.md ---
@@ -0,0 +1,100 @@
+---
+title: "Apache Cassandra Connector"
+
+# Sub-level navigation
[
https://issues.apache.org/jira/browse/FLINK-3412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148417#comment-15148417
]
Stefano Baghino commented on FLINK-3412:
This one looks easy, I can take care of it immediately.
[
https://issues.apache.org/jira/browse/FLINK-3413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148418#comment-15148418
]
Aljoscha Krettek commented on FLINK-3413:
-
+1
> Remove implicit Seq to DataStream conversion
>
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148416#comment-15148416
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52993077
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,195 @@
+/**
+ *
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148415#comment-15148415
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52992939
--- Diff: docs/apis/streaming/connectors/cassandra.md ---
@@ -0,0 +1,100 @@
+---
+title: "Apache Cassandra Connector"
+
+# Sub-level
[
https://issues.apache.org/jira/browse/FLINK-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148413#comment-15148413
]
ASF GitHub Bot commented on FLINK-3396:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1633#discussion_r52992451
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1073,57 +1073,73 @@ class JobManager(
//
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52991586
--- Diff: flink-streaming-java/pom.xml ---
@@ -108,6 +108,7 @@ under the License.
maven-surefire-plugin
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148406#comment-15148406
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Stephan Ewen created FLINK-3413:
---
Summary: Remove implicit Seq to DataStream conversion
Key: FLINK-3413
URL: https://issues.apache.org/jira/browse/FLINK-3413
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148398#comment-15148398
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52991019
--- Diff: docs/apis/streaming/connectors/cassandra.md ---
@@ -0,0 +1,100 @@
+---
+title: "Apache Cassandra Connector"
+
+# Sub-level
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148397#comment-15148397
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52990933
--- Diff: flink-streaming-java/pom.xml ---
@@ -108,6 +108,7 @@ under the License.
maven-surefire-plugin
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148396#comment-15148396
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1640#issuecomment-184609151
Thanks for your contribution @zentol. Changes look good to me. I only had a
comment concerning the type serializer and our usage of the term "exactly once".
---
Stephan Ewen created FLINK-3412:
---
Summary: Remove implicit conversions JavaStream / ScalaStream
Key: FLINK-3412
URL: https://issues.apache.org/jira/browse/FLINK-3412
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148393#comment-15148393
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148392#comment-15148392
]
ASF GitHub Bot commented on FLINK-3332:
---
Github user zentol commented on a diff in the pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52990714
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,195 @@
+/**
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52990602
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,195 @@
+/**
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52990687
--- Diff: docs/apis/streaming/connectors/cassandra.md ---
@@ -0,0 +1,100 @@
+---
+title: "Apache Cassandra Connector"
+
+# Sub-level navigation
101 - 200 of 239 matches
Mail list logo
