Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/3459
@stefanobortoli One PR should has only one commit as soon as possible. If
having so many commit, it's hard to review..
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895571#comment-15895571
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user shijinkui commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895569#comment-15895569
]
ASF GitHub Bot commented on FLINK-5956:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3470
Hi @shaoxuan-wang, yes. That's a very good point. We should definitely add
non-retractable `MIN` and `MAX` aggregates. Would be good to have them now to
use them in batch queries.
---
If your proje
[
https://issues.apache.org/jira/browse/FLINK-5956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895566#comment-15895566
]
ASF GitHub Bot commented on FLINK-5956:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3470
Thanks for the PR @shaoxuan-wang. I haven't had a detailed look yet. I
think we also need non-retract versions of `MIN` and `MAX`. The retracted
version cannot be used to compute unbounded OVER windo
Github user shijinkui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3459#discussion_r104282393
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/nodes/datastream/DataStreamProcTimeTimeAggregate.java
---
@@ -0,0 +1,162 @
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895563#comment-15895563
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user shijinkui commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895561#comment-15895561
]
ASF GitHub Bot commented on FLINK-5963:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3472#discussion_r104282353
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetAggregate.scala
---
@@ -87,47 +89,67 @@ class DataSetA
[
https://issues.apache.org/jira/browse/FLINK-5963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895558#comment-15895558
]
ASF GitHub Bot commented on FLINK-5963:
---
Github user shaoxuan-wang commented on a di
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3472#discussion_r104282131
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetAggregate.scala
---
@@ -87,47 +89,67 @@ class Da
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895553#comment-15895553
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3438
@rmetzger Yes, it's unfortunate that in our model not all elements always
have a timestamp. The other alternative is throwing an exception when trying to
access a non-existing timestamp.
---
If yo
[
https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895513#comment-15895513
]
ASF GitHub Bot commented on FLINK-4810:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3334
Ping for reviews here!!!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wish
[
https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895498#comment-15895498
]
ASF GitHub Bot commented on FLINK-5833:
---
GitHub user clarkyzl opened a pull request:
GitHub user clarkyzl opened a pull request:
https://github.com/apache/flink/pull/3473
[FLINK-5833] [table] Support for Hive GenericUDF
Type: New Feature
Priority: Major
Components: table, udf
Problem definition: Make Flink call Hive User-Defined Functions, support
for si
Github user shijinkui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3408#discussion_r104277608
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -317,6 +319,10 @@ public AbstractYarnClusterDescriptor
create
[
https://issues.apache.org/jira/browse/FLINK-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895480#comment-15895480
]
ASF GitHub Bot commented on FLINK-5903:
---
Github user shijinkui commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-5586.
-
> Extend TableProgramsTestBase for object reuse modes
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young resolved FLINK-5586.
---
Resolution: Implemented
> Extend TableProgramsTestBase for object reuse modes
> --
[
https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-5586:
--
Fix Version/s: 1.3.0
> Extend TableProgramsTestBase for object reuse modes
> ---
[
https://issues.apache.org/jira/browse/FLINK-5586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895399#comment-15895399
]
ASF GitHub Bot commented on FLINK-5586:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3339
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-5956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895382#comment-15895382
]
ASF GitHub Bot commented on FLINK-5956:
---
Github user shaoxuan-wang commented on the
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3470
@fhueske, we should add different built-in aggregates for the ones that are
not easy to be retracted (for instance Max and Min), one as withRetract(used
for over window as # of items are limite
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/3472
[FLINK-5963] [table] Remove prepare mapper of DataSetAggregate.
We remove the preparation mapper to
- save one operator
- be able to apply `AggregateFunction.accumulate()` in a
`GroupCombin
[
https://issues.apache.org/jira/browse/FLINK-5963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895178#comment-15895178
]
ASF GitHub Bot commented on FLINK-5963:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895177#comment-15895177
]
ASF GitHub Bot commented on FLINK-5722:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/3471
[FLINK-5722] [table] Add dedicated DataSetDistinct operator.
A dedicated DISTINCT operator is more efficient because we can use a
`ReduceFunction` which (optionally) support hash-based combining.
Y
[
https://issues.apache.org/jira/browse/FLINK-5963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-5963:
Assignee: Fabian Hueske
> Remove preparation mapper of DataSetAggregate
> -
Fabian Hueske created FLINK-5963:
Summary: Remove preparation mapper of DataSetAggregate
Key: FLINK-5963
URL: https://issues.apache.org/jira/browse/FLINK-5963
Project: Flink
Issue Type: Sub-t
[
https://issues.apache.org/jira/browse/FLINK-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-5722:
Assignee: Fabian Hueske
> Implement DISTINCT as dedicated operator
> --
[
https://issues.apache.org/jira/browse/FLINK-5838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894992#comment-15894992
]
ASF GitHub Bot commented on FLINK-5838:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894999#comment-15894999
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3438
I looked over the changes and didn't find anything critical. The only thing
that made me thinking was the boxed `Long` type for the timestamp(). I assume
you decided for this approach to signal time
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3352
Changes look good in my opinion.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled an
[
https://issues.apache.org/jira/browse/FLINK-5067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894978#comment-15894978
]
ASF GitHub Bot commented on FLINK-5067:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2804
Looks good to merge.
I'm currently verifying the change, then, I'll merge it:
https://travis-ci.org/rmetzger/flink/builds/207494237
---
If your project is set up for it, you can reply to t
[
https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894967#comment-15894967
]
ASF GitHub Bot commented on FLINK-4286:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3270
Hi @mylog00, thanks a lot for your contribution.
I wonder if it makes more sense to just upgrade the existing Kafka examples
to use Kafka 0.9 instead of having two examples that are almost identi
[
https://issues.apache.org/jira/browse/FLINK-4286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894965#comment-15894965
]
Robert Metzger commented on FLINK-4286:
---
I would vote to not have two examples that
[
https://issues.apache.org/jira/browse/FLINK-5598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894932#comment-15894932
]
Robert Metzger commented on FLINK-5598:
---
Thanks a lot for fixing this issue. I assig
[
https://issues.apache.org/jira/browse/FLINK-5598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894933#comment-15894933
]
ASF GitHub Bot commented on FLINK-5598:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-5598:
-
Assignee: Fabian Wollert
> Return jar name when jar is uploaded
> ---
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3469
Good change. +1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishe
[
https://issues.apache.org/jira/browse/FLINK-5956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894749#comment-15894749
]
ASF GitHub Bot commented on FLINK-5956:
---
GitHub user shaoxuan-wang opened a pull req
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3470
[FLINK-5956] [table] Add retract method for aggregateFunction
This PR adds retraction method for AggregateFunction, it also implements
retract methods as well as test cases for all built-in ag
Till Rohrmann created FLINK-5962:
Summary: Cancel checkpoint canceller tasks in CheckpointCoordinator
Key: FLINK-5962
URL: https://issues.apache.org/jira/browse/FLINK-5962
Project: Flink
Issu
Stefan Richter created FLINK-5961:
-
Summary: Queryable State is broken for HeapKeyedStateBackend
Key: FLINK-5961
URL: https://issues.apache.org/jira/browse/FLINK-5961
Project: Flink
Issue Typ
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104188272
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/annotation/ExternalCatalogCompatible.java
---
@@ -0,0 +1,63 @@
+/*
+ * Li
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104156636
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,139 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104176638
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogSchema.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Licens
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104184922
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104158740
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,139 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104160007
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,139 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104166130
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104191673
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CommonTestData.scala
---
@@ -68,6 +62,90 @@ object CommonTestData {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104178022
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogSchema.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Licens
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104022427
--- Diff: flink-libraries/flink-table/pom.xml ---
@@ -92,7 +92,12 @@ under the License.
-
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104167894
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104159675
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,139 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104194149
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CommonTestData.scala
---
@@ -68,6 +62,90 @@ object CommonTestData {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104159480
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,139 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104167970
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104177526
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogSchema.scala
---
@@ -0,0 +1,166 @@
+/*
+ * Licens
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104163154
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104158678
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,139 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104150546
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/annotation/ExternalCatalogCompatible.java
---
@@ -0,0 +1,63 @@
+/*
+ * Li
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104191562
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CommonTestData.scala
---
@@ -68,6 +62,90 @@ object CommonTestData {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r104185348
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala
---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-5598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894688#comment-15894688
]
ASF GitHub Bot commented on FLINK-5598:
---
GitHub user drummerwolli opened a pull requ
GitHub user drummerwolli opened a pull request:
https://github.com/apache/flink/pull/3469
[FLINK-5598] return filename after jar upload
We use the Flink Web Backend to control Flink Jobs running in our Cluster.
We would like to have more control in the API. This is the first change
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894682#comment-15894682
]
Aljoscha Krettek commented on FLINK-3089:
-
[~StephanEwen] you were also a great pr
[
https://issues.apache.org/jira/browse/FLINK-4275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4275.
---
Resolution: Not A Problem
Not a problem anymore since they are not in the code base anymore.
[
https://issues.apache.org/jira/browse/FLINK-5958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5958.
---
Resolution: Duplicate
[~srichter] please transfer the text and PR to the older issue. (If you
Till Rohrmann created FLINK-5960:
Summary: Make CheckpointCoordinator less blocking
Key: FLINK-5960
URL: https://issues.apache.org/jira/browse/FLINK-5960
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894614#comment-15894614
]
Stefan Richter commented on FLINK-3387:
---
[~sbcd90] are you still working on this? [~
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894609#comment-15894609
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5219.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with 728c936dd2ac18701e1d8696da251ae
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3266
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894606#comment-15894606
]
Stefan Richter commented on FLINK-3089:
---
Does this solve the problem and we can clos
[
https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894605#comment-15894605
]
Stefan Richter commented on FLINK-4760:
---
[~zhenzhongxu] is this still a problem or c
[
https://issues.apache.org/jira/browse/FLINK-4275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894595#comment-15894595
]
Stefan Richter commented on FLINK-4275:
---
One more ping on this. Can I close this iss
[
https://issues.apache.org/jira/browse/FLINK-5904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894555#comment-15894555
]
ASF GitHub Bot commented on FLINK-5904:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3414#discussion_r104174440
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -110,7 +110,12 @@
public static final String EXECU
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3414#discussion_r104174086
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -306,12 +308,16 @@ public AbstractYarnClusterDescriptor
cr
[
https://issues.apache.org/jira/browse/FLINK-5904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894554#comment-15894554
]
ASF GitHub Bot commented on FLINK-5904:
---
Github user tillrohrmann commented on a dif
Till Rohrmann created FLINK-5959:
Summary: Verify that mesos-appmaster.sh respects
env.java.opts(.jobmanager)
Key: FLINK-5959
URL: https://issues.apache.org/jira/browse/FLINK-5959
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894531#comment-15894531
]
ASF GitHub Bot commented on FLINK-5916:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3415#discussion_r104170895
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java
---
@@ -360,6 +360,7 @@ public static String getTas
[
https://issues.apache.org/jira/browse/FLINK-5916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894525#comment-15894525
]
Till Rohrmann commented on FLINK-5916:
--
I think the {{mesos-taskmanager.sh}} script d
[
https://issues.apache.org/jira/browse/FLINK-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894510#comment-15894510
]
Till Rohrmann commented on FLINK-5936:
--
Hi Alex,
what do you mean by keyed vectors?
[
https://issues.apache.org/jira/browse/FLINK-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5936:
-
Priority: Minor (was: Major)
> Can't pass keyed vectors to KNN join algorithm
> ---
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894493#comment-15894493
]
Till Rohrmann commented on FLINK-5949:
--
This should also be relevant for {{1.3.0}}, r
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3304#discussion_r104160029
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -168,6 +168,11 @@
public static final String LIBRA
[
https://issues.apache.org/jira/browse/FLINK-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894462#comment-15894462
]
ASF GitHub Bot commented on FLINK-5791:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3304#discussion_r104159696
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java ---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the Apache Softwa
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3304#discussion_r104160736
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java
---
@@ -119,6 +122,9 @@ public boolean equal
1 - 100 of 276 matches
Mail list logo
