GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5150
upgrade Calcite dependency to 1.15
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution in th
[
https://issues.apache.org/jira/browse/FLINK-7858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287163#comment-16287163
]
ASF GitHub Bot commented on FLINK-7858:
---
GitHub user zjureel opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/5149
[FLINK-7858][flp6] Port JobVertexTaskManagersHandler to REST endpoint
## What is the purpose of the change
Port JobVertexTaskManagersHandler to REST endpoint
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8240:
Description:
At the moment every table source has different ways for configuration and
instantiatio
[
https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8240:
Description:
At the moment every table source has different ways for configuration and
instantiatio
[
https://issues.apache.org/jira/browse/FLINK-8228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16287027#comment-16287027
]
ASF GitHub Bot commented on FLINK-8228:
---
Github user yew1eb commented on the issue:
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5143
If this change does not improve performance, I agree with you keep origin
formatting. :)
---
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6352:
---
Fix Version/s: 1.5.0
> FlinkKafkaConsumer should support to use timestamp to set up st
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6352:
---
Priority: Blocker (was: Major)
> FlinkKafkaConsumer should support to use timestamp t
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286936#comment-16286936
]
Tzu-Li (Gordon) Tai commented on FLINK-6352:
We seem to have a user asking for
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5116#discussion_r156233400
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkRoundRobinPartitioner.java
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5116#discussion_r156233349
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkRoundRobinPartitioner.java
---
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286777#comment-16286777
]
ASF GitHub Bot commented on FLINK-8191:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286775#comment-16286775
]
ASF GitHub Bot commented on FLINK-8191:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5116#discussion_r156233850
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkRoundRobinPartitioner.java
---
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286776#comment-16286776
]
ASF GitHub Bot commented on FLINK-8191:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286774#comment-16286774
]
ASF GitHub Bot commented on FLINK-8191:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286778#comment-16286778
]
ASF GitHub Bot commented on FLINK-8191:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5116#discussion_r156233639
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkRoundRobinPartitionerTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286782#comment-16286782
]
Tzu-Li (Gordon) Tai commented on FLINK-7913:
As a side note for clarification:
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286799#comment-16286799
]
Tzu-Li (Gordon) Tai commented on FLINK-7913:
We should probably take that into
[
https://issues.apache.org/jira/browse/FLINK-8217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286845#comment-16286845
]
ASF GitHub Bot commented on FLINK-8217:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5138
I agree with @tzulitai . FLINK-8192 acknowledges some un-annotated APIs as
'public', not necessarily changing existing official public APIs
---
[
https://issues.apache.org/jira/browse/FLINK-5728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5728:
---
Priority: Blocker (was: Major)
> FlinkKafkaProducer should flush on checkpoint by def
[
https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5704:
---
Priority: Blocker (was: Critical)
> Deprecate FlinkKafkaConsumer constructors in favo
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286705#comment-16286705
]
Tzu-Li (Gordon) Tai commented on FLINK-7913:
[~aljoscha] [~klalafaryan] Yes.
I
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5116#discussion_r156234010
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkRoundRobinPartitioner.java
---
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286779#comment-16286779
]
ASF GitHub Bot commented on FLINK-8191:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5116#discussion_r156233704
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkRoundRobinPartitioner.java
---
[
https://issues.apache.org/jira/browse/FLINK-8217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286736#comment-16286736
]
ASF GitHub Bot commented on FLINK-8217:
---
Github user tzulitai commented on a diff in
GitHub user walterddr opened a pull request:
https://github.com/apache/flink/pull/5148
[FLINK-8215][Table] fix codegen issue on array/map value constructor
dealing with implicit type cast
## What is the purpose of the change
This pull request fix the codegen issue when valu
[
https://issues.apache.org/jira/browse/FLINK-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286763#comment-16286763
]
ASF GitHub Bot commented on FLINK-8215:
---
GitHub user walterddr opened a pull request
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5138#discussion_r156231965
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchemaWrapper
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5138#discussion_r156231822
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java
---
@@ -24,9 +
[
https://issues.apache.org/jira/browse/FLINK-8217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286731#comment-16286731
]
ASF GitHub Bot commented on FLINK-8217:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5138
@bowenli86 @greghogan
To my understanding, the proposed changes for FLINK-8192 simply suggests
adding proper annotations to the APIs in the Flink connectors. This does not
count as a public API
[
https://issues.apache.org/jira/browse/FLINK-8217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286741#comment-16286741
]
ASF GitHub Bot commented on FLINK-8217:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286706#comment-16286706
]
Tzu-Li (Gordon) Tai commented on FLINK-7913:
This issue seems to troubling qui
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7913:
---
Priority: Blocker (was: Major)
> Add support for Kafka default partitioner
>
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-8191:
---
Priority: Blocker (was: Major)
> Add a RoundRobinPartitioner to be shipped with the K
Chesnay Schepler created FLINK-8241:
---
Summary: Remove ResultPartitionWriter related PrepareForTest
annotations
Key: FLINK-8241
URL: https://issues.apache.org/jira/browse/FLINK-8241
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286292#comment-16286292
]
ASF GitHub Bot commented on FLINK-8241:
---
GitHub user zentol opened a pull request:
Timo Walther created FLINK-8240:
---
Summary: Create unified interfaces to configure and instatiate
TableSources
Key: FLINK-8240
URL: https://issues.apache.org/jira/browse/FLINK-8240
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8240:
Description:
At the moment every table source has different ways for configuration and
instantiatio
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5147
[FLINK-8241][tests] Remove ResultPartitionWriter-related "@PrepareForTest"
annotations
## What is the purpose of the change
This is a cleanup PR that removes usages of powermocks `@PrepareFo
[
https://issues.apache.org/jira/browse/FLINK-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-8211:
-
Reopen to remove fix version
> Rename ResultPartitionWriter to OutputGate
> -
[
https://issues.apache.org/jira/browse/FLINK-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8211.
---
Resolution: Won't Fix
Fix Version/s: (was: 1.5.0)
> Rename ResultPartitionWriter to
[
https://issues.apache.org/jira/browse/FLINK-8228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286214#comment-16286214
]
ASF GitHub Bot commented on FLINK-8228:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5143
I think these zeros are there to make the formatting more similar and to
also highlight, that this is the case were we don't shift. So I would like to
keep this as is. What do you think?
---
[
https://issues.apache.org/jira/browse/FLINK-8229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8229.
---
Resolution: Duplicate
Please see this issue: https://issues.apache.org/jira/browse/FLINK-3659
[
https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3659:
---
Assignee: Kostas Kloudas (was: Aljoscha Krettek)
> Add ConnectWithBroadcast Operatio
[
https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-3659:
-
Assignee: Kostas Kloudas (was: Aljoscha Krettek)
> Add ConnectWithBroadcast Operation
>
[
https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-3659:
---
Assignee: Aljoscha Krettek (was: Kostas Kloudas)
> Add ConnectWithBroadcast Operatio
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286189#comment-16286189
]
Aljoscha Krettek commented on FLINK-7913:
-
[~tzulitai] I think you also already th
[
https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286098#comment-16286098
]
ASF GitHub Bot commented on FLINK-7692:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5115
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-8236:
--
Assignee: Xingcan Cui
> Allow to set the parallelism of table queries
> ---
[
https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285998#comment-16285998
]
ASF GitHub Bot commented on FLINK-6909:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285997#comment-16285997
]
ASF GitHub Bot commented on FLINK-6909:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285999#comment-16285999
]
ASF GitHub Bot commented on FLINK-6909:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5097#discussion_r156090203
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -1822,13 +1828,15 @@ private static Type
materializeTypeV
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5097#discussion_r156090443
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -1837,56 +1845,111 @@ private boolean isValidPojoField(Fie
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5097#discussion_r156088318
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java
---
@@ -338,4 +340,78 @@ public static boolean hasSuperclas
Chesnay Schepler created FLINK-8239:
---
Summary: Extend StreamTaskTestHarness to support TwoInput head
operators
Key: FLINK-8239
URL: https://issues.apache.org/jira/browse/FLINK-8239
Project: Flink
Chesnay Schepler created FLINK-8238:
---
Summary: StreamTaskTestHarness should only allow one setup call
Key: FLINK-8238
URL: https://issues.apache.org/jira/browse/FLINK-8238
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-8238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8238:
---
Assignee: Chesnay Schepler
> StreamTaskTestHarness should only allow one setup call
>
Gábor Hermann created FLINK-8237:
Summary: BucketingSink throws NPE when Writer.duplicate returns
null
Key: FLINK-8237
URL: https://issues.apache.org/jira/browse/FLINK-8237
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8236:
Affects Version/s: 1.4.0
> Allow to set the parallelism of table queries
> -
Timo Walther created FLINK-8236:
---
Summary: Allow to set the parallelism of table queries
Key: FLINK-8236
URL: https://issues.apache.org/jira/browse/FLINK-8236
Project: Flink
Issue Type: Improve
Github user alpinegizmo commented on the issue:
https://github.com/apache/flink/pull/5129
+1
---
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285816#comment-16285816
]
Konstantin Lalafaryan commented on FLINK-7913:
--
- Kafka uses round-robin part
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285814#comment-16285814
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5099
@greghogan I've addressed your comments.
---
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285812#comment-16285812
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r156052191
--- Diff: docs/monitoring/metrics.md ---
@@ -329,11 +329,11 @@ or by assigning unique names to jobs and operators.
Metrics can be exposed to an external s
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285809#comment-16285809
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r156051769
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java
---
@@ -44,7 +48,13 @@
private static volatil
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285756#comment-16285756
]
ASF GitHub Bot commented on FLINK-7797:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5140
Thanks for the PR @xccui.
I'll try to have a look at it sometime this week.
Best, Fabian
---
[
https://issues.apache.org/jira/browse/FLINK-5573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5573.
---
Resolution: Duplicate
Haven't seen this one in a while and the Kafka 0.8 connector is very old
[
https://issues.apache.org/jira/browse/FLINK-8235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285749#comment-16285749
]
ASF GitHub Bot commented on FLINK-8235:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5146
[FLINK-8235][build] Spotbugs exclusion file path now absolute
## What is the purpose of the change
With this PR the spotbugs plugin can now be run on a single sub-module. The
path to the exc
Chesnay Schepler created FLINK-8235:
---
Summary: Cannot run spotbugs for single module
Key: FLINK-8235
URL: https://issues.apache.org/jira/browse/FLINK-8235
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-7586:
-
Reopen to change fixVersion
> Report Watermark metrics in all operators
> ---
[
https://issues.apache.org/jira/browse/FLINK-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7586.
---
Resolution: Duplicate
Fix Version/s: (was: 1.4.0)
> Report Watermark metrics in all
[
https://issues.apache.org/jira/browse/FLINK-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7586.
---
Resolution: Duplicate
> Report Watermark metrics in all operators
> --
[
https://issues.apache.org/jira/browse/FLINK-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-7586:
-
Reopen to change fixVersion
> Report Watermark metrics in all operators
> ---
[
https://issues.apache.org/jira/browse/FLINK-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285683#comment-16285683
]
Fabian Hueske commented on FLINK-7934:
--
Calcite 1.15 has been released:
[announcemen
[
https://issues.apache.org/jira/browse/FLINK-8229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285659#comment-16285659
]
Fabian Hueske commented on FLINK-8229:
--
In the DataSet API, a broadcast variable is c
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285654#comment-16285654
]
ASF GitHub Bot commented on FLINK-7812:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4801#discussion_r156010369
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunnerITCase.java
---
@@ -0,0 +1,132 @@
+/*
+ * Licensed to
Till Rohrmann created FLINK-8234:
Summary: Cache JobExecutionResult from finished JobManagerRunners
Key: FLINK-8234
URL: https://issues.apache.org/jira/browse/FLINK-8234
Project: Flink
Issue
Till Rohrmann created FLINK-8233:
Summary: Retrieve ExecutionResult by REST polling
Key: FLINK-8233
URL: https://issues.apache.org/jira/browse/FLINK-8233
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285647#comment-16285647
]
ASF GitHub Bot commented on FLINK-7812:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4801#discussion_r156008613
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/utils/SystemResourcesCounter.java
---
@@ -0,0 +1,236 @@
+/*
+ * Licens
Till Rohrmann created FLINK-8232:
Summary: Create RestHandler for long running operations
Key: FLINK-8232
URL: https://issues.apache.org/jira/browse/FLINK-8232
Project: Flink
Issue Type: Sub-
Till Rohrmann created FLINK-8231:
Summary: Extend AbstractRestHandler to return response headers
Key: FLINK-8231
URL: https://issues.apache.org/jira/browse/FLINK-8231
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16285632#comment-16285632
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5107
Changes look good. Will merge this.
---
99 matches
Mail list logo
