[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283159#comment-16283159
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5134
@zentol putting this code in external repository would make those
benchmarks very fragile, since they depend on Flink internals. Almost any
refactor made in Flink's network stack would brake the
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5112
Hi @tillrohrmann , per our discussion, I sent out an email to dev@flink,
but seems it didn't catch any attention. What do you think about this PR?
---
[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283113#comment-16283113
]
ASF GitHub Bot commented on FLINK-8175:
---
Github user bowenli86 commented on the issue:
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5138
[FLINK-8192] Properly annotate APIs of flink-connector-kinesis
## What is the purpose of the change
Properly annotate classes in flink-connector-kinesis
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283108#comment-16283108
]
ASF GitHub Bot commented on FLINK-8192:
---
GitHub user bowenli86 opened a pull request:
Github user shuai-xu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4991#discussion_r155708446
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -61,16 +80,26 @@
* @param
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4911
@tillrohrmann , I agree with you that adding a build looks better, I
changed it according to your comments. Do you think it works now?
---
[
https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282937#comment-16282937
]
ASF GitHub Bot commented on FLINK-7878:
---
Github user shuai-xu commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5133
[ERROR]
src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceUtils.java:[41,8]
(imports) UnusedImports: Unused import: java.net.InetSocketAddress.
---
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5133
@casidiablo please also describe why or how the removed code came to be
unused. I see that `StandaloneHaServices#RESOURCE_MANAGER_RPC_ENDPOINT_NAME`
was left unused by `433a345e`.
---
[
https://issues.apache.org/jira/browse/FLINK-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282799#comment-16282799
]
Rong Rong commented on FLINK-8215:
--
Agree. as long as the ValidationException is thrown for TableAPI, we
Github user casidiablo commented on a diff in the pull request:
https://github.com/apache/flink/pull/5134#discussion_r155667757
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/benchmark/SerializingLongReceiver.java
---
@@ -0,0 +1,101 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282687#comment-16282687
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user casidiablo commented on a diff in the pull
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5072
@yew1eb have you looked at FLINK-6965?
---
[
https://issues.apache.org/jira/browse/FLINK-8223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282572#comment-16282572
]
ASF GitHub Bot commented on FLINK-8223:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/5137
[FLINK-8223] [build] Update Hadoop versions
## What is the purpose of the change
Update Hadoop minor versions for Flink 1.5 development cycle.
## Brief change log
Update
[
https://issues.apache.org/jira/browse/FLINK-8222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282490#comment-16282490
]
ASF GitHub Bot commented on FLINK-8222:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/5136
[FLINK-8222] [build] Update Scala version
## What is the purpose of the change
This is an incremental upgrade to the Scala security release 2.11.12.
"A privilege escalation
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282444#comment-16282444
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r155625966
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/metrics/MetricRegistryImplTest.java
---
@@ -76,8 +76,27 @@ public void testIsShutdown() {
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r155620220
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java
---
@@ -108,15 +118,36 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282443#comment-16282443
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5135#discussion_r155627163
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -585,7 +585,7 @@ class TaskManager(
[
https://issues.apache.org/jira/browse/FLINK-7984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282466#comment-16282466
]
ASF GitHub Bot commented on FLINK-7984:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282445#comment-16282445
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282446#comment-16282446
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user greghogan commented on a diff in the pull
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r155618187
--- Diff: docs/monitoring/metrics.md ---
@@ -329,11 +329,11 @@ or by assigning unique names to jobs and operators.
Metrics can be exposed to an
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r155623170
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java
---
@@ -44,7 +48,13 @@
private static
GitHub user casidiablo opened a pull request:
https://github.com/apache/flink/pull/5135
[hotfix] [doc] Fix typo in TaskManager and EnvironmentInformation doc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/casidiablo/flink
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155604499
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -266,104 +279,367 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282293#comment-16282293
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282300#comment-16282300
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155605251
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/LogicalSlot.java
---
@@ -0,0 +1,165 @@
+/*
+ * Licensed to the Apache Software
Greg Hogan created FLINK-8222:
-
Summary: Update Scala version
Key: FLINK-8222
URL: https://issues.apache.org/jira/browse/FLINK-8222
Project: Flink
Issue Type: Improvement
Components:
Greg Hogan created FLINK-8223:
-
Summary: Update Hadoop versions
Key: FLINK-8223
URL: https://issues.apache.org/jira/browse/FLINK-8223
Project: Flink
Issue Type: Improvement
Components:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155590317
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -266,104 +279,367 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282216#comment-16282216
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282181#comment-16282181
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user greghogan commented on the issue:
Github user harborl commented on the issue:
https://github.com/apache/flink/pull/5047
Yes, after a few learning, it turns out that, in this project, POJO is a
sort of reasonable style of parameters. Sorry for interruption, I think I am
exited about learning more further.
---
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282185#comment-16282185
]
Fabian Hueske commented on FLINK-7129:
--
It won't go into Flink 1.4.0 because feature freeze was more
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5134
Or if `flink-benchmarks` does not need to be distributed then that code
could be contributed to the main Flink repository.
---
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16282080#comment-16282080
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5134
Why do you want to add these to flink when they are only used by an
external repository? Wouldn't it make sense to consolidate all benchmarking
code to the flink-benchmark repo?
---
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281998#comment-16281998
]
ASF GitHub Bot commented on FLINK-8220:
---
GitHub user pnowojski opened a pull request:
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5134
[FLINK-8220] Implement set of network benchmarks
This PR implements sets of network benchmarks that are intended to simulate
various workloads for network stack. Benchmarks will be executed by
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281986#comment-16281986
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155549755
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/LogicalSlot.java
---
@@ -32,6 +34,20 @@
*/
public interface LogicalSlot {
Piotr Nowojski created FLINK-8221:
-
Summary: Implement set of network latency benchmarks in Flink
Key: FLINK-8221
URL: https://issues.apache.org/jira/browse/FLINK-8221
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8220:
--
Summary: Implement set of network throughput benchmarks in Flink (was:
Define set of network
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8220:
--
Description:
Benchmarks should be defined and implemented in flink project and they will be
Piotr Nowojski created FLINK-8220:
-
Summary: Define set of network throughput benchmarks in Flink
Key: FLINK-8220
URL: https://issues.apache.org/jira/browse/FLINK-8220
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281918#comment-16281918
]
ASF GitHub Bot commented on FLINK-8078:
---
Github user GJL commented on the issue:
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5086
LGTM
---
Gary Oslon created FLINK-8219:
-
Summary: Kinesis Connector metrics
Key: FLINK-8219
URL: https://issues.apache.org/jira/browse/FLINK-8219
Project: Flink
Issue Type: Bug
Components:
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5133
LGTM.
---
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281885#comment-16281885
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281883#comment-16281883
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281884#comment-16281884
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155519870
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155528224
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155520946
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-8124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281876#comment-16281876
]
ASF GitHub Bot commented on FLINK-8124:
---
Github user casidiablo commented on the issue:
Github user casidiablo commented on the issue:
https://github.com/apache/flink/pull/5073
> I thought this was mainly about making the time triggers more relaxed so
that they accept a Window in addition to only TimeWindow.
That's exactly what this PR is about.
---
GitHub user casidiablo opened a pull request:
https://github.com/apache/flink/pull/5133
[hotfix] Fix typo in AkkaUtils method
Also, removed unused code:
- `StandaloneHaServices#RESOURCE_MANAGER_RPC_ENDPOINT_NAME`
-
[
https://issues.apache.org/jira/browse/FLINK-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281851#comment-16281851
]
ASF GitHub Bot commented on FLINK-8122:
---
Github user xccui commented on the issue:
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5068
Thanks for the review @fhueske.
* I added the `explainSink()` method to make the `TableSink` consistent
with the `TableSource`. Discarding this method and using the
[
https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281834#comment-16281834
]
dongtingting commented on FLINK-8093:
-
[~aljoscha] I think clientid is thread safe and static. But one
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5052
---
[
https://issues.apache.org/jira/browse/FLINK-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281796#comment-16281796
]
ASF GitHub Bot commented on FLINK-8133:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8133.
---
Resolution: Fixed
master: 610fde722fc91ff760cff3865564a51a4b945f19
> Generate documentation
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281780#comment-16281780
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155507607
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155507294
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281778#comment-16281778
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281775#comment-16281775
]
ASF GitHub Bot commented on FLINK-7684:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4723
I think this needs a lot more description of what is happening.
For example, this introduces a prominent new configuration setting on the
`ExecutionConfig` that is nowhere described, making
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281768#comment-16281768
]
ASF GitHub Bot commented on FLINK-7812:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281767#comment-16281767
]
ASF GitHub Bot commented on FLINK-7812:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281766#comment-16281766
]
ASF GitHub Bot commented on FLINK-7812:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4801#discussion_r155503740
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java
---
@@ -102,37 +103,16 @@ public static void
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4801#discussion_r155503385
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/utils/SystemResourcesCounter.java
---
@@ -0,0 +1,236 @@
+/*
+ *
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4801#discussion_r155501129
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunnerITCase.java
---
@@ -0,0 +1,132 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281765#comment-16281765
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155503866
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/SchedulerTest.java
---
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281764#comment-16281764
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155503994
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/SchedulerTest.java
---
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281759#comment-16281759
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155502971
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/TestingAllocatedSlotActions.java
---
@@ -0,0 +1,53 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281754#comment-16281754
]
ASF GitHub Bot commented on FLINK-8133:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5052
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281752#comment-16281752
]
ASF GitHub Bot commented on FLINK-8174:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281753#comment-16281753
]
ASF GitHub Bot commented on FLINK-8133:
---
Github user zentol commented on a diff in the pull request:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5114
It depends a little bit on 1.4. We have serious build stability issues in
the `release-1.3` branch and it would take a serious effort to stabilize it
again. If I could choose, then we wouldn't
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5052#discussion_r155501188
--- Diff:
flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java ---
@@ -0,0 +1,315 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-7561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281748#comment-16281748
]
ASF GitHub Bot commented on FLINK-7561:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4626
I think it would be nice to have a utility here in order to make this
easier to use:
```java
DataStream result =
Utils.withPreaggregation(
[
https://issues.apache.org/jira/browse/FLINK-8089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281732#comment-16281732
]
ASF GitHub Bot commented on FLINK-8089:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5090#discussion_r155496482
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/instance/SlotPoolTest.java
---
@@ -383,6 +386,76 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16281731#comment-16281731
]
ASF GitHub Bot commented on FLINK-8203:
---
GitHub user twalthr opened a pull request:
1 - 100 of 165 matches
Mail list logo
