[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174288#comment-16174288
]
Bowen Li commented on FLINK-7635:
-
[~foxss] [~aljoscha]
After taking a quick look at the code structure,
Bowen Li created FLINK-7660:
---
Summary: Support sideOutput in ProcessAllWindowFunction
Key: FLINK-7660
URL: https://issues.apache.org/jira/browse/FLINK-7660
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7635:
Summary: Support sideOutput in ProcessWindowFunciton (was: Support
sideOutput in ProcessWindowFunciton &
[
https://issues.apache.org/jira/browse/FLINK-7571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174248#comment-16174248
]
ASF GitHub Bot commented on FLINK-7571:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/4635
Hi @fhueske , thanks for the work! It is a very important fix! I'm fine
with the changes.
+1 to merge
---
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173959#comment-16173959
]
Kent Murra edited comment on FLINK-7657 at 9/21/17 12:34 AM:
-
I've noticed
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173959#comment-16173959
]
Kent Murra edited comment on FLINK-7657 at 9/20/17 10:48 PM:
-
I've noticed
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173959#comment-16173959
]
Kent Murra commented on FLINK-7657:
---
I've noticed that the scope of the problem is a bit larger than
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173936#comment-16173936
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user EronWright commented on the issue:
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/4616
+1
---
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173931#comment-16173931
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user EronWright commented on a diff in the pull
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4616#discussion_r140108752
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
---
@@ -31,10 +31,50 @@
public
Ted Yu created FLINK-7659:
-
Summary: Unprotected access to inProgress in
JobCancellationWithSavepointHandlers#handleNewRequest
Key: FLINK-7659
URL: https://issues.apache.org/jira/browse/FLINK-7659
Project:
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173814#comment-16173814
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140089533
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/MultisetRelDataType.scala
---
@@ -0,0 +1,50 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173810#comment-16173810
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140089018
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -329,6 +329,35 @@ class
Shuyi Chen created FLINK-7658:
-
Summary: Support COLLECT Aggregate function in Flink TABLE API
Key: FLINK-7658
URL: https://issues.apache.org/jira/browse/FLINK-7658
Project: Flink
Issue Type:
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140083074
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173777#comment-16173777
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user suez1224 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173670#comment-16173670
]
ASF GitHub Bot commented on FLINK-7571:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4635
@wuchong can you have a look at this PR?
It fixes the code generation for table sources with time attributes.
Thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173652#comment-16173652
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user EronWright commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173649#comment-16173649
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user EronWright commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173651#comment-16173651
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user EronWright commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173650#comment-16173650
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user EronWright commented on a diff in the pull
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4628#discussion_r140051191
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java
---
@@ -663,6 +666,7 @@ private void
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4628#discussion_r140021958
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
---
@@ -366,6 +425,34 @@ public
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4628#discussion_r140022455
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java
---
@@ -155,7 +155,7 @@ public int
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4628#discussion_r140038861
--- Diff: docs/ops/deployment/mesos.md ---
@@ -226,6 +226,10 @@ When running Flink with Marathon, the whole Flink
cluster including the job mana
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4657
@tzulitai Thank you, Gordon!
---
[
https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173629#comment-16173629
]
ASF GitHub Bot commented on FLINK-7508:
---
Github user bowenli86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173631#comment-16173631
]
ASF GitHub Bot commented on FLINK-7600:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4656
@tzulitai Thank you!
---
[
https://issues.apache.org/jira/browse/FLINK-7603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173626#comment-16173626
]
ASF GitHub Bot commented on FLINK-7603:
---
Github user bowenli86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173625#comment-16173625
]
ASF GitHub Bot commented on FLINK-7603:
---
Github user bowenli86 commented on a diff in the pull
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4684
cc @zentol
---
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4684#discussion_r140050554
--- Diff: docs/ops/cli.md ---
@@ -138,17 +138,30 @@ This allows the job to finish processing all inflight
data.
[
https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173526#comment-16173526
]
ASF GitHub Bot commented on FLINK-7647:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/4691
[FLINK-7647] [flip6] Port JobManagerConfigHandler to new REST endpoint
## What is the purpose of the change
This PR ports the existing `JobManagerConfigHandler` to the new REST
endpoint.
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173505#comment-16173505
]
Kent Murra commented on FLINK-7657:
---
Thats great, thanks!
> SQL Timestamps Converted To Wrong Type By
[
https://issues.apache.org/jira/browse/FLINK-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173502#comment-16173502
]
ASF GitHub Bot commented on FLINK-7656:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4690
[FLINK-7656] [runtime] Switch to user classloader before calling
initializeOnMaster and finalizeOnMaster.
## What is the purpose of the change
Fixes a classloading issue for
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7486:
Assignee: Bhumika Bayani
> flink-mesos: Support for adding unique attribute / group_by
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173486#comment-16173486
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173484#comment-16173484
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173485#comment-16173485
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173483#comment-16173483
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173487#comment-16173487
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140024187
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140022994
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140026944
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -329,6 +329,35 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140009815
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala
---
@@ -0,0 +1,121 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4585#discussion_r140025368
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/MultisetRelDataType.scala
---
@@ -0,0 +1,50 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173442#comment-16173442
]
Fabian Hueske commented on FLINK-7657:
--
Thanks for reporting this bug and investigating the cause
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-7657:
Assignee: Kent Murra
> SQL Timestamps Converted To Wrong Type By Optimizer Causing
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Affects Version/s: 1.3.1
> SQL Timestamps Converted To Wrong Type By Optimizer Causing
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Affects Version/s: 1.3.2
> SQL Timestamps Converted To Wrong Type By Optimizer Causing
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173419#comment-16173419
]
Kent Murra edited comment on FLINK-7657 at 9/20/17 4:12 PM:
I'm looking at
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Description:
I have a SQL statement using the Tables API that has a timestamp in it. When
the
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173419#comment-16173419
]
Kent Murra commented on FLINK-7657:
---
I'm looking at taking my bugfix and formatting it as a code
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Description:
I have a SQL statement using the Tables API that has a timestamp in it. When
the
[
https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kent Murra updated FLINK-7657:
--
Description:
I have a SQL statement using the Tables API that has a timestamp in it. When
the
Kent Murra created FLINK-7657:
-
Summary: SQL Timestamps Converted To Wrong Type By Optimizer
Causing ClassCastException
Key: FLINK-7657
URL: https://issues.apache.org/jira/browse/FLINK-7657
Project:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4603
---
[
https://issues.apache.org/jira/browse/FLINK-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173388#comment-16173388
]
ASF GitHub Bot commented on FLINK-7534:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7534.
Resolution: Fixed
Fix Version/s: 1.4.0
Added via dbabdb1cc2c122dbf1e83ffb9960491eaf4914bb
>
[
https://issues.apache.org/jira/browse/FLINK-7655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173367#comment-16173367
]
ASF GitHub Bot commented on FLINK-7655:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4689
[FLINK-7655] [flip6] Set fencing token to null if not leader
## What is the purpose of the change
This commit changes the fencing behaviour such that a component which is
not the
[
https://issues.apache.org/jira/browse/FLINK-7638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173295#comment-16173295
]
ASF GitHub Bot commented on FLINK-7638:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4688
[FLINK-7638] [flip6] Port CurrentJobsOverviewHandler to new REST endpoint
## What is the purpose of the change
Ports the CurrentJobsOverviewHandler to the new REST endpoint by letting
[
https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5372:
Priority: Blocker (was: Major)
> Fix
[
https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5372:
Fix Version/s: 1.4.0
> Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()
>
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173278#comment-16173278
]
Aljoscha Krettek commented on FLINK-4228:
-
The other parts are not relevant anymore since the
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4228:
Priority: Blocker (was: Major)
> RocksDB semi-async snapshot to S3AFileSystem fails
>
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4228:
Fix Version/s: 1.4.0
> RocksDB semi-async snapshot to S3AFileSystem fails
>
[
https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173277#comment-16173277
]
Aljoscha Krettek commented on FLINK-4228:
-
Moved to critical for the part about checking whether
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173246#comment-16173246
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7357.
Resolution: Fixed
Fix Version/s: 1.3.3
1.4.0
Release Note:
Fixed for
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r139986193
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala
---
@@ -383,13 +384,158 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173236#comment-16173236
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r139983961
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -131,340 +116,308 @@ class
Fabian Hueske created FLINK-7656:
Summary: Switch to user ClassLoader when invoking
initializeOnMaster finalizeOnMaster
Key: FLINK-7656
URL: https://issues.apache.org/jira/browse/FLINK-7656
Project:
GitHub user alpinegizmo opened a pull request:
https://github.com/apache/flink/pull/4687
[hotfix][docs][CEP] wrong method name for PatternFlatSelectFunction
The name of the single abstract method in the PatternFlatSelectFunction
interface is flatSelect, not select.
This PR
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173193#comment-16173193
]
Robert Metzger commented on FLINK-7608:
---
[~Zentol] Is there a nice way to solve this generically?
I
Github user bbayani commented on the issue:
https://github.com/apache/flink/pull/4628
@EronWright , @tillrohrmann Can you please review this?
---
[
https://issues.apache.org/jira/browse/FLINK-7486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173192#comment-16173192
]
ASF GitHub Bot commented on FLINK-7486:
---
Github user bbayani commented on the issue:
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/4572#discussion_r139971451
--- Diff: flink-connectors/flink-parquet/pom.xml ---
@@ -0,0 +1,81 @@
+
+
+http://maven.apache.org/POM/4.0.0;
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173185#comment-16173185
]
Hai Zhou_UTC+8 commented on FLINK-7608:
---
[~rmetzger] I do not know jmx, do not know why it is a
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4358#discussion_r139969639
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java
---
@@ -0,0 +1,322 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173180#comment-16173180
]
ASF GitHub Bot commented on FLINK-7068:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou_UTC+8 reassigned FLINK-7608:
-
Assignee: (was: Hai Zhou_UTC+8)
> LatencyGauge change to histogram metric
>
[
https://issues.apache.org/jira/browse/FLINK-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173176#comment-16173176
]
ASF GitHub Bot commented on FLINK-7068:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173179#comment-16173179
]
ASF GitHub Bot commented on FLINK-7068:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4358#discussion_r139969076
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java
---
@@ -0,0 +1,322 @@
+/*
+ * Licensed to the Apache
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4358#discussion_r139968617
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobCache.java
---
@@ -0,0 +1,429 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173169#comment-16173169
]
ASF GitHub Bot commented on FLINK-7068:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4358#discussion_r139966738
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobCache.java
---
@@ -0,0 +1,429 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16173158#comment-16173158
]
ASF GitHub Bot commented on FLINK-7552:
---
Github user StephanEwen commented on the issue:
Github user mustafaakin commented on the issue:
https://github.com/apache/flink/pull/4572
Any inputs on this? Would be much useful and I can get rid of Drill / Presto
---
1 - 100 of 204 matches
Mail list logo
