Biao Liu created FLINK-5140:
---
Summary: NoResourceAvailableException is thrown while starting a
new job
Key: FLINK-5140
URL: https://issues.apache.org/jira/browse/FLINK-5140
Project: Flink
Issue Ty
jing lining created FLINK-5139:
--
Summary: consum kafka can set offset
Key: FLINK-5139
URL: https://issues.apache.org/jira/browse/FLINK-5139
Project: Flink
Issue Type: Improvement
Compo
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5138:
-
Description:
Users may specify the state size in *setResource* API, then the different
*StateBack
[
https://issues.apache.org/jira/browse/FLINK-5138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5138:
-
Component/s: Core
> The StateBackend provides the method to estimate memory usage based on hint
>
Zhijiang Wang created FLINK-5138:
Summary: The StateBackend provides the method to estimate memory
usage based on hint of state size in ResourceSpec
Key: FLINK-5138
URL: https://issues.apache.org/jira/browse/FLINK
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5134:
Assignee: Zhijiang Wang
> Aggregate ResourceSpe for chained operators when generating job g
[
https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5133:
Assignee: Zhijiang Wang
> Add new setResource API for DataStream and DataSet
>
[
https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5136:
Assignee: Zhijiang Wang
> Aggregation of slot ResourceProfile and framework memory by Resou
[
https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5135:
Assignee: Zhijiang Wang
> ResourceProfile for slot request should be expanded to correspond
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5132:
Assignee: Zhijiang Wang
> Introduce the ResourceSpec for grouping different resource factor
[
https://issues.apache.org/jira/browse/FLINK-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-5137:
Assignee: Zhijiang Wang
> Config JVM options and set onto the TaskManager container
> -
[
https://issues.apache.org/jira/browse/FLINK-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5137:
-
Description: The users can config JVM options in job level. And the
*ResourceManager* will set rel
Zhijiang Wang created FLINK-5137:
Summary: Config JVM options and set onto the TaskManager container
Key: FLINK-5137
URL: https://issues.apache.org/jira/browse/FLINK-5137
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5136:
-
Description:
When *ResourceManager* requests container resource from cluster, the framework
memor
[
https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5136:
-
Summary: Aggregation of slot ResourceProfile and framework memory by
ResourceManager (was: Aggreg
[
https://issues.apache.org/jira/browse/FLINK-5136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5136:
-
Summary: Aggregation of slot ResourceProfile and framework memory for
requesting resource from clu
Zhijiang Wang created FLINK-5136:
Summary: ResourceManager should consider both slot resource
profile and framework memory for requesting resource from cluster
Key: FLINK-5136
URL: https://issues.apache.org/jira/b
[
https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5135:
-
Description: The *JobManager* requests slot by *ResourceProfile* from
*ResourceManager* before sub
[
https://issues.apache.org/jira/browse/FLINK-5135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5135:
-
Summary: ResourceProfile for slot request should be expanded to correspond
with ResourceSpec (was
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
Zhijiang Wang created FLINK-5135:
Summary: ResourceProfile should be expanded to correspond with
ResourceSpec
Key: FLINK-5135
URL: https://issues.apache.org/jira/browse/FLINK-5135
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Description:
In *JobGraph* generation, each *JobVertex* corresponds to a series of chained
operat
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Description:
In *JobGraph* generation, each *JobVertex* corresponds to a series of chained
operat
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Summary: Aggregate ResourceSpe for chained operators when generating job
graph (was: Aggregate Re
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Description: In DataStream API, the *ResourceSpec* is setted onto the
internal transformation (wa
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5134:
-
Description: In datastream API,
> Aggregate ResourceSpe for chained operators when generating stre
Zhijiang Wang created FLINK-5134:
Summary: Aggregate ResourceSpe for chained operators when
generating stream graph
Key: FLINK-5134
URL: https://issues.apache.org/jira/browse/FLINK-5134
Project: Flink
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/2792
@fhueske thanks a lot for the review. I have refactored AggregateUtil and
updated the PR .
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688860#comment-15688860
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on the
[
https://issues.apache.org/jira/browse/FLINK-5133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5133:
-
Description:
This is part of the fine-grained resource configuration.
For *DataStream*, the *setR
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688809#comment-15688809
]
ASF GitHub Bot commented on FLINK-5023:
---
Github user shixiaogang commented on the is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/2768
@aljoscha Thanks for your review. I have updated the PR according to your
suggestion.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
Zhijiang Wang created FLINK-5133:
Summary: Add new setResource API for DataStream and DataSet
Key: FLINK-5133
URL: https://issues.apache.org/jira/browse/FLINK-5133
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5132:
-
Description:
This is part of the fine-grained resource configuration.
The current resource factors
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5132:
-
Description:
This is part of the fine-grained resource configuration.
The current resource factor
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r89252908
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -135,6 +138,32 @
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688781#comment-15688781
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user sunjincheng121 commented on a d
Zhijiang Wang created FLINK-5132:
Summary: Introduce the ResourceSpec for grouping different
resource factors in API
Key: FLINK-5132
URL: https://issues.apache.org/jira/browse/FLINK-5132
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-5131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-5131:
-
Description:
Normally the UDF just creates short-life small objects and these can be
recycled qui
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89249046
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ objec
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688661#comment-15688661
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688654#comment-15688654
]
Manu Zhang commented on FLINK-5061:
---
Agreed. Just some of my thoughts and should not blo
Zhijiang Wang created FLINK-5131:
Summary: Fine-grained Resource Configuration
Key: FLINK-5131
URL: https://issues.apache.org/jira/browse/FLINK-5131
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688612#comment-15688612
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688613#comment-15688613
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89247407
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ objec
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89247416
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ objec
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688608#comment-15688608
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89247362
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -39,66 +45,69 @@ object A
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688606#comment-15688606
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89247312
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -39,66 +45,69 @@ object A
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89244761
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ objec
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688533#comment-15688533
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89242998
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -61,25 +61,108 @@ object
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688485#comment-15688485
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688370#comment-15688370
]
ASF GitHub Bot commented on FLINK-4669:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2541
@StephanEwen have any improvement needed?
---
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
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688284#comment-15688284
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688285#comment-15688285
]
ASF GitHub Bot commented on FLINK-5107:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4910.
--
Resolution: Fixed
Fixed via ba8ed263695d16eacb4bdfdf195dd22c83bb53ed
> Introduce safety net for
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2837
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2691
---
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-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-5107.
--
Resolution: Fixed
Fixed via f5af7f1025aac9cac3f83de5f0e3aece5730ec0f
> Job Manager goes out of
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2837
Thanks for the contribution @StefanRRichter. Failing tests are unrelated.
Merging this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688084#comment-15688084
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688088#comment-15688088
]
ASF GitHub Bot commented on FLINK-5107:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2691
Thanks for the great contribution @StefanRRichter. 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 well. If your projec
[
https://issues.apache.org/jira/browse/FLINK-5082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5082.
Resolution: Fixed
Fixed in 1.2 via ae4b274a9919d01a236df4e819a0a07c5d8543ac
Fixed in 1.1.4 via 7fb71
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688077#comment-15688077
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user senorcarbone commented on the i
Github user senorcarbone commented on the issue:
https://github.com/apache/flink/pull/1668
Ok, so I am progressing this a bit independently from the termination stuff
and then we rebase to the first PR that is merged. I just changed everything
and rebased to the current master.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2820
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2815
---
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-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5085.
Resolution: Fixed
Fixed in 1.2 via c590912c93a4059b40452dfa6cffbdd4d58cac13
Fixed in 1.1.4 via cf4b2
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2825
---
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-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5073.
Resolution: Fixed
Fixed in 1.2 via 3fb92d8687f03c1fac8b87396b2b5a7ff29f6dd6
Fixed in 1.1.4 via f2e4c
[
https://issues.apache.org/jira/browse/FLINK-5082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688071#comment-15688071
]
ASF GitHub Bot commented on FLINK-5082:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688073#comment-15688073
]
ASF GitHub Bot commented on FLINK-5085:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688072#comment-15688072
]
ASF GitHub Bot commented on FLINK-5073:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15688042#comment-15688042
]
ASF GitHub Bot commented on FLINK-5085:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2825
Build passed locally
https://travis-ci.org/tillrohrmann/flink/builds/178011045. Merging this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930
]
Ted Yu edited comment on FLINK-4848 at 11/22/16 9:32 PM:
-
There is
[
https://issues.apache.org/jira/browse/FLINK-4999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-4999.
---
Resolution: Won't Fix
> Improve accuracy of SingleInputGate#getNumberOfQueuedBuffers
> ---
[
https://issues.apache.org/jira/browse/FLINK-5050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687938#comment-15687938
]
ASF GitHub Bot commented on FLINK-5050:
---
Github user tedyu commented on the issue:
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/2824
lgtm
---
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
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687902#comment-15687902
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2842
@vasia should `Graph` be using the function specific
`TypeExtractor.getMapReturnTypes` (not sure why this is plural) and similar
where core Functions are used?
For `Gelly` functions, I thi
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2851#discussion_r89192379
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala
---
@@ -656,38 +656,56 @@ object ScalarOp
[
https://issues.apache.org/jira/browse/FLINK-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687674#comment-15687674
]
ASF GitHub Bot commented on FLINK-5124:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687675#comment-15687675
]
ASF GitHub Bot commented on FLINK-5124:
---
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/2851#discussion_r89192110
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala
---
@@ -656,38 +656,56 @@ object ScalarOp
[
https://issues.apache.org/jira/browse/FLINK-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687673#comment-15687673
]
ASF GitHub Bot commented on FLINK-5124:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687642#comment-15687642
]
ASF GitHub Bot commented on FLINK-4895:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2850
I haven't tried it yet.
---
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
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2664
Thank you for fixing the issue so quickly.
I'm wondering whether the current approach is a good idea, because it
requires manual checking of all transitive dependencies. We have something
simila
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687629#comment-15687629
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user rmetzger commented on the issue
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2852
Thanks for the fix @BorisOsipov!
+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 fe
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15687577#comment-15687577
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issu
1 - 100 of 327 matches
Mail list logo
