[
https://issues.apache.org/jira/browse/FLINK-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996257#comment-15996257
]
ASF GitHub Bot commented on FLINK-6367:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3769
Patience please...
---
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
[
https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996245#comment-15996245
]
ASF GitHub Bot commented on FLINK-6439:
---
GitHub user fanyon opened a pull request:
GitHub user fanyon opened a pull request:
https://github.com/apache/flink/pull/3819
[FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil
â¦tUtil
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following chec
[
https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996233#comment-15996233
]
ASF GitHub Bot commented on FLINK-6364:
---
Github user shixiaogang commented on the is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3801
@StefanRRichter Thanks a lot for your review. I have updated the pull
request as suggested. The following changes are made
1. Remove the checkpoint type for incremental checkpoints. Now
[
https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996218#comment-15996218
]
ASF GitHub Bot commented on FLINK-6364:
---
Github user shixiaogang commented on a diff
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3801#discussion_r114703946
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -808,6 +1
[
https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996212#comment-15996212
]
ASF GitHub Bot commented on FLINK-6364:
---
Github user shixiaogang commented on a diff
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3801#discussion_r114703775
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -621,6 +6
[
https://issues.apache.org/jira/browse/FLINK-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-6439:
Assignee: Fang Yong
> Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()
>
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3569#discussion_r114697342
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala
---
@@ -44,6 +43,8 @@ case class ExternalCa
[
https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-6381:
Description:
It seems that currently there are two places should not employ the
{{synchronized}} to
[
https://issues.apache.org/jira/browse/FLINK-6346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996133#comment-15996133
]
ASF GitHub Bot commented on FLINK-6346:
---
Github user fanyon commented on the issue:
Github user fanyon commented on the issue:
https://github.com/apache/flink/pull/3812
@zhangminglei @zentol thanks for your suggestions, and I have updated the
code.
As discussed in
[https://github.com/apache/flink/pull/3750#issuecomment-298869900](url), it may
not need to r
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3569#discussion_r114695239
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/catalog/ExternalCatalogTablePartition.scala
---
@@ -0,0 +1,44 @@
+/*
+
Github user ifndef-SleePy commented on a diff in the pull request:
https://github.com/apache/flink/pull/3810#discussion_r114693043
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MultipleProgramsTestBase.java
---
@@ -80,29 +80,36 @@
Github user ifndef-SleePy commented on the issue:
https://github.com/apache/flink/pull/3810
@StephanEwen
I agree that a static unset method would be a much easier implementation.
Do you think it's acceptable that the unset method is static but set method is
not static in TestEnvi
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996078#comment-15996078
]
ASF GitHub Bot commented on FLINK-5906:
---
Github user shaoxuan-wang commented on a di
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996076#comment-15996076
]
ASF GitHub Bot commented on FLINK-5906:
---
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/3809#discussion_r114692346
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/AggSqlFunction.scala
---
@@ -0,0 +1,177 @@
+/*
+ *
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114692276
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/AggSqlFunction.scala
---
@@ -0,0 +1,177 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-6441:
--
Description: According to [FLINK-6334], UDTF's apply method return a
unbounded Table which consists of a
[
https://issues.apache.org/jira/browse/FLINK-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-6441:
--
Description: According to [FLINK-6334]
https://issues.apache.org/jira/browse/FLINK-6334, UDTF's apply me
Ruidong Li created FLINK-6441:
-
Summary: Improve the UDTF
Key: FLINK-6441
URL: https://issues.apache.org/jira/browse/FLINK-6441
Project: Flink
Issue Type: Improvement
Reporter: Ruidon
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996055#comment-15996055
]
ASF GitHub Bot commented on FLINK-5906:
---
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/3809#discussion_r114690845
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/aggregations.scala
---
@@ -130,3 +142,63 @@ case class Avg(chi
GitHub user godfreyhe opened a pull request:
https://github.com/apache/flink/pull/3818
[FLINK-5514] [table] Implement an efficient physical execution for
CUBE/ROLLUP/GROUPING SETS
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/
[
https://issues.apache.org/jira/browse/FLINK-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996041#comment-15996041
]
ASF GitHub Bot commented on FLINK-5514:
---
GitHub user godfreyhe opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996039#comment-15996039
]
ASF GitHub Bot commented on FLINK-6367:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/3769
hi, @zentol @StephanEwen It didn't merge in. @zentol Please check again.
---
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 proj
Github user fanyon closed the pull request at:
https://github.com/apache/flink/pull/3759
---
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-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996036#comment-15996036
]
ASF GitHub Bot commented on FLINK-6366:
---
Github user fanyon closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-5514:
-
Assignee: godfrey he
> Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS
>
[
https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996018#comment-15996018
]
ASF GitHub Bot commented on FLINK-6275:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3724
@StephanEwen Thanks. I might close this PR as there is a refactor to
```YarnFlinkApplicationMasterRunner ``` by combining with
```AbstractYarnFlinkApplicationMasterRunner``` in one class. See :
[
https://issues.apache.org/jira/browse/FLINK-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995971#comment-15995971
]
ASF GitHub Bot commented on FLINK-6428:
---
GitHub user sunjincheng121 opened a pull re
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3817
[FLINK-6428][table] Add support DISTINCT in dataStream SQL
With the changes of this PR. `DISTINCT` keyword can be supported `SELECT
Clause` of dataStream SQL.
In standard database t
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995858#comment-15995858
]
Bill Liu commented on FLINK-4022:
-
any update on this feature? will it be released in 1.3
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995668#comment-15995668
]
ASF GitHub Bot commented on FLINK-5906:
---
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/3809#discussion_r114651484
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/aggregations.scala
---
@@ -130,3 +142,63 @@ case class Avg(child: Ex
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6334.
Resolution: Fixed
Fixed for 1.3 with c969237fce4fe5394e1cfdbb1186db6d73d0
> Refactoring UDTF in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995546#comment-15995546
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3791
---
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
Stephan Ewen created FLINK-6440:
---
Summary: Noisy logs from metric fetcher
Key: FLINK-6440
URL: https://issues.apache.org/jira/browse/FLINK-6440
Project: Flink
Issue Type: Bug
Componen
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995253#comment-15995253
]
ASF GitHub Bot commented on FLINK-5906:
---
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/3809#discussion_r114602957
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -178,4 +178,24 @@ class BatchTableEn
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995244#comment-15995244
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995241#comment-15995241
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995242#comment-15995242
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995243#comment-15995243
]
ASF GitHub Bot commented on FLINK-6334:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995245#comment-15995245
]
ASF GitHub Bot commented on FLINK-6334:
---
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/3791#discussion_r114556553
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/TableConversions.scala
---
@@ -35,6 +36,10 @@ class TableConversions(t
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114553215
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -49,11 +49,11 @@ import
org.apache.flink.tabl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114558126
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -358,4 +360,45 @@ object U
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114590580
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -417,13 +507,45 @@ class Table(
}
pri
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3791#discussion_r114590134
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala
---
@@ -93,6 +103,11 @@ class Table(
* }}}
*/
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3793
Thanks for the PR @suez1224. I think we need to rework this PR a little
bit, before we can merge it. I saw that you had problems using basic type
arrays such as `Integer[]`. I think we should cover t
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995194#comment-15995194
]
ASF GitHub Bot commented on FLINK-6013:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3736#discussion_r114595396
--- Diff:
flink-metrics/flink-metrics-datadog/src/test/java/org/apache/flink/metrics/datadog/DatadogHttpClientTest.java
---
@@ -0,0 +1,194 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995187#comment-15995187
]
ASF GitHub Bot commented on FLINK-5906:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114593800
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -178,4 +178,24 @@ class BatchTableEn
Ted Yu created FLINK-6439:
-
Summary: Unclosed InputStream in
OperatorSnapshotUtil#readStateHandle()
Key: FLINK-6439
URL: https://issues.apache.org/jira/browse/FLINK-6439
Project: Flink
Issue Type: B
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3801#discussion_r114580123
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -769,9 +769,10 @@ public OperatorStateBa
[
https://issues.apache.org/jira/browse/FLINK-5720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995134#comment-15995134
]
ASF GitHub Bot commented on FLINK-5720:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3816
[FLINK-5720] Deprecate DataStream#fold()
This PR deprecates the various `DataStream#fold()` methods and all related
internal classes.
You can merge this pull request into a Git repository by running
[
https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995105#comment-15995105
]
ASF GitHub Bot commented on FLINK-6364:
---
Github user StefanRRichter commented on a d
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114581240
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -178,4 +178,24 @@ class BatchTableEn
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3692
Alright, this makes sense. The common denominator is that every dns name
will have an optional task placeholder (`_TASK`) and everything else is static,
right?
---
If your project is set up fo
[
https://issues.apache.org/jira/browse/FLINK-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995123#comment-15995123
]
ASF GitHub Bot commented on FLINK-5974:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995099#comment-15995099
]
ASF GitHub Bot commented on FLINK-5974:
---
Github user EronWright commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995108#comment-15995108
]
ASF GitHub Bot commented on FLINK-6364:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995115#comment-15995115
]
ASF GitHub Bot commented on FLINK-5906:
---
Github user fhueske commented on a diff in
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3801#discussion_r114579898
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateHandle.java
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995101#comment-15995101
]
ASF GitHub Bot commented on FLINK-5906:
---
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/3809#discussion_r114579772
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/table/DSetUDAGGITCase.scala
---
@@ -0,0 +1,192 @@
+/*
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/3692
@tillrohrmann Mesos DNS is not the only DNS solution for Mesos, it is
merely the DCOS solution. By using an interpolated string, the name is fully
configurable.
---
If your project is set up fo
[
https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995087#comment-15995087
]
ASF GitHub Bot commented on FLINK-6217:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3648
Thanks for your contribution @haohui and the review @StephanEwen. Changes
look good to me. Merging this PR.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995080#comment-15995080
]
ASF GitHub Bot commented on FLINK-5906:
---
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/3809#discussion_r114576600
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -178,4 +178,24 @@ class BatchT
[
https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995049#comment-15995049
]
ASF GitHub Bot commented on FLINK-5718:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3811
Thanks for your contribution @zimmermatt. Changes look good to me. Merging
this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
[
https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995044#comment-15995044
]
ASF GitHub Bot commented on FLINK-5906:
---
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/3809#discussion_r114571910
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala
---
@@ -327,4 +332,56 @@ object Projection
Github user soniclavier closed the pull request at:
https://github.com/apache/flink/pull/3763
---
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
[
https://issues.apache.org/jira/browse/FLINK-6372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995011#comment-15995011
]
ASF GitHub Bot commented on FLINK-6372:
---
Github user soniclavier closed the pull req
[
https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995008#comment-15995008
]
ASF GitHub Bot commented on FLINK-6364:
---
Github user shixiaogang commented on a diff
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3801#discussion_r114565991
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -769,9 +769,10 @@ public OperatorStateBacke
[
https://issues.apache.org/jira/browse/FLINK-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995007#comment-15995007
]
ASF GitHub Bot commented on FLINK-6364:
---
Github user shixiaogang commented on a diff
Github user shixiaogang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3801#discussion_r114565968
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateHandle.java
---
@@ -0,0 +1,20
[
https://issues.apache.org/jira/browse/FLINK-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995000#comment-15995000
]
ASF GitHub Bot commented on FLINK-5974:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3692
Why do we actually make `TaskManager` hostname configurable via
`mesos.resourcemanager.tasks.hostname`? Isn't the mesos-dns hostname already
uniquely defined by the `TaskID` and the framework na
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3802
What makes this graph 'evenly'? See
`org.apache.flink.graph.drivers.input.CompleteGraph` for creating an input for
`Runner` (the default class executed when doing a `/bin/flink run` on the
flink-g
[
https://issues.apache.org/jira/browse/FLINK-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson reassigned FLINK-6438:
-
Assignee: David Anderson
> Expand docs home page a little
> -
David Anderson created FLINK-6438:
-
Summary: Expand docs home page a little
Key: FLINK-6438
URL: https://issues.apache.org/jira/browse/FLINK-6438
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15994987#comment-15994987
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3778
@zentol Thanks for reviewing! ð
I merged this also on master, so that we have backwards compatibility tests
from 1.2 to the current master, which was the reason for this whole exercise.
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5969.
---
Resolution: Fixed
Fix Version/s: 1.2.2
Implemented on release-1.2 in:
- 852a710b4d91bd
[
https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15994974#comment-15994974
]
ASF GitHub Bot commented on FLINK-5969:
---
Github user aljoscha commented on the issue
1 - 100 of 374 matches
Mail list logo
