[GitHub] [flink] flinkbot commented on issue #9361: [FLINK-13540] DDL do not support properties key that contains number …

flinkbot commented on issue #9361: [FLINK-13540] DDL do not support properties key that contains number … URL: https://github.com/apache/flink/pull/9361#issuecomment-518225256 ## CI report: * 85a4cfddcdeb17c939d90350b5d8dc25db707f50 : PENDING [Build](https://travis-ci.com/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #9361: [FLINK-13540] DDL do not support properties key that contains number …

flinkbot edited a comment on issue #9361: [FLINK-13540] DDL do not support properties key that contains number … URL: https://github.com/apache/flink/pull/9361#issuecomment-518225256 ## CI report: * 85a4cfddcdeb17c939d90350b5d8dc25db707f50 : CANCELED [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9357: [FLINK-13579] Only set managed memory when starting an active RM

flinkbot edited a comment on issue #9357: [FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9357#issuecomment-518174722 ## CI report: * 83b8631729cd9ec114201fcd746906871a2cb1f7 : FAILURE [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] fhueske commented on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

fhueske commented on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#issuecomment-518234229 Thanks for the update@knaufk! I'll have a final look and will try to merge it. Fabian -

[GitHub] [flink] tillrohrmann commented on a change in pull request #9357: [FLINK-13579] Only set managed memory when starting an active RM

tillrohrmann commented on a change in pull request #9357: [FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9357#discussion_r310608173 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/Standal

[GitHub] [flink] tillrohrmann commented on a change in pull request #9357: [FLINK-13579] Only set managed memory when starting an active RM

tillrohrmann commented on a change in pull request #9357: [FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9357#discussion_r310608142 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ActiveR

[GitHub] [flink] godfreyhe opened a new pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

godfreyhe opened a new pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362 ## What is the purpose of the change *Add documentation for how to use blink planner* ## Brief change log

[jira] [Updated] (FLINK-13354) Add documentation for how to use blink planner

