[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7468.
---
Resolution: Fixed
> Implement sender backlog logic for credit-based
>
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reopened FLINK-7456:
-
> Implement Netty sender incoming pipeline for credit-based
>
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16328393#comment-16328393
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on the issu
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4552
@NicoK , I have submitted the switch for keeping the old mode and the new
credit-based mode.
---
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-7456.
---
Resolution: Fixed
> Implement Netty sender incoming pipeline for credit-based
> --
[
https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16328386#comment-16328386
]
Dongwon Kim commented on FLINK-8431:
[~eronwright] I'm testing my implementation by la
[
https://issues.apache.org/jira/browse/FLINK-7938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327907#comment-16327907
]
ASF GitHub Bot commented on FLINK-7938:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5281#discussion_r161905498
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBListState.java
---
@@ -167,24 +167,48 @@
[
https://issues.apache.org/jira/browse/FLINK-8441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-8441:
Affects Version/s: 1.5.0
> serialize values and value separator directly to stream in RocksDBListState
> ---
[
https://issues.apache.org/jira/browse/FLINK-8441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-8441:
Fix Version/s: 1.5.0
> serialize values and value separator directly to stream in RocksDBListState
> ---
Bowen Li created FLINK-8441:
---
Summary: serialize values and value separator directly to stream
in RocksDBListState
Key: FLINK-8441
URL: https://issues.apache.org/jira/browse/FLINK-8441
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327389#comment-16327389
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r161822214
--- Diff: flink-yarn/src/test/resources/flink-conf.yaml ---
@@ -0,0 +1,23 @@
+
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327388#comment-16327388
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r161822100
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java ---
@@ -142,19 +134,22 @@ public static void runYarnTaskManager(String
[
https://issues.apache.org/jira/browse/FLINK-8435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aegeaner reassigned FLINK-8435:
---
Assignee: Aegeaner
> Adding BloomFilter/HyperLogLog state as Managed once
> -
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327379#comment-16327379
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r161821092
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java ---
@@ -126,12 +124,6 @@ public static void runYarnTaskManager(String[
[
https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aegeaner reassigned FLINK-8354:
---
Assignee: Aegeaner
> Flink Kafka connector ignores Kafka message headers
>
Josh Lemer created FLINK-8440:
-
Summary: Create Gitter Chanel for Flink users
Key: FLINK-8440
URL: https://issues.apache.org/jira/browse/FLINK-8440
Project: Flink
Issue Type: Task
Rep
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327369#comment-16327369
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user EronWright commented on a diff
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r161818655
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java
---
@@ -48,7 +48,7 @@ public static SecurityContext getInstall
Github user dyanarose commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161807900
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SessionWindowTimeGapExtractor.java
---
@@ -0,0 +1,30 @@
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327322#comment-16327322
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user dyanarose commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327323#comment-16327323
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user dyanarose commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327325#comment-16327325
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user dyanarose commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327326#comment-16327326
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user dyanarose commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327324#comment-16327324
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user dyanarose commented on a diff i
Github user dyanarose commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161807869
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java
---
@@ -0,0 +1,10
Github user dyanarose commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161807837
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java
---
@@ -0,0 +1,101 @@
Github user dyanarose commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161807850
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java
---
@@ -0,0 +1,10
Github user dyanarose commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161807828
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java
---
@@ -0,0 +1,101 @@
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161798960
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java
---
@@ -0,0 +1,10
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327307#comment-16327307
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161800866
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SessionWindowTimeGapExtractor.java
---
@@ -0,0 +1,30
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161799107
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java
---
@@ -0,0 +1,10
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327308#comment-16327308
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327310#comment-16327310
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327306#comment-16327306
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327309#comment-16327309
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161799438
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java
---
@@ -0,0
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r161799387
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java
---
@@ -0,0
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4649#discussion_r161791264
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
---
@@ -411,6 +413,13 @@ private void addEdgeInternal(I
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4649#discussion_r161797181
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
---
@@ -411,6 +413,13 @@ private void addEdgeInternal(I
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327282#comment-16327282
]
ASF GitHub Bot commented on FLINK-6116:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327285#comment-16327285
]
ASF GitHub Bot commented on FLINK-6116:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4649#discussion_r161793609
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java
---
@@ -127,7 +127,8 @@ protected
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327284#comment-16327284
]
ASF GitHub Bot commented on FLINK-6116:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327279#comment-16327279
]
ASF GitHub Bot commented on FLINK-6116:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4649#discussion_r161799248
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -183,6 +183,14 @@ public Long map(Long value) throw
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327283#comment-16327283
]
ASF GitHub Bot commented on FLINK-6116:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327281#comment-16327281
]
ASF GitHub Bot commented on FLINK-6116:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327280#comment-16327280
]
ASF GitHub Bot commented on FLINK-6116:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327278#comment-16327278
]
ASF GitHub Bot commented on FLINK-6116:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4649#discussion_r161793648
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTaskTestHarness.java
---
@@ -143,7 +144,8 @@ protected
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4649#discussion_r161795511
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -183,6 +183,14 @@ public Long map(Long value) throw
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4649#discussion_r161799381
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
---
@@ -624,6 +633,10 @@ public long getLoopTimeout(Int
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4649#discussion_r161797751
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java
---
@@ -60,17 +60,23 @@
*/
private Stre
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5303
I would suggest to start thinking about the dependencies the following way:
- There are pure user-code projects where the Flink runtime is "provided"
and they are started using an exist
Dyana Rose created FLINK-8439:
-
Summary: Document using a custom AWS Credentials Provider with
flink-3s-fs-hadoop
Key: FLINK-8439
URL: https://issues.apache.org/jira/browse/FLINK-8439
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327217#comment-16327217
]
ASF GitHub Bot commented on FLINK-8422:
---
Github user sunjincheng121 commented on the
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/5292
Looks good to me. +1
---
[
https://issues.apache.org/jira/browse/FLINK-7364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-7364:
-
Just ran into this on master, will investigate in which circumstances this
happens. Neither t
[
https://issues.apache.org/jira/browse/FLINK-7604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou UTC+8 closed FLINK-7604.
-
Resolution: Won't Do
Fix Version/s: (was: 1.5.0)
> Add OpenTSDB metrics reporter
>
[
https://issues.apache.org/jira/browse/FLINK-4940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327201#comment-16327201
]
Kostas Kloudas edited comment on FLINK-4940 at 1/16/18 3:01 PM:
[
https://issues.apache.org/jira/browse/FLINK-4940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327201#comment-16327201
]
Kostas Kloudas edited comment on FLINK-4940 at 1/16/18 2:59 PM:
[
https://issues.apache.org/jira/browse/FLINK-4940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327201#comment-16327201
]
Kostas Kloudas edited comment on FLINK-4940 at 1/16/18 2:58 PM:
[
https://issues.apache.org/jira/browse/FLINK-4940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327201#comment-16327201
]
Kostas Kloudas commented on FLINK-4940:
---
"We therefore only have to checkpoint the s
[
https://issues.apache.org/jira/browse/FLINK-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327197#comment-16327197
]
David Anderson commented on FLINK-8438:
---
This code (adapted from the Flink scala qui
[
https://issues.apache.org/jira/browse/FLINK-4940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-4940:
-
Assignee: Kostas Kloudas
> Add support for broadcast state
>
[
https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327153#comment-16327153
]
Stephan Ewen commented on FLINK-8033:
-
IIRC, we need to bump Netty to a newer version,
Timo Walther created FLINK-8438:
---
Summary: Ensure that implicit Scala TypeInformation works in
Eclipse IDE
Key: FLINK-8438
URL: https://issues.apache.org/jira/browse/FLINK-8438
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327130#comment-16327130
]
ASF GitHub Bot commented on FLINK-8290:
---
GitHub user maqingxiang opened a pull reque
GitHub user maqingxiang opened a pull request:
https://github.com/apache/flink/pull/5304
[FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8
Now the Clientid that consumes the all topics are
constant("flink-kafka-consumer-legacy-" + broker.id()), and it is not easy f
[
https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327118#comment-16327118
]
xymaqingxiang edited comment on FLINK-8290 at 1/16/18 1:33 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327118#comment-16327118
]
xymaqingxiang commented on FLINK-8290:
--
The description of “client.id” is “An id stri
[
https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xymaqingxiang updated FLINK-8290:
-
Description:
Now the Clientid that consumes the all topics are
constant("flink-kafka-consumer-leg
[
https://issues.apache.org/jira/browse/FLINK-8437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8437:
Description:
The current API for retrieving Side Outputs is a bit ambiguous. Consider the
p
[
https://issues.apache.org/jira/browse/FLINK-8437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8437:
Priority: Minor (was: Major)
> SideOutput() API is ambiguous
>
[
https://issues.apache.org/jira/browse/FLINK-8437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8437:
Issue Type: Improvement (was: Bug)
> SideOutput() API is ambiguous
> --
Chesnay Schepler created FLINK-8437:
---
Summary: SideOutput() API is ambiguous
Key: FLINK-8437
URL: https://issues.apache.org/jira/browse/FLINK-8437
Project: Flink
Issue Type: Bug
C
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5303
[hotfix][docs] Adjust RocksDb dependency docs
Small adjustment as per
https://github.com/apache/flink/commit/5623ac66bd145d52f3488ac2fff9dbc762d0bda1#commitcomment-26867793.
@StephanEwen @rm
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327072#comment-16327072
]
ASF GitHub Bot commented on FLINK-:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-.
---
Resolution: Fixed
master: 988bdde17fec8896aae4bc041a10d5e30a4cb702
> Bump japicmp to 0.11.0
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5302
---
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327066#comment-16327066
]
ASF GitHub Bot commented on FLINK-:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5302
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
flora karniav closed FLINK-8414.
Resolution: Feedback Received
> Gelly performance seriously decreases when using the suggested paral
[
https://issues.apache.org/jira/browse/FLINK-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8187:
Description:
When submitting a jar with no defined Main class, the web client does not
resp
Github user zentol commented on the pull request:
https://github.com/apache/flink/commit/907361d862c77a70ff60d27e7fcc13647eac0e6d#commitcomment-26885301
In
flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/CollectSink.java:
In
flink-streaming-java/src/mai
[
https://issues.apache.org/jira/browse/FLINK-8050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-8050.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Merged with 642e11a9cd31c83fbbabe860871c714f3d4ca981
[
https://issues.apache.org/jira/browse/FLINK-8049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-8049.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Merged with 7da32d19f9623ca98c8a4ba76e7c406bf9318d4d
[
https://issues.apache.org/jira/browse/FLINK-8049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16326974#comment-16326974
]
ASF GitHub Bot commented on FLINK-8049:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5057
---
[
https://issues.apache.org/jira/browse/FLINK-8436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8436:
Description: When implementing a table sink that should have the
functionality of both a {{RetractSt
[
https://issues.apache.org/jira/browse/FLINK-8436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16326963#comment-16326963
]
Fabian Hueske commented on FLINK-8436:
--
+1
> Allow implementing both RetractTableSin
Timo Walther created FLINK-8436:
---
Summary: Allow implementing both RetractTableSink and
BatchTableSink in one class
Key: FLINK-8436
URL: https://issues.apache.org/jira/browse/FLINK-8436
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16326911#comment-16326911
]
ASF GitHub Bot commented on FLINK-7938:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5281#discussion_r161694419
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBListState.java
---
@@ -167,24 +167,4
[
https://issues.apache.org/jira/browse/FLINK-7938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16326905#comment-16326905
]
ASF GitHub Bot commented on FLINK-7938:
---
Github user StefanRRichter commented on a d
1 - 100 of 106 matches
Mail list logo
