wuchong 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_r274952010
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin closed FLINK-11750.
---
Resolution: Won't Fix
Release Note:
see
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816377#comment-16816377
]
Till Rohrmann commented on FLINK-10052:
---
Looking at the provided link, it should be fine to
StefanRRichter commented on a change in pull request #7571: [FLINK-10724]
Refactor failure handling in check point coordinator
URL: https://github.com/apache/flink/pull/7571#discussion_r274975985
##
File path:
StefanRRichter commented on a change in pull request #7571: [FLINK-10724]
Refactor failure handling in check point coordinator
URL: https://github.com/apache/flink/pull/7571#discussion_r274979364
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816167#comment-16816167
]
Chesnay Schepler commented on FLINK-10984:
--
{{flink-shaded-hadoop2}} moved to flink-shaded in
[
https://issues.apache.org/jira/browse/FLINK-10984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10984:
-
Fix Version/s: shaded-7.0
> Move flink-shaded-hadoop to flink-shaded
>
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:29 AM:
--
Taking a guess, u may
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:28 AM:
--
Taking a guess, u may
[
https://issues.apache.org/jira/browse/FLINK-12171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao reassigned FLINK-12171:
---
Assignee: Yun Gao
> The network buffer memory size should not be checked against the heap size on
[
https://issues.apache.org/jira/browse/FLINK-12171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-12171:
Environment:
Flink-1.7.2, and Flink-1.8 seems have not modified the logic here.
was:
I tested with
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add
ReadableCatalog, ReadableWritableCatalog, and other …
URL: https://github.com/apache/flink/pull/8007#discussion_r274896725
##
File path:
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add
ReadableCatalog, ReadableWritableCatalog, and other …
URL: https://github.com/apache/flink/pull/8007#discussion_r274899236
##
File path:
wuchong 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_r274952010
##
File path:
StefanRRichter commented on a change in pull request #7571: [FLINK-10724]
Refactor failure handling in check point coordinator
URL: https://github.com/apache/flink/pull/7571#discussion_r274966185
##
File path:
StefanRRichter commented on a change in pull request #7571: [FLINK-10724]
Refactor failure handling in check point coordinator
URL: https://github.com/apache/flink/pull/7571#discussion_r274976664
##
File path:
StefanRRichter commented on a change in pull request #7571: [FLINK-10724]
Refactor failure handling in check point coordinator
URL: https://github.com/apache/flink/pull/7571#discussion_r274979853
##
File path:
StefanRRichter commented on a change in pull request #7571: [FLINK-10724]
Refactor failure handling in check point coordinator
URL: https://github.com/apache/flink/pull/7571#discussion_r274979853
##
File path:
dawidwys merged pull request #8153: Update metrics.md
URL: https://github.com/apache/flink/pull/8153
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Jark Wu created FLINK-12173:
---
Summary: Optimize "SELECT DISTINCT" into Deduplicate with keep
first row
Key: FLINK-12173
URL: https://issues.apache.org/jira/browse/FLINK-12173
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816445#comment-16816445
]
Rong Rong commented on FLINK-11935:
---
I think [~julianhyde] is correct. actually I ran the test again
Hequn Cheng created FLINK-12174:
---
Summary: Introduce FlinkAggregateExtractProjectRule and remove
extractFieldReferences
Key: FLINK-12174
URL: https://issues.apache.org/jira/browse/FLINK-12174
Project:
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274865419
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTest.java
##
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274865419
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTest.java
##
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S commented on FLINK-5970:
Taking a guess, u may be executing test as root user, hence the
GJL commented on issue #7986: [FLINK-10517][rest] Add stability test
URL: https://github.com/apache/flink/pull/7986#issuecomment-482539269
I think overall this looks good. I have left some minor comments.
This is an automated
Yun Gao created FLINK-12171:
---
Summary: The network buffer memory size should not be checked
against the heap size on the TM side
Key: FLINK-12171
URL: https://issues.apache.org/jira/browse/FLINK-12171
flinkbot commented on issue #8159: [hotfix][runtime] fix error log description
URL: https://github.com/apache/flink/pull/8159#issuecomment-482587198
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We
leesf opened a new pull request #8159: [hotfix][runtime] fix error log
description
URL: https://github.com/apache/flink/pull/8159
[hotfix][runtime] fix error log description.
This is an automated message from the Apache Git
zjffdu 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_r274920821
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mario Georgiev updated FLINK-12172:
---
Description:
Hello,
The problem is if you have a BucketingSink, the following case may
Mario Georgiev created FLINK-12172:
---
Summary: Flink fails to close pending BucketingSink
Key: FLINK-12172
URL: https://issues.apache.org/jira/browse/FLINK-12172
Project: Flink
Issue Type:
beyond1920 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_r274949277
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816345#comment-16816345
]
Kurt Young commented on FLINK-10929:
I'm not sure everyone who have already involved to this
xuefuz commented on a change in pull request #8007: [FLINK-11474][table] Add
ReadableCatalog, ReadableWritableCatalog, and other …
URL: https://github.com/apache/flink/pull/8007#discussion_r274898608
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:26 AM:
--
Taking a guess, u may
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:26 AM:
--
Taking a guess, u may
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:27 AM:
--
Taking a guess, u may
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:27 AM:
--
Taking a guess, u may
pnowojski commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r274819324
##
File path:
xuefuz commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog,
ReadableWritableCatalog, and other …
URL: https://github.com/apache/flink/pull/8007#issuecomment-482569613
> Hi @sunjincheng121 , @xuefuz , @bowenli86
>
> Regarding to the `listTables()`, I'm fine with
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274493121
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/RestAPIStabilityTest.java
##
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274864247
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutine.java
##
godfreyhe commented on a change in pull request #8148: [FLINK-12161]
[table-planner-blink] Supports partial-final optimization for stream group
aggregate
URL: https://github.com/apache/flink/pull/8148#discussion_r274864535
##
File path:
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274479508
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutines.java
##
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r274863253
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/util/DocumentingDispatcherRestEndpoint.java
[
https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816192#comment-16816192
]
Stephan Ewen commented on FLINK-10929:
--
There are two different considerations:
(1) Arrow for
godfreyhe commented on a change in pull request #8148: [FLINK-12161]
[table-planner-blink] Supports partial-final optimization for stream group
aggregate
URL: https://github.com/apache/flink/pull/8148#discussion_r274869130
##
File path:
pnowojski commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r274834483
##
File path:
pnowojski commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r274820408
##
File path:
pnowojski commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r274511889
##
File path:
pnowojski commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r274868359
##
File path:
pnowojski commented on a change in pull request #8124: [FLINK-11877] Implement
the runtime handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#discussion_r274512975
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:34 AM:
--
Taking a guess, u may
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:32 AM:
--
Taking a guess, u may
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:31 AM:
--
Taking a guess, u may
asfgit closed pull request #8155: [FLINK-12169] [javadocs] improve javadoc of
MessageAcknowledgingSource…
URL: https://github.com/apache/flink/pull/8155
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:32 AM:
--
Taking a guess, u may
[
https://issues.apache.org/jira/browse/FLINK-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816185#comment-16816185
]
Ajith S edited comment on FLINK-5970 at 4/12/19 11:30 AM:
--
Taking a guess, u may
sunjincheng121 commented on issue #8155: [FLINK-12169] [javadocs] improve
javadoc of MessageAcknowledgingSource…
URL: https://github.com/apache/flink/pull/8155#issuecomment-482589074
@flinkbot approve all
Merging...
This
[
https://issues.apache.org/jira/browse/FLINK-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-12169.
---
Resolution: Fixed
Fix Version/s: 1.8.1
1.9.0
1.7.3
TisonKun created FLINK-12180:
Summary: Port ExecutionVertexCancelTest to new codebase
Key: FLINK-12180
URL: https://issues.apache.org/jira/browse/FLINK-12180
Project: Flink
Issue Type: Sub-task
TisonKun created FLINK-12179:
Summary: Remove legacy Instance
Key: FLINK-12179
URL: https://issues.apache.org/jira/browse/FLINK-12179
Project: Flink
Issue Type: Sub-task
Components:
[
https://issues.apache.org/jira/browse/FLINK-10569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun closed FLINK-10569.
Resolution: Staged
Close and superseded by removals of `Scheduler` FLINK-12178 and `Instance`
TisonKun created FLINK-12177:
Summary: Remove legacy FlinkUntypedActor
Key: FLINK-12177
URL: https://issues.apache.org/jira/browse/FLINK-12177
Project: Flink
Issue Type: Sub-task
flinkbot commented on issue #8160: [FLINK-12177][coordination] Remove legacy
FlinkUntypedActor
URL: https://github.com/apache/flink/pull/8160#issuecomment-482774698
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
TisonKun opened a new pull request #8160: [FLINK-12177][coordination] Remove
legacy FlinkUntypedActor
URL: https://github.com/apache/flink/pull/8160
## What is the purpose of the change
Remove legacy `FlinkUntypedActor`.
## Verifying this change
This change is a
TisonKun commented on issue #7815: [FLINK-10569][tests] Remove Instance usages
in valid Test
URL: https://github.com/apache/flink/pull/7815#issuecomment-482774728
Close and separated FLINK-10569 as removals of `Scheduler` and `Instance`
individually.
TisonKun closed pull request #7815: [FLINK-10569][tests] Remove Instance
usages in valid Test
URL: https://github.com/apache/flink/pull/7815
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-12177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12177:
---
Labels: pull-request-available (was: )
> Remove legacy FlinkUntypedActor
>
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816755#comment-16816755
]
Julian Hyde commented on FLINK-11935:
-
My advice is don't trust Java, do trust PostgreSQL. Java
[
https://issues.apache.org/jira/browse/FLINK-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-12176:
-
Description:
Currently, we create {{JobGraph}} by the following process
* if the cluster start in job
TisonKun created FLINK-12178:
Summary: Remove legacy Scheduler
Key: FLINK-12178
URL: https://issues.apache.org/jira/browse/FLINK-12178
Project: Flink
Issue Type: Sub-task
Components:
piyushnarang commented on issue #8117: [FLINK-12115] [filesystems]: Add support
for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-482722850
@Myasuka - did you get a chance to take a look at the rework? Anything else
to address or can we merge this?
TisonKun created FLINK-12176:
Summary: Unify JobGraph creation in CliFrontend
Key: FLINK-12176
URL: https://issues.apache.org/jira/browse/FLINK-12176
Project: Flink
Issue Type: Improvement
TisonKun created FLINK-12181:
Summary: Port ExecutionGraphRestartTest to new codebase
Key: FLINK-12181
URL: https://issues.apache.org/jira/browse/FLINK-12181
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-12178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun reassigned FLINK-12178:
Assignee: (was: TisonKun)
> Remove legacy Scheduler
> ---
>
>
Dylan Adams created FLINK-12175:
---
Summary: TypeExtractor.getMapReturnTypes produces different
TypeInformation than createTypeInformation for classes with parameterized
ancestors
Key: FLINK-12175
URL:
101 - 178 of 178 matches
Mail list logo
