[
https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Artiga updated FLINK-17506:
-
Description: {{SavepointEnvironment}} [creates an
flinkbot edited a comment on pull request #11985:
URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781
## CI report:
* 945427a9cf24c43097883cc9fccbac2983ab8bac Azure:
flinkbot edited a comment on pull request #11985:
URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781
## CI report:
* de26ba11042772d77be2416fd6c829d80c9c66b7 Azure:
flinkbot edited a comment on pull request #11985:
URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781
## CI report:
* de26ba11042772d77be2416fd6c829d80c9c66b7 Azure:
RocMarshal commented on pull request #11979:
URL: https://github.com/apache/flink/pull/11979#issuecomment-623845807
Hi, @wuchong . I have completed the translation of this page and made
corresponding improvements according to the suggestions of community members.
If you have free time,
[
https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099479#comment-17099479
]
RocMarshal edited comment on FLINK-17291 at 5/5/20, 3:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099479#comment-17099479
]
RocMarshal edited comment on FLINK-17291 at 5/5/20, 1:46 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099479#comment-17099479
]
RocMarshal commented on FLINK-17291:
Hi,[~alpinegizmo].
I have completed the translation of this
flinkbot edited a comment on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853
## CI report:
* 5a2f6e8bd534d439b30e10b41a17821a3ea93590 Azure:
RocMarshal commented on pull request #11979:
URL: https://github.com/apache/flink/pull/11979#issuecomment-623785660
Hi, @XBaith ,I have updated the document according to your suggestions.
Obviously, it is very helpful for the translation of the document. Thank you
very much for your help.
RocMarshal commented on pull request #11979:
URL: https://github.com/apache/flink/pull/11979#issuecomment-623783106
@flinkbot run travis
This is an automated message from the Apache Git Service.
To respond to the message,
caozhen1937 commented on pull request #11978:
URL: https://github.com/apache/flink/pull/11978#issuecomment-623782234
Hi @wuchong , if you have free time , please review it, thank you
This is an automated message from the
flinkbot edited a comment on pull request #11986:
URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672
## CI report:
* 1597769183be673722456fb55e296d38d0fad837 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman reassigned FLINK-17506:
Assignee: Seth Wiesman
> SavepointEnvironment does not honour 'io.tmp.dirs' property
>
flinkbot edited a comment on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853
## CI report:
* 2113227fdc0076eb9e2f72ae7883c2d5d245cbab Azure:
flinkbot edited a comment on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853
## CI report:
* 2113227fdc0076eb9e2f72ae7883c2d5d245cbab Azure:
[
https://issues.apache.org/jira/browse/FLINK-17465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin reassigned FLINK-17465:
---
Assignee: Xintong Song
> Update Chinese user documentation for job manager memory
Flavio Pompermaier created FLINK-17509:
--
Summary: Support OracleDialect
Key: FLINK-17509
URL: https://issues.apache.org/jira/browse/FLINK-17509
Project: Flink
Issue Type: Sub-task
Flavio Pompermaier created FLINK-17508:
--
Summary: Develop OracleCatalog
Key: FLINK-17508
URL: https://issues.apache.org/jira/browse/FLINK-17508
Project: Flink
Issue Type: Sub-task
David Anderson created FLINK-17507:
--
Summary: Training figure program_dataflow.svg should use preferred
parts of the API
Key: FLINK-17507
URL: https://issues.apache.org/jira/browse/FLINK-17507
[
https://issues.apache.org/jira/browse/FLINK-17507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-17507:
---
Description:
It would be better if fig/program_dataflow.svg used a
flinkbot edited a comment on pull request #11986:
URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672
## CI report:
* 4cc9434270958dcbdf322483531c97c108c4a2e8 Azure:
rkhachatryan commented on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-623702887
@edu05 can you please squash the commits and rebase to the latest master
(Azure build still fails)?
This
flinkbot edited a comment on pull request #11986:
URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672
## CI report:
* 4cc9434270958dcbdf322483531c97c108c4a2e8 Azure:
fpompermaier commented on pull request #11900:
URL: https://github.com/apache/flink/pull/11900#issuecomment-623697631
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
fpompermaier removed a comment on pull request #11900:
URL: https://github.com/apache/flink/pull/11900#issuecomment-623697329
@flinkbot run travis
@flinkbot run azure
This is an automated message from the Apache Git
fpompermaier removed a comment on pull request #11900:
URL: https://github.com/apache/flink/pull/11900#issuecomment-623310522
@flinkbot run travis
@flinkbot run azure
This is an automated message from the Apache Git
fpompermaier commented on pull request #11900:
URL: https://github.com/apache/flink/pull/11900#issuecomment-623697329
@flinkbot run travis
@flinkbot run azure
This is an automated message from the Apache Git Service.
zentol commented on a change in pull request #11983:
URL: https://github.com/apache/flink/pull/11983#discussion_r419698801
##
File path: flink-dist/pom.xml
##
@@ -137,8 +137,8 @@ under the License.
${project.version}
rmetzger commented on a change in pull request #11983:
URL: https://github.com/apache/flink/pull/11983#discussion_r419675846
##
File path: flink-dist/pom.xml
##
@@ -137,8 +137,8 @@ under the License.
${project.version}
flinkbot edited a comment on pull request #11988:
URL: https://github.com/apache/flink/pull/11988#issuecomment-623640141
## CI report:
* cc4fa4fe94ef8a6ff97a2a9b7bb752302224c5c4 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099232#comment-17099232
]
John Lonergan commented on FLINK-17464:
---
Yep think failing the job is the lesser evil.
A wrecked
flinkbot commented on pull request #11988:
URL: https://github.com/apache/flink/pull/11988#issuecomment-623622490
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-17244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17244:
---
Labels: pull-request-available (was: )
> Update Getting Started / Overview: training and
[
https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099208#comment-17099208
]
Kostas Kloudas commented on FLINK-17500:
[~uce] and [~trohrmann] with the introduction of the
zentol commented on a change in pull request #11983:
URL: https://github.com/apache/flink/pull/11983#discussion_r419630074
##
File path: flink-dist/pom.xml
##
@@ -137,8 +137,8 @@ under the License.
${project.version}
flinkbot commented on pull request #11987:
URL: https://github.com/apache/flink/pull/11987#issuecomment-623621331
## CI report:
* db7481419288348aebf6a09127410424ff517b01 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
alpinegizmo opened a new pull request #11988:
URL: https://github.com/apache/flink/pull/11988
## What is the purpose of the change
* Generally improve the content of this page
* Add the Python Table API code walkthrough
* Add the Hands-on Training
## Translation
*
flinkbot commented on pull request #11987:
URL: https://github.com/apache/flink/pull/11987#issuecomment-623611390
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot edited a comment on pull request #11986:
URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672
## CI report:
* 4cc9434270958dcbdf322483531c97c108c4a2e8 Azure:
qqibrow opened a new pull request #11987:
URL: https://github.com/apache/flink/pull/11987
Adding hostname in error message could help us detect host issue. The new
error message would be like:
```
2019-12-07 05:04:43,264 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph
[
https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-17313:
-
Fix Version/s: 1.11.0
> Validation error when insert decimal/varchar with precision
flinkbot edited a comment on pull request #11986:
URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672
## CI report:
* 4cc9434270958dcbdf322483531c97c108c4a2e8 Azure:
David Artiga created FLINK-17506:
Summary: SavepointEnvironment does not honour 'io.tmp.dirs'
property
Key: FLINK-17506
URL: https://issues.apache.org/jira/browse/FLINK-17506
Project: Flink
flinkbot commented on pull request #11986:
URL: https://github.com/apache/flink/pull/11986#issuecomment-623579672
## CI report:
* 4cc9434270958dcbdf322483531c97c108c4a2e8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #11986:
URL: https://github.com/apache/flink/pull/11986#issuecomment-623574742
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099106#comment-17099106
]
Flavio Pompermaier commented on FLINK-17361:
As I commented in the PR I named the property
fpompermaier opened a new pull request #11986:
URL: https://github.com/apache/flink/pull/11986
## What is the purpose of the change
Enable users to create a JDBC source table using a custom query / prepared
statement.
## Brief change log
- Managed
[
https://issues.apache.org/jira/browse/FLINK-17361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17361:
---
Labels: pull-request-available (was: )
> Support creating of a JDBC table using a custom
flinkbot edited a comment on pull request #11985:
URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781
## CI report:
* de26ba11042772d77be2416fd6c829d80c9c66b7 Azure:
flinkbot edited a comment on pull request #11854:
URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491
## CI report:
* bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN
* dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN
*
walterddr commented on pull request #11936:
URL: https://github.com/apache/flink/pull/11936#issuecomment-623568748
@aljoscha could you take another look?
This is an automated message from the Apache Git Service.
To respond
pnowojski commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419564857
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
##
@@ -731,33 +726,29 @@
flinkbot edited a comment on pull request #11985:
URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781
## CI report:
* de26ba11042772d77be2416fd6c829d80c9c66b7 Azure:
flinkbot edited a comment on pull request #11554:
URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909
## CI report:
* 14e9fe3bfdeeae480047848801243f9fbed03cb4 UNKNOWN
* a11dbc2d6b25ff16ef3cff4ecc751538d6867e68 UNKNOWN
*
edu05 commented on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-623554001
@rkhachatryan Are there any outstanding issues?
This is an automated message from the Apache Git Service.
To
flinkbot edited a comment on pull request #11979:
URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252
## CI report:
* 51f00c041b126b54616f191f669750e819c733db Azure:
flinkbot commented on pull request #11985:
URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781
## CI report:
* de26ba11042772d77be2416fd6c829d80c9c66b7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #11554:
URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909
## CI report:
* 14e9fe3bfdeeae480047848801243f9fbed03cb4 UNKNOWN
* a11dbc2d6b25ff16ef3cff4ecc751538d6867e68 UNKNOWN
*
zhijiangW commented on pull request #11687:
URL: https://github.com/apache/flink/pull/11687#issuecomment-623538520
Thanks for the further reviews @pnowojski !
> I'm still not sure if this is the right approach. It's better compared to
the original proposal, at a cost of much more
flinkbot commented on pull request #11985:
URL: https://github.com/apache/flink/pull/11985#issuecomment-623535573
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099045#comment-17099045
]
Aljoscha Krettek commented on FLINK-17327:
--
I believe that
flinkbot edited a comment on pull request #11979:
URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252
## CI report:
* 51f00c041b126b54616f191f669750e819c733db Azure:
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419522975
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/AbstractRecordReader.java
##
@@ -63,6 +63,8 @@ protected
[
https://issues.apache.org/jira/browse/FLINK-16989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16989:
---
Labels: pull-request-available (was: )
> Support ScanTableSource in planner
>
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419521815
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
##
@@ -97,6 +100,18 @@ public
wuchong opened a new pull request #11985:
URL: https://github.com/apache/flink/pull/11985
## What is the purpose of the change
Support the `ScanTableSource` interface in planner. We don't support change
mode `[I, UA, D]` (`UPDATE_AFTER` without `UPDATE_BEFORE`) in first
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419521605
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -371,7 +373,14 @@
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419520547
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -105,12 +98,15 @@
[
https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099035#comment-17099035
]
Robert Metzger commented on FLINK-16947:
MSFT hosted:
rmetzger commented on pull request #11983:
URL: https://github.com/apache/flink/pull/11983#issuecomment-623529249
The YARN failure on Azure is a known YARN issue:
https://issues.apache.org/jira/browse/FLINK-15534
This is an
flinkbot edited a comment on pull request #11854:
URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491
## CI report:
* bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN
* dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN
*
flinkbot edited a comment on pull request #11554:
URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909
## CI report:
* 14e9fe3bfdeeae480047848801243f9fbed03cb4 UNKNOWN
* a11dbc2d6b25ff16ef3cff4ecc751538d6867e68 UNKNOWN
*
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419513791
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
##
@@ -168,6 +175,12 @@ public
[
https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099029#comment-17099029
]
Robert Metzger commented on FLINK-16947:
rmetzger commented on pull request #11554:
URL: https://github.com/apache/flink/pull/11554#issuecomment-623522364
The bot needs quite some time to update. I notified Chesnay already to look
into it.
This is an automated
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419508820
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
##
@@ -168,6 +175,12 @@ public
flinkbot edited a comment on pull request #11979:
URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252
## CI report:
* 51f00c041b126b54616f191f669750e819c733db Azure:
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419502301
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java
##
@@ -87,10 +90,14 @@ public
becketqin commented on pull request #11554:
URL: https://github.com/apache/flink/pull/11554#issuecomment-623516373
@rmetzger Thanks for the help. I just tried to do a rebase as well as an
empty commit. But it seems the CI test was still not triggered.
flinkbot edited a comment on pull request #11854:
URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491
## CI report:
* bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN
* dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman resolved FLINK-17499.
--
Resolution: Fixed
> LazyTimerService used to register timers via State Processing API
[
https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099011#comment-17099011
]
Seth Wiesman commented on FLINK-17499:
--
Fixed in master: d6439c8d0e7792961635e3e4297c3dbfb01938e3
[
https://issues.apache.org/jira/browse/FLINK-17499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-17499:
-
Affects Version/s: (was: 1.10.0)
1.10.2
> LazyTimerService used to
[
https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099007#comment-17099007
]
Jiayi Liao commented on FLINK-17453:
[~aljoscha] It's {{HashMap}}. I've attached the udaf
[
https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-17453:
---
Attachment: udaf
> KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue
>
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419494982
##
File path:
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BackPressureITCase.java
##
@@ -94,7 +94,7 @@ private static
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419494982
##
File path:
flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BackPressureITCase.java
##
@@ -94,7 +94,7 @@ private static
rmetzger commented on pull request #11554:
URL: https://github.com/apache/flink/pull/11554#issuecomment-623508089
Sadly, Flinkbot does not re-run the CI if the last status is "UNKNOWN". You
need to do another push to the branch (empty commit, rebase).
[
https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-17327:
--
I'm re-opening for now since I think the KafkaConsumer is working as designed,
i.e.
becketqin opened a new pull request #11554:
URL: https://github.com/apache/flink/pull/11554
## What is the purpose of the change
This patch is a part of
[FLIP-27](https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface).
It adds the implementation for
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419490643
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java
##
@@ -65,14 +65,10 @@
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419489175
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java
##
@@ -0,0 +1,356 @@
+/*
+ *
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419487035
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java
##
@@ -0,0 +1,356 @@
+/*
+ *
flinkbot edited a comment on pull request #11984:
URL: https://github.com/apache/flink/pull/11984#issuecomment-623399971
## CI report:
* 3f9eb6a6f30b0a00b44eef6f3b331da442c0ddab Azure:
pnowojski commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419484431
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/AbstractRecordReader.java
##
@@ -63,6 +63,8 @@ protected
[
https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098982#comment-17098982
]
Till Rohrmann edited comment on FLINK-17464 at 5/4/20, 2:35 PM:
Thanks
[
https://issues.apache.org/jira/browse/FLINK-17464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098982#comment-17098982
]
Till Rohrmann commented on FLINK-17464:
---
Thanks for reporting this issue [~johnlon]. Your
[
https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098975#comment-17098975
]
Piotr Nowojski commented on FLINK-11499:
A small status update here.
1. I was doing some PoC in
zhijiangW commented on a change in pull request #11687:
URL: https://github.com/apache/flink/pull/11687#discussion_r419472411
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##
@@ -321,111 +274,43 @@
1 - 100 of 283 matches
Mail list logo
