[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631848#comment-15631848
]
Tzu-Li (Gordon) Tai commented on FLINK-4576:
Back to analysis of the original problem:
I
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631848#comment-15631848
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/3/16 7:11 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631848#comment-15631848
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/3/16 7:10 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631848#comment-15631848
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/3/16 7:11 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631848#comment-15631848
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/3/16 7:12 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15631848#comment-15631848
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4576 at 11/3/16 7:27 AM:
-
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2744
[FLINK-4928] [yarn] Implement FLIP-6 YARN Application Master Runner
YARN Application Master Runner's responsibility is the following:
Read all configuration and environment variables, computing
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632093#comment-15632093
]
ASF GitHub Bot commented on FLINK-4928:
---
GitHub user shuai-xu opened a pull request:
Aljoscha Krettek created FLINK-5003:
---
Summary: Provide Access to State Stores in Operator Snapshot
Context
Key: FLINK-5003
URL: https://issues.apache.org/jira/browse/FLINK-5003
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632238#comment-15632238
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
@fhueske I have updated this PR for the following changes.
1. Remove CROSS/OUTER APPLY support in SQL
2. Change Java Table API from `.crossApply("split(c)", "s")` to
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuhaifeng updated FLINK-4840:
--
Summary: Measure latency of record processing and expose it as a metric
(was: Measure latency/delay of
[
https://issues.apache.org/jira/browse/FLINK-5001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632274#comment-15632274
]
Robert Metzger commented on FLINK-5001:
---
The {{kafka.admin.ConsumerGroupCommand}} object contains
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2745
[yarn] fix debug string displayed for failed applications
Merging for `master` and `release-1.1`.
You can merge this pull request into a Git repository by running:
$ git pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2745
---
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
[
https://issues.apache.org/jira/browse/FLINK-5001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632307#comment-15632307
]
Robert Metzger commented on FLINK-5001:
---
Okay, this is a limitation of the {{KafkaConsumer}}. Since
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632332#comment-15632332
]
Maximilian Michels commented on FLINK-2821:
---
Glad to hear it's working, [~philipp.bussche].
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2746
R @aljoscha
---
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,
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2746
[hotfix] SubtaskState::hasState ignores raw operator state
`SubtaskState::hasState` ignored raw operator state and returned false even
if there was raw operator state. PR includes a unit
[
https://issues.apache.org/jira/browse/FLINK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4960:
--
Summary: Allow the AbstractStreamOperatorTestHarness to test scaling down
(was: Enable testing
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632378#comment-15632378
]
Jamie Grier commented on FLINK-4022:
Rather than emitting Long.MAX_VALUE for subtasks without
[
https://issues.apache.org/jira/browse/FLINK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4960:
--
Description:
Currently the AbstractStreamOperatorTestHarness allows for testing an
operator
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632388#comment-15632388
]
Tzu-Li (Gordon) Tai commented on FLINK-4022:
Hi [~jgrier], I actually was thinking about a
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632388#comment-15632388
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 11/3/16 11:06 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632388#comment-15632388
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 11/3/16 11:06 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632388#comment-15632388
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 11/3/16 11:08 AM:
--
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2747
[FLINK-4960] Allow the AbstractStreamOperatorTestHarness to test scaling
down
As the title describes, this PR just adds a method in the
`AbstractStreamOperatorTestHarness` that allows multiple
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632388#comment-15632388
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 11/3/16 11:09 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632397#comment-15632397
]
ASF GitHub Bot commented on FLINK-4960:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-5001:
-
Assignee: Robert Metzger
> Ensure that the Kafka 0.9+ connector is compatible with
>
[
https://issues.apache.org/jira/browse/FLINK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632401#comment-15632401
]
ASF GitHub Bot commented on FLINK-4960:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632388#comment-15632388
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4022 at 11/3/16 11:10 AM:
--
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2747
R: @aljoscha
---
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
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632474#comment-15632474
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632476#comment-15632476
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632473#comment-15632473
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632475#comment-15632475
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r86323404
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java
---
@@ -101,6 +102,14 @@ public void run() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r86321008
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -64,26 +64,25 @@
static final String
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r86322286
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -120,6 +136,15 @@ static LengthFieldBasedFrameDecoder
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r86321320
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -64,26 +64,25 @@
static final String
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632481#comment-15632481
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r86324769
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -54,24 +58,36 @@
// constructor in order to
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632537#comment-15632537
]
Jamie Grier commented on FLINK-4022:
Yes, definitely get input from Stephan and/or Aljoscha. There
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632537#comment-15632537
]
Jamie Grier edited comment on FLINK-4022 at 11/3/16 12:03 PM:
--
Yes,
Ufuk Celebi created FLINK-5004:
--
Summary: Add task manager option to disable queryable state server
Key: FLINK-5004
URL: https://issues.apache.org/jira/browse/FLINK-5004
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632608#comment-15632608
]
Jamie Grier commented on FLINK-4545:
Big +1!
In general I would love to see this improved. In my
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632615#comment-15632615
]
Stephan Ewen commented on FLINK-4576:
-
+1 for the "watermark idle" messages approach. That strikes me
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632652#comment-15632652
]
Stephan Ewen commented on FLINK-4545:
-
For a YARN-job-at-a-time setup, one could pre-compute that.
For
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632656#comment-15632656
]
Aljoscha Krettek commented on FLINK-3089:
-
[~nielsbasjes] There is now {{TimelyFlatMapFunction}}
Andrew Roberts created FLINK-5005:
-
Summary: Publish Scala 2.12 artifacts
Key: FLINK-5005
URL: https://issues.apache.org/jira/browse/FLINK-5005
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632701#comment-15632701
]
Aljoscha Krettek commented on FLINK-4576:
-
It's a good solution for the problem of idle sources
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2425#discussion_r86340045
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -788,75 +719,125 @@ private void logAndSysout(String message) {
Ufuk Celebi created FLINK-5006:
--
Summary: SystemProcessingTimeServiceTest.testTimerSorting fails
Key: FLINK-5006
URL: https://issues.apache.org/jira/browse/FLINK-5006
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632707#comment-15632707
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user mxm commented on a diff in the pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2748
[FLINK-5004] [runtime] Add option to disable queryable state
- By default, the queryable state server is enabled (current behaviour)
- Via config option `query.server.start` it can be disabled
-
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632781#comment-15632781
]
Greg Hogan commented on FLINK-4545:
---
In 1.2 we now expose metrics for the number of allocated and in use
[
https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632822#comment-15632822
]
Maximilian Michels commented on FLINK-3813:
---
This is caused by the main thread not waiting on
[
https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632828#comment-15632828
]
ASF GitHub Bot commented on FLINK-3813:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2749
[FLINK-3813][yarn] wait for CLI to complete before checking output
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-3813
[
https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-3813:
-
Assignee: Maximilian Michels
> YARNSessionFIFOITCase.testDetachedMode failed on
Ufuk Celebi created FLINK-5007:
--
Summary: Retain externalized checkpoint on suspension
Key: FLINK-5007
URL: https://issues.apache.org/jira/browse/FLINK-5007
Project: Flink
Issue Type: Bug
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2750
[FLINK-5007] [checkpointing] Retain externalized checkpoint on suspension
Handles graceful cluster shut down (non-HA) like cancellation and respects
the configured clean up behaviour.
```
[
https://issues.apache.org/jira/browse/FLINK-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632974#comment-15632974
]
ASF GitHub Bot commented on FLINK-5007:
---
GitHub user uce opened a pull request:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2707
Hi @zentol thanks for the review. I suppose that the comment that it does
not work, implies that it does not work when rescaling right? Not in general.
If I am right, then this is expected. As you can
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15632999#comment-15632999
]
ASF GitHub Bot commented on FLINK-4939:
---
Github user kl0u commented on the issue:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2751
Window operator changes
The changes are described in the commit message of each commit.
### [FLINK-4993] Don't Allow Trigger.onMerge() to return TriggerResult
Allowing
[
https://issues.apache.org/jira/browse/FLINK-4993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633017#comment-15633017
]
ASF GitHub Bot commented on FLINK-4993:
---
GitHub user aljoscha opened a pull request:
Nico Kruber created FLINK-5008:
--
Summary: Update IDE setup documentation
Key: FLINK-5008
URL: https://issues.apache.org/jira/browse/FLINK-5008
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-5008:
--
Assignee: Nico Kruber
> Update IDE setup documentation
> --
>
>
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r86366630
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java
---
@@ -264,6 +265,7 @@ public void getFlatFields(String
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633036#comment-15633036
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633099#comment-15633099
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on the issue:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86340921
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -540,15 +540,12 @@ private boolean
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86350872
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/streaming/api/StreamingOperatorsITCase.java
---
@@ -195,6 +202,70 @@ public Integer
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86197630
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,194 @@
Ufuk Celebi created FLINK-5009:
--
Summary: FS checkpoints leave empty directory
Key: FLINK-5009
URL: https://issues.apache.org/jira/browse/FLINK-5009
Project: Flink
Issue Type: Bug
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86308340
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollector.java
---
@@ -0,0 +1,86 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86196580
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,194 @@
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633108#comment-15633108
]
ASF GitHub Bot commented on FLINK-4391:
---
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/2629#discussion_r86196655
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,194 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r8678
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
---
@@ -0,0 +1,256 @@
+/*
+
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86200906
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java
---
@@ -0,0 +1,108 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86353453
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollector.java
---
@@ -0,0 +1,86 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633106#comment-15633106
]
ASF GitHub Bot commented on FLINK-4391:
---
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/2629#discussion_r86201732
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java
---
@@ -0,0 +1,108 @@
+/*
+ *
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86320859
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633109#comment-15633109
]
ASF GitHub Bot commented on FLINK-4391:
---
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/2629#discussion_r86312736
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86312565
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633121#comment-15633121
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633118#comment-15633118
]
ASF GitHub Bot commented on FLINK-4391:
---
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/2629#discussion_r86347697
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBufferTest.java
---
@@ -0,0 +1,293 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86321156
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86360445
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86195976
--- Diff:
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java
---
@@ -0,0 +1,194 @@
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633114#comment-15633114
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633107#comment-15633107
]
ASF GitHub Bot commented on FLINK-4391:
---
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/2629#discussion_r86367216
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15633115#comment-15633115
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on a diff in the pull
1 - 100 of 292 matches
Mail list logo
