[
https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16248266#comment-16248266
]
ASF GitHub Bot commented on FLINK-4500:
---
Github user mcfongtw commented on the issue
Github user mcfongtw commented on the issue:
https://github.com/apache/flink/pull/4605
Hi, @zentol , thanks for reviewing this PR. I recalled that I put a [caveat
](https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/connectors/cassandra.html#checkpointing-and-fault-toleran
[
https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16248142#comment-16248142
]
Chuyang Wan commented on FLINK-4575:
[~ggevay], if you are ok with converting the POJO
[
https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16248136#comment-16248136
]
ASF GitHub Bot commented on FLINK-7702:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/4998
[FLINK-7702] Add maven-bundle-plugin to root pom
Before, we had it in places that require it. This doesn't work when
running mvn javadoc:aggregate because this will only run for the root
pom
[
https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7488:
--
Description:
{code}
compareNetworkBufShellScriptWithJava(org.apache.flink.dist.TaskManagerHeapSizeCalculationJav
Jessica Negara created FLINK-8047:
-
Summary: Create HTTP Sink
Key: FLINK-8047
URL: https://issues.apache.org/jira/browse/FLINK-8047
Project: Flink
Issue Type: Improvement
Components
[
https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247846#comment-16247846
]
Juan Miguel Cejuela commented on FLINK-8046:
Since we are at this, it is in my
[
https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247825#comment-16247825
]
ASF GitHub Bot commented on FLINK-8046:
---
GitHub user juanmirocks opened a pull reque
GitHub user juanmirocks opened a pull request:
https://github.com/apache/flink/pull/4997
[FLINK-8046] [flink-streaming-java] Have filter of timestamp compare with
strictly SMALLER (NOT smaller or equal)
## What is the purpose of the change
This change fixes the wrong ignori
Juan Miguel Cejuela created FLINK-8046:
--
Summary: ContinuousFileMonitoringFunction wrongly ignores files
with exact same timestamp
Key: FLINK-8046
URL: https://issues.apache.org/jira/browse/FLINK-8046
[
https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7702:
Summary: Javadocs are not being built (was: Javadocs link broken)
> Javadocs are not being
[
https://issues.apache.org/jira/browse/FLINK-8045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-8045:
Description:
Currently DATE/TIME/TIMESTAMP have internal representation. Such as Date is
represente
Zhenghua Gao created FLINK-8045:
---
Summary: Add Internal DATE/TIME/TIMESTAMP as internal
representation of DATE/TIME/TIMESTAMP
Key: FLINK-8045
URL: https://issues.apache.org/jira/browse/FLINK-8045
Projec
Github user pnowojski closed the pull request at:
https://github.com/apache/flink/pull/4996
---
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4996
Thanks @aljoscha for merging!
---
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247785#comment-16247785
]
Piotr Nowojski commented on FLINK-7845:
---
Could you strip down your example to some m
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-7880:
---
Assignee: Kostas Kloudas (was: Aljoscha Krettek)
> flink-queryable-state-java fails
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-7880:
---
Assignee: Aljoscha Krettek (was: Kostas Kloudas)
> flink-queryable-state-java fails
[
https://issues.apache.org/jira/browse/FLINK-7919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247736#comment-16247736
]
Fabian Hueske commented on FLINK-7919:
--
Hi [~greghogan], yes that would be an option
[
https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247727#comment-16247727
]
ASF GitHub Bot commented on FLINK-7973:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4961
I did include your end-to-end tests (with some fixes) and the fixes for the
errors they found. Should be fine now, let's see what travis says...
---
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247724#comment-16247724
]
ASF GitHub Bot commented on FLINK-4228:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247722#comment-16247722
]
ASF GitHub Bot commented on FLINK-4228:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4939#discussion_r150275387
--- Diff: flink-yarn/pom.xml ---
@@ -153,6 +159,63 @@ under the License.
+
+
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4939#discussion_r150275161
--- Diff: flink-yarn/pom.xml ---
@@ -153,6 +159,63 @@ under the License.
+
+
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4939
1) yes, I have tested the changes on a YARN cluster as described in the PR
comment (before the changes on the unit tests)
2) regarding the `pom.xml` changes: I actually took those from
991af3652479
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247721#comment-16247721
]
ASF GitHub Bot commented on FLINK-4228:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247674#comment-16247674
]
Seth Wiesman edited comment on FLINK-7999 at 11/10/17 3:47 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247674#comment-16247674
]
Seth Wiesman commented on FLINK-7999:
-
Sure, I will use the example of my use case.
[
https://issues.apache.org/jira/browse/FLINK-6163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-6163.
---
Resolution: Fixed
Documented on master in
d98ba08a7a73dc93c839c77d11245aba70869ab5
Documented
[
https://issues.apache.org/jira/browse/FLINK-6163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247603#comment-16247603
]
ASF GitHub Bot commented on FLINK-6163:
---
Github user aljoscha closed the pull reques
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/4992
---
[
https://issues.apache.org/jira/browse/FLINK-6163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247601#comment-16247601
]
ASF GitHub Bot commented on FLINK-6163:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4992
Thanks for the review! ð
---
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247539#comment-16247539
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user kl0u commented on a diff in the
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4996
[hotfix][docs] Change mailing list link in quickstart to flink-user
Change mailing list link in quickstart to flink-user. Previously it was
pointing to flink-dev.
This change only fixes m
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150243346
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@ -260,25
[
https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247518#comment-16247518
]
ASF GitHub Bot commented on FLINK-7811:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/4995
[hotfix] [docs] Fix broken link to FLINK-7811
This fixes a broken hyperlink on page
https://ci.apache.org/projects/flink/flink-docs-release-1.4/start/building.html#scala-versions
![image](http
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4994
---
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247487#comment-16247487
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150232000
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150231729
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247484#comment-16247484
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247473#comment-16247473
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247472#comment-16247472
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247459#comment-16247459
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247470#comment-16247470
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247456#comment-16247456
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247458#comment-16247458
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247479#comment-16247479
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247460#comment-16247460
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247467#comment-16247467
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247463#comment-16247463
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247480#comment-16247480
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247461#comment-16247461
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247482#comment-16247482
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247477#comment-16247477
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247471#comment-16247471
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247476#comment-16247476
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247462#comment-16247462
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247478#comment-16247478
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247452#comment-16247452
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247468#comment-16247468
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247475#comment-16247475
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247469#comment-16247469
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247481#comment-16247481
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247451#comment-16247451
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247465#comment-16247465
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247474#comment-16247474
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247454#comment-16247454
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247466#comment-16247466
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247455#comment-16247455
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247457#comment-16247457
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247464#comment-16247464
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247453#comment-16247453
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150230620
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -166,27 +168
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150224448
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150225368
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -166,27 +168
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150228196
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -419,20 +440
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150221573
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150229482
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -483,27 +511
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150225343
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150224857
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150228244
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -419,20 +440
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150225411
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -166,27 +168
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150228810
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -483,27 +511
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150223999
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150221248
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150230125
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -419,20 +440
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150226027
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -166,27 +168
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150225215
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150223049
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150221458
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150224310
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150224362
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java
---
@@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150228785
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -483,27 +511
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150226886
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -166,27 +168
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4993#discussion_r150227018
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java
---
@@ -309,31 +323
1 - 100 of 142 matches
Mail list logo