GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/3383
[FLINK-5877] [docs] Fix Scala snippet in Async I/O API doc
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Github user alkagin commented on the issue:
https://github.com/apache/flink/pull/2149
I am on vacations, I will address your comments as soon as I get back.
---
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
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r68937366
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -132,9 +132,9 @@
- private final Configuration
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r68750010
--- Diff: flink-dist/src/main/flink-bin/bin/flink ---
@@ -17,20 +17,41 @@
# limitations under the License
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r68743480
--- Diff: flink-dist/src/main/flink-bin/bin/flink ---
@@ -17,20 +17,41 @@
# limitations under the License
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r68743195
--- Diff: flink-dist/src/main/flink-bin/bin/flink ---
@@ -17,20 +17,41 @@
# limitations under the License
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r68742339
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/CliFrontendRunTest.java ---
@@ -100,15 +100,22 @@ public void testRun
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r68568030
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -132,9 +132,9 @@
- private final Configuration
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2149#discussion_r68567354
--- Diff: docs/apis/cli.md ---
@@ -187,6 +187,8 @@ Action "run" compiles and runs
GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/2163
[FLINK-4119] Null checks in close() for Cassandra Input/Output Formats,
checking arguments via Flink Preconditions
Thanks for contributing to Apache Flink. Before you open your pull request
GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/2149
[FLINK-4084] Add configDir parameter to CliFrontend and flink shell script
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/2144
[FLINK-4097] Cassandra Sink throws NPE on closing if server is not available
[Jira Issue](https://issues.apache.org/jira/browse/FLINK-4097)
You can merge this pull request into a Git
Github user alkagin commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-217159043
Hi guys :) any update on this?
---
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 alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r61419752
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -0,0
Github user alkagin closed the pull request at:
https://github.com/apache/flink/pull/1660
---
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
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r56825863
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericAtLeastOnceSink.java
---
@@ -0,0 +1,197
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r56823697
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericAtLeastOnceSink.java
---
@@ -0,0 +1,197
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r56807419
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -0,0
Github user alkagin commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-199224407
Hi,
I am testing the Cassandra connector and I may have found a bug using
CassandraSink-DSL. During the execution it throws
`java.io.NotSerializableException
GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/1810
[docs] typo seperate - separate
Hi guys,
Fixed a couple of typo's in JobManager High Availability (HA).
You can merge this pull request into a Git repository by running:
$ git pull
Github user alkagin commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-194294832
Great work :+1:
---
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 alkagin commented on the pull request:
https://github.com/apache/flink/pull/1660#issuecomment-189313813
No objections, sounds good.
---
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 alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1660#discussion_r53440225
--- Diff: flink-streaming-connectors/flink-connector-cassandra/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1660#discussion_r53300199
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/connectors/cassandra/batch/CassandraOutputFormat.java
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1660#discussion_r53299825
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/connectors/cassandra/batch/CassandraOutputFormat.java
Github user alkagin commented on the pull request:
https://github.com/apache/flink/pull/1660#issuecomment-185652429
@zentol I am looking CassandraConnectorTest.batch to figure out the problem.
Other tests work fine if i run locally, how kind of problem they throw to
you?
---
If
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1660#discussion_r53294081
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/connectors/cassandra/streaming/ClusterConfigurator.java
Github user alkagin commented on a diff in the pull request:
https://github.com/apache/flink/pull/1660#discussion_r53244631
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/connectors/cassandra/batch/CassandraOutputFormat.java
GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/1660
[FLINK-3311] Add a connector for streaming data into Cassandra
[FLINK-3311](https://issues.apache.org/jira/browse/FLINK-3311): this PR
adds OutputFormat and InputFormat, just for Tuples, for batch
GitHub user alkagin opened a pull request:
https://github.com/apache/flink/pull/1602
[hotfix] typo IllegalArgumentException
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/radicalbit/flink typo-jdbcinputformat
Alternatively you
30 matches
Mail list logo
