[
https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517821#comment-16517821
]
ASF GitHub Bot commented on FLINK-9325:
---
Github user sihuazhou commented on the iss
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5982
Could anybody have a look at this?
---
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6185
CC @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517794#comment-16517794
]
ASF GitHub Bot commented on FLINK-9619:
---
GitHub user sihuazhou opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517795#comment-16517795
]
ASF GitHub Bot commented on FLINK-9619:
---
Github user sihuazhou commented on the iss
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/6185
[FLINK-9619][YARN] Eagerly close the connection with task manager when the
container is completed
## What is the purpose of the change
*We should always eagerly close the connection with
Sihua Zhou created FLINK-9619:
-
Summary: Always close the task manager connection when the
container is completed in YarnResourceManager
Key: FLINK-9619
URL: https://issues.apache.org/jira/browse/FLINK-9619
[
https://issues.apache.org/jira/browse/FLINK-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517790#comment-16517790
]
Sihua Zhou commented on FLINK-9417:
---
Hi [~till.rohrmann] One thing come to my mind, If
[
https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517789#comment-16517789
]
ASF GitHub Bot commented on FLINK-9187:
---
Github user lamber-ken commented on the is
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6184
Please click here for details
[old-flink-9187](https://github.com/apache/flink/pull/5857)
---
[
https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517788#comment-16517788
]
ASF GitHub Bot commented on FLINK-9187:
---
Github user lamber-ken closed the pull req
Github user lamber-ken closed the pull request at:
https://github.com/apache/flink/pull/5857
---
GitHub user lamber-ken opened a pull request:
https://github.com/apache/flink/pull/6184
add prometheus pushgateway reporter
## What is the purpose of the change
This pull request makes flink system can send metrics to prometheus via
pushgateway. it may be useful.
## Bri
[
https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517760#comment-16517760
]
ASF GitHub Bot commented on FLINK-9187:
---
Github user lamber-ken commented on the is
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/5857
sorry, I reforked `flink` project, do I need to start a new PR?
---
[
https://issues.apache.org/jira/browse/FLINK-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517732#comment-16517732
]
ASF GitHub Bot commented on FLINK-9588:
---
Github user Aitozi commented on the issue:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/6168
Is it ok now ? @dawidwys
---
[
https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517718#comment-16517718
]
Deepak Sharma commented on FLINK-9380:
--
Hi [~till.rohrmann], just a friendly reminde
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517717#comment-16517717
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user deepaks4077 commented on the i
Github user deepaks4077 commented on the issue:
https://github.com/apache/flink/pull/6170
Hi @zentol, just a friendly reminder about this pull request :)
---
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517679#comment-16517679
]
mingleizhang commented on FLINK-9614:
-
I close this since we catch a throwable. stack
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang closed FLINK-9614.
---
> Improve the error message for Compiler#compile
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang resolved FLINK-9614.
-
Resolution: Not A Problem
> Improve the error message for Compiler#compile
>
[
https://issues.apache.org/jira/browse/FLINK-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517645#comment-16517645
]
Aaron Langford commented on FLINK-9618:
---
I would be happy to take the work to fix t
Aaron Langford created FLINK-9618:
-
Summary: NullPointerException in FlinkKinesisProducer when
aws.region is not set and aws.endpoint is set
Key: FLINK-9618
URL: https://issues.apache.org/jira/browse/FLINK-9618
[
https://issues.apache.org/jira/browse/FLINK-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517528#comment-16517528
]
Eron Wright commented on FLINK-9611:
-
I really like this idea, except for the propos
[
https://issues.apache.org/jira/browse/FLINK-9612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517525#comment-16517525
]
Eron Wright commented on FLINK-9612:
-
Yes it makes sense that the overlays would be
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517490#comment-16517490
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196556101
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/FileUploadsTest.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196453980
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java
---
@@ -129,4 +137,9 @@ public R getRequestBody() {
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517480#comment-16517480
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196559335
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -0,0 +1,471 @@
+/*
+ * Licensed to the Ap
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196558949
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageHeaders.java
---
@@ -63,4 +63,13 @@
* @return description
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517479#comment-16517479
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517492#comment-16517492
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196559093
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -0,0 +1,471 @@
+/*
+ * Licensed to the Ap
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196554025
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/AbstractHandler.java
---
@@ -103,77 +104,74 @@ protected void respondAsLeader(Chann
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517481#comment-16517481
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517477#comment-16517477
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196557260
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java
---
@@ -39,15 +41,21 @@
public class HandlerReques
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196452418
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -116,5 +136,16 @@ private void reset() {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196560163
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/FileUploadHandlerTest.java
---
@@ -0,0 +1,471 @@
+/*
+ * Licensed to the Ap
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196555487
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java
---
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apac
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196455211
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/AbstractHandler.java
---
@@ -103,77 +104,74 @@ protected void respondAsLeader(Chann
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517478#comment-16517478
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r19670
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java
---
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apac
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196452755
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -95,14 +107,22 @@ protected void channelRead0(final
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517486#comment-16517486
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517483#comment-16517483
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196452583
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -116,5 +136,16 @@ private void reset() {
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517487#comment-16517487
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517491#comment-16517491
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517488#comment-16517488
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196453584
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java
---
@@ -0,0 +1,136 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517485#comment-16517485
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517484#comment-16517484
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517493#comment-16517493
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517482#comment-16517482
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196452024
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -95,14 +107,22 @@ protected void channelRead0(final
[
https://issues.apache.org/jira/browse/FLINK-9599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517476#comment-16517476
]
ASF GitHub Bot commented on FLINK-9599:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6178#discussion_r196453235
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java
---
@@ -95,14 +107,22 @@ protected void channelRead0(final
[
https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517283#comment-16517283
]
Timo Walther commented on FLINK-4542:
-
Hi [~Sergey Nuyanzin],
I thought Calcite has
[
https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517268#comment-16517268
]
Timo Walther commented on FLINK-8921:
-
[~RuidongLi] what is the status of this issue.
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517233#comment-16517233
]
ASF GitHub Bot commented on FLINK-7897:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5777
@StefanRRichter , does this PR look good to you?
---
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517230#comment-16517230
]
ASF GitHub Bot commented on FLINK-9352:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6092
cc @zentol @kl0u
---
Piotr Nowojski created FLINK-9617:
-
Summary: Provide alias for whole records in Table API
Key: FLINK-9617
URL: https://issues.apache.org/jira/browse/FLINK-9617
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-9616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517205#comment-16517205
]
ASF GitHub Bot commented on FLINK-9616:
---
GitHub user addisonj opened a pull request
GitHub user addisonj opened a pull request:
https://github.com/apache/flink/pull/6183
[FLINK-9616][metrics] Fix datadog to include shaded deps
## What is the purpose of the change
This fixes a broken build that wasn't properly including a shaded in the
jar it builds. T
Addison Higham created FLINK-9616:
-
Summary: DatadogHttpReporter fails to be created due to missing
shaded dependency
Key: FLINK-9616
URL: https://issues.apache.org/jira/browse/FLINK-9616
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517150#comment-16517150
]
ASF GitHub Bot commented on FLINK-8795:
---
GitHub user dawidwys opened a pull request
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/6182
[FLINK-8795] Fixed local scala shell for Flip6
## What is the purpose of the change
Enable to run scala-shell in local mode with new runtime mode.
## Brief change log
- Cr
[
https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517128#comment-16517128
]
Fabian Hueske commented on FLINK-9615:
--
Thanks for opening this issue!
This is (part
[
https://issues.apache.org/jira/browse/FLINK-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517115#comment-16517115
]
ASF GitHub Bot commented on FLINK-9610:
---
Github user nielsbasjes commented on a dif
Github user nielsbasjes commented on a diff in the pull request:
https://github.com/apache/flink/pull/6181#discussion_r196435400
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkKeyHashPartitioner.java
---
[
https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9615:
Comment: was deleted
(was: I can take care of that :) It's not a big improvement to be made
[
https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16517095#comment-16517095
]
Dominik Wosiński commented on FLINK-9615:
-
I can take care of that :) It's not a
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Description:
When the below sql has too long. Like
case when case when .
when host in
(
[
https://issues.apache.org/jira/browse/FLINK-9615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-9615:
Summary: Add possibility to use Connectors as Sinks in SQL Client (was:
Add)
> Add possib
Dominik Wosiński created FLINK-9615:
---
Summary: Add
Key: FLINK-9615
URL: https://issues.apache.org/jira/browse/FLINK-9615
Project: Flink
Issue Type: Improvement
Reporter: Dominik
[
https://issues.apache.org/jira/browse/FLINK-9614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9614:
Component/s: Table API & SQL
> Improve the error message for Compiler#compile
> ---
mingleizhang created FLINK-9614:
---
Summary: Improve the error message for Compiler#compile
Key: FLINK-9614
URL: https://issues.apache.org/jira/browse/FLINK-9614
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-9367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangxinyu closed FLINK-9367.
-
Resolution: Won't Do
BucketingSink is going to be rewritten, and hadoop below 2.7 won't be
supported. Th
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516986#comment-16516986
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user zentol closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516985#comment-16516985
]
ASF GitHub Bot commented on FLINK-9280:
---
Github user zentol commented on the issue:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/6147
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6147
I will split this PR to address the various issues separately.
---
[
https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516972#comment-16516972
]
Shimin Yang commented on FLINK-9567:
Thanks for assigning the issue to me, I will do
[
https://issues.apache.org/jira/browse/FLINK-9367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516961#comment-16516961
]
ASF GitHub Bot commented on FLINK-9367:
---
Github user zhangxinyu1 closed the pull re
Github user zhangxinyu1 closed the pull request at:
https://github.com/apache/flink/pull/6108
---
[
https://issues.apache.org/jira/browse/FLINK-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516914#comment-16516914
]
ASF GitHub Bot commented on FLINK-9610:
---
Github user tedyu commented on a diff in t
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/6181#discussion_r196368052
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkKeyHashPartitioner.java
---
@
Sihua Zhou created FLINK-9613:
-
Summary: YARNSessionCapacitySchedulerITCase failed because
YarnTestBase.checkClusterEmpty()
Key: FLINK-9613
URL: https://issues.apache.org/jira/browse/FLINK-9613
Project: F
[
https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516911#comment-16516911
]
ASF GitHub Bot commented on FLINK-9187:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516912#comment-16516912
]
ASF GitHub Bot commented on FLINK-9569:
---
Github user sihuazhou commented on a diff
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6151#discussion_r196366033
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java
---
@@ -105,41 +108,54 @@
/** The cur
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5857
I I see the value of a `cluster_id` but you're mixing concerns here. It is
not the responsibility of a `reporter` to introduce a `cluster_id` tag.
Reporters are to faithfully report the metrics and th
[
https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16516863#comment-16516863
]
ASF GitHub Bot commented on FLINK-9187:
---
Github user lamber-ken commented on the is
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/5857
@zentol , thanks for review.
first, there is a small point that the IDs may be duplicated when use JM/TM
actual unique ID to compose the job name of pushgateway, like the picture below.
