[jira] [Created] (FLINK-12309) JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align

FaxianZhao created FLINK-12309: -- Summary: JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align Key: FLINK-12309 URL: https://issues.apache.org/jira/browse/FLINK-12309 Project: Flink

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r277975059 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/Sche

[GitHub] [flink] link3280 edited a comment on issue #8068: [FLINK-12042][StateBackends] Fix RocksDBStateBackend's mistaken usage of default filesystem

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 return

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r277975059 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/Sche

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r277970928 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/Exec

[GitHub] [flink] zhijiangW edited a comment on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes

zhijiangW edited a comment on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes URL: https://github.com/apache/flink/pull/8181#issuecomment-484820243 Thanks for the reviews @azagrebin ! If I understand correctly, the total IO

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface URL: https://github.com/apache/flink/pull/8233#discussion_r277970928 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/Exec

[jira] [Closed] (FLINK-11534) Don't exit JVM after job termination with standalone job

[ https://issues.apache.org/jira/browse/FLINK-11534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-11534. --- Resolution: Fixed Fix Version/s: 1.9.0 > Don't exit JVM after job termination with standalone

[GitHub] [flink] uce merged pull request #8188: [FLINK-11534] [container] Allow ExecutionMode configuration

uce merged pull request #8188: [FLINK-11534] [container] Allow ExecutionMode configuration URL: https://github.com/apache/flink/pull/8188 This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824834#comment-16824834 ] Dian Fu commented on FLINK-12308: - Thanks [~sunjincheng121] for creating this ticket. A

[GitHub] [flink] wuchong commented on issue #8234: [FLINK-12288] [table-planner-blink] Bump Calcite dependency to 1.19.0 in blink planner

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 oth

[GitHub] [flink] godfreyhe commented on issue #8234: [FLINK-12288] [table-planner-blink] Bump Calcite dependency to 1.19.0 in blink planner

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 aut

[GitHub] [flink] xuefuz commented on issue #8212: [FLINK-11519][table] Add function related catalog APIs

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 autom

[jira] [Created] (FLINK-12308) Support python language in Flink Table API

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 Feat

[GitHub] [flink] Kejian-Li closed pull request #8247: Change the name of variable "log" into "LOG" to correspond to other class files.

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. T

[GitHub] [flink] Kejian-Li opened a new pull request #8247: Change the name of variable "log" into "LOG" to correspond to other class files.

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

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor

[GitHub] [flink] xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ReadableCatalog.

[GitHub] [flink] xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor

[GitHub] [flink] xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/exceptions/Funct

[GitHub] [flink] xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFunction.

[GitHub] [flink] xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFunction.

[jira] [Closed] (FLINK-4653) Refactor JobClientActor to adapt to the new Rpc framework and new cluster managerment

[ 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 > manage

[GitHub] [flink] bowenli86 commented on a change in pull request #8214: [FLINK-11476] [table] Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema

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: flink-table/flink-table-common/src/main/j

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFuncti

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFuncti

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/exceptions/Fu

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ReadableCatal

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFuncti

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFuncti

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericCata

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[GitHub] [flink] bowenli86 commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMe

[jira] [Created] (FLINK-12307) Support translation from StreamExecWindowJoin to StreamTransformation.

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

[GitHub] [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

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: flink-table/flink-table-planner-blink/src/test/resources/

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8233: [FLINK-12227] [runtime] introduce SchedulingStrategy interface

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: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/Exec

[GitHub] [flink] JingsongLi commented on a change in pull request #8234: [FLINK-12288] [table-planner-blink] Bump Calcite dependency to 1.19.0 in blink planner

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: flink-table/flink-table-planner-blink/src/test/resources

[GitHub] [flink] wuchong commented on a change in pull request #8234: [FLINK-12288] [table-planner-blink] Bump Calcite dependency to 1.19.0 in blink planner

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: flink-table/flink-table-planner-blink/src/test/resources/or

[jira] [Commented] (FLINK-11848) Delete outdated kafka topics caused UNKNOWN_TOPIC_EXCEPTIION

[ https://issues.apache.org/jira/browse/FLINK-11848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824781#comment-16824781 ] Shengnan YU commented on FLINK-11848: - It does not work, I have looked up the source

[GitHub] [flink] link3280 edited a comment on issue #8068: [FLINK-12042][StateBackends] Fix RocksDBStateBackend's mistaken usage of default filesystem

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 return

[jira] [Updated] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ 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 o

[jira] [Commented] (FLINK-11614) Translate the "Configuring Dependencies" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824772#comment-16824772 ] Jark Wu commented on FLINK-11614: - I have left comments in your pull request. [~yangfei]

[GitHub] [flink] wuchong commented on issue #8200: [FLINK-11614] [docs-zh] Translate the "Configuring Dependencies" page into Chinese

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 comm

[jira] [Commented] (FLINK-11636) Translate "State Schema Evolution" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824762#comment-16824762 ] Congxian Qiu(klion26) commented on FLINK-11636: --- [~yangfei] Now I'm not wo

[GitHub] [flink] JingsongLi commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFunct

[GitHub] [flink] JingsongLi commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFunct

[GitHub] [flink] JingsongLi commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFunct

[GitHub] [flink] JingsongLi commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ReadableWrit

[GitHub] [flink] JingsongLi commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFunct

[GitHub] [flink] JingsongLi commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInM

[GitHub] [flink] JingsongLi commented on a change in pull request #8212: [FLINK-11519][table] Add function related catalog APIs

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: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFunct

[jira] [Commented] (FLINK-11636) Translate "State Schema Evolution" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824761#comment-16824761 ] YangFei commented on FLINK-11636: - Hi [~klion26] , I want to know if you are working on

[jira] [Commented] (FLINK-11614) Translate the "Configuring Dependencies" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824755#comment-16824755 ] YangFei commented on FLINK-11614: - Hi [~jark].  I have made some changes after reading 

[jira] [Issue Comment Deleted] (FLINK-11614) Translate the "Configuring Dependencies" page into Chinese

[ 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 Specifi

[jira] [Commented] (FLINK-11614) Translate the "Configuring Dependencies" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824754#comment-16824754 ] YangFei commented on FLINK-11614: - Hi JarkWu . I have made some changes after reading [“

[GitHub] [flink] link3280 commented on issue #8068: [FLINK-12042][StateBackends] Fix RocksDBStateBackend's mistaken usage of default filesystem

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 loca

[GitHub] [flink] liyafan82 commented on a change in pull request #8236: [FLINK-12289][flink-runtime]Fix bugs and typos in Memory manager

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

[jira] [Updated] (FLINK-11945) Support over aggregation for blink streaming runtime

[ 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) >

[GitHub] [flink] Aitozi commented on a change in pull request #8236: [FLINK-12289][flink-runtime]Fix bugs and typos in Memory manager

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 ##

[jira] [Assigned] (FLINK-12304) AvroInputFormat should support schema evolution

[ 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 > --

[GitHub] [flink] flinkbot commented on issue #8246: [hotfix] Add error message to precondition in HeapPriorityQueueSet

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 y

[GitHub] [flink] link3280 commented on issue #8068: [FLINK-12042][StateBackends] Fix RocksDBStateBackend's mistaken usage of default filesystem

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 `IllegalStat

[GitHub] [flink] sjwiesman opened a new pull request #8246: [hotfix] Add error message to precondition in HeapPriorityQueueSet

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

[GitHub] [flink] liyafan82 commented on a change in pull request #8236: [FLINK-12289][flink-runtime]Fix bugs and typos in Memory manager

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

[GitHub] [flink] Aitozi closed pull request #4935: [Flink-7945][Metrics&connector]Fix per partition-lag metric lost in kafka connector

Aitozi closed pull request #4935: [Flink-7945][Metrics&connector]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.

[GitHub] [flink] Aitozi closed pull request #7543: [FLINK-10996]Fix the possible state leak with CEP processing time model

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 to

[jira] [Updated] (FLINK-10972) Enhancements to Flink Table API

[ 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 > --- > >

[jira] [Updated] (FLINK-12306) Change the name of variable "log" to Upper case "LOG"

[ 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 "

[GitHub] [flink] Kejian-Li closed pull request #8245: Change the name of variable "log" to upper case "LOG"

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, p

[GitHub] [flink] bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/ja

[jira] [Updated] (FLINK-12306) Change the name of variable "log" to Upper case "LOG"

[ 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 U

[GitHub] [flink] flinkbot commented on issue #8245: Change the name of variable "log" to upper case "LOG"

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 requ

[GitHub] [flink] Kejian-Li opened a new pull request #8245: Change the name of variable "log" to upper case "LOG"

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.

[GitHub] [flink] Kejian-Li closed pull request #8241: Update MainThreadValidatorUtil.java

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 Git

[jira] [Created] (FLINK-12306) Change the name of variable "log" to Upper case "LOG"

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: I

[GitHub] [flink] Kejian-Li commented on issue #8241: Update MainThreadValidatorUtil.java

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

[GitHub] [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

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: flink-table/flink-table-planner-blink/src/test/resources/

[GitHub] [flink] xuefuz commented on a change in pull request #8205: [FLINK-12238] [hive] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

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: flink-connectors/fli

[jira] [Created] (FLINK-12305) Table API Clarification

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 Compo

[GitHub] [flink] bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/ja

[GitHub] [flink] bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/ja

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16824491#comment-16824491 ] seed Z commented on FLINK-12296: Unchaining the operator makes the new job be able to sa

[GitHub] [flink] bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/ja

[GitHub] [flink] bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/ja

[GitHub] [flink] bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/ja

[GitHub] [flink] bowenli86 commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/ja

[GitHub] [flink] ijuma commented on issue #7156: [FLINK-10967] Update kafka dependency to 2.2.0

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. :) ---

[GitHub] [flink] xuefuz commented on a change in pull request #8214: [FLINK-11476] [table] Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema

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: flink-table/flink-table-common/src/main/java

[GitHub] [flink] xuefuz commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/java/

[GitHub] [flink] xuefuz commented on a change in pull request #8222: [FLINK-11518] [table] Add partition related catalog APIs and implement them in GenericInMemoryCatalog

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: flink-table/flink-table-common/src/main/java/

  1   2   3   4   >