[
https://issues.apache.org/jira/browse/FLINK-12380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837766#comment-16837766
]
Yun Tang commented on FLINK-12380:
--
[~azagrebin] If so why current
Myasuka commented on issue #8328: [FLINK-12380] Add thread name in the
log4j.properties
URL: https://github.com/apache/flink/pull/8328#issuecomment-491482568
@StephanEwen As you are the founder of Flink and the most-contributed coder,
I believe and respect your choice.
However, your
XuQianJin-Stars commented on issue #8244: [FLINK-11945] [table-runtime-blink]
Support over aggregation for blink streaming runtime
URL: https://github.com/apache/flink/pull/8244#issuecomment-491482291
hi @wuchong Thank you very much,Comments addressed.
godfreyhe commented on issue #8317: [FLINK-12371] [table-planner-blink] Add
support for converting (NOT) IN/ (NOT) EXISTS to semi-join/anti-join, and
generating optimized logical plan
URL: https://github.com/apache/flink/pull/8317#issuecomment-491481206
@KurtYoung I have fixed the failed
eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229]
[runtime] Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r283083182
##
File path:
eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229]
[runtime] Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r283082959
##
File path:
eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229]
[runtime] Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r283082955
##
File path:
eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229]
[runtime] Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r283082635
##
File path:
eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229]
[runtime] Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r283082502
##
File path:
eaglewatcherwb commented on a change in pull request #8309: [FLINK-12229]
[runtime] Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r283082509
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837692#comment-16837692
]
Stephan Ewen commented on FLINK-8513:
-
Fixed in {{master}} in
[
https://issues.apache.org/jira/browse/FLINK-10249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837691#comment-16837691
]
Stephan Ewen commented on FLINK-10249:
--
Fixed in {{master}} in
[
https://issues.apache.org/jira/browse/FLINK-12388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837690#comment-16837690
]
Stephan Ewen commented on FLINK-12388:
--
Fixed in {{master}} in
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-12070.
> Make blocking result partitions consumable multiple times
>
[
https://issues.apache.org/jira/browse/FLINK-12378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837694#comment-16837694
]
Stephan Ewen commented on FLINK-12378:
--
Fixed in {{master}} in
[
https://issues.apache.org/jira/browse/FLINK-12378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-12378:
-
Fix Version/s: 1.8.1
1.9.0
> Consolidate FileSystem Documentation
>
[
https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-8513:
Fix Version/s: 1.8.1
1.9.0
> Add documentation for connecting to non-AWS S3
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-12070.
--
Resolution: Implemented
Assignee: Stephan Ewen (was: BoWang)
Fix Version/s:
[
https://issues.apache.org/jira/browse/FLINK-12378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12378:
---
Labels: pull-request-available (was: )
> Consolidate FileSystem Documentation
>
asfgit closed pull request #8326: [FLINK-12378][docs] Consolidate FileSystem
Documentation
URL: https://github.com/apache/flink/pull/8326
This is an automated message from the Apache Git Service.
To respond to the message,
StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new
bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#issuecomment-491457613
Manually merged in a7cf24383be9f310fb5ccc5a032721421fa45791
asfgit closed pull request #8330: [FLINK-12388][docs] Update the production
readiness checklist
URL: https://github.com/apache/flink/pull/8330
This is an automated message from the Apache Git Service.
To respond to the
StephanEwen closed pull request #8290: [FLINK-12070] [network] Implement new
bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290
This is an automated message from the Apache Git Service.
To respond
bowenli86 commented on a change in pull request #8404: [FLINK-11476][table]
Create CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283063574
##
File path:
bowenli86 commented on a change in pull request #8404: [FLINK-11476][table]
Create CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283062024
##
File path:
bowenli86 commented on a change in pull request #8404: [FLINK-11476][table]
Create CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283060689
##
File path:
bowenli86 commented on a change in pull request #8404: [FLINK-11476][table]
Create CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283062301
##
File path:
bowenli86 commented on a change in pull request #8404: [FLINK-11476][table]
Create CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283062652
##
File path:
bowenli86 commented on a change in pull request #8404: [FLINK-11476][table]
Create CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283059466
##
File path:
bowenli86 commented on a change in pull request #8404: [FLINK-11476][table]
Create CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283063171
##
File path:
bowenli86 commented on a change in pull request #8404: [FLINK-11476][table]
Create CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283061626
##
File path:
bowenli86 commented on issue #8390: [FLINK-12469][table] Clean up catalog API
on default/current database
URL: https://github.com/apache/flink/pull/8390#issuecomment-491445937
+1
@dawidwys can you take another look? if you don't have other comments, I'll
merge this once CI is
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r283056348
##
File path:
xuefuz commented on a change in pull request #8390: [FLINK-12469][table] Clean
up catalog API on default/current database
URL: https://github.com/apache/flink/pull/8390#discussion_r283047530
##
File path:
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r283039874
##
File path:
bowenli86 commented on a change in pull request #8390: [FLINK-12469][table]
Clean up catalog API on default/current database
URL: https://github.com/apache/flink/pull/8390#discussion_r283037447
##
File path:
bowenli86 commented on a change in pull request #8390: [FLINK-12469][table]
Clean up catalog API on default/current database
URL: https://github.com/apache/flink/pull/8390#discussion_r283036856
##
File path:
azagrebin commented on issue #8416: [FLINK-12331] Introduce partition/gate
setup to decouple task registration with NetworkEnvironment
URL: https://github.com/apache/flink/pull/8416#issuecomment-491418905
@flinkbot attention @zhijiangW
flinkbot commented on issue #8416: [FLINK-12331] Introduce partition/gate setup
to decouple task registration with NetworkEnvironment
URL: https://github.com/apache/flink/pull/8416#issuecomment-491418683
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
azagrebin opened a new pull request #8416: [FLINK-12331] Introduce
partition/gate setup to decouple task registration with NetworkEnvironment
URL: https://github.com/apache/flink/pull/8416
## What is the purpose of the change
Introduce partition/gate setup to decouple task
xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create
CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r283025643
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837525#comment-16837525
]
Tim commented on FLINK-10520:
-
Is there any update on this issue?
> Job save points REST API fails
[
https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837512#comment-16837512
]
Piyush Goyal commented on FLINK-7697:
-
+1 on adding metrics to ES Sink.
Few others metrics that
xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create
CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r282981545
##
File path:
yuyang08 closed pull request #8067: [FLINK-11746][formats] Add thrift format
support to Flink
URL: https://github.com/apache/flink/pull/8067
This is an automated message from the Apache Git Service.
To respond to the
StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new
bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#issuecomment-491373523
@zhijiangW Our reasoning about the three options seems similar.
My understanding is that even if
StephanEwen commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r282978232
##
File path:
StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new
bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#issuecomment-491372403
Thank you for the reviews.
I refactored some code:
- Pulled out the `MemoryMappedBuffers`) class to
xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create
CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r282976905
##
File path:
xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create
CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r282967862
##
File path:
xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create
CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r282961373
##
File path:
xuefuz commented on a change in pull request #8390: [FLINK-12469][table] Clean
up catalog API on default/current database
URL: https://github.com/apache/flink/pull/8390#discussion_r282954828
##
File path:
StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new
bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#issuecomment-491335910
@zhijiangW Thanks for the detailed review and good comments.
StephanEwen commented on issue #8290: [FLINK-12070] [network] Implement new
bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#issuecomment-491336129
@eaglewatcherwb This implementation makes no assumption when a partition
will be released. That is the
ambition119 commented on issue #8387: [FLINK-11982] [table] File System
Connector's support JSON Format and JSON file BatchTableSource
URL: https://github.com/apache/flink/pull/8387#issuecomment-491337056
> Ad. 1 Once again we aim to separate connector and formats => JsonFile =
Json +
ambition119 closed pull request #8387: [FLINK-11982] [table] File System
Connector's support JSON Format and JSON file BatchTableSource
URL: https://github.com/apache/flink/pull/8387
This is an automated message from the
StephanEwen commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r282938868
##
File path:
StephanEwen commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r282938255
##
File path:
StephanEwen commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r282938159
##
File path:
StephanEwen commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r282938334
##
File path:
sjwiesman commented on a change in pull request #8330: [FLINK-12388][docs]
Update the production readiness checklist
URL: https://github.com/apache/flink/pull/8330#discussion_r282937987
##
File path: docs/ops/production_ready.md
##
@@ -22,79 +22,54 @@ specific language
fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update
the production readiness checklist
URL: https://github.com/apache/flink/pull/8330#discussion_r282917921
##
File path: docs/ops/production_ready.md
##
@@ -22,79 +22,54 @@ specific language
fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update
the production readiness checklist
URL: https://github.com/apache/flink/pull/8330#discussion_r282921904
##
File path: docs/ops/production_ready.md
##
@@ -22,79 +22,54 @@ specific language
fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update
the production readiness checklist
URL: https://github.com/apache/flink/pull/8330#discussion_r282919635
##
File path: docs/ops/production_ready.md
##
@@ -22,79 +22,54 @@ specific language
fhueske commented on a change in pull request #8330: [FLINK-12388][docs] Update
the production readiness checklist
URL: https://github.com/apache/flink/pull/8330#discussion_r282920531
##
File path: docs/ops/production_ready.md
##
@@ -22,79 +22,54 @@ specific language
yanghua commented on a change in pull request #8410: [FLINK-11159] Allow
configuration whether to fall back to savepoints for restore
URL: https://github.com/apache/flink/pull/8410#discussion_r282921569
##
File path:
yanghua commented on a change in pull request #8410: [FLINK-11159] Allow
configuration whether to fall back to savepoints for restore
URL: https://github.com/apache/flink/pull/8410#discussion_r282921234
##
File path:
yanghua commented on a change in pull request #8410: [FLINK-11159] Allow
configuration whether to fall back to savepoints for restore
URL: https://github.com/apache/flink/pull/8410#discussion_r282919368
##
File path:
gyfora commented on a change in pull request #8410: [FLINK-11159] Allow
configuration whether to fall back to savepoints for restore
URL: https://github.com/apache/flink/pull/8410#discussion_r282908128
##
File path:
gyfora commented on a change in pull request #8410: [FLINK-11159] Allow
configuration whether to fall back to savepoints for restore
URL: https://github.com/apache/flink/pull/8410#discussion_r282907507
##
File path:
gyfora commented on a change in pull request #8410: [FLINK-11159] Allow
configuration whether to fall back to savepoints for restore
URL: https://github.com/apache/flink/pull/8410#discussion_r282909021
##
File path:
azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers
the termination of all running Tasks when shutting down TaskExecutor
URL: https://github.com/apache/flink/pull/7757#discussion_r282897244
##
File path:
azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers
the termination of all running Tasks when shutting down TaskExecutor
URL: https://github.com/apache/flink/pull/7757#discussion_r282884262
##
File path:
azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers
the termination of all running Tasks when shutting down TaskExecutor
URL: https://github.com/apache/flink/pull/7757#discussion_r282882662
##
File path:
azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers
the termination of all running Tasks when shutting down TaskExecutor
URL: https://github.com/apache/flink/pull/7757#discussion_r282888225
##
File path:
azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers
the termination of all running Tasks when shutting down TaskExecutor
URL: https://github.com/apache/flink/pull/7757#discussion_r282882465
##
File path:
azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers
the termination of all running Tasks when shutting down TaskExecutor
URL: https://github.com/apache/flink/pull/7757#discussion_r282884777
##
File path:
azagrebin commented on a change in pull request #7757: [FLINK-11630] Triggers
the termination of all running Tasks when shutting down TaskExecutor
URL: https://github.com/apache/flink/pull/7757#discussion_r282896944
##
File path:
dawidwys commented on issue #8387: [FLINK-11982] [table] File System
Connector's support JSON Format and JSON file BatchTableSource
URL: https://github.com/apache/flink/pull/8387#issuecomment-491308505
Ad. 1 Once again we aim to separate connector and formats => JsonFile = Json
+ File
hequn8128 commented on issue #8359: [FLINK-11051][table] Add streaming window
FlatAggregate to Table API
URL: https://github.com/apache/flink/pull/8359#issuecomment-491306744
@sunjincheng121 Thank you very much for your suggestions and meticulous
review. I have addressed all your comments
dawidwys commented on a change in pull request #8390: [FLINK-12469][table]
Clean up catalog API on default/current database
URL: https://github.com/apache/flink/pull/8390#discussion_r282904007
##
File path:
ambition119 edited a comment on issue #8387: [FLINK-11982] [table] File System
Connector's support JSON Format and JSON file BatchTableSource
URL: https://github.com/apache/flink/pull/8387#issuecomment-491298616
> Hi @ambition119
> I agree with @StephanEwen that this PR mixes the
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r282898836
##
File path:
yanghua commented on issue #8410: [FLINK-11159] Allow configuration whether to
fall back to savepoints for restore
URL: https://github.com/apache/flink/pull/8410#issuecomment-491302415
@gyfora If you have time, can you review this PR for me? thanks.
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r282898836
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang reassigned FLINK-12473:
-
Assignee: Luo Gen
> Add the interface of ML pipeline and ML lib
>
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r282892019
##
File path:
ambition119 commented on issue #8387: [FLINK-11982] [table] File System
Connector's support JSON Format and JSON file BatchTableSource
URL: https://github.com/apache/flink/pull/8387#issuecomment-491298616
> Hi @ambition119
> I agree with @StephanEwen that this PR mixes the concepts of
xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create
CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r282893011
##
File path:
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r282892019
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837302#comment-16837302
]
jack commented on FLINK-12428:
--
Have you finished the task?
> Translate the "Event Time" page into Chinese
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r282887147
##
File path:
flinkbot commented on issue #8414: [FLINK-12477][Build] Enforce maven version
3.1.1
URL: https://github.com/apache/flink/pull/8414#issuecomment-491294860
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request.
[
https://issues.apache.org/jira/browse/FLINK-12477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12477:
---
Labels: pull-request-available (was: )
> Change threading-model in StreamTask to a
rmetzger opened a new pull request #8414: [FLINK-12477][Build] Enforce maven
version 3.1.1
URL: https://github.com/apache/flink/pull/8414
## Contribution Checklist
## What is the purpose of the change
The `frontend-maven-plugin` introduced in
fhueske commented on a change in pull request #8354: [FLINK-12421][docs-zh]
Synchronize the latest documentation changes (commits to 7b46f604) into Chinese
documents
URL: https://github.com/apache/flink/pull/8354#discussion_r282885332
##
File path: docs/dev/connectors/kafka.zh.md
[
https://issues.apache.org/jira/browse/FLINK-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jack reassigned FLINK-12428:
Assignee: jack (was: YangFei)
> Translate the "Event Time" page into Chinese
>
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r282887147
##
File path:
Piotr Nowojski created FLINK-12490:
--
Summary: Introduce NetworkInput class
Key: FLINK-12490
URL: https://issues.apache.org/jira/browse/FLINK-12490
Project: Flink
Issue Type: Sub-task
GJL closed pull request #8130: [FLINK-12053][runtime] Calculate job vertex
parallelism based on metrics
URL: https://github.com/apache/flink/pull/8130
This is an automated message from the Apache Git Service.
To respond to
1 - 100 of 333 matches
Mail list logo