[jira] [Created] (FLINK-12248) Support e2e over window in blink batch

Jingsong Lee created FLINK-12248: Summary: Support e2e over window in blink batch Key: FLINK-12248 URL: https://issues.apache.org/jira/browse/FLINK-12248 Project: Flink Issue Type: New

[GitHub] [flink] bowenli86 opened a new pull request #8205: [FLINK-12238] [TABLE/SQL] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

bowenli86 opened a new pull request #8205: [FLINK-12238] [TABLE/SQL] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205 ## What is the purpose of the change This PR creates

[GitHub] [flink] yanghua commented on a change in pull request #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0

yanghua commented on a change in pull request #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 URL: https://github.com/apache/flink/pull/8055#discussion_r276531766 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client.sh ## @@

[GitHub] [flink] yanghua commented on issue #7718: [FLINK-10718] Use IO executor in RpcService for message serialization

yanghua commented on issue #7718: [FLINK-10718] Use IO executor in RpcService for message serialization URL: https://github.com/apache/flink/pull/7718#issuecomment-484374317 Hi @tillrohrmann this PR holds a long time, can you view it? Thanks.

[GitHub] [flink] sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface

sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface URL: https://github.com/apache/flink/pull/8124#discussion_r276532049 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276531613 ## File path:

[GitHub] [flink] flinkbot commented on issue #8205: [FLINK-12238] [TABLE/SQL] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

flinkbot commented on issue #8205: [FLINK-12238] [TABLE/SQL] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-484369983 Thanks a lot for your contribution to the Apache

[jira] [Updated] (FLINK-12238) Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

