Gary Yao created FLINK-12123:
Summary: Upgrade Jepsen to 0.1.13 in flink-jepsen
Key: FLINK-12123
URL: https://issues.apache.org/jira/browse/FLINK-12123
Project: Flink
Issue Type: Improvement
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272965384
##
File path:
twalthr commented on a change in pull request #8062: [FLINK-11884][table]
Implement expression resolution on top of new Expressions
URL: https://github.com/apache/flink/pull/8062#discussion_r272964598
##
File path:
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272964014
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812283#comment-16812283
]
Lifei Chen commented on FLINK-7464:
---
Hi, [~sunjincheng121], I think `FIRST_VALUE` and `LAST_VALUE`
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-12122:
-
Assignee: Till Rohrmann
> Spread out tasks evenly across all available registered
Till Rohrmann created FLINK-12122:
-
Summary: Spread out tasks evenly across all available registered
TaskManagers
Key: FLINK-12122
URL: https://issues.apache.org/jira/browse/FLINK-12122
Project:
[
https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812271#comment-16812271
]
Ji Liu edited comment on FLINK-10437 at 4/8/19 9:34 AM:
[~Tison] I have checked
[
https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812271#comment-16812271
]
Ji Liu commented on FLINK-10437:
[~Tison] I have checked usages of _ConfigOption.withDeparecatedKeys_
[
https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812268#comment-16812268
]
sunjincheng commented on FLINK-10984:
-
+1 for this proposal.
I think this JIRA should first add the
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r272951340
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812265#comment-16812265
]
Fabian Hueske commented on FLINK-12008:
---
Yes, IIRC we recently added support for multiple paths to
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r272955876
##
File path:
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r272954758
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10984:
---
Labels: pull-request-available (was: )
> Move flink-shaded-hadoop to flink-shaded
>
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r272951210
##
File path:
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r272956271
##
File path:
tillrohrmann commented on a change in pull request #8002:
[FLINK-11923][metrics] MetricRegistryConfiguration provides MetricReporters
Suppliers
URL: https://github.com/apache/flink/pull/8002#discussion_r272950654
##
File path:
flinkbot commented on issue #8121: [FLINK-10437]Some of keys under
withDeprecatedKeys aren't marked as @…
URL: https://github.com/apache/flink/pull/8121#issuecomment-480754474
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
tianchen92 opened a new pull request #8121: [FLINK-10437]Some of keys under
withDeprecatedKeys aren't marked as @…
URL: https://github.com/apache/flink/pull/8121
…depreacted
## What is the purpose of the change
*RestOptions#BIND_ADDRESS is
[
https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10437:
---
Labels: pull-request-available (was: )
> Some of keys under withDeprecatedKeys aren't
tzulitai commented on a change in pull request #8078: [FLINK-12066] [State
Backends] Remove StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078#discussion_r272922134
##
File path:
tzulitai commented on a change in pull request #8078: [FLINK-12066] [State
Backends] Remove StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078#discussion_r272921407
##
File path:
tzulitai commented on a change in pull request #8078: [FLINK-12066] [State
Backends] Remove StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078#discussion_r272922020
##
File path:
zhijiangW commented on a change in pull request #8090: [FLINK-12067][network]
Refactor the constructor of NetworkEnvironment
URL: https://github.com/apache/flink/pull/8090#discussion_r272944389
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812243#comment-16812243
]
Yu Li commented on FLINK-12121:
---
Mark as a blocker of FLINK-12066
> Use composition instead of
Yu Li created FLINK-12121:
-
Summary: Use composition instead of inheritance for the
InternalKeyContext logic in backend
Key: FLINK-12121
URL: https://issues.apache.org/jira/browse/FLINK-12121
Project: Flink
KurtYoung commented on issue #8109: [FLINK-12017][table-planner-blink] Support
translation from Rank/Deduplicate to StreamTransformation
URL: https://github.com/apache/flink/pull/8109#issuecomment-480743717
BTW, i think we need some dedicated tests for all rank functions.
[
https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812233#comment-16812233
]
TisonKun commented on FLINK-10437:
--
Yes. You might decide whether replace with {{withFallbackKeys}} or
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272878173
##
File path:
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272880935
##
File path:
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272879137
##
File path:
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272878814
##
File path:
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272879175
##
File path:
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272878861
##
File path:
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272882131
##
File path:
KurtYoung commented on a change in pull request #8109:
[FLINK-12017][table-planner-blink] Support translation from Rank/Deduplicate to
StreamTransformation
URL: https://github.com/apache/flink/pull/8109#discussion_r272878296
##
File path:
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r272922309
##
File path:
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r272925609
##
File path:
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r272927404
##
File path:
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r272923859
##
File path:
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r272921337
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-4785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1681#comment-1681
]
Flavio Pompermaier commented on FLINK-4785:
---
Which url is no longer valid?
pnowojski commented on a change in pull request #8038: [FLINK-11953] Introduce
Plugin/Loading system and integrate it with FileSystem
URL: https://github.com/apache/flink/pull/8038#discussion_r272927782
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812221#comment-16812221
]
Fabian Hueske commented on FLINK-10684:
---
Hi, please have a look at
[
https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812220#comment-16812220
]
Till Rohrmann commented on FLINK-8801:
--
Hi [~Tao Yang] and [~yanyan300300], thanks for reporting
JingsongLi commented on issue #8102: [FLINK-12087][table-runtime-blink]
Introduce over window operators to blink batch
URL: https://github.com/apache/flink/pull/8102#issuecomment-480731189
I try implement it like "immediately determine the left and right boundary",
but even if we
[
https://issues.apache.org/jira/browse/FLINK-12010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mario Georgiev updated FLINK-12010:
---
Description:
{code:java}
Error relocating
[
https://issues.apache.org/jira/browse/FLINK-11855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-11855:
-
Fix Version/s: (was: 1.8.1)
(was: 1.9.0)
zhijiangW commented on a change in pull request #8090: [FLINK-12067][network]
Refactor the constructor of NetworkEnvironment
URL: https://github.com/apache/flink/pull/8090#discussion_r272919268
##
File path:
flinkbot edited a comment on issue #8078: [FLINK-12066] [State Backends] Remove
StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078#issuecomment-477977949
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
tzulitai commented on issue #8078: [FLINK-12066] [State Backends] Remove
StateSerializerProvider field in keyed state backends
URL: https://github.com/apache/flink/pull/8078#issuecomment-480712590
@flinkbot approve description
@flinkbot approve consensus
[
https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812167#comment-16812167
]
Takanobu Asanuma commented on FLINK-8033:
-
bq. because you still have to solve most of the issues
[
https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812161#comment-16812161
]
LiuJi commented on FLINK-3991:
--
Hi [~Zentol] It seems now in ConfigConstants, some deprecated keys have no
[
https://issues.apache.org/jira/browse/FLINK-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812155#comment-16812155
]
LiuJi commented on FLINK-7916:
--
Agree, I think move these tests to _org.apache.flink.test.manual_ under
KurtYoung commented on issue #8102: [FLINK-12087][table-runtime-blink]
Introduce over window operators to blink batch
URL: https://github.com/apache/flink/pull/8102#issuecomment-480705151
I don't think it's an optimization. I would say it's intuition every reader
will have in the first
dawidwys commented on a change in pull request #8062: [FLINK-11884][table]
Implement expression resolution on top of new Expressions
URL: https://github.com/apache/flink/pull/8062#discussion_r272903193
##
File path:
hequn8128 commented on a change in pull request #7196: [FLINK-10974] [table]
Add support for flatMap to table API
URL: https://github.com/apache/flink/pull/7196#discussion_r272878771
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Table.java
hequn8128 commented on a change in pull request #7196: [FLINK-10974] [table]
Add support for flatMap to table API
URL: https://github.com/apache/flink/pull/7196#discussion_r272875577
##
File path: docs/dev/table/tableApi.md
##
@@ -1847,6 +1847,22 @@ Table table = input
hequn8128 commented on a change in pull request #7196: [FLINK-10974] [table]
Add support for flatMap to table API
URL: https://github.com/apache/flink/pull/7196#discussion_r272877997
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Table.java
hequn8128 commented on a change in pull request #7196: [FLINK-10974] [table]
Add support for flatMap to table API
URL: https://github.com/apache/flink/pull/7196#discussion_r272899748
##
File path:
hequn8128 commented on a change in pull request #7196: [FLINK-10974] [table]
Add support for flatMap to table API
URL: https://github.com/apache/flink/pull/7196#discussion_r272878971
##
File path:
hequn8128 commented on a change in pull request #7196: [FLINK-10974] [table]
Add support for flatMap to table API
URL: https://github.com/apache/flink/pull/7196#discussion_r272877780
##
File path: docs/dev/table/tableApi.md
##
@@ -1847,6 +1847,22 @@ Table table = input
hequn8128 commented on a change in pull request #7196: [FLINK-10974] [table]
Add support for flatMap to table API
URL: https://github.com/apache/flink/pull/7196#discussion_r272878215
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Table.java
dawidwys commented on a change in pull request #8062: [FLINK-11884][table]
Implement expression resolution on top of new Expressions
URL: https://github.com/apache/flink/pull/8062#discussion_r272902524
##
File path:
dawidwys commented on a change in pull request #8062: [FLINK-11884][table]
Implement expression resolution on top of new Expressions
URL: https://github.com/apache/flink/pull/8062#discussion_r272901252
##
File path:
JingsongLi commented on issue #8102: [FLINK-12087][table-runtime-blink]
Introduce over window operators to blink batch
URL: https://github.com/apache/flink/pull/8102#issuecomment-480702530
>> As I said before, you can immediately determine the left and right
boundary with currentIndex -
JingsongLi edited a comment on issue #8102: [FLINK-12087][table-runtime-blink]
Introduce over window operators to blink batch
URL: https://github.com/apache/flink/pull/8102#issuecomment-480702530
>> As I said before, you can immediately determine the left and right
boundary with
[
https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812145#comment-16812145
]
LiuJi commented on FLINK-9787:
--
Agree, it's a good idea to avoid NPE when invoke
[
https://issues.apache.org/jira/browse/FLINK-12120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12120:
---
Labels: pull-request-available (was: )
> Support queries like "select sum(b), count(c)
KurtYoung commented on issue #8102: [FLINK-12087][table-runtime-blink]
Introduce over window operators to blink batch
URL: https://github.com/apache/flink/pull/8102#issuecomment-480699105
I think the problem is the methods you proposed: `isLeftBoundRowInWindow`
and
flinkbot commented on issue #8120: [FLINK-12120][table-planner-blink] Support
queries like "select sum(b), count(c) from T group by a" run in batch mode
URL: https://github.com/apache/flink/pull/8120#issuecomment-480699193
Thanks a lot for your contribution to the Apache Flink project. I'm
[
https://issues.apache.org/jira/browse/FLINK-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812138#comment-16812138
]
LiuJi commented on FLINK-10437:
---
You mean we should check all classes which use _withDeprecatedKeys_，if
JingsongLi opened a new pull request #8120: [FLINK-12120][table-planner-blink]
Introduce "select sum(b), count(c) from T group by a" in Blink batch
URL: https://github.com/apache/flink/pull/8120
## What is the purpose of the change
Introduce "select sum(b), count(c) from T group by
[
https://issues.apache.org/jira/browse/FLINK-12120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-12120:
---
Summary: Support queries like "select sum(b), count(c) from T group by a"
run in batch mode (was:
Jingsong Lee created FLINK-12120:
Summary: Introduce "select sum(b), count(c) from T group by a" in
Blink batch
Key: FLINK-12120
URL: https://issues.apache.org/jira/browse/FLINK-12120
Project: Flink
zhijiangW commented on a change in pull request #8090: [FLINK-12067][network]
Refactor the constructor of NetworkEnvironment
URL: https://github.com/apache/flink/pull/8090#discussion_r272894672
##
File path:
JingsongLi edited a comment on issue #8102: [FLINK-12087][table-runtime-blink]
Introduce over window operators to blink batch
URL: https://github.com/apache/flink/pull/8102#issuecomment-480694448
Consider a new `BaseSlidingOverFrame`:
It has two abstract method:
1.`public abstract
JingsongLi commented on issue #8102: [FLINK-12087][table-runtime-blink]
Introduce over window operators to blink batch
URL: https://github.com/apache/flink/pull/8102#issuecomment-480694448
Consider a new `BaseSlidingOverFrame`:
It has two abstract method:
1.`public abstract boolean
201 - 279 of 279 matches
Mail list logo
