[
https://issues.apache.org/jira/browse/FLINK-5021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-5021:
--
Summary: Makes the ContinuousFileReaderOperator rescalable. (was: Make the
ContinuousFileReader
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15640766#comment-15640766
]
ASF GitHub Bot commented on FLINK-3873:
---
GitHub user mushketyk opened a pull request
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2762
[FLINK-3873] Implement Kafka TableSink with Avro serialization
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-4896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15640334#comment-15640334
]
ASF GitHub Bot commented on FLINK-4896:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2733
Hi @greghogan,
thanks for this PR. Do you have any idea how this implementation compares
with the existing ones? I'm curious since it uses a bulk iteration and the
existing ones are using delta ite
[
https://issues.apache.org/jira/browse/FLINK-4970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15640223#comment-15640223
]
ASF GitHub Bot commented on FLINK-4970:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2730
Thanks for the PR @greghogan. Changes look good. Just make sure to also
update the docs before merging.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15640091#comment-15640091
]
ASF GitHub Bot commented on FLINK-3551:
---
GitHub user ch33hau opened a pull request:
GitHub user ch33hau opened a pull request:
https://github.com/apache/flink/pull/2761
[FLINK-3551] [examples] Sync Scala Streaiming Examples
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If you
[
https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15639604#comment-15639604
]
ASF GitHub Bot commented on FLINK-4260:
---
Github user miaoever commented on a diff in
Github user miaoever commented on a diff in the pull request:
https://github.com/apache/flink/pull/2758#discussion_r86664382
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java
---
@@ -54,6 +51,18 @@
*/
public class Co
[
https://issues.apache.org/jira/browse/FLINK-5014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15639342#comment-15639342
]
ASF GitHub Bot commented on FLINK-5014:
---
GitHub user melentye opened a pull request:
GitHub user melentye opened a pull request:
https://github.com/apache/flink/pull/2760
[FLINK-5014] [RocksDB backend] add toString for RocksDBStateBackend
Adding toString() for RocksDBStateBackend.
Example output 1:
> RocksDB State Backend {isInitialized=false, confi
[
https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15639116#comment-15639116
]
ASF GitHub Bot commented on FLINK-4260:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15639113#comment-15639113
]
ASF GitHub Bot commented on FLINK-4260:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2758#discussion_r86661415
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/sql/SqlITCase.java
---
@@ -118,4 +119,39 @@ public void testJoin() throws
[
https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15639114#comment-15639114
]
ASF GitHub Bot commented on FLINK-4260:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2758#discussion_r86661449
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/sql/SqlITCase.java
---
@@ -118,4 +119,39 @@ public void testJoin() throws
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2758#discussion_r86661440
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/sql/SqlITCase.java
---
@@ -118,4 +119,39 @@ public void testJoin() throws
[
https://issues.apache.org/jira/browse/FLINK-4260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15639115#comment-15639115
]
ASF GitHub Bot commented on FLINK-4260:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2758#discussion_r86661487
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java
---
@@ -54,6 +51,18 @@
*/
public class Col
21 matches
Mail list logo