[ https://issues.apache.org/jira/browse/FLINK-12238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12238: --- Labels: pull-request-available (was: ) > Support database related operations in

[jira] [Created] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

lamber-ken created FLINK-12246: -- Summary: can't get any option from the jobConfiguration of JobGraph Key: FLINK-12246 URL: https://issues.apache.org/jira/browse/FLINK-12246 Project: Flink Issue

[GitHub] [flink] yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276531537 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276534055 ## File path:

[GitHub] [flink] bowenli86 commented on issue #8205: [FLINK-12238] [TABLE/SQL] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module

bowenli86 commented on issue #8205: [FLINK-12238] [TABLE/SQL] Support database related operations in GenericHiveMetastoreCatalog and setup flink-connector-hive module URL: https://github.com/apache/flink/pull/8205#issuecomment-484370443 cc @sunjincheng121 @xuefuz

[jira] [Commented] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

[ https://issues.apache.org/jira/browse/FLINK-12246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820763#comment-16820763 ] Liya Fan commented on FLINK-12246: -- Thanks for opening this issue. I do not see this is a problem. The

[GitHub] [flink] sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface

sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface URL: https://github.com/apache/flink/pull/8124#discussion_r276532049 ## File path:

[jira] [Created] (FLINK-12247) fix NPE when writing an archive file to a FileSystem

lamber-ken created FLINK-12247: -- Summary: fix NPE when writing an archive file to a FileSystem Key: FLINK-12247 URL: https://issues.apache.org/jira/browse/FLINK-12247 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #7718: [FLINK-10718] Use IO executor in RpcService for message serialization

flinkbot edited a comment on issue #7718: [FLINK-10718] Use IO executor in RpcService for message serialization URL: https://github.com/apache/flink/pull/7718#issuecomment-464293892 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Comment Edited] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

[ https://issues.apache.org/jira/browse/FLINK-12246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820790#comment-16820790 ] Zhu Zhu edited comment on FLINK-12246 at 4/18/19 7:56 AM: -- Currently most of

[GitHub] [flink] StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276577217 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276580234 ## File path:

[jira] [Comment Edited] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820940#comment-16820940 ] ryantaocer edited comment on FLINK-12070 at 4/18/19 10:18 AM: --

[jira] [Comment Edited] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820940#comment-16820940 ] ryantaocer edited comment on FLINK-12070 at 4/18/19 10:19 AM: --

[GitHub] [flink] tillrohrmann closed pull request #8189: [FLINK-12195] [YARN] Incorrect resource time setting causes flink to fail to submit

tillrohrmann closed pull request #8189: [FLINK-12195] [YARN] Incorrect resource time setting causes flink to fail to submit URL: https://github.com/apache/flink/pull/8189 This is an automated message from the Apache Git

[GitHub] [flink] zhijiangW commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#issuecomment-484453030 Thanks for the reviews @azagrebin @zentol I have submitted and arranged the commits

[jira] [Commented] (FLINK-12251) Rework the Table API & SQL type system

[ https://issues.apache.org/jira/browse/FLINK-12251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820971#comment-16820971 ] Kurt Young commented on FLINK-12251: Big +1 on this! > Rework the Table API & SQL type system >

[GitHub] [flink] yanghua commented on issue #8174: [FLINK-12190] Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot

yanghua commented on issue #8174: [FLINK-12190] Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot URL: https://github.com/apache/flink/pull/8174#issuecomment-484458736 @zentol Sorry, I have added more details. It is because the exists code did not

[GitHub] [flink] JingsongLi opened a new pull request #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch

JingsongLi opened a new pull request #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch URL: https://github.com/apache/flink/pull/8206 ## What is the purpose of the change Supporting all major over window operations ## Verifying this change

[jira] [Commented] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820797#comment-16820797 ] Hequn Cheng commented on FLINK-12249: - [~dawidwys] Thank you for providing the valuable information

[GitHub] [flink] azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276564432 ## File path:

[jira] [Commented] (FLINK-12172) Flink fails to close pending BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820841#comment-16820841 ] Mario Georgiev commented on FLINK-12172: - Hi Biao, I read all the documentation regarding the

[jira] [Comment Edited] (FLINK-12172) Flink fails to close pending BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820841#comment-16820841 ] Mario Georgiev edited comment on FLINK-12172 at 4/18/19 8:27 AM: -- Hi

[GitHub] [flink] sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface

sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface URL: https://github.com/apache/flink/pull/8124#discussion_r276564388 ## File path:

[GitHub] [flink] kezhuw commented on a change in pull request #8052: [FLINK-11458][checkpointing, rest] Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34)

kezhuw commented on a change in pull request #8052: [FLINK-11458][checkpointing, rest] Add TERMINATE/SUSPEND Job with Savepoint (FLIP-34) URL: https://github.com/apache/flink/pull/8052#discussion_r276568123 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276572354 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276569079 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276567441 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276571337 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276573998 ## File path:

[jira] [Updated] (FLINK-12229) Implement Lazy Scheduling Strategy

[ https://issues.apache.org/jira/browse/FLINK-12229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang updated FLINK-12229: --- Description: Implement a {{SchedulingStrategy}} that covers the functionality of

[GitHub] [flink] zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276579361 ## File path:

[GitHub] [flink] yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276583353 ## File path:

[jira] [Comment Edited] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

[ https://issues.apache.org/jira/browse/FLINK-12246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820882#comment-16820882 ] lamber-ken edited comment on FLINK-12246 at 4/18/19 9:20 AM: - [~fan_li_ya],

[GitHub] [flink] flinkbot edited a comment on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

flinkbot edited a comment on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#issuecomment-483741002 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] KurtYoung commented on issue #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate

KurtYoung commented on issue #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate URL: https://github.com/apache/flink/pull/8176#issuecomment-484460591 There is an error:

[GitHub] [flink] KurtYoung edited a comment on issue #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate

KurtYoung edited a comment on issue #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate URL: https://github.com/apache/flink/pull/8176#issuecomment-484460591 There is an error: 10:44:03.354 [ERROR] Tests

[jira] [Assigned] (FLINK-12249) Type equivalence check fails for Window Aggregates

[ https://issues.apache.org/jira/browse/FLINK-12249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-12249: --- Assignee: Hequn Cheng > Type equivalence check fails for Window Aggregates >

[jira] [Commented] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

[ https://issues.apache.org/jira/browse/FLINK-12246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820790#comment-16820790 ] Zhu Zhu commented on FLINK-12246: - Currently most of the configs defined in *Option.java are cluster

[jira] [Comment Edited] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

[ https://issues.apache.org/jira/browse/FLINK-12246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820790#comment-16820790 ] Zhu Zhu edited comment on FLINK-12246 at 4/18/19 7:14 AM: -- Currently most of

[GitHub] [flink] klion26 commented on issue #8200: [FLINK-11614] [chinese-translation,Documentation] Translate the "Conf…

klion26 commented on issue #8200: [FLINK-11614] [chinese-translation,Documentation] Translate the "Conf… URL: https://github.com/apache/flink/pull/8200#issuecomment-484384593 @Leev thanks for your contribution, we'll wait for #7754 to be merged, so we can easily know what the changes

[jira] [Closed] (FLINK-12211) Add more IT cases to blink batch

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

[GitHub] [flink] zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276580533 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276582735 ## File path:

[jira] [Commented] (FLINK-12246) can't get any option from the jobConfiguration of JobGraph

[ https://issues.apache.org/jira/browse/FLINK-12246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820882#comment-16820882 ] lamber-ken commented on FLINK-12246: [~fan_li_ya], thanks for concern about this issue. I think it's

[GitHub] [flink] azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

azagrebin commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276585909 ## File path:

[jira] [Updated] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-12070: --- Attachment: image-2019-04-18-17-38-24-949.png > Make blocking result partitions consumable multiple

[GitHub] [flink] Fokko opened a new pull request #8207: [FLINK-12250] Rewrite assembleNewPartPath to let it return a new PartPath

Fokko opened a new pull request #8207: [FLINK-12250] Rewrite assembleNewPartPath to let it return a new PartPath URL: https://github.com/apache/flink/pull/8207 While debugging some code, I've noticed assembleNewPartPath does not really return a new path. Also rewrote the code a bit so the

[jira] [Updated] (FLINK-12250) Rewrite assembleNewPartPath to let it return a new PartPath

[ https://issues.apache.org/jira/browse/FLINK-12250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12250: --- Labels: pull-request-available (was: ) > Rewrite assembleNewPartPath to let it return a

[GitHub] [flink] flinkbot commented on issue #8207: [FLINK-12250] Rewrite assembleNewPartPath to let it return a new PartPath

flinkbot commented on issue #8207: [FLINK-12250] Rewrite assembleNewPartPath to let it return a new PartPath URL: https://github.com/apache/flink/pull/8207#issuecomment-484433504 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] art4ul commented on issue #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types

art4ul commented on issue #8179: [FLINK-12200] [Table API] Support UNNEST for MAP types URL: https://github.com/apache/flink/pull/8179#issuecomment-484433550 Guys! Could you please review this pull request? This is an

[jira] [Updated] (FLINK-12250) Rewrite assembleNewPartPath to let it return a new PartPath

[ https://issues.apache.org/jira/browse/FLINK-12250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong updated FLINK-12250: - Description: While debugging some code, I've noticed assembleNewPartPath does not

[GitHub] [flink] KurtYoung commented on a change in pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime

KurtYoung commented on a change in pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime URL: https://github.com/apache/flink/pull/8202#discussion_r276593388 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime

KurtYoung commented on a change in pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime URL: https://github.com/apache/flink/pull/8202#discussion_r276594279 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276597211 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch

KurtYoung commented on a change in pull request #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch URL: https://github.com/apache/flink/pull/8206#discussion_r276598411 ## File path:

[jira] [Commented] (FLINK-12114) Try to perform UDF By Reflection

[ https://issues.apache.org/jira/browse/FLINK-12114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820937#comment-16820937 ] Timo Walther commented on FLINK-12114: -- [~jiaqiang] I saw this type of exception in the past. It

[GitHub] [flink] zentol merged pull request #8204: [hotfix][docs] fix typo in best_practices doc

zentol merged pull request #8204: [hotfix][docs] fix typo in best_practices doc URL: https://github.com/apache/flink/pull/8204 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] KurtYoung commented on a change in pull request #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch

KurtYoung commented on a change in pull request #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch URL: https://github.com/apache/flink/pull/8206#discussion_r276598941 ## File path:

[jira] [Created] (FLINK-12253) Setup a class hierarchy for the new type system

Timo Walther created FLINK-12253: Summary: Setup a class hierarchy for the new type system Key: FLINK-12253 URL: https://issues.apache.org/jira/browse/FLINK-12253 Project: Flink Issue Type:

[GitHub] [flink] tillrohrmann commented on issue #8189: [FLINK-12195] [YARN] Incorrect resource time setting causes flink to fail to submit

tillrohrmann commented on issue #8189: [FLINK-12195] [YARN] Incorrect resource time setting causes flink to fail to submit URL: https://github.com/apache/flink/pull/8189#issuecomment-48599 Closed because this issue needs further discussion. See

[jira] [Updated] (FLINK-12251) Rework the Table API & SQL type system

[ https://issues.apache.org/jira/browse/FLINK-12251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-12251: - Description: Currently, the Table & SQL API relies on Flink’s TypeInformation at different

[GitHub] [flink] wuchong commented on a change in pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime

wuchong commented on a change in pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime URL: https://github.com/apache/flink/pull/8202#discussion_r276607264 ## File path:

[GitHub] [flink] art4ul opened a new pull request #8208: [FLINK-12252][TableSQL/Planner] Support not escaped table name for External Catalogs in INSERT SQL statement

art4ul opened a new pull request #8208: [FLINK-12252][TableSQL/Planner] Support not escaped table name for External Catalogs in INSERT SQL statement URL: https://github.com/apache/flink/pull/8208 ## What is the purpose of the change In case if I want to write SQL stream

[GitHub] [flink] wuchong commented on a change in pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime

wuchong commented on a change in pull request #8202: [FLINK-12133] [table-runtime-blink] Support unbounded aggregate in streaming table runtime URL: https://github.com/apache/flink/pull/8202#discussion_r276607566 ## File path:

[GitHub] [flink] flinkbot commented on issue #8208: [FLINK-12252][TableSQL/Planner] Support not escaped table name for External Catalogs in INSERT SQL statement

flinkbot commented on issue #8208: [FLINK-12252][TableSQL/Planner] Support not escaped table name for External Catalogs in INSERT SQL statement URL: https://github.com/apache/flink/pull/8208#issuecomment-484445141 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-12252) Support not escaped table name for External Catalogs in INSERT SQL statement

[ https://issues.apache.org/jira/browse/FLINK-12252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12252: --- Labels: pull-request-available (was: ) > Support not escaped table name for External

[GitHub] [flink] zentol commented on issue #8174: [FLINK-12190] Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot

zentol commented on issue #8174: [FLINK-12190] Fix IllegalArgumentException thrown by FlinkKinesisConsumerMigrationTest#writeSnapshot URL: https://github.com/apache/flink/pull/8174#issuecomment-484455964 Please expand the description. It should explain what the underlying problem is and

[GitHub] [flink] flinkbot commented on issue #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch

flinkbot commented on issue #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch URL: https://github.com/apache/flink/pull/8206#issuecomment-484378624 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-12248) Support e2e over window in blink batch

[ https://issues.apache.org/jira/browse/FLINK-12248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12248: --- Labels: pull-request-available (was: ) > Support e2e over window in blink batch >

[jira] [Created] (FLINK-12249) Type equivalence check fails for Window Aggregates

Dawid Wysakowicz created FLINK-12249: Summary: Type equivalence check fails for Window Aggregates Key: FLINK-12249 URL: https://issues.apache.org/jira/browse/FLINK-12249 Project: Flink

[jira] [Issue Comment Deleted] (FLINK-11159) Allow configuration whether to fall back to savepoints for restore

[ https://issues.apache.org/jira/browse/FLINK-11159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11159: - Comment: was deleted (was: [~till.rohrmann] We meet an issue about savepoint just now but is not about

[GitHub] [flink] KurtYoung merged pull request #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch

KurtYoung merged pull request #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch URL: https://github.com/apache/flink/pull/8184 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276581786 ## File path:

[GitHub] [flink] yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276587765 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

StefanRRichter commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276597909 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch

KurtYoung commented on a change in pull request #8206: [FLINK-12248][table-planner-blink] Support e2e over window in blink batch URL: https://github.com/apache/flink/pull/8206#discussion_r276598619 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zentol commented on a change in pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#discussion_r276601701 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276597514 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276595922 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276600388 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276607089 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276605879 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276596335 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276597632 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276596192 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276596570 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276612056 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276596296 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276605227 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276604911 ## File path:

[GitHub] [flink] fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

fhueske commented on a change in pull request #8034: [FLINK-11733] Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper URL: https://github.com/apache/flink/pull/8034#discussion_r276596099 ## File path:

[GitHub] [flink] rmetzger commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type

rmetzger commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#issuecomment-484388255 Once @GJL's comments have been resolved, I'm +1 on merging this.

  1   2   3   >