[ https://issues.apache.org/jira/browse/FLINK-13354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13354: --- Labels: pull-request-available (was: ) > Add documentation for how to use blink planner > -

[GitHub] [flink] godfreyhe commented on issue #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

godfreyhe commented on issue #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#issuecomment-518238356 cc @twalthr @dawidwys @wuchong This is an automate

[GitHub] [flink] flinkbot commented on issue #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

flinkbot commented on issue #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#issuecomment-518239218 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] tillrohrmann commented on issue #9357: [FLINK-13579] Only set managed memory when starting an active RM

tillrohrmann commented on issue #9357: [FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9357#issuecomment-518239730 Thanks for the review @xintongsong. I've addressed your comments. Merging once Travis gives green light. --

[GitHub] [flink] flinkbot commented on issue #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

flinkbot commented on issue #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#issuecomment-518240447 ## CI report: * cdafb97521bc0cef7b01eb8df20c478f3bba99fe : PENDING [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job

flinkbot edited a comment on issue #9359: [FLINK-13441][e2e] Add e2e test for sql batch job URL: https://github.com/apache/flink/pull/9359#issuecomment-518212897 ## CI report: * fa3a355bd70a013aff95403532a4b1861a6bc173 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/12

[jira] [Commented] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900096#comment-16900096 ] Ufuk Celebi commented on FLINK-13566: - I see that having a good default checkpointin

[GitHub] [flink] flinkbot edited a comment on issue #9353: Add a new connector ' flink-connector-rocketmq'

flinkbot edited a comment on issue #9353: Add a new connector ' flink-connector-rocketmq' URL: https://github.com/apache/flink/pull/9353#issuecomment-518013889 ## CI report: * ae86a133468c692d9d29a78e4189412c997a5752 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/1218

[jira] [Commented] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900098#comment-16900098 ] Gyula Fora commented on FLINK-13566: Thanks for the feedback [~uce] . I am planning

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310576821 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/execu

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310611585 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/execu

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r31060 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/concu

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310546715 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/execu

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310609212 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/concu

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310546339 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpoint

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310544452 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/check

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310575939 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/concu

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310545689 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/execu

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310607451 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/concu

[jira] [Commented] (FLINK-13548) Support priority of the Flink YARN application

[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900099#comment-16900099 ] thy commented on FLINK-13548: - [~walterddr]: Thanks for your advice! First, I would say sorr

[GitHub] [flink] flinkbot edited a comment on issue #9357: [FLINK-13579] Only set managed memory when starting an active RM

flinkbot edited a comment on issue #9357: [FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9357#issuecomment-518174722 ## CI report: * 83b8631729cd9ec114201fcd746906871a2cb1f7 : FAILURE [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot edited a comment on issue #9358: [BP-1.9][FLINK-13579] Only set managed memory when starting an active RM

flinkbot edited a comment on issue #9358: [BP-1.9][FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9358#issuecomment-518174739 ## CI report: * cb29febd55b3c900e1bc081c33f2dab356cf88e5 : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] tillrohrmann commented on a change in pull request #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable.

tillrohrmann commented on a change in pull request #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable. URL: https://github.com/apache/flink/pull/9339#discussion_r310620978 ## File path: flink-runtime/src/main/java/org/apache/flin

[GitHub] [flink] xintongsong commented on a change in pull request #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable.

xintongsong commented on a change in pull request #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable. URL: https://github.com/apache/flink/pull/9339#discussion_r310624549 ## File path: flink-runtime/src/main/java/org/apache/flink/

[jira] [Commented] (FLINK-13460) Rework SerializedThrowableTest to not use Unsafe.defineClass()

[ https://issues.apache.org/jira/browse/FLINK-13460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900114#comment-16900114 ] Stephan Ewen commented on FLINK-13460: -- If we refactor all these tests now, would b

[GitHub] [flink] flinkbot edited a comment on issue #9360: [FLINK-13584][table-planner-blink] RankLikeAggFunctionBase should respect type to construct literal

flinkbot edited a comment on issue #9360: [FLINK-13584][table-planner-blink] RankLikeAggFunctionBase should respect type to construct literal URL: https://github.com/apache/flink/pull/9360#issuecomment-518220854 ## CI report: * ffc2d466eff4574a787c6d20d07ead4d651e999a : SUCCESS [Bui

[jira] [Created] (FLINK-13586) Method ClosureCleaner.clean broke backward compatibility between 1.8.0 and 1.8.1

Gaël Renoux created FLINK-13586: --- Summary: Method ClosureCleaner.clean broke backward compatibility between 1.8.0 and 1.8.1 Key: FLINK-13586 URL: https://issues.apache.org/jira/browse/FLINK-13586 Projec

[GitHub] [flink] flinkbot edited a comment on issue #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable.

flinkbot edited a comment on issue #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable. URL: https://github.com/apache/flink/pull/9339#issuecomment-517712846 ## CI report: * dfe5ef072dadfc0e1510f1923911304c635e54af : SUCCESS [Build]

[jira] [Created] (FLINK-13587) Fix some transformation names are not set in blink planner

Jark Wu created FLINK-13587: --- Summary: Fix some transformation names are not set in blink planner Key: FLINK-13587 URL: https://issues.apache.org/jira/browse/FLINK-13587 Project: Flink Issue Type:

[GitHub] [flink] wuchong opened a new pull request #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

wuchong opened a new pull request #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363 ## What is the purpose of the change Currently, there are some transformation names are not set in b

[jira] [Updated] (FLINK-13587) Fix some transformation names are not set in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13587: --- Labels: pull-request-available (was: ) > Fix some transformation names are not set in blink

[GitHub] [flink] flinkbot commented on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

flinkbot commented on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518263446 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

[GitHub] [flink] wuchong commented on issue #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink

wuchong commented on issue #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink URL: https://github.com/apache/flink/pull/9099#issuecomment-518263615 Merging... This is an automated message from th

[GitHub] [flink] asfgit closed pull request #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink

asfgit closed pull request #9099: [FLINK-13237][table-planner-blink] Add expression table api test to blink URL: https://github.com/apache/flink/pull/9099 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on issue #9353: Add a new connector ' flink-connector-rocketmq'

flinkbot edited a comment on issue #9353: Add a new connector ' flink-connector-rocketmq' URL: https://github.com/apache/flink/pull/9353#issuecomment-518013889 ## CI report: * ae86a133468c692d9d29a78e4189412c997a5752 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/1218

[GitHub] [flink] flinkbot commented on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

flinkbot commented on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518265997 ## CI report: * 1fe6c332279c34546ec3db24a574dfd53500d20b : PENDING [Build](https://travis-

[jira] [Resolved] (FLINK-13237) Add expression table api test to blink

[ https://issues.apache.org/jira/browse/FLINK-13237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13237. - Resolution: Fixed Fix Version/s: 1.10.0 [FLINK-13237][table-planner-blink] Fix regexpReplace and

[GitHub] [flink] tillrohrmann commented on a change in pull request #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable.

tillrohrmann commented on a change in pull request #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable. URL: https://github.com/apache/flink/pull/9339#discussion_r310644309 ## File path: flink-runtime/src/main/java/org/apache/flin

[GitHub] [flink] ifndef-SleePy commented on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the …

ifndef-SleePy commented on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the … URL: https://github.com/apache/flink/pull/9321#issuecomment-518266924 Hi @kl0u , sorry for the late response. I have addressed the comments and revert the unnecessary changes.

[GitHub] [flink] ifndef-SleePy edited a comment on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the …

ifndef-SleePy edited a comment on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the … URL: https://github.com/apache/flink/pull/9321#issuecomment-518266924 Hi @kl0u , sorry for the late response. I have addressed the comments and reverted the unnecessary c

[GitHub] [flink] flinkbot edited a comment on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the …

flinkbot edited a comment on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the … URL: https://github.com/apache/flink/pull/9321#issuecomment-517266286 ## CI report: * 8738fc7248be508edcf3e1c0dcea6578f7b35a7e : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] dmvk commented on issue #9022: [FLINK-13127] Fix --yarnship classpath

dmvk commented on issue #9022: [FLINK-13127] Fix --yarnship classpath URL: https://github.com/apache/flink/pull/9022#issuecomment-518271162 @tillrohrmann did you have a time to take a look at this? This is an automated message

[GitHub] [flink] flinkbot edited a comment on issue #9361: [FLINK-13540] DDL do not support properties key that contains number …

flinkbot edited a comment on issue #9361: [FLINK-13540] DDL do not support properties key that contains number … URL: https://github.com/apache/flink/pull/9361#issuecomment-518225256 ## CI report: * 85a4cfddcdeb17c939d90350b5d8dc25db707f50 : CANCELED [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable.

flinkbot edited a comment on issue #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable. URL: https://github.com/apache/flink/pull/9339#issuecomment-517712846 ## CI report: * dfe5ef072dadfc0e1510f1923911304c635e54af : SUCCESS [Build]

[jira] [Commented] (FLINK-13586) Method ClosureCleaner.clean broke backward compatibility between 1.8.0 and 1.8.1

[ https://issues.apache.org/jira/browse/FLINK-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900142#comment-16900142 ] Victor Wong commented on FLINK-13586: - Hi Gaël, could you assign this ticket to me,

[jira] [Commented] (FLINK-13550) Support for CPU FlameGraphs in new web UI

[ https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900143#comment-16900143 ] David Moravek commented on FLINK-13550: --- [~vthinkxie] Great! I'll ping you once I

[GitHub] [flink] flinkbot edited a comment on issue #9353: Add a new connector ' flink-connector-rocketmq'

flinkbot edited a comment on issue #9353: Add a new connector ' flink-connector-rocketmq' URL: https://github.com/apache/flink/pull/9353#issuecomment-518013889 ## CI report: * ae86a133468c692d9d29a78e4189412c997a5752 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/1218

[jira] [Commented] (FLINK-13586) Method ClosureCleaner.clean broke backward compatibility between 1.8.0 and 1.8.1

[ https://issues.apache.org/jira/browse/FLINK-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900153#comment-16900153 ] Gaël Renoux commented on FLINK-13586: - Hi Victor, I don't seem to have the permissio

[GitHub] [flink] asfgit closed pull request #9024: [FLINK-13119] add blink table config to documentation

asfgit closed pull request #9024: [FLINK-13119] add blink table config to documentation URL: https://github.com/apache/flink/pull/9024 This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on issue #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

flinkbot edited a comment on issue #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#issuecomment-518240447 ## CI report: * cdafb97521bc0cef7b01eb8df20c478f3bba99fe : SUCCESS [Build](https://travis-ci.com/flink-

[jira] [Closed] (FLINK-13119) Add blink table config to documentation

[ https://issues.apache.org/jira/browse/FLINK-13119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-13119. Resolution: Fixed Fixed in 1.10.0: 00e0baae8664cf06dbba88542af102c764fb7730 Fixed in 1.9.0: d3f33a

[GitHub] [flink] flinkbot edited a comment on issue #9358: [BP-1.9][FLINK-13579] Only set managed memory when starting an active RM

flinkbot edited a comment on issue #9358: [BP-1.9][FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9358#issuecomment-518174739 ## CI report: * cb29febd55b3c900e1bc081c33f2dab356cf88e5 : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] Myasuka commented on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

Myasuka commented on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-518294644 Sorry for late reply. @GJL , No problem, please go ahead to take over this PR to finish the

[GitHub] [flink] flinkbot edited a comment on issue #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable.

flinkbot edited a comment on issue #9339: [FLINK-13555][runtime] SlotPool fails batch slot requests immediately if they are unfulfillable. URL: https://github.com/apache/flink/pull/9339#issuecomment-517712846 ## CI report: * dfe5ef072dadfc0e1510f1923911304c635e54af : SUCCESS [Build]

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310671058 ## File path: docs/dev/table/common.md ## @@ -27,6 +27,20 @@ The Table API and SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310674136 ## File path: docs/dev/table/common.md ## @@ -592,8 +675,8 @@ The following examp

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310679771 ## File path: docs/dev/table/common.md ## @@ -1304,20 +1417,52 @@ val table: Tabl

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310670732 ## File path: docs/dev/table/common.md ## @@ -27,6 +27,20 @@ The Table API and SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310675449 ## File path: docs/dev/table/common.md ## @@ -755,6 +838,11 @@ result.insert_into

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310677585 ## File path: docs/dev/table/common.md ## @@ -768,11 +856,36 @@ A Table API or SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310677684 ## File path: docs/dev/table/common.md ## @@ -768,11 +856,36 @@ A Table API or SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310676201 ## File path: docs/dev/table/common.md ## @@ -755,6 +838,11 @@ result.insert_into

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310669808 ## File path: docs/dev/table/common.md ## @@ -27,6 +27,20 @@ The Table API and SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310678779 ## File path: docs/dev/table/common.md ## @@ -768,11 +856,36 @@ A Table API or SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310669473 ## File path: docs/dev/table/common.md ## @@ -27,6 +27,20 @@ The Table API and SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310674210 ## File path: docs/dev/table/common.md ## @@ -682,8 +765,8 @@ The following examp

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310679038 ## File path: docs/dev/table/common.md ## @@ -1304,20 +1417,52 @@ val table: Tabl

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310674028 ## File path: docs/dev/table/common.md ## @@ -527,8 +610,8 @@ The following examp

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310677474 ## File path: docs/dev/table/common.md ## @@ -768,11 +856,36 @@ A Table API or SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310678504 ## File path: docs/dev/table/common.md ## @@ -768,11 +856,36 @@ A Table API or SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310670241 ## File path: docs/dev/table/common.md ## @@ -27,6 +27,20 @@ The Table API and SQ

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310673851 ## File path: docs/dev/table/common.md ## @@ -344,8 +425,8 @@ A `TableSink` is re

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310676402 ## File path: docs/dev/table/common.md ## @@ -755,6 +838,11 @@ result.insert_into

[GitHub] [flink] sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner

sjwiesman commented on a change in pull request #9362: [FLINK-13354] [docs] Add documentation for how to use blink planner URL: https://github.com/apache/flink/pull/9362#discussion_r310671482 ## File path: docs/dev/table/common.md ## @@ -142,82 +150,153 @@ A `Table` is alw

[GitHub] [flink] flinkbot edited a comment on issue #9357: [FLINK-13579] Only set managed memory when starting an active RM

flinkbot edited a comment on issue #9357: [FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9357#issuecomment-518174722 ## CI report: * 83b8631729cd9ec114201fcd746906871a2cb1f7 : FAILURE [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner

flinkbot edited a comment on issue #9363: [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner URL: https://github.com/apache/flink/pull/9363#issuecomment-518265997 ## CI report: * 1fe6c332279c34546ec3db24a574dfd53500d20b : SUCCESS [Build](https://

[jira] [Commented] (FLINK-13548) Support priority of the Flink YARN application

[ https://issues.apache.org/jira/browse/FLINK-13548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900232#comment-16900232 ] Rong Rong commented on FLINK-13548: --- Yes. I think setting it to the default YARN prior

[GitHub] [flink] flinkbot edited a comment on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the …

flinkbot edited a comment on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the … URL: https://github.com/apache/flink/pull/9321#issuecomment-517266286 ## CI report: * 8738fc7248be508edcf3e1c0dcea6578f7b35a7e : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9353: Add a new connector ' flink-connector-rocketmq'

flinkbot edited a comment on issue #9353: Add a new connector ' flink-connector-rocketmq' URL: https://github.com/apache/flink/pull/9353#issuecomment-518013889 ## CI report: * ae86a133468c692d9d29a78e4189412c997a5752 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/1218

[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516257535 ## CI report: * 59b1a6d50b025925afd14a09b2b95a507889800a : FAILURE [Build](http

[jira] [Created] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

John Lonergan created FLINK-13588: - Summary: StreamTask.handleAsyncException throws away the exception cause Key: FLINK-13588 URL: https://issues.apache.org/jira/browse/FLINK-13588 Project: Flink

[GitHub] [flink] tillrohrmann closed pull request #9357: [FLINK-13579] Only set managed memory when starting an active RM

tillrohrmann closed pull request #9357: [FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9357 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] tillrohrmann closed pull request #9358: [BP-1.9][FLINK-13579] Only set managed memory when starting an active RM

tillrohrmann closed pull request #9358: [BP-1.9][FLINK-13579] Only set managed memory when starting an active RM URL: https://github.com/apache/flink/pull/9358 This is an automated message from the Apache Git Service. To res

[jira] [Resolved] (FLINK-13579) Failed launching standalone cluster due to improper configured irrelevant config options for active mode.

[ https://issues.apache.org/jira/browse/FLINK-13579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13579. --- Resolution: Fixed Fixed via 1.10.0: 634a634bb21b50649b3a819bf73f179d5cbe7931 1.9.0: 789c605

[GitHub] [flink] GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on a change in pull request #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#discussion_r310609212 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/concu

[jira] [Commented] (FLINK-13558) Include table examples in flink-dist

[ https://issues.apache.org/jira/browse/FLINK-13558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900343#comment-16900343 ] Seth Wiesman commented on FLINK-13558: -- Sounds good, thanks for the clarification.

[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516257535 ## CI report: * 59b1a6d50b025925afd14a09b2b95a507889800a : FAILURE [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516257535 ## CI report: * 59b1a6d50b025925afd14a09b2b95a507889800a : FAILURE [Build](http

[GitHub] [flink] GJL commented on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

GJL commented on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-518380525 Please review @tillrohrmann This

[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516257535 ## CI report: * 59b1a6d50b025925afd14a09b2b95a507889800a : FAILURE [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions

flinkbot edited a comment on issue #9268: [FLINK-13452] Ensure to fail global when exception happens during reseting tasks of regions URL: https://github.com/apache/flink/pull/9268#issuecomment-516257535 ## CI report: * 59b1a6d50b025925afd14a09b2b95a507889800a : FAILURE [Build](http

[jira] [Created] (FLINK-13589) DelimitedInputFormat index error on multi-byte delimiters with whole file input splits

Adric Eckstein created FLINK-13589: -- Summary: DelimitedInputFormat index error on multi-byte delimiters with whole file input splits Key: FLINK-13589 URL: https://issues.apache.org/jira/browse/FLINK-13589

[GitHub] [flink] xuefuz commented on a change in pull request #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors

xuefuz commented on a change in pull request #9342: [FLINK-13438][hive] Fix DataTypes.DATE/TIME/TIMESTAMP support for hive connectors URL: https://github.com/apache/flink/pull/9342#discussion_r310787344 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/fl

<    1   2   3   4   5   >