[jira] [Closed] (FLINK-11309) Make SpillableSubpartition repeatably read to enable

[ https://issues.apache.org/jira/browse/FLINK-11309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang closed FLINK-11309. -- Resolution: Fixed > Make SpillableSubpartition repeatably read to enable >

[jira] [Commented] (FLINK-12481) Make processing time timer trigger run via the mailbox

[ https://issues.apache.org/jira/browse/FLINK-12481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838280#comment-16838280 ] aitozi commented on FLINK-12481: Hi, [~srichter] After going through the doc of this feature, I think it

[GitHub] [flink] yuyang08 edited a comment on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink

yuyang08 edited a comment on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink URL: https://github.com/apache/flink/pull/8067#issuecomment-491611680 @Myasuka Updated the pr to fix build failure, and handle thrift binaries from different code generators. With this

[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r283183410 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r283183237 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r283183177 ## File path:

[jira] [Assigned] (FLINK-12494) JDBCOutputFormat support reconnect when link failure and flush by timeInterval

[ https://issues.apache.org/jira/browse/FLINK-12494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhaoshijie reassigned FLINK-12494: -- Assignee: (was: zhaoshijie) > JDBCOutputFormat support reconnect when link failure and

[jira] [Updated] (FLINK-12494) JDBCOutputFormat support reconnect when link failure and flush by timeInterval

[ https://issues.apache.org/jira/browse/FLINK-12494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhaoshijie updated FLINK-12494: --- Description: when i JDBCSink(flink-1.4.2) wite recode to mysql,find exception as flow :  

[jira] [Assigned] (FLINK-12494) JDBCOutputFormat support reconnect when link failure and flush by timeInterval

[ https://issues.apache.org/jira/browse/FLINK-12494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhaoshijie reassigned FLINK-12494: -- Assignee: zhaoshijie > JDBCOutputFormat support reconnect when link failure and flush by

[jira] [Created] (FLINK-12494) JDBCOutputFormat support reconnect when link failure and flush by timeInterval

zhaoshijie created FLINK-12494: -- Summary: JDBCOutputFormat support reconnect when link failure and flush by timeInterval Key: FLINK-12494 URL: https://issues.apache.org/jira/browse/FLINK-12494 Project:

[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r283180286 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r283180077 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r283179736 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

godfreyhe commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356#discussion_r283179812 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

zhijiangW commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r283179736 ## File path:

[GitHub] [flink] sunnyholyd commented on issue #7803: [FLINK-11606][chinese-translation,Documentation] Translate the "Distr…

sunnyholyd commented on issue #7803: [FLINK-11606][chinese-translation,Documentation] Translate the "Distr… URL: https://github.com/apache/flink/pull/7803#issuecomment-491664888 Hi @wuchong , I have rebase my commit to the latest master, please start review, thanks.

[GitHub] [flink] KurtYoung commented on issue #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

KurtYoung 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-491664650 Thanks @XuQianJin-Stars for the PR, i will try to take a look soon.

[jira] [Closed] (FLINK-12457) Remove char support in blink

[ https://issues.apache.org/jira/browse/FLINK-12457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12457. -- Resolution: Fixed Fix Version/s: 1.9.0 merged in 1.9.0:

[GitHub] [flink] KurtYoung merged pull request #8379: [FLINK-12457][table-planner-blink] Remove char support in blink

KurtYoung merged pull request #8379: [FLINK-12457][table-planner-blink] Remove char support in blink URL: https://github.com/apache/flink/pull/8379 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] KurtYoung commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

KurtYoung commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356#discussion_r283178387 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283174870 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283174796 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283164112 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283162046 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283175328 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283164397 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283166175 ## File path: docs/dev/table/tableApi.md ## @@ -2066,16 +2066,37 @@ Table

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283169490 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283163670 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API

sunjincheng121 commented on a change in pull request #8359: [FLINK-11051][table] Add streaming window FlatAggregate to Table API URL: https://github.com/apache/flink/pull/8359#discussion_r283162404 ## File path:

[jira] [Commented] (FLINK-12428) Translate the "Event Time" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838231#comment-16838231 ] YangFei commented on FLINK-12428: - [~lyy900111] I have not started to do this issue . You can do that >

[GitHub] [flink] godfreyhe commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

godfreyhe commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356#discussion_r283175327 ## File path:

[GitHub] [flink] wuchong commented on issue #8244: [FLINK-11945] [table-runtime-blink] Support over aggregation for blink streaming runtime

wuchong 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-491659910 Thanks for the contribution @XuQianJin-Stars . It looks good to me now. @KurtYoung do

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283169262 ## File path: flink-python/pyflink/table/table.py ## @@ -118,3 +463,112 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283168926 ## File path: flink-python/pyflink/table/table.py ## @@ -118,3 +463,112 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283168536 ## File path: flink-python/pyflink/table/table.py ## @@ -106,6 +113,344 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283172434 ## File path: flink-python/pyflink/table/table_config.py ## @@ -44,18 +47,55 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283167182 ## File path: flink-python/pyflink/table/table.py ## @@ -106,6 +113,344 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283166998 ## File path: flink-python/pyflink/table/table.py ## @@ -106,6 +113,344 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283169049 ## File path: flink-python/pyflink/table/table.py ## @@ -118,3 +463,112 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283169083 ## File path: flink-python/pyflink/table/table.py ## @@ -118,3 +463,112 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283172563 ## File path: flink-python/pyflink/table/table_config.py ## @@ -44,18 +47,55 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r283174219 ## File path: flink-python/pyflink/table/window.py ## @@ -0,0 +1,482 @@

[GitHub] [flink] carryxyh commented on issue #8243: [FLINK-12299] ExecutionConfig#setAutoWatermarkInterval should check param(interval should not less than zero)

carryxyh commented on issue #8243: [FLINK-12299] ExecutionConfig#setAutoWatermarkInterval should check param(interval should not less than zero) URL: https://github.com/apache/flink/pull/8243#issuecomment-491659489 @zentol Fix it soon. Thx for your review.

[GitHub] [flink] JingsongLi commented on issue #8379: [FLINK-12457][table-planner-blink] Remove char support in blink

JingsongLi commented on issue #8379: [FLINK-12457][table-planner-blink] Remove char support in blink URL: https://github.com/apache/flink/pull/8379#issuecomment-491659432 > LGTM，btw does flink planner support CHAR right? In flink planner: There are some useless code (three lines)

[GitHub] [flink] beyond1920 commented on issue #8389: [FLINK-12399][table] Fix FilterableTableSource does not change after applyPredicate

beyond1920 commented on issue #8389: [FLINK-12399][table] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8389#issuecomment-491659360 @walterddr good catch, we also encountered the problem in Blink before. The key question is

[GitHub] [flink] tianchen92 edited a comment on issue #8121: [FLINK-10437]Some of keys under withDeprecatedKeys aren't marked as @…

tianchen92 edited a comment on issue #8121: [FLINK-10437]Some of keys under withDeprecatedKeys aren't marked as @… URL: https://github.com/apache/flink/pull/8121#issuecomment-481077070 Hi, @zentol could you please help review this PR? thanks very much!

[GitHub] [flink] tianchen92 commented on issue #8171: [FLINK-9542]ExEnv#registerCachedFile should accept Path

tianchen92 commented on issue #8171: [FLINK-9542]ExEnv#registerCachedFile should accept Path URL: https://github.com/apache/flink/pull/8171#issuecomment-491658630 @zentol Could you please help review this PR? thanks very much!

[GitHub] [flink] tianchen92 opened a new pull request #8266: [FLINK-9904]Allow users to control MaxDirectMemorySize

tianchen92 opened a new pull request #8266: [FLINK-9904]Allow users to control MaxDirectMemorySize URL: https://github.com/apache/flink/pull/8266 ## What is the purpose of the change *This PR is related to [FLINK-9904](https://issues.apache.org/jira/browse/FLINK-9904). Make

[GitHub] [flink] tianchen92 closed pull request #8266: [FLINK-9904]Allow users to control MaxDirectMemorySize

tianchen92 closed pull request #8266: [FLINK-9904]Allow users to control MaxDirectMemorySize URL: https://github.com/apache/flink/pull/8266 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] shaoxuan-wang commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

shaoxuan-wang commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r283172319 ## File path: flink-ml/pom.xml ## @@ -0,0 +1,39 @@ + +

[jira] [Commented] (FLINK-11214) Support non mergable aggregates for group windows on batch table

[ https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838216#comment-16838216 ] Dian Fu commented on FLINK-11214: - Sounds good. BYW, you can take this ticket and continue the work. :)

[jira] [Assigned] (FLINK-11214) Support non mergable aggregates for group windows on batch table

[ https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-11214: --- Assignee: (was: Dian Fu) > Support non mergable aggregates for group windows on batch table >

[jira] [Commented] (FLINK-11214) Support non mergable aggregates for group windows on batch table

[ https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16838211#comment-16838211 ] Hequn Cheng commented on FLINK-11214: - [~dian.fu] Hi, great job! Thanks for reporting this problem

[GitHub] [flink] KurtYoung commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

KurtYoung commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356#discussion_r283169722 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

KurtYoung commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356#discussion_r283169137 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization

KurtYoung commented on a change in pull request #8356: [FLINK-12424] [table-planner-blink] Supports dag (multiple-sinks query) optimization URL: https://github.com/apache/flink/pull/8356#discussion_r283168624 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

bowenli86 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r283168261 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

bowenli86 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r283166023 ## File path: flink-ml/flink-ml-api/pom.xml ## @@ -0,0 +1,45 @@ + +

[GitHub] [flink] bowenli86 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

bowenli86 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r283167391 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java

[GitHub] [flink] KurtYoung commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime

KurtYoung commented on a change in pull request #8302: [FLINK-12269][table-blink] Support Temporal Table Join in blink planner and runtime URL: https://github.com/apache/flink/pull/8302#discussion_r283168033 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8407: [FLINK-12374][table-planner-blink] Support translation from StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransfor

KurtYoung commented on a change in pull request #8407: [FLINK-12374][table-planner-blink] Support translation from StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransformation. URL: https://github.com/apache/flink/pull/8407#discussion_r283167016 ## File path:

[jira] [Closed] (FLINK-12487) Introduce planner rules to rewrite expression and merge calc

[ https://issues.apache.org/jira/browse/FLINK-12487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12487. -- Resolution: Implemented Fix Version/s: 1.9.0 merge in 1.9.0:

[GitHub] [flink] dianfu commented on a change in pull request #8392: [FLINK-12370][python][travis] Integrated Travis for Python Table API.

dianfu commented on a change in pull request #8392: [FLINK-12370][python][travis] Integrated Travis for Python Table API. URL: https://github.com/apache/flink/pull/8392#discussion_r283166413 ## File path: tools/travis_python_watchdog.sh ## @@ -0,0 +1,196 @@

[GitHub] [flink] KurtYoung merged pull request #8411: [FLINK-12487] [table-planner-blink] Introduce planner rules to rewrite expression and merge calc

KurtYoung merged pull request #8411: [FLINK-12487] [table-planner-blink] Introduce planner rules to rewrite expression and merge calc URL: https://github.com/apache/flink/pull/8411 This is an automated message from the

[GitHub] [flink] dianfu commented on a change in pull request #8392: [FLINK-12370][python][travis] Integrated Travis for Python Table API.

dianfu commented on a change in pull request #8392: [FLINK-12370][python][travis] Integrated Travis for Python Table API. URL: https://github.com/apache/flink/pull/8392#discussion_r283164819 ## File path: tools/travis/stage.sh ## @@ -23,6 +23,7 @@

[jira] [Updated] (FLINK-12485) Add a tool to check the user interface of Python Table API aligns with Java Table API.

[ https://issues.apache.org/jira/browse/FLINK-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12485: Description: After FLINK-12407 Python Table API will align with current Java Table API. So, In

[jira] [Updated] (FLINK-12485) Add a tool to check the user interface of Python Table API aligns with Java Table API.

[ https://issues.apache.org/jira/browse/FLINK-12485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12485: Environment:     was: After FLINK-12407 Python Table API will align with current Java Table

[GitHub] [flink] flinkbot edited a comment on issue #8338: [BP-1.6][FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators

flinkbot edited a comment on issue #8338: [BP-1.6][FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators URL: https://github.com/apache/flink/pull/8338#issuecomment-489284633 Thanks a lot for your contribution to the Apache Flink

[GitHub] [flink] klion26 commented on issue #8338: [BP-1.6][FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators

klion26 commented on issue #8338: [BP-1.6][FLINK-12296][StateBackend] Fix local state directory collision with state loss for chained keyed operators URL: https://github.com/apache/flink/pull/8338#issuecomment-491642057 @flinkbot attention @StefanRRichter

[GitHub] [flink] walterddr commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

walterddr commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r283158556 ## File path: flink-ml/pom.xml ## @@ -0,0 +1,39 @@ + +

[GitHub] [flink] flinkbot commented on issue #8422: FLINK-12493 [docs] Add step to export Hadoop classpath

flinkbot commented on issue #8422: FLINK-12493 [docs] Add step to export Hadoop classpath URL: https://github.com/apache/flink/pull/8422#issuecomment-491633527 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-12493) AWS EMR instructions lead to ClassNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-12493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12493: --- Labels: pull-request-available (was: ) > AWS EMR instructions lead to

[GitHub] [flink] a-romero opened a new pull request #8422: FLINK-12493 [docs] Add step to export Hadoop classpath

a-romero opened a new pull request #8422: FLINK-12493 [docs] Add step to export Hadoop classpath URL: https://github.com/apache/flink/pull/8422 ## What is the purpose of the change Add reference to ensure Hadoop classpath is present before submitting jobs to EMR.

[GitHub] [flink] yuyang08 edited a comment on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink

yuyang08 edited a comment on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink URL: https://github.com/apache/flink/pull/8067#issuecomment-491611680 @Myasuka With this change, we can use the following code to have `ThriftSerializer` work with Flink SQL. Any reason

[jira] [Updated] (FLINK-12493) AWS EMR instructions lead to ClassNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-12493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alberto Romero updated FLINK-12493: --- Priority: Major (was: Critical) > AWS EMR instructions lead to ClassNotFoundException >

[jira] [Created] (FLINK-12493) AWS EMR instructions lead to ClassNotFoundException

Alberto Romero created FLINK-12493: -- Summary: AWS EMR instructions lead to ClassNotFoundException Key: FLINK-12493 URL: https://issues.apache.org/jira/browse/FLINK-12493 Project: Flink

[GitHub] [flink] yuyang08 edited a comment on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink

yuyang08 edited a comment on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink URL: https://github.com/apache/flink/pull/8067#issuecomment-491611680 @Myasuka With this change, we can use the following code to have `ThriftSerializer` work with Flink SQL. Any reason

[GitHub] [flink] yuyang08 edited a comment on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink

yuyang08 edited a comment on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink URL: https://github.com/apache/flink/pull/8067#issuecomment-491611680 @Myasuka With this change, we can use the following code to have `ThriftSerializer` work with Flink SQL. Any reason

[GitHub] [flink] yuyang08 commented on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink

yuyang08 commented on issue #8067: [FLINK-11746][formats] Add thrift format support to Flink URL: https://github.com/apache/flink/pull/8067#issuecomment-491611680 @Myasuka With this change, we can use the following code to have `ThriftSerializer` work with Flink SQL. Any reason that we

[GitHub] [flink] flinkbot edited a comment on issue #8421: [FLINK-12492]Minor optimize the cep operator by avoiding unnecessary copy

flinkbot edited a comment on issue #8421: [FLINK-12492]Minor optimize the cep operator by avoiding unnecessary copy URL: https://github.com/apache/flink/pull/8421#issuecomment-491605949 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] Aitozi commented on issue #8421: [FLINK-12492]Minor optimize the cep operator by avoiding unnecessary copy

Aitozi commented on issue #8421: [FLINK-12492]Minor optimize the cep operator by avoiding unnecessary copy URL: https://github.com/apache/flink/pull/8421#issuecomment-491605962 @flinkbot attention @dawidwys This is an

[jira] [Updated] (FLINK-12492) Minor optimize the cep operator by avoiding unnecessary copy

[ https://issues.apache.org/jira/browse/FLINK-12492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12492: --- Labels: pull-request-available (was: ) > Minor optimize the cep operator by avoiding

[GitHub] [flink] flinkbot commented on issue #8421: [FLINK-12492]Minor optimize the cep operator by avoiding unnecessary copy

flinkbot commented on issue #8421: [FLINK-12492]Minor optimize the cep operator by avoiding unnecessary copy URL: https://github.com/apache/flink/pull/8421#issuecomment-491605949 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] Aitozi opened a new pull request #8421: [FLINK-12492]Minor optimize the cep operator by avoiding unnecessary copy

Aitozi opened a new pull request #8421: [FLINK-12492]Minor optimize the cep operator by avoiding unnecessary copy URL: https://github.com/apache/flink/pull/8421 ## What is the purpose of the change When use with rocksdbbackend, we can skip the copy of input events. But to make this

[jira] [Created] (FLINK-12492) Minor optimize the cep operator by avoiding unnecessary copy

aitozi created FLINK-12492: -- Summary: Minor optimize the cep operator by avoiding unnecessary copy Key: FLINK-12492 URL: https://issues.apache.org/jira/browse/FLINK-12492 Project: Flink Issue

[GitHub] [flink] flinkbot commented on issue #8420: [FLINK-12408][python] Allow to define the data types in Python

flinkbot commented on issue #8420: [FLINK-12408][python] Allow to define the data types in Python URL: https://github.com/apache/flink/pull/8420#issuecomment-491604302 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-12408) Support to define all kinds of types in Python API

[ https://issues.apache.org/jira/browse/FLINK-12408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12408: --- Labels: pull-request-available (was: ) > Support to define all kinds of types in Python

[GitHub] [flink] dianfu opened a new pull request #8420: [FLINK-12408][python] Allow to define the data types in Python

dianfu opened a new pull request #8420: [FLINK-12408][python] Allow to define the data types in Python URL: https://github.com/apache/flink/pull/8420 ## What is the purpose of the change *This pull request adds the basic types in Python to allow to define data types in Python*

[GitHub] [flink] ex00 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

ex00 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r283131754 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/ParamInfo.java

[GitHub] [flink] ex00 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

ex00 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r283131882 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java

[GitHub] [flink] ex00 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib

ex00 commented on a change in pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib URL: https://github.com/apache/flink/pull/8402#discussion_r283130149 ## File path: flink-ml/flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java

[GitHub] [flink] wuchong commented on a change in pull request #8354: [FLINK-12421][docs-zh] Synchronize the latest documentation changes (commits to 7b46f604) into Chinese documents

wuchong 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_r283128011 ## File path: docs/dev/connectors/kafka.zh.md

[jira] [Assigned] (FLINK-12413) Implement ExecutionFailureHandler

[ https://issues.apache.org/jira/browse/FLINK-12413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-12413: --- Assignee: Zhu Zhu (was: Gary Yao) > Implement ExecutionFailureHandler >

[GitHub] [flink] yuyang08 opened a new pull request #8067: [FLINK-11746][formats] Add thrift format support to Flink

yuyang08 opened a new pull request #8067: [FLINK-11746][formats] Add thrift format support to Flink URL: https://github.com/apache/flink/pull/8067 ## What is the purpose of the change `org.apache.flink.api.java.typeutils.TypeExtractor` is not able to construct TypeInformation

[GitHub] [flink] Aitozi edited a comment on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function

Aitozi edited a comment on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle the wrapped function URL: https://github.com/apache/flink/pull/8280#issuecomment-491563946 Hi, @StephanEwen I have followed your suggestion to add some fix. Still two have to confim: 1. check at the