Bowen Li created FLINK-8218:
---
Summary: move flink-connector-kinesis examples from /src to /test
Key: FLINK-8218
URL: https://issues.apache.org/jira/browse/FLINK-8218
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281455#comment-16281455
]
ASF GitHub Bot commented on FLINK-8149:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5069
@bowenli86 do you mean the `ProduceIntoKinesis` and `ConsumeFromKinesis`
classes?
I agree that we should move them to `/test`, but we should consider that as
a separate issue than this one.
[
https://issues.apache.org/jira/browse/FLINK-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281449#comment-16281449
]
ASF GitHub Bot commented on FLINK-8149:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5069
@tzulitai @yew1eb I just saw the code in src tree and traced back to this
PR. I feel it's really bad to have runnable examples (with java main method) in
a lib jar that Flink distributes.
Bowen Li created FLINK-8217:
---
Summary: Properly annotate APIs of flink-connector-kinesis
Key: FLINK-8217
URL: https://issues.apache.org/jira/browse/FLINK-8217
Project: Flink
Issue Type: Sub-task
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5130
[FLINK-8216] Unify test utils in flink-connector-kinesis
## What is the purpose of the change
currently there are a few ways to get a `Properties` object with required
fields (aws access
[
https://issues.apache.org/jira/browse/FLINK-8216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281434#comment-16281434
]
ASF GitHub Bot commented on FLINK-8216:
---
GitHub user bowenli86 opened a pull request:
Bowen Li created FLINK-8216:
---
Summary: Unify test utils in flink-connector-kinesis
Key: FLINK-8216
URL: https://issues.apache.org/jira/browse/FLINK-8216
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7897:
--
Component/s: Local Runtime
> Consider using nio.Files for file deletion in TransientBlobCleanupTask
>
Rong Rong created FLINK-8215:
Summary: Collections codegen exception when constructing Array or
Map via SQL API
Key: FLINK-8215
URL: https://issues.apache.org/jira/browse/FLINK-8215
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281078#comment-16281078
]
Martin Eden commented on FLINK-8205:
Hi [~kkl0u]. Glad it was already on the map. We are using 1.3.2
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5129
[Hotfix for State doc in 1.4 and 1.5] update State's doc and javaDoc to
clarify replacement of foldingstate
## What is the purpose of the change
Clarify that `aggregatingstate` is the
[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280664#comment-16280664
]
ASF GitHub Bot commented on FLINK-4812:
---
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/5125#discussion_r155327970
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
---
@@ -80,7 +91,10 @@ public void init()
[
https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280547#comment-16280547
]
ASF GitHub Bot commented on FLINK-8174:
---
Github user EronWright commented on the issue:
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/5114
@tillrohrmann should we patch the 1.3 release too? Or is 1.3.2 the last
release there?
---
[
https://issues.apache.org/jira/browse/FLINK-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280513#comment-16280513
]
ASF GitHub Bot commented on FLINK-8120:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5128
[FLINK-8120] [flip6] Register Yarn application with correct tracking URL
## What is the purpose of the change
The cluster entrypoints start the ResourceManager with the web interface
[
https://issues.apache.org/jira/browse/FLINK-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280506#comment-16280506
]
ASF GitHub Bot commented on FLINK-8087:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5088#discussion_r155296898
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/instance/AllocatedSlot.java
---
@@ -144,6 +144,78 @@ public TaskManagerGateway
[
https://issues.apache.org/jira/browse/FLINK-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-8120:
Assignee: Till Rohrmann
> Cannot access Web UI from YARN application overview in FLIP-6
[
https://issues.apache.org/jira/browse/FLINK-7746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280454#comment-16280454
]
ASF GitHub Bot commented on FLINK-7746:
---
Github user NicoK closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280453#comment-16280453
]
ASF GitHub Bot commented on FLINK-7746:
---
Github user NicoK commented on the issue:
Github user NicoK closed the pull request at:
https://github.com/apache/flink/pull/4759
---
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4759
closed in favour of a different approach in #5127
---
[
https://issues.apache.org/jira/browse/FLINK-7749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280446#comment-16280446
]
ASF GitHub Bot commented on FLINK-7749:
---
Github user NicoK closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280445#comment-16280445
]
ASF GitHub Bot commented on FLINK-7749:
---
Github user NicoK commented on the issue:
Github user NicoK closed the pull request at:
https://github.com/apache/flink/pull/4762
---
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4762
closed in favour of #5127
---
[
https://issues.apache.org/jira/browse/FLINK-7749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280441#comment-16280441
]
ASF GitHub Bot commented on FLINK-7749:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5127
[FLINK-7749][network] refactor the ResultPartitionWriter into an interface
## What is the purpose of the change
After moving task event notification into the `TaskEventDispatcher`
(#4761),
[
https://issues.apache.org/jira/browse/FLINK-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280378#comment-16280378
]
ASF GitHub Bot commented on FLINK-8087:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5088#discussion_r155279729
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/instance/SlotPool.java ---
@@ -312,24 +312,36 @@ public void returnAllocatedSlot(Slot slot) {
[
https://issues.apache.org/jira/browse/FLINK-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280352#comment-16280352
]
ASF GitHub Bot commented on FLINK-8087:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5088#discussion_r155276432
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/slots/SlotContext.java
---
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280339#comment-16280339
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4993
It was merged as part of https://github.com/apache/flink/pull/5062
---
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280336#comment-16280336
]
ASF GitHub Bot commented on FLINK-7974:
---
Github user kl0u closed the pull request at:
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/4993
---
[
https://issues.apache.org/jira/browse/FLINK-7974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-7974.
-
Resolution: Fixed
Release Note: Merged on master (74d052bb045031363652116ab8226d8ac00e0cd0)
[
https://issues.apache.org/jira/browse/FLINK-7975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-7975.
-
Resolution: Fixed
Merged on master (5760677b3bb26245ca4816548833da0257ec7c7a) and 1.4.
>
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-7880.
-
Resolution: Fixed
Merged on master (a3fd548e9c76c67609bbf159d5fb743d756450b1) and 1.4.
>
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280295#comment-16280295
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5062
---
[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280264#comment-16280264
]
ASF GitHub Bot commented on FLINK-4812:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-8205:
--
Fix Version/s: (was: 1.4.0)
1.5.0
> Multi key get
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-8087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280265#comment-16280265
]
ASF GitHub Bot commented on FLINK-8087:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5088#discussion_r155258087
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/instance/SlotsTestImplContext.java
---
@@ -31,7 +30,7 @@
import static
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5125#discussion_r155257760
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
---
@@ -80,7 +91,10 @@ public void init()
Piotr Nowojski created FLINK-8214:
-
Summary: Do not use mockito for collecting results in
StreamMockEnvironment
Key: FLINK-8214
URL: https://issues.apache.org/jira/browse/FLINK-8214
Project: Flink
Chesnay Schepler created FLINK-8213:
---
Summary: Prevent potential metric-related ClassCastExceptions
Key: FLINK-8213
URL: https://issues.apache.org/jira/browse/FLINK-8213
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280221#comment-16280221
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280222#comment-16280222
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155245759
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -507,6 +514,41 @@ public void handleError(final Exception
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155245771
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -507,6 +514,41 @@ public void handleError(final Exception
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280210#comment-16280210
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280212#comment-16280212
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155242826
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -86,122 +125,143 @@ public static void teardown() {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155242900
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -86,122 +125,143 @@ public static void teardown() {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155242108
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/InMemorySubmittedJobGraphStore.java
---
@@ -0,0 +1,90 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280199#comment-16280199
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155240139
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/InMemorySubmittedJobGraphStore.java
---
@@ -0,0 +1,90 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155237910
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -86,122 +125,143 @@ public static void teardown()
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155225461
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -507,6 +514,41 @@ public void handleError(final
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280189#comment-16280189
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280188#comment-16280188
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280187#comment-16280187
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280185#comment-16280185
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280186#comment-16280186
]
ASF GitHub Bot commented on FLINK-8176:
---
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/5107#discussion_r155225963
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -86,122 +125,143 @@ public static void teardown()
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155229002
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/InMemorySubmittedJobGraphStore.java
---
@@ -0,0 +1,90 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r155225574
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -507,6 +514,41 @@ public void handleError(final
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5062
Thanks @zentol ! I will let another travis run, and then merge.
---
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280184#comment-16280184
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280140#comment-16280140
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5062
ð
---
[
https://issues.apache.org/jira/browse/FLINK-8085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280136#comment-16280136
]
ASF GitHub Bot commented on FLINK-8085:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5087#discussion_r155227397
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/instance/SimpleSlot.java
---
@@ -208,27 +209,61 @@ public void setLocality(Locality locality) {
[
https://issues.apache.org/jira/browse/FLINK-8085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280127#comment-16280127
]
ASF GitHub Bot commented on FLINK-8085:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5087#discussion_r155225733
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/instance/LogicalSlot.java
---
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280124#comment-16280124
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280126#comment-16280126
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280125#comment-16280125
]
ASF GitHub Bot commented on FLINK-7880:
---
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/5062#discussion_r155224199
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java
---
@@ -224,6 +225,7 @@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5062#discussion_r155224312
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java
---
@@ -234,9 +236,14 @@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5062#discussion_r155225199
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16278585#comment-16278585
]
Till Rohrmann edited comment on FLINK-8073 at 12/6/17 12:26 PM:
Happened
[
https://issues.apache.org/jira/browse/FLINK-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-8211.
-
Resolution: Won't Fix
> Rename ResultPartitionWriter to OutputGate
>
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5062#discussion_r155212885
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAAbstractQueryableStateTestBase.java
---
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280060#comment-16280060
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280061#comment-16280061
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5062#discussion_r155212865
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/HAAbstractQueryableStateTestBase.java
---
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5062#discussion_r155212313
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280057#comment-16280057
]
ASF GitHub Bot commented on FLINK-7880:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280053#comment-16280053
]
Kostas Kloudas commented on FLINK-8205:
---
Hi [~MartinEden131] ! That is a nice idea, and something we
[
https://issues.apache.org/jira/browse/FLINK-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280050#comment-16280050
]
ASF GitHub Bot commented on FLINK-7928:
---
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/4991#discussion_r155211436
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -61,16 +80,26 @@
* @param
[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16280046#comment-16280046
]
ASF GitHub Bot commented on FLINK-4812:
---
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/5125#discussion_r155210876
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
---
@@ -80,7 +91,10 @@ public void init()
1 - 100 of 175 matches
Mail list logo
