[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688809#comment-15688809
]
ASF GitHub Bot commented on FLINK-5023:
---
Github user shixiaogang commented on the issue:
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
[
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
[
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
[
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
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:
[
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
[
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
[
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
[
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:
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
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-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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688606#comment-15688606
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688608#comment-15688608
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
[
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
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688781#comment-15688781
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user sunjincheng121 commented on a diff in the pull
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-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
[
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
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/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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688661#comment-15688661
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
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 @@
[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688654#comment-15688654
]
Manu Zhang commented on FLINK-5061:
---
Agreed. Just some of my thoughts and should not block the changes.
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:
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-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
[
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
[
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
[
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
[
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-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
[
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-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688612#comment-15688612
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688613#comment-15688613
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
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
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
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-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
[
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
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
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 @@
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 @@
[
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
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688860#comment-15688860
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on the issue:
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
[
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
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=15688485#comment-15688485
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
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 @@
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688533#comment-15688533
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686075#comment-15686075
]
Flavio Pompermaier commented on FLINK-5122:
---
Can you try and see if our pull request fix your
[
https://issues.apache.org/jira/browse/FLINK-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-4895:
-
Assignee: Robert Metzger
> Drop support for Hadoop 1
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-5057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686230#comment-15686230
]
ASF GitHub Bot commented on FLINK-5057:
---
Github user uce closed the pull request at:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89101873
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ object
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686702#comment-15686702
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686703#comment-15686703
]
ASF GitHub Bot commented on FLINK-4937:
---
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/2792#discussion_r89090109
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ object
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686709#comment-15686709
]
ASF GitHub Bot commented on FLINK-4937:
---
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/2792#discussion_r89088166
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -39,66 +45,69 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89089242
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89102066
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89101806
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89086106
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -39,66 +45,69 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89088443
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ object
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2822
Thanks for the review @StephanEwen. I'm pretty sure this doesn't affect the
normal Kinesis shard discovery. I'll give it some final tests before merging
(would like to get this in before the next
[
https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686551#comment-15686551
]
ASF GitHub Bot commented on FLINK-5075:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686800#comment-15686800
]
Aljoscha Krettek commented on FLINK-5061:
-
We can also leave it in since it's not a maintenance
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2822#discussion_r89119126
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686816#comment-15686816
]
ASF GitHub Bot commented on FLINK-5075:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686760#comment-15686760
]
ASF GitHub Bot commented on FLINK-4964:
---
Github user tfournier314 commented on the issue:
Github user tfournier314 commented on the issue:
https://github.com/apache/flink/pull/2740
Hello @thvasilo @greghogan
Ok I've updated documentation. I stay tuned for updating code.
Regards
Thomas
---
If your project is set up for it, you can reply to this
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89088819
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -39,66 +45,69 @@ object
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686711#comment-15686711
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686705#comment-15686705
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686700#comment-15686700
]
ASF GitHub Bot commented on FLINK-4937:
---
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/2792#discussion_r89086247
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -39,66 +45,69 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r89088322
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -39,66 +45,69 @@ object
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686712#comment-15686712
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686706#comment-15686706
]
ASF GitHub Bot commented on FLINK-4937:
---
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/2792#discussion_r89089095
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ object
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686707#comment-15686707
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686708#comment-15686708
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686704#comment-15686704
]
ASF GitHub Bot commented on FLINK-4937:
---
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/2792#discussion_r89101976
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
---
@@ -115,14 +124,210 @@ object
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686710#comment-15686710
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in the pull
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2842
Hi @greghogan,
I was able to fix the problem in `fromDataSet()` and `groupReduceOnEdges()`
with `EdgesFunction`. In the rest of the uses, I don't seem to find a way to
pass all the input types
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686757#comment-15686757
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15686810#comment-15686810
]
ASF GitHub Bot commented on FLINK-4155:
---
Github user tzulitai commented on the issue:
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2822#discussion_r89100942
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1568#comment-1568
]
Robert Metzger commented on FLINK-5049:
---
Another instance of the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2681
Thanks for the review @rmetzger.
No, actually I haven't refactored the table tests yet. I'll file up the
follow-up JIRAs mentioned in the comments, and merge the PR as is.
---
If your
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
> In addition, the TableSource should know project information (including
order) not just fieldIncluded. So maybe we should also adapt RowCsvInputFormat.
Do you mean we need to shuffle field
1 - 100 of 325 matches
Mail list logo
