[
https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824834#comment-16824834
]
Dian Fu commented on FLINK-12308:
-
Thanks [~sunjincheng121] for creating this ticket. A big +1 on this
wuchong commented on issue #8234: [FLINK-12288] [table-planner-blink] Bump
Calcite dependency to 1.19.0 in blink planner
URL: https://github.com/apache/flink/pull/8234#issuecomment-486071536
Thanks @godfreyhe .
Hi @walterddr @twalthr @KurtYoung , I will merge this if you have no
godfreyhe commented on issue #8234: [FLINK-12288] [table-planner-blink] Bump
Calcite dependency to 1.19.0 in blink planner
URL: https://github.com/apache/flink/pull/8234#issuecomment-486071031
LGTM, +1 to merge
This is an
xuefuz commented on issue #8212: [FLINK-11519][table] Add function related
catalog APIs
URL: https://github.com/apache/flink/pull/8212#issuecomment-486070424
Pushed more updates based on review feedback here.
This is an
sunjincheng created FLINK-12308:
---
Summary: Support python language in Flink Table API
Key: FLINK-12308
URL: https://issues.apache.org/jira/browse/FLINK-12308
Project: Flink
Issue Type: New
Kejian-Li closed pull request #8247: Change the name of variable "log" into
"LOG" to correspond to other class files.
URL: https://github.com/apache/flink/pull/8247
This is an automated message from the Apache Git Service.
Kejian-Li opened a new pull request #8247: Change the name of variable "log"
into "LOG" to correspond to other class files.
URL: https://github.com/apache/flink/pull/8247
## What is the purpose of the change
change the name of variable "log" into "LOG" to correspond to other
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277954981
##
File path:
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277953303
##
File path:
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277954019
##
File path:
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277953303
##
File path:
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277953161
##
File path:
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277952965
##
File path:
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277950610
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang closed FLINK-4653.
-
Resolution: Invalid
> Refactor JobClientActor to adapt to the new Rpc framework and new cluster
>
bowenli86 commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r277950481
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277948967
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277949377
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277948682
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277949973
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r27795
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277949417
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277950050
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277948110
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277949318
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277949341
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277949437
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277950075
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277949134
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277950023
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277947738
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277948736
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277948627
##
File path:
bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277949400
##
File path:
Jing Zhang created FLINK-12307:
--
Summary: Support translation from StreamExecWindowJoin to
StreamTransformation.
Key: FLINK-12307
URL: https://issues.apache.org/jira/browse/FLINK-12307
Project: Flink
walterddr commented on a change in pull request #8234: [FLINK-12288]
[table-planner-blink] Bump Calcite dependency to 1.19.0 in blink planner
URL: https://github.com/apache/flink/pull/8234#discussion_r277949412
##
File path:
eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227]
[runtime] introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r277948095
##
File path:
JingsongLi commented on a change in pull request #8234: [FLINK-12288]
[table-planner-blink] Bump Calcite dependency to 1.19.0 in blink planner
URL: https://github.com/apache/flink/pull/8234#discussion_r277948264
##
File path:
wuchong commented on a change in pull request #8234: [FLINK-12288]
[table-planner-blink] Bump Calcite dependency to 1.19.0 in blink planner
URL: https://github.com/apache/flink/pull/8234#discussion_r277944655
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824781#comment-16824781
]
Shengnan YU commented on FLINK-11848:
-
It does not work, I have looked up the source code. Flink
link3280 edited a comment on issue #8068: [FLINK-12042][StateBackends] Fix
RocksDBStateBackend's mistaken usage of default filesystem
URL: https://github.com/apache/flink/pull/8068#issuecomment-486042889
> Moreover, I was wondering whether `SnapshotDirectory.temporary` should
always
[
https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu(klion26) updated FLINK-12296:
--
Description:
As the mail list said[1], there may be a problem when more than
[
https://issues.apache.org/jira/browse/FLINK-11614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824772#comment-16824772
]
Jark Wu commented on FLINK-11614:
-
I have left comments in your pull request. [~yangfei]
> Translate
wuchong commented on issue #8200: [FLINK-11614] [docs-zh] Translate the
"Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#issuecomment-486050262
Hi @Leev , please do not MERGE master. You can use `IDEA > VCS > Git >
Rebase` tool to rebase
[
https://issues.apache.org/jira/browse/FLINK-11636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824762#comment-16824762
]
Congxian Qiu(klion26) commented on FLINK-11636:
---
[~yangfei] Now I'm not working on it,
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277934970
##
File path:
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277936243
##
File path:
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277932067
##
File path:
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277937225
##
File path:
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277934671
##
File path:
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277936838
##
File path:
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r277934944
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824761#comment-16824761
]
YangFei commented on FLINK-11636:
-
Hi [~klion26] , I want to know if you are working on this issue .If
[
https://issues.apache.org/jira/browse/FLINK-11614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824755#comment-16824755
]
YangFei commented on FLINK-11614:
-
Hi [~jark].
I have made some changes after reading [“Flink
[
https://issues.apache.org/jira/browse/FLINK-11614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YangFei updated FLINK-11614:
Comment: was deleted
(was: Hi JarkWu . I have made some changes after reading [“Flink Translation
[
https://issues.apache.org/jira/browse/FLINK-11614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824754#comment-16824754
]
YangFei commented on FLINK-11614:
-
Hi JarkWu . I have made some changes after reading [“Flink
link3280 commented on issue #8068: [FLINK-12042][StateBackends] Fix
RocksDBStateBackend's mistaken usage of default filesystem
URL: https://github.com/apache/flink/pull/8068#issuecomment-486042889
> Moreover, I was wondering whether `SnapshotDirectory.temporary` should
always return a
liyafan82 commented on a change in pull request #8236:
[FLINK-12289][flink-runtime]Fix bugs and typos in Memory manager
URL: https://github.com/apache/flink/pull/8236#discussion_r277935627
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
[
https://issues.apache.org/jira/browse/FLINK-11945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-11945:
Summary: Support over aggregation for blink streaming runtime (was:
Support Over aggregation for SQL)
>
Aitozi commented on a change in pull request #8236:
[FLINK-12289][flink-runtime]Fix bugs and typos in Memory manager
URL: https://github.com/apache/flink/pull/8236#discussion_r277933794
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
[
https://issues.apache.org/jira/browse/FLINK-12304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-12304:
Assignee: vinoyang
> AvroInputFormat should support schema evolution
>
flinkbot commented on issue #8246: [hotfix] Add error message to precondition
in HeapPriorityQueueSet
URL: https://github.com/apache/flink/pull/8246#issuecomment-486039200
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
link3280 commented on issue #8068: [FLINK-12042][StateBackends] Fix
RocksDBStateBackend's mistaken usage of default filesystem
URL: https://github.com/apache/flink/pull/8068#issuecomment-486039068
Thanks for the review @tillrohrmann!
To answer the first three questions: the
sjwiesman opened a new pull request #8246: [hotfix] Add error message to
precondition in HeapPriorityQueueSet
URL: https://github.com/apache/flink/pull/8246
## What is the purpose of the change
Add error message to precondition in HeapPriorityQueueSet
## Verifying this change
liyafan82 commented on a change in pull request #8236:
[FLINK-12289][flink-runtime]Fix bugs and typos in Memory manager
URL: https://github.com/apache/flink/pull/8236#discussion_r277931471
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java
Aitozi closed pull request #4935: [Flink-7945][Metrics]Fix per
partition-lag metric lost in kafka connector
URL: https://github.com/apache/flink/pull/4935
This is an automated message from the Apache Git Service.
To
Aitozi closed pull request #7543: [FLINK-10996]Fix the possible state leak with
CEP processing time model
URL: https://github.com/apache/flink/pull/7543
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-10972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-10972:
Affects Version/s: 1.9.0
> Enhancements to Flink Table API
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-12306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kejian Li updated FLINK-12306:
--
External issue URL: (was: https://github.com/apache/flink/pull/8245)
> Change the name of variable
Kejian-Li closed pull request #8245: Change the name of variable "log" to upper
case "LOG"
URL: https://github.com/apache/flink/pull/8245
This is an automated message from the Apache Git Service.
To respond to the message,
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277851836
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kejian Li updated FLINK-12306:
--
External issue URL: https://github.com/apache/flink/pull/8245
> Change the name of variable "log" to
flinkbot commented on issue #8245: Change the name of variable "log" to upper
case "LOG"
URL: https://github.com/apache/flink/pull/8245#issuecomment-486030536
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
Kejian-Li opened a new pull request #8245: Change the name of variable "log" to
upper case "LOG"
URL: https://github.com/apache/flink/pull/8245
## What is the purpose of the change
Change the name of variable "log" to upper case "LOG" to correspond to other
class files.
Kejian-Li closed pull request #8241: Update MainThreadValidatorUtil.java
URL: https://github.com/apache/flink/pull/8241
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Kejian Li created FLINK-12306:
-
Summary: Change the name of variable "log" to Upper case "LOG"
Key: FLINK-12306
URL: https://issues.apache.org/jira/browse/FLINK-12306
Project: Flink
Issue Type:
Kejian-Li commented on issue #8241: Update MainThreadValidatorUtil.java
URL: https://github.com/apache/flink/pull/8241#issuecomment-486024371
> @Kejian-Li thanks for your contribution, I think the target branch should
be `master` and please update the title and description according to the
walterddr commented on a change in pull request #8234: [FLINK-12288]
[table-planner-blink] Bump Calcite dependency to 1.19.0 in blink planner
URL: https://github.com/apache/flink/pull/8234#discussion_r277912372
##
File path:
xuefuz commented on a change in pull request #8205: [FLINK-12238] [hive]
Support database related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#discussion_r277893627
##
File path:
Alex Barnes created FLINK-12305:
---
Summary: Table API Clarification
Key: FLINK-12305
URL: https://issues.apache.org/jira/browse/FLINK-12305
Project: Flink
Issue Type: Improvement
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277853190
##
File path:
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277853190
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824491#comment-16824491
]
seed Z commented on FLINK-12296:
Unchaining the operator makes the new job be able to save the state via
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277851836
##
File path:
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277851366
##
File path:
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277851183
##
File path:
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277849954
##
File path:
ijuma commented on issue #7156: [FLINK-10967] Update kafka dependency to 2.2.0
URL: https://github.com/apache/flink/pull/7156#issuecomment-485949235
Thanks for the reference. I'll close this PR. Hopefully #8055 gets reviewed
and merged more quickly than this one. :)
xuefuz commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r277833211
##
File path:
xuefuz commented on a change in pull request #8222: [FLINK-11518] [table] Add
partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277790658
##
File path:
xuefuz commented on a change in pull request #8222: [FLINK-11518] [table] Add
partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277804076
##
File path:
xuefuz commented on a change in pull request #8222: [FLINK-11518] [table] Add
partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277804076
##
File path:
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277803504
##
File path:
bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277801129
##
File path:
bowenli86 commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r277796313
##
File path:
bowenli86 commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r277796069
##
File path:
xuefuz commented on a change in pull request #8222: [FLINK-11518] [table] Add
partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277794804
##
File path:
dawidwys commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r277795351
##
File path:
xuefuz commented on a change in pull request #8222: [FLINK-11518] [table] Add
partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r277795191
##
File path:
dawidwys commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r277793581
##
File path:
1 - 100 of 368 matches
Mail list logo