flinkbot edited a comment on pull request #12202:
URL: https://github.com/apache/flink/pull/12202#issuecomment-629806443
## CI report:
* 9385209a72fa1314e604a3998a149d93a12617d9 UNKNOWN
* 1b46780c0bf016a524a379cec83d120563ddcb9d Azure:
flinkbot edited a comment on pull request #12199:
URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563
## CI report:
* f11005c6596ecf41efd898ba324374948b2eb8cb Azure:
flinkbot edited a comment on pull request #12186:
URL: https://github.com/apache/flink/pull/12186#issuecomment-629492236
## CI report:
* f512eeef60f86107d945f975b1ca8dead57db9c4 Azure:
flinkbot edited a comment on pull request #12181:
URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595
## CI report:
* 9a73076f072352ba5539bf558f90a94572fb6c36 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17626:
---
Labels: pull-request-available (was: )
> Fs connector should use FLIP-122 format options
[
https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109980#comment-17109980
]
Robert Metzger commented on FLINK-17730:
In FLINK-17336, we introduced a timeout of 5 minutes.
godfreyhe commented on a change in pull request #12188:
URL: https://github.com/apache/flink/pull/12188#discussion_r426426306
##
File path:
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliClientTest.java
##
@@ -90,9 +92,9 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-17167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-17167:
Parent: (was: FLINK-17160)
Issue Type: Improvement (was: Sub-task)
> Extend
[
https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1711#comment-1711
]
Chesnay Schepler commented on FLINK-17789:
--
I'd argue that the behavior of
wuchong commented on pull request #11837:
URL: https://github.com/apache/flink/pull/11837#issuecomment-630014046
Passed:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1680=results
Merging...
This
rmetzger commented on pull request #11725:
URL: https://github.com/apache/flink/pull/11725#issuecomment-630013296
Note: changes merged through this PR broke master:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1686=results
flinkbot commented on pull request #12210:
URL: https://github.com/apache/flink/pull/12210#issuecomment-630018809
## CI report:
* 35a0b961d4d1a1dbb7485ff847c7b5e2a5068c80 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #12202:
URL: https://github.com/apache/flink/pull/12202#issuecomment-629806443
## CI report:
* 9385209a72fa1314e604a3998a149d93a12617d9 UNKNOWN
* 1b46780c0bf016a524a379cec83d120563ddcb9d Azure:
flinkbot commented on pull request #12211:
URL: https://github.com/apache/flink/pull/12211#issuecomment-630018919
## CI report:
* 439f4f136e73eebb6c424f7f706ab91655516ed3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
tillrohrmann closed pull request #11987:
URL: https://github.com/apache/flink/pull/11987
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
flinkbot commented on pull request #12213:
URL: https://github.com/apache/flink/pull/12213#issuecomment-630019128
## CI report:
* 74c9e440c684f255faa2075c12e4438590631dae UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12212:
URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032
## CI report:
* 0ec02542ed4721376e60ea71090cbb335885e6b0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
wangxiyuan opened a new pull request #23:
URL: https://github.com/apache/flink-docker/pull/23
The docker image `openjdk:8-jre` only works for amd64.
When running test on arm64, use `arm64v8/openjdk:8-jre` instead.
aljoscha commented on a change in pull request #12132:
URL: https://github.com/apache/flink/pull/12132#discussion_r426448856
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/filesystem/TestUtils.java
##
@@ -414,4 +419,50 @@ public
flinkbot commented on pull request #12215:
URL: https://github.com/apache/flink/pull/12215#issuecomment-630034151
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-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17788:
---
Labels: pull-request-available (was: )
> scala shell in yarn mode is broken
>
zjffdu opened a new pull request #12216:
URL: https://github.com/apache/flink/pull/12216
## What is the purpose of the change
The root cause of scala shell broken in yarn mode is that target is set as
`yarn-per-job` which is not correct. This PR fix this issue by removing
`target`
guoweiM commented on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-630035754
About the manual file clean up, we could move the template file to a temp
folder.
And use a special `RecovrableWriter` that could know the temp folder. WDYT?
docete commented on pull request #12218:
URL: https://github.com/apache/flink/pull/12218#issuecomment-630039520
@wuchong This PR fix FLINK-16160 on release-1.10, please have a look and
merge, Thanks.
This is an automated
dawidwys merged pull request #12201:
URL: https://github.com/apache/flink/pull/12201
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-17791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-17791.
--
Assignee: Caizhi Weng
Resolution: Fixed
master: cfeaedd9df677b90c8e31214ca7704eead4e6655
>
KurtYoung merged pull request #12202:
URL: https://github.com/apache/flink/pull/12202
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-13987:
-
Summary: Better TM/JM Log Display (was: add log list and read log by name)
> Better TM/JM Log Display
[
https://issues.apache.org/jira/browse/FLINK-17557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-17557:
---
Component/s: FileSystems
> Add configuration to disallow ambiguous file schemes
>
[
https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110071#comment-17110071
]
Till Rohrmann commented on FLINK-17194:
---
Another instance reported by [~rmetzger]. The problem
[
https://issues.apache.org/jira/browse/FLINK-17556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-17556:
---
Component/s: Runtime / Coordination
> FATAL: Thread
curcur edited a comment on pull request #12219:
URL: https://github.com/apache/flink/pull/12219#issuecomment-630056221
Please refer to
PR https://github.com/apache/flink/pull/11725 for revewing details.
The PR is reverted because of conflicts with
[FLINK-17659] Rework
[
https://issues.apache.org/jira/browse/FLINK-17675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110077#comment-17110077
]
Robert Metzger commented on FLINK-17675:
Thanks for opening this ticket. We are using jQuery
[
https://issues.apache.org/jira/browse/FLINK-17725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-17725:
--
Priority: Critical (was: Major)
> FileUploadHandlerTest.testUploadCleanupOnFailure fails
curcur commented on pull request #11725:
URL: https://github.com/apache/flink/pull/11725#issuecomment-630059574
The PR is reverted because of conflicts with
[FLINK-17659] Rework WatermarkStrategy, add Suppliers for
TimestampAssigner/WatermarkGenerator
committed last night.
[
https://issues.apache.org/jira/browse/FLINK-16303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-16303:
-
Release Note: Requesting an unavailable log or stdout file from the
JobManager's HTTP server returns
[
https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-17726:
--
Fix Version/s: 1.11.0
> Scheduler should take care of tasks directly canceled by TaskManager
kl0u edited a comment on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-630047870
Hi, these are some comments with renamings and moving classes for
consistency https://github.com/kl0u/flink/tree/FLINK-17593-comments.
Please check them out.
[
https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110083#comment-17110083
]
Yang Wang commented on FLINK-15792:
---
[~trohrmann] No, even after FLINK-17166, we still could not
[
https://issues.apache.org/jira/browse/FLINK-17703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-17703.
---
Resolution: Fixed
Fixed in [https://github.com/dataArtisans/flink-benchmarks] (master) via
[
https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110012#comment-17110012
]
Jark Wu commented on FLINK-16160:
-
Fixed in
- master (1.11.0):
flinkbot edited a comment on pull request #12103:
URL: https://github.com/apache/flink/pull/12103#issuecomment-627456433
## CI report:
* 05ab513e7a7aed7481001668eecddf26b8fd05cb Azure:
[
https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110019#comment-17110019
]
Eui Heo commented on FLINK-17077:
-
In either case, flink-conf.yaml is mounted only with the configMap.
[
https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110018#comment-17110018
]
Jingsong Lee commented on FLINK-17789:
--
If there is an option = ConfigOptions.key("prefix.v1"),
rmetzger commented on pull request #11725:
URL: https://github.com/apache/flink/pull/11725#issuecomment-630021791
Change has been reverted
https://github.com/apache/flink/commit/bf58725e7ad80f276a458007a2d5b890d8ffc4f5
This
curcur commented on pull request #11725:
URL: https://github.com/apache/flink/pull/11725#issuecomment-630025655
It is because of commit of unifying the watermark Strategy committed last
night...
This is an automated message
wangyang0918 commented on pull request #12214:
URL: https://github.com/apache/flink/pull/12214#issuecomment-630029338
cc @zentol Could you have a look? When i update the `flink-console.sh`, i
find this issue.
This is an
flinkbot edited a comment on pull request #8693:
URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065
## CI report:
* 40f0f8f733b268c3ddcf2864313b3ec67fe3757c Azure:
[
https://issues.apache.org/jira/browse/FLINK-17618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17618:
---
Labels: pull-request-available (was: )
> Update the outdated comments in the log4j
guoweiM commented on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-630028998
NP
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
flinkbot edited a comment on pull request #12213:
URL: https://github.com/apache/flink/pull/12213#issuecomment-630019128
## CI report:
* 74c9e440c684f255faa2075c12e4438590631dae Azure:
flinkbot edited a comment on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415
## CI report:
* 449b8494248924ab0c9a4a5187458933902a13a3 Azure:
flinkbot edited a comment on pull request #12197:
URL: https://github.com/apache/flink/pull/12197#issuecomment-629768433
## CI report:
* 15cb31fea013766318c482cd266aa294b9df225b Azure:
flinkbot edited a comment on pull request #12139:
URL: https://github.com/apache/flink/pull/12139#issuecomment-628360660
## CI report:
* b02e502fa3bb3ae57d4678d23868cad20d51caca Azure:
flinkbot edited a comment on pull request #12210:
URL: https://github.com/apache/flink/pull/12210#issuecomment-630018809
## CI report:
* 35a0b961d4d1a1dbb7485ff847c7b5e2a5068c80 Azure:
flinkbot edited a comment on pull request #12204:
URL: https://github.com/apache/flink/pull/12204#issuecomment-629847515
## CI report:
* 097ac2b06f10900c435115c24e699c5328ee3227 Azure:
flinkbot edited a comment on pull request #12211:
URL: https://github.com/apache/flink/pull/12211#issuecomment-630018919
## CI report:
* 439f4f136e73eebb6c424f7f706ab91655516ed3 Azure:
flinkbot edited a comment on pull request #12202:
URL: https://github.com/apache/flink/pull/12202#issuecomment-629806443
## CI report:
* 9385209a72fa1314e604a3998a149d93a12617d9 UNKNOWN
* a13b735e5ecbb1c90479056ebda8d738a1a43584 Azure:
flinkbot edited a comment on pull request #12212:
URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032
## CI report:
* 0ec02542ed4721376e60ea71090cbb335885e6b0 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-17384:
-
Comment: was deleted
(was: Hi [~liyu], I have committed my code, but the log is below, which is not
lirui-apache commented on pull request #12217:
URL: https://github.com/apache/flink/pull/12217#issuecomment-630038276
@JingsongLi Please take a look. Thanks.
This is an automated message from the Apache Git Service.
To
Gary Yao created FLINK-17794:
Summary: Tear down installed software in reverse order in Jepsen
Tests
Key: FLINK-17794
URL: https://issues.apache.org/jira/browse/FLINK-17794
Project: Flink
Issue
docete opened a new pull request #12218:
URL: https://github.com/apache/flink/pull/12218
…nvironment.connect().createTemporaryTable()
## What is the purpose of the change
Since FLINK-14490 , proctime()/rowtime() doesn't work for
[
https://issues.apache.org/jira/browse/FLINK-17786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17786:
---
Labels: pull-request-available (was: )
> Cannot switch dialect in SQL CLI
>
twalthr commented on a change in pull request #12201:
URL: https://github.com/apache/flink/pull/12201#discussion_r426467949
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java
##
@@ -909,12 +909,10 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110052#comment-17110052
]
Till Rohrmann commented on FLINK-15792:
---
[~fly_in_gis] why do we still need
[
https://issues.apache.org/jira/browse/FLINK-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110051#comment-17110051
]
Chesnay Schepler edited comment on FLINK-17789 at 5/18/20, 8:52 AM:
flinkbot commented on pull request #12217:
URL: https://github.com/apache/flink/pull/12217#issuecomment-630041279
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 commented on pull request #12218:
URL: https://github.com/apache/flink/pull/12218#issuecomment-630041237
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-17789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110051#comment-17110051
]
Chesnay Schepler edited comment on FLINK-17789 at 5/18/20, 8:51 AM:
flinkbot edited a comment on pull request #12139:
URL: https://github.com/apache/flink/pull/12139#issuecomment-628360660
## CI report:
* b02e502fa3bb3ae57d4678d23868cad20d51caca Azure:
flinkbot edited a comment on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415
## CI report:
* 10ef0c696350fcd84866fde27f19ed2a0312ee4b Azure:
flinkbot edited a comment on pull request #12103:
URL: https://github.com/apache/flink/pull/12103#issuecomment-627456433
## CI report:
* 460711a0fe014e079ea2eb9c6e98da11e1946b48 Azure:
flinkbot edited a comment on pull request #12204:
URL: https://github.com/apache/flink/pull/12204#issuecomment-629847515
## CI report:
* 097ac2b06f10900c435115c24e699c5328ee3227 Azure:
flinkbot edited a comment on pull request #12181:
URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595
## CI report:
* b954ba073cba912b98c5992b05caec91e7657871 Azure:
flinkbot edited a comment on pull request #12209:
URL: https://github.com/apache/flink/pull/12209#issuecomment-629971018
## CI report:
* c91cdd32db0464d8b60d0efc0763078388a15daf Azure:
flinkbot commented on pull request #12214:
URL: https://github.com/apache/flink/pull/12214#issuecomment-630047206
## CI report:
* 78d9cd9f70ac69a78f6d045d998a004492ce4cfe UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #12197:
URL: https://github.com/apache/flink/pull/12197#issuecomment-629768433
## CI report:
* 15cb31fea013766318c482cd266aa294b9df225b Azure:
flinkbot commented on pull request #12215:
URL: https://github.com/apache/flink/pull/12215#issuecomment-630047332
## CI report:
* 5f357acabcb13d64d8e9a042af14329415db0f87 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12217:
URL: https://github.com/apache/flink/pull/12217#issuecomment-630047579
## CI report:
* a9407fa236d3cb710f131c04ced0ae449bbc15a9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12216:
URL: https://github.com/apache/flink/pull/12216#issuecomment-630047470
## CI report:
* 9b24ab2448e35acd0fabcf226409d37162136391 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-16863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-16863:
-
Affects Version/s: 1.11.0
> Sorting descendingly on the last modified date of LogInfo
>
kl0u commented on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-630047870
Hi, these are some comments with renamings and moving classes for
consistency https://github.com/kl0u/flink/tree/FLINK-17593-comments.
Please check them out. Probably we
TsReaper commented on a change in pull request #12199:
URL: https://github.com/apache/flink/pull/12199#discussion_r426477145
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java
##
@@ -124,17 +134,22 @@ public static void
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-13987.
Resolution: Fixed
> add log list and read log by name
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-13987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-13987:
-
Fix Version/s: 1.11.0
> add log list and read log by name
> -
>
>
TsReaper commented on a change in pull request #12199:
URL: https://github.com/apache/flink/pull/12199#discussion_r426454791
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/BatchSelectTableSink.java
##
@@ -43,71 +43,68 @@
[
https://issues.apache.org/jira/browse/FLINK-17715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-17715.
--
Assignee: Danny Chen
Resolution: Fixed
master: 20c28ac77ecd6b8d11e38ed84c9a5c36317721f3
>
KurtYoung merged pull request #12171:
URL: https://github.com/apache/flink/pull/12171
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-16863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-16863:
-
Parent: (was: FLINK-13987)
Issue Type: Improvement (was: Sub-task)
> Sorting descendingly
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng resolved FLINK-14807.
-
Resolution: Implemented
> Add Table#collect api for fetching data to client
>
[
https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110068#comment-17110068
]
Kurt Young commented on FLINK-17793:
+1, how about calling it `CatalogTableSchema` or something
[
https://issues.apache.org/jira/browse/FLINK-16303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-16303:
-
Summary: Add JobMananger Log List and enable reading Logs by Filename
(was: add log list and read log
liuyongvs removed a comment on pull request #12144:
URL: https://github.com/apache/flink/pull/12144#issuecomment-629091637
> ## CI report:
> *
[5addfcf](https://github.com/apache/flink/commit/5addfcff9eb59b5153e76627ed74e7255fe8b69b)
Azure:
JingsongLi opened a new pull request #12220:
URL: https://github.com/apache/flink/pull/12220
## What is the purpose of the change
Integrate mapred record writer to hive streaming sink.
Hadoop Record writer can support all hive/hadoop formats.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-17781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-17781:
---
Component/s: Runtime / Coordination
> OperatorCoordinator Context must support calls from
curcur opened a new pull request #12219:
URL: https://github.com/apache/flink/pull/12219
## What is the purpose of the change
This pull request is to provide a Kafka Source/Sink pair to simulate a
KafkaShuffle that can:
1. Read topics that are already partitioned by key
[
https://issues.apache.org/jira/browse/FLINK-15666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-15666.
--
Fix Version/s: 1.11.0
Resolution: Duplicate
> GPU scheduling support in Kubernetes mode
>
[
https://issues.apache.org/jira/browse/FLINK-17750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110074#comment-17110074
]
Till Rohrmann commented on FLINK-17750:
---
The problem might be that a previous Yarn test did not
[
https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-17726:
--
Affects Version/s: 1.11.0
> Scheduler should take care of tasks directly canceled by
101 - 200 of 827 matches
Mail list logo
