[GitHub] [flink] StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

StephanEwen commented on a change in pull request #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#discussion_r299701304 ## File path:

[GitHub] [flink] bowenli86 closed pull request #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings

bowenli86 closed pull request #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings URL: https://github.com/apache/flink/pull/8953 This is an

[GitHub] [flink] bowenli86 removed a comment on issue #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings

bowenli86 removed a comment on issue #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings URL: https://github.com/apache/flink/pull/8953#issuecomment-507850582 cc @xuefuz @dawidwys

[GitHub] [flink] bowenli86 commented on issue #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings

bowenli86 commented on issue #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings URL: https://github.com/apache/flink/pull/8953#issuecomment-507850582 cc @xuefuz @dawidwys

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299657989 ## File path:

[GitHub] [flink] flinkbot commented on issue #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings

flinkbot commented on issue #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings URL: https://github.com/apache/flink/pull/8953#issuecomment-507819063 Thanks a lot for your contribution to the Apache Flink

[jira] [Closed] (FLINK-13022) unify catalog function implementations

[ https://issues.apache.org/jira/browse/FLINK-13022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13022. Resolution: Fixed merged in 1.9.0: 16cb60ff0df4225e8323bb3153b3ff3ba04781e8 > unify catalog function

[jira] [Closed] (FLINK-12841) Unify catalog meta-objects implementations

[ https://issues.apache.org/jira/browse/FLINK-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12841. Resolution: Fixed closing this as this ticket have been broken into other subtasks and they are all done

[GitHub] [flink] bowenli86 opened a new pull request #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings

bowenli86 opened a new pull request #8953: [hotfix][table] rename defaultCatalog and defaultDatabase to currentCatalog and currentDatabase, to be consistent with namings URL: https://github.com/apache/flink/pull/8953 ## What is the purpose of the change This PR fixes a naming

[GitHub] [flink] asfgit closed pull request #8941: [FLINK-13048][hive] support decimal in Flink's integration with Hive …

asfgit closed pull request #8941: [FLINK-13048][hive] support decimal in Flink's integration with Hive … URL: https://github.com/apache/flink/pull/8941 This is an automated message from the Apache Git Service. To respond to

[jira] [Closed] (FLINK-13048) support decimal in Flink's integration with Hive user defined functions

[ https://issues.apache.org/jira/browse/FLINK-13048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13048. Resolution: Fixed merged in 1.9.0: 64bb08d776ea4d153a74bbe992b59e52c3044425 > support decimal in Flink's

[GitHub] [flink] bowenli86 commented on issue #8941: [FLINK-13048][hive] support decimal in Flink's integration with Hive …

bowenli86 commented on issue #8941: [FLINK-13048][hive] support decimal in Flink's integration with Hive … URL: https://github.com/apache/flink/pull/8941#issuecomment-507797127 Build queue is too congested. Ran test locally. Merging

[jira] [Created] (FLINK-13064) Add Python Table API to Table Api Walkthrough

Seth Wiesman created FLINK-13064: Summary: Add Python Table API to Table Api Walkthrough Key: FLINK-13064 URL: https://issues.apache.org/jira/browse/FLINK-13064 Project: Flink Issue Type:

[GitHub] [flink] sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299567479 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@

[GitHub] [flink] sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299567479 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@

[GitHub] [flink] asfgit closed pull request #8939: [FLINK-13046][hive] rename hive-site-path to hive-conf-dir to be cons…

asfgit closed pull request #8939: [FLINK-13046][hive] rename hive-site-path to hive-conf-dir to be cons… URL: https://github.com/apache/flink/pull/8939 This is an automated message from the Apache Git Service. To respond to

[jira] [Closed] (FLINK-13046) rename hive-site-path to hive-conf-dir to be consistent with standard name in Hive

[ https://issues.apache.org/jira/browse/FLINK-13046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13046. Resolution: Fixed merged in 1.9.0: 011006f81c11e0d0c8bb37c20e06daad1dcb7148 > rename hive-site-path to

[jira] [Closed] (FLINK-13047) Fix the Optional.orElse() usage issue in DatabaseCalciteSchema

[ https://issues.apache.org/jira/browse/FLINK-13047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13047. Resolution: Fixed merged in 1.9.0: 3358cd3b6d6ffebb313b6c02f2a53e6dbd6ec1ed > Fix the Optional.orElse()

[GitHub] [flink] asfgit closed pull request #8926: [FLINK-13021][table][hive] unify catalog partition implementations

asfgit closed pull request #8926: [FLINK-13021][table][hive] unify catalog partition implementations URL: https://github.com/apache/flink/pull/8926 This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-13021) unify catalog partition implementations

[ https://issues.apache.org/jira/browse/FLINK-13021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13021. Resolution: Fixed merged in 1.9.0: 59ff00d71d298fa61a92efa4fecd46f3cefc50f6 > unify catalog partition

[GitHub] [flink] bowenli86 commented on issue #8926: [FLINK-13021][table][hive] unify catalog partition implementations

bowenli86 commented on issue #8926: [FLINK-13021][table][hive] unify catalog partition implementations URL: https://github.com/apache/flink/pull/8926#issuecomment-507789120 @xuefuz thanks for your review! Due to the build queue is so congested now and my build request hasn't

[GitHub] [flink] asfgit closed pull request #8940: [FLINK-13047][table] Fix the Optional.orElse() usage issue in Databas…

asfgit closed pull request #8940: [FLINK-13047][table] Fix the Optional.orElse() usage issue in Databas… URL: https://github.com/apache/flink/pull/8940 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] bowenli86 commented on issue #8940: [FLINK-13047][table] Fix the Optional.orElse() usage issue in Databas…

bowenli86 commented on issue #8940: [FLINK-13047][table] Fix the Optional.orElse() usage issue in Databas… URL: https://github.com/apache/flink/pull/8940#issuecomment-507786264 since the build queue is so congested now and this PR's build may not finish probably till tomorrow, I built and

[GitHub] [flink] flinkbot commented on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

flinkbot commented on issue #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager URL: https://github.com/apache/flink/pull/8952#issuecomment-507785614 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] HuangZhenQiu closed pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

HuangZhenQiu closed pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356 This is an automated message from the Apache Git Service.

[GitHub] [flink] HuangZhenQiu commented on issue #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

HuangZhenQiu commented on issue #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#issuecomment-507785245 @tillrohrmann After the rebase master, the conflict is mistakenly reported. I created another PR

[GitHub] [flink] HuangZhenQiu opened a new pull request #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

HuangZhenQiu opened a new pull request #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager URL: https://github.com/apache/flink/pull/8952 ## What is the purpose of the change Add failure rate for resource manager, so that every type of Resource Managers can handle

[GitHub] [flink] sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299610872 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[GitHub] [flink] Myasuka commented on issue #8845: [FLINK-12353] Collect all japicmp output under tools directory

Myasuka commented on issue #8845: [FLINK-12353] Collect all japicmp output under tools directory URL: https://github.com/apache/flink/pull/8845#issuecomment-507780831 @StephanEwen Thanks for your review, already updated based on your comments. BTW, the actual property from the "highest

[jira] [Commented] (FLINK-12701) Column name alias causes exception when used with where and group-by

[ https://issues.apache.org/jira/browse/FLINK-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877195#comment-16877195 ] Robert Metzger commented on FLINK-12701: I also tried reproducing the issue with this query

[jira] [Updated] (FLINK-13063) AsyncWaitOperator shouldn't be releasing checkpointingLock

[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13063: --- Summary: AsyncWaitOperator shouldn't be releasing checkpointingLock (was:

[jira] [Commented] (FLINK-12921) Flink Job Scheduling

[ https://issues.apache.org/jira/browse/FLINK-12921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877167#comment-16877167 ] Robert Metzger commented on FLINK-12921: Should we rename this ticket? Or can we close it? >

[GitHub] [flink] bowenli86 commented on issue #8935: [Flink-12973]Support reading Hive complex types like array and map

bowenli86 commented on issue #8935: [Flink-12973]Support reading Hive complex types like array and map URL: https://github.com/apache/flink/pull/8935#issuecomment-507766728 @zjuwangg thanks for your contribution! LGTM, will merge once CI passes

[jira] [Updated] (FLINK-13063) AsyncWaitOperator is broken

[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13063: --- Description: 1. For the following setup of chained operators: {noformat} SourceOperator ->

[jira] [Updated] (FLINK-13063) AsyncWaitOperator is broken

[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13063: --- Description: 1. For the following setup of chained operators: {noformat} SourceOperator ->

[jira] [Updated] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13052: --- Component/s: Table SQL / API > Supporting multi-topic when using >

[jira] [Updated] (FLINK-13063) AsyncWaitOperator is broken

[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13063: --- Summary: AsyncWaitOperator is broken (was: AsyncWaitOperator can loose data during

[jira] [Updated] (FLINK-13061) Support set hive table Ser/de properites in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-13061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13061: --- Component/s: Connectors / Hive > Support set hive table Ser/de properites in HiveCatalog >

[jira] [Updated] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13052: --- Component/s: Connectors / Kafka > Supporting multi-topic when using >

[GitHub] [flink] yanyan300300 opened a new pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

yanyan300300 opened a new pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215 ## What is the purpose of the change This change reverts the original fix for FLINK-8801's

[jira] [Updated] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3

[ https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8801: -- Labels: pull-request-available (was: ) > S3's eventual consistent read-after-write may fail

[jira] [Commented] (FLINK-13063) AsyncWaitOperator can loose data during checkpointing

[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877112#comment-16877112 ] Piotr Nowojski commented on FLINK-13063: Hot fix is to ensure that {{AsyncWaitOperator}} is

[GitHub] [flink] yanyan300300 closed pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

yanyan300300 closed pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215 This is an automated message from the

[GitHub] [flink] yanyan300300 commented on a change in pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

yanyan300300 commented on a change in pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215#discussion_r299571156 ## File path:

[jira] [Updated] (FLINK-13063) AsyncWaitOperator can loose data during checkpointing

[ https://issues.apache.org/jira/browse/FLINK-13063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13063: --- Description: For the following setup of chained operators: {noformat} SourceOperator ->

[jira] [Created] (FLINK-13063) AsyncWaitOperator can loose data during checkpointing

Piotr Nowojski created FLINK-13063: -- Summary: AsyncWaitOperator can loose data during checkpointing Key: FLINK-13063 URL: https://issues.apache.org/jira/browse/FLINK-13063 Project: Flink

[GitHub] [flink] sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299567479 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@

[GitHub] [flink] aljoscha commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline

aljoscha commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline URL: https://github.com/apache/flink/pull/8951#issuecomment-507738509 Sure, please take time to sleep!  This is

[GitHub] [flink] zhijiangW commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zhijiangW commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#discussion_r299556207 ## File path:

[GitHub] [flink] dawidwys closed pull request #8860: [FLINK-12906][table-planner] Ported OperationTreeBuilder to java

dawidwys closed pull request #8860: [FLINK-12906][table-planner] Ported OperationTreeBuilder to java URL: https://github.com/apache/flink/pull/8860 This is an automated message from the Apache Git Service. To respond to

[jira] [Closed] (FLINK-11884) Port Table to flink-api-java

[ https://issues.apache.org/jira/browse/FLINK-11884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-11884. Resolution: Implemented Fix Version/s: 1.9.0 > Port Table to flink-api-java >

[jira] [Closed] (FLINK-12906) Port OperationTreeBuilder to Java

[ https://issues.apache.org/jira/browse/FLINK-12906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-12906. Resolution: Fixed Implemented in 6cc8e44adfaab2d6e3ae4c1992b8fa73c4066c81 > Port

[GitHub] [flink] ifndef-SleePy commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline

ifndef-SleePy commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline URL: https://github.com/apache/flink/pull/8951#issuecomment-507734604 Wow, It's amazing that you have already finished this proposal! I have taken a glance at it. I got

[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877073#comment-16877073 ] zhijiang commented on FLINK-12852: -- [~StephanEwen] thanks for concerning this issue and sharing the

[jira] [Closed] (FLINK-13045) Move Scala expression DSL to flink-table-api-scala

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

[GitHub] [flink] asfgit closed pull request #8945: [FLINK-13045][table] Move Scala expression DSL to flink-table-api-scala

asfgit closed pull request #8945: [FLINK-13045][table] Move Scala expression DSL to flink-table-api-scala URL: https://github.com/apache/flink/pull/8945 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299511383 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299517997 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299507072 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299493179 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299514990 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299505821 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299492109 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler

tillrohrmann commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8922#discussion_r299507148 ## File path:

[jira] [Closed] (FLINK-12069) Add proper lifecycle management for intermediate result partitions

[ https://issues.apache.org/jira/browse/FLINK-12069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12069. Resolution: Fixed Fix Version/s: 1.9.0 > Add proper lifecycle management for

[jira] [Updated] (FLINK-12883) Add elaborate partition release logic

[ https://issues.apache.org/jira/browse/FLINK-12883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12883: - Summary: Add elaborate partition release logic (was: Add elaborated partition release

[jira] [Closed] (FLINK-12883) Add elaborated partition release logic

[ https://issues.apache.org/jira/browse/FLINK-12883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12883. Resolution: Fixed Fix Version/s: 1.9.0 master:

[GitHub] [flink] zentol merged pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zentol merged pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804 This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-12735) Make shuffle environment implementation independent with IOManager

[ https://issues.apache.org/jira/browse/FLINK-12735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12735. Resolution: Fixed Fix Version/s: 1.9.0 master:

[GitHub] [flink] zentol merged pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zentol merged pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646 This is an automated message from the Apache Git

[GitHub] [flink] aljoscha commented on issue #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig

aljoscha commented on issue #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig URL: https://github.com/apache/flink/pull/8931#issuecomment-507706592 I opened a PR for my last proposal: #8951 This is an

[GitHub] [flink] aljoscha opened a new pull request #8951: Dag bounded flag

aljoscha opened a new pull request #8951: Dag bounded flag URL: https://github.com/apache/flink/pull/8951 ## What is the purpose of the change The new Blink-based Table Runner needs "streaming pipelines" to be executed with `ScheduleMode.LAZY_FROM_SOURCES` if all sources are

[jira] [Commented] (FLINK-13062) Set ScheduleMode based on boundedness of streaming Pipeline

[ https://issues.apache.org/jira/browse/FLINK-13062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877026#comment-16877026 ] Aljoscha Krettek commented on FLINK-13062: -- [https://github.com/apache/flink/pull/8951] > Set

[GitHub] [flink] flinkbot commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline

flinkbot commented on issue #8951: [FLINK-13062] Set ScheduleMode based on boundedness of streaming Pipeline URL: https://github.com/apache/flink/pull/8951#issuecomment-507707203 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] twalthr commented on issue #8945: [FLINK-13045][table] Move Scala expression DSL to flink-table-api-scala

twalthr commented on issue #8945: [FLINK-13045][table] Move Scala expression DSL to flink-table-api-scala URL: https://github.com/apache/flink/pull/8945#issuecomment-507707411 Thanks for your thoughts. I think the purpose of this annotation is to mark code where people need to think twice

[GitHub] [flink] aljoscha commented on issue #8951: Dag bounded flag

aljoscha commented on issue #8951: Dag bounded flag URL: https://github.com/apache/flink/pull/8951#issuecomment-507706357 This is an alternative proposal for #8931 cc @ifndef-SleePy This is an automated message from

[GitHub] [flink] zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#discussion_r299514891 ## File path:

[jira] [Closed] (FLINK-12798) Port TableEnvironment to flink-api modules

[ https://issues.apache.org/jira/browse/FLINK-12798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-12798. Resolution: Fixed Fixed in 1.9.0: 95944e231315f085d5e23717332aa2866caa5d8a > Port

[GitHub] [flink] asfgit closed pull request #8852: [FLINK-12798][table-api][table-planner] Add a proper discover mechanism that will enable switching between Flink & Blink Planner/Executor

asfgit closed pull request #8852: [FLINK-12798][table-api][table-planner] Add a proper discover mechanism that will enable switching between Flink & Blink Planner/Executor URL: https://github.com/apache/flink/pull/8852

[jira] [Created] (FLINK-13062) Set ScheduleMode based on boundedness of streaming Pipeline

Aljoscha Krettek created FLINK-13062: Summary: Set ScheduleMode based on boundedness of streaming Pipeline Key: FLINK-13062 URL: https://issues.apache.org/jira/browse/FLINK-13062 Project: Flink

[GitHub] [flink] dawidwys commented on a change in pull request #8860: [FLINK-12906][table-planner] Ported OperationTreeBuilder to java

dawidwys commented on a change in pull request #8860: [FLINK-12906][table-planner] Ported OperationTreeBuilder to java URL: https://github.com/apache/flink/pull/8860#discussion_r299503170 ## File path:

[GitHub] [flink] zjuwangg commented on a change in pull request #8935: [Flink-12973]Support reading Hive complex types like array and map

zjuwangg commented on a change in pull request #8935: [Flink-12973]Support reading Hive complex types like array and map URL: https://github.com/apache/flink/pull/8935#discussion_r299498304 ## File path:

[GitHub] [flink] zjuwangg commented on a change in pull request #8935: [Flink-12973]Support reading Hive complex types like array and map

zjuwangg commented on a change in pull request #8935: [Flink-12973]Support reading Hive complex types like array and map URL: https://github.com/apache/flink/pull/8935#discussion_r299484788 ## File path:

[jira] [Created] (FLINK-13061) Support set hive table Ser/de properites in HiveCatalog

zjuwangg created FLINK-13061: Summary: Support set hive table Ser/de properites in HiveCatalog Key: FLINK-13061 URL: https://issues.apache.org/jira/browse/FLINK-13061 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on issue #8950: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool

flinkbot commented on issue #8950: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool URL: https://github.com/apache/flink/pull/8950#issuecomment-507676192 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot commented on issue #8949: [BP-1.8][FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool

flinkbot commented on issue #8949: [BP-1.8][FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool URL: https://github.com/apache/flink/pull/8949#issuecomment-507675589 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] tillrohrmann opened a new pull request #8950: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool

tillrohrmann opened a new pull request #8950: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool URL: https://github.com/apache/flink/pull/8950 Backport of #8948 for `release-1.7`. This PR does not contain the test because it would have been too much work

[GitHub] [flink] tillrohrmann opened a new pull request #8949: [BP-1.8][FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool

tillrohrmann opened a new pull request #8949: [BP-1.8][FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool URL: https://github.com/apache/flink/pull/8949 Backport of #8948 for `release-1.8`. This PR does not contain the test because it would have been too

[GitHub] [flink] flinkbot commented on issue #8948: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool

flinkbot commented on issue #8948: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool URL: https://github.com/apache/flink/pull/8948#issuecomment-507672616 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12889: --- Labels: pull-request-available (was: ) > Job keeps in FAILING state >

[GitHub] [flink] tillrohrmann opened a new pull request #8948: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool

tillrohrmann opened a new pull request #8948: [FLINK-12889] Set FatalExitExceptionHandler for StreamTask#asyncOperationsThreadPool URL: https://github.com/apache/flink/pull/8948 ## What is the purpose of the change In order to avoid the swallowing of uncaught exceptions in

[GitHub] [flink] twalthr commented on issue #8852: [FLINK-12798][table-api][table-planner] Add a proper discover mechanism that will enable switching between Flink & Blink Planner/Executor

twalthr commented on issue #8852: [FLINK-12798][table-api][table-planner] Add a proper discover mechanism that will enable switching between Flink & Blink Planner/Executor URL: https://github.com/apache/flink/pull/8852#issuecomment-507666816 Thank you @dawidwys. I will take care of

[GitHub] [flink] GJL commented on issue #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on issue #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#issuecomment-507666927 LGTM This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on issue #8947: [hotfix][python] Remove the redundant 'python setup.py install' from tox.ini

flinkbot commented on issue #8947: [hotfix][python] Remove the redundant 'python setup.py install' from tox.ini URL: https://github.com/apache/flink/pull/8947#issuecomment-507664999 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] dianfu opened a new pull request #8947: [hotfix][python] Remove the redundant 'python setup.py install' from tox.ini

dianfu opened a new pull request #8947: [hotfix][python] Remove the redundant 'python setup.py install' from tox.ini URL: https://github.com/apache/flink/pull/8947 ## What is the purpose of the change *Currently the command `python setup.py install` is executed twice for each

[GitHub] [flink] dawidwys closed pull request #8932: [FLINK-13029][table-planner] Removed usages of ExpressionBridge in QueryOperation's factories

dawidwys closed pull request #8932: [FLINK-13029][table-planner] Removed usages of ExpressionBridge in QueryOperation's factories URL: https://github.com/apache/flink/pull/8932 This is an automated message from the Apache

[jira] [Closed] (FLINK-13029) Remove expressionBridge from QueryOperations factories

[ https://issues.apache.org/jira/browse/FLINK-13029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-13029. Resolution: Fixed Implemented in 9fa61aa505b09a3c57e9b8432ac05fe1fcc838ec > Remove

[GitHub] [flink] zentol commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zentol commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r299465452 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zentol commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r299461260 ## File path:

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

eaglewatcherwb commented on a change in pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#discussion_r299455697 ## File path:

<    1   2   3   4   5   >