[GitHub] [flink] KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-09 Thread GitBox
KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r364610607 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -606,25 +606,33 @@

[jira] [Commented] (FLINK-15500) "SQL Client end-to-end test for Kafka" failed in my local environment

2020-01-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011594#comment-17011594 ] Jark Wu commented on FLINK-15500: - Hi [~twalthr], I think at least we can include Avro dependencies for

[jira] [Updated] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15533: --- Affects Version/s: 1.10.0 > Writing DataStream as text file fails due to output path

[jira] [Updated] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15533: --- Component/s: Client / Job Submission > Writing DataStream as text file fails due to output

[GitHub] [flink] TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs

2020-01-09 Thread GitBox
TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs URL: https://github.com/apache/flink/pull/10658#discussion_r364630402 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java

[GitHub] [flink] TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs

2020-01-09 Thread GitBox
TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs URL: https://github.com/apache/flink/pull/10658#discussion_r364630402 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011609#comment-17011609 ] Jingsong Lee commented on FLINK-15527: -- Hi [~trohrmann], But what users really want is control the

[GitHub] [flink] TisonKun opened a new pull request #10808: [FLINK-15536][configuration] Revert removal of ConfigConstants.YARN_MAX_FAILED_CONTAINERS

2020-01-09 Thread GitBox
TisonKun opened a new pull request #10808: [FLINK-15536][configuration] Revert removal of ConfigConstants.YARN_MAX_FAILED_CONTAINERS URL: https://github.com/apache/flink/pull/10808 Revert breaking changes introduced by FLINK-15359 #10658 cc @tillrohrmann

[jira] [Updated] (FLINK-15517) Use back 'network' in 'shuffle' memory config option names

2020-01-09 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-15517: Priority: Blocker (was: Critical) > Use back 'network' in 'shuffle' memory config option

[jira] [Commented] (FLINK-15531) Nightly build stalls in e2e-ha-scala-2.12 stage

2020-01-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011656#comment-17011656 ] Yang Wang commented on FLINK-15531: --- I think the root cause is starting the minikube failed and we

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011657#comment-17011657 ] Yuan Mei commented on FLINK-14163: -- [~zhuzh] Thank you sooo much. I prefer option 3 better as well,

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011657#comment-17011657 ] Yuan Mei edited comment on FLINK-14163 at 1/9/20 10:16 AM: --- [~zhuzh] Thank you

[GitHub] [flink] flinkbot edited a comment on issue #10757: [FLINK-15464][hive] Fix HiveTableSourceTest::testPartitionFilterDateT…

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10757: [FLINK-15464][hive] Fix HiveTableSourceTest::testPartitionFilterDateT… URL: https://github.com/apache/flink/pull/10757#issuecomment-570480960 ## CI report: * d14af3d28168e537fd24b45f743c6c6422ea2b62 Travis:

[GitHub] [flink] wuchong commented on issue #10803: [FLINK-15518][web]: don not hide web frontend side pane automatically

2020-01-09 Thread GitBox
wuchong commented on issue #10803: [FLINK-15518][web]: don not hide web frontend side pane automatically URL: https://github.com/apache/flink/pull/10803#issuecomment-572515158 Thanks @vthinkxie , great job! I built and verified in my local machine and it works as expected. So +1 from

[jira] [Updated] (FLINK-15523) ConfigConstants generally excluded from japicmp

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15523: - Fix Version/s: 1.9.2 1.8.4 > ConfigConstants generally excluded from

[jira] [Assigned] (FLINK-15457) Remove the finished TODO in the YarnEntrypointUtils

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-15457: Assignee: Yang Wang > Remove the finished TODO in the YarnEntrypointUtils >

[jira] [Updated] (FLINK-15457) Remove outdated TODO in YarnEntrypointUtils

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15457: - Summary: Remove outdated TODO in YarnEntrypointUtils (was: Remove the finished TODO in

[GitHub] [flink] dawidwys commented on a change in pull request #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

2020-01-09 Thread GitBox
dawidwys commented on a change in pull request #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781#discussion_r364712338 ## File path:

[jira] [Closed] (FLINK-15457) Remove the finished TODO in the YarnEntrypointUtils

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15457. Resolution: Fixed master: 3872c0dcf0e3de99f5ce8bf879836068006c5121 > Remove the finished

[jira] [Updated] (FLINK-15457) Remove the finished TODO in the YarnEntrypointUtils

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15457: - Issue Type: Improvement (was: Task) > Remove the finished TODO in the

[jira] [Updated] (FLINK-15457) Remove the finished TODO in the YarnEntrypointUtils

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15457: - Fix Version/s: 1.11.0 > Remove the finished TODO in the YarnEntrypointUtils >

[GitHub] [flink] zentol merged pull request #10761: [FLINK-15457][yarn] Remove finished TODO in YarnEntrypointUtils

2020-01-09 Thread GitBox
zentol merged pull request #10761: [FLINK-15457][yarn] Remove finished TODO in YarnEntrypointUtils URL: https://github.com/apache/flink/pull/10761 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on issue #10806: [hotfix][documentation] Fix wrong DataStream class type

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10806: [hotfix][documentation] Fix wrong DataStream class type URL: https://github.com/apache/flink/pull/10806#issuecomment-572427981 ## CI report: * 51b0c913fea359f7103d51bd84cfa09f09fea276 Travis:

[jira] [Commented] (FLINK-15535) Add usage of ProcessFunctionTestHarnesses for testing documentation

2020-01-09 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011542#comment-17011542 ] vinoyang commented on FLINK-15535: -- [~aljoscha] and [~trohrmann] WDYT? > Add usage of

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-09 Thread GitBox
KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r364614042 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -606,25 +606,33 @@

[jira] [Commented] (FLINK-13651) Blink planner should parse char(n)/varchar(n)/decimal(p, s) inside a string to corresponding datatype

2020-01-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011551#comment-17011551 ] Timo Walther commented on FLINK-13651: -- Until FLIP-55 is finally in place, we could think about a

[GitHub] [flink] dawidwys commented on a change in pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection

2020-01-09 Thread GitBox
dawidwys commented on a change in pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection URL: https://github.com/apache/flink/pull/10606#discussion_r364628055 ## File path:

[jira] [Commented] (FLINK-15523) ConfigConstants generally excluded from japicmp

2020-01-09 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011597#comment-17011597 ] Till Rohrmann commented on FLINK-15523: --- I would suggest the following: Re-enable japicmp check

[GitHub] [flink] twalthr commented on a change in pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection

2020-01-09 Thread GitBox
twalthr commented on a change in pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection URL: https://github.com/apache/flink/pull/10606#discussion_r364627748 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection

2020-01-09 Thread GitBox
dawidwys commented on a change in pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection URL: https://github.com/apache/flink/pull/10606#discussion_r364627856 ## File path:

[jira] [Commented] (FLINK-15434) testResourceManagerConnectionAfterRegainingLeadership test fail when run azure

2020-01-09 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011613#comment-17011613 ] Gary Yao commented on FLINK-15434: -- [~hailong wang] I assigned you to the issue. We should fix all

[jira] [Updated] (FLINK-15536) Revert removal of ConfigConstants.YARN_MAX_FAILED_CONTAINERS

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15536: - Priority: Blocker (was: Major) > Revert removal of

[jira] [Commented] (FLINK-15509) Use sql cilents create view occur Unexpected exception

2020-01-09 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011659#comment-17011659 ] Zhenghua Gao commented on FLINK-15509: -- Should we verify whether the properties exist, or whether

[jira] [Issue Comment Deleted] (FLINK-15489) Cannot update jobmanager/taskmanager logs

2020-01-09 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-15489: --- Comment: was deleted (was: As [~vthinkxie] said, it's to reduce the pressure of the rest server. As the

[GitHub] [flink] flinkbot commented on issue #10809: [FLINK-15538] Separate decimal implementations into separate sub-classes

2020-01-09 Thread GitBox
flinkbot commented on issue #10809: [FLINK-15538] Separate decimal implementations into separate sub-classes URL: https://github.com/apache/flink/pull/10809#issuecomment-572504661 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 #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces

2020-01-09 Thread GitBox
twalthr commented on issue #10781: [FLINK-15281][table-planner-blink] Map Flink's TypeInference to Calcite's interfaces URL: https://github.com/apache/flink/pull/10781#issuecomment-572514036 Thank you @dawidwys. I will merge this in my next batch if there are no objections.

[jira] [Comment Edited] (FLINK-15489) Cannot update jobmanager/taskmanager logs

2020-01-09 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011703#comment-17011703 ] Gary Yao edited comment on FLINK-15489 at 1/9/20 11:10 AM: --- Mac OS X 10.14.6,

[jira] [Commented] (FLINK-15489) Cannot update jobmanager/taskmanager logs

2020-01-09 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011703#comment-17011703 ] Gary Yao commented on FLINK-15489: -- Mac OS X 10.14.6, Firefox 72.0.1 (64-bit) !screenshot-2.png! >

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011726#comment-17011726 ] Yang Wang commented on FLINK-15527: --- [~lzljs3620320] Currently, {{YarnResourceManager}} is an

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011725#comment-17011725 ] Rui Li commented on FLINK-15533: [~kkl0u] That's correct. I also quickly tried with 1.9.1 and it works.

[jira] [Commented] (FLINK-15523) ConfigConstants generally excluded from japicmp

2020-01-09 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011724#comment-17011724 ] Stephan Ewen commented on FLINK-15523: -- True, the original exclusion looks like a mistake. Should

[GitHub] [flink] flinkbot commented on issue #10812: [FLINK-15523][conf] Japicmp checks ConfigConstants

2020-01-09 Thread GitBox
flinkbot commented on issue #10812: [FLINK-15523][conf] Japicmp checks ConfigConstants URL: https://github.com/apache/flink/pull/10812#issuecomment-572536096 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] flinkbot commented on issue #10811: [FLINK-15504] Allow output to stdout/stderr during execution of PackagedProgram

2020-01-09 Thread GitBox
flinkbot commented on issue #10811: [FLINK-15504] Allow output to stdout/stderr during execution of PackagedProgram URL: https://github.com/apache/flink/pull/10811#issuecomment-572536116 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Created] (FLINK-15539) Allow user to choose planner for scala shell

2020-01-09 Thread Rui Li (Jira)
Rui Li created FLINK-15539: -- Summary: Allow user to choose planner for scala shell Key: FLINK-15539 URL: https://issues.apache.org/jira/browse/FLINK-15539 Project: Flink Issue Type: Improvement

[GitHub] [flink] lirui-apache opened a new pull request #10813: [FLINK-15515][hive][doc] Document that Hive connector should be used …

2020-01-09 Thread GitBox
lirui-apache opened a new pull request #10813: [FLINK-15515][hive][doc] Document that Hive connector should be used … URL: https://github.com/apache/flink/pull/10813 …with blink planner ## What is the purpose of the change Document Hive connector only works with blink

[jira] [Commented] (FLINK-15500) "SQL Client end-to-end test for Kafka" failed in my local environment

2020-01-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011557#comment-17011557 ] Jingsong Lee commented on FLINK-15500: -- I think at least we can improve the documents to remind

[GitHub] [flink] KurtYoung merged pull request #10760: [FLINK-15466][table-planner] Fix bug of `FlinkAggregateExpandDistinct…

2020-01-09 Thread GitBox
KurtYoung merged pull request #10760: [FLINK-15466][table-planner] Fix bug of `FlinkAggregateExpandDistinct… URL: https://github.com/apache/flink/pull/10760 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011575#comment-17011575 ] Zili Chen commented on FLINK-15533: --- The default value of {{parallelism.default}} is {{1}}. So it

[jira] [Commented] (FLINK-15523) ConfigConstants generally excluded from japicmp

2020-01-09 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011577#comment-17011577 ] Till Rohrmann commented on FLINK-15523: --- {{YARN_MAX_FAILED_CONTAINERS}} seems to be removed as

[GitHub] [flink] TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs

2020-01-09 Thread GitBox
TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs URL: https://github.com/apache/flink/pull/10658#discussion_r364632604 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java

[GitHub] [flink] TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs

2020-01-09 Thread GitBox
TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs URL: https://github.com/apache/flink/pull/10658#discussion_r364632604 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java

[GitHub] [flink] flinkbot edited a comment on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved.

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved. URL: https://github.com/apache/flink/pull/10774#issuecomment-571093161 ## CI report: * bf30d45bc7c1faa05786f6c7b2aca46a49cbf1dd Travis:

[jira] [Commented] (FLINK-15537) Type of keys should be `BinaryRow` when manipulating map state with `BaseRow` as key type.

2020-01-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011712#comment-17011712 ] Jark Wu commented on FLINK-15537: - Nice catch! > Type of keys should be `BinaryRow` when manipulating

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011714#comment-17011714 ] Kostas Kloudas commented on FLINK-15533: [~lirui] To summarize the problem, your job: 1) ALWAYS

[jira] [Assigned] (FLINK-15537) Type of keys should be `BinaryRow` when manipulating map state with `BaseRow` as key type.

2020-01-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15537: --- Assignee: Shuo Cheng > Type of keys should be `BinaryRow` when manipulating map state with

[jira] [Comment Edited] (FLINK-15534) YARNSessionCapacitySchedulerITCase#perJobYarnClusterWithParallelism failed due to NPE

2020-01-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011620#comment-17011620 ] Yang Wang edited comment on FLINK-15534 at 1/9/20 11:38 AM: After diving

[GitHub] [flink] flinkbot edited a comment on issue #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#issuecomment-572399586 ## CI report: * 1bdc001077b6c87a7b27598ed01d250d3d5c4fbf Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10809: [FLINK-15538] Separate decimal implementations into separate sub-classes

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10809: [FLINK-15538] Separate decimal implementations into separate sub-classes URL: https://github.com/apache/flink/pull/10809#issuecomment-572517529 ## CI report: * a8055c21a4c5c246607fe1ab2d26095531f2699e Travis:

[GitHub] [flink] flinkbot commented on issue #10810: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSink

2020-01-09 Thread GitBox
flinkbot commented on issue #10810: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSink URL: https://github.com/apache/flink/pull/10810#issuecomment-572529011 ## CI report: * 6699dae9f0822c7d65aa524f419b17632fe46fd5 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection URL: https://github.com/apache/flink/pull/10606#issuecomment-566547800 ## CI report: * 3be9ae695a857c1fcff5213a8bbbc765a0e51339 Travis:

[GitHub] [flink] xintongsong commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-09 Thread GitBox
xintongsong commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r364710536 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -606,25 +606,33 @@

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-09 Thread GitBox
KarmaGYZ commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r364601882 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -606,25 +606,33 @@

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011530#comment-17011530 ] Rui Li commented on FLINK-15533: [~lzljs3620320] Thanks for the suggestions. Yes it can be reproduced

[GitHub] [flink] tillrohrmann commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs

2020-01-09 Thread GitBox
tillrohrmann commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs URL: https://github.com/apache/flink/pull/10658#discussion_r364623782 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java

[jira] [Closed] (FLINK-15466) `FlinkAggregateExpandDistinctAggregatesRule` generates wrong plan for cases that have distinct aggs with filter.

2020-01-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15466. -- Resolution: Fixed master: 6f2e9abffb0b1ef68e4f2cf058a24524b61e88a1 1.10.0: 

[GitHub] [flink] TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs

2020-01-09 Thread GitBox
TisonKun commented on a change in pull request #10658: [FLINK-15359] Remove unused YarnConfigOptions, Tests, Docs URL: https://github.com/apache/flink/pull/10658#discussion_r364629166 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java

[jira] [Commented] (FLINK-15489) Cannot update jobmanager/taskmanager logs

2020-01-09 Thread Yadong Xie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011617#comment-17011617 ] Yadong Xie commented on FLINK-15489: cc [~lining] > Cannot update jobmanager/taskmanager logs >

[jira] [Updated] (FLINK-14255) Introduce FileSystemStreamingSink

2020-01-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14255: - Summary: Introduce FileSystemStreamingSink (was: Introduce StreamingFileSystemSink) >

[GitHub] [flink] zentol merged pull request #10808: [FLINK-15536][configuration] Revert removal of ConfigConstants.YARN_MAX_FAILED_CONTAINERS

2020-01-09 Thread GitBox
zentol merged pull request #10808: [FLINK-15536][configuration] Revert removal of ConfigConstants.YARN_MAX_FAILED_CONTAINERS URL: https://github.com/apache/flink/pull/10808 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-15536) Revert removal of ConfigConstants.YARN_MAX_FAILED_CONTAINERS

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15536. Resolution: Fixed master: 57912987e3c58b68b584bc15cf547329802d626e > Revert removal of

[jira] [Updated] (FLINK-15536) Revert removal of ConfigConstants.YARN_MAX_FAILED_CONTAINERS

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15536: - Issue Type: Bug (was: Test) > Revert removal of

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011651#comment-17011651 ] Kostas Kloudas commented on FLINK-15533: I have

[GitHub] [flink] xintongsong commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-09 Thread GitBox
xintongsong commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r364656826 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -606,25 +606,33 @@

[jira] [Updated] (FLINK-15538) Separate decimal implementations into separate sub-classes

2020-01-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15538: --- Labels: pull-request-available (was: ) > Separate decimal implementations into separate

[GitHub] [flink] liyafan82 opened a new pull request #10809: [FLINK-15538] Separate decimal implementations into separate sub-classes

2020-01-09 Thread GitBox
liyafan82 opened a new pull request #10809: [FLINK-15538] Separate decimal implementations into separate sub-classes URL: https://github.com/apache/flink/pull/10809 ## What is the purpose of the change The current implementation of Decimal values have two (somewhat

[GitHub] [flink] flinkbot edited a comment on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved.

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved. URL: https://github.com/apache/flink/pull/10774#issuecomment-571093161 ## CI report: * bf30d45bc7c1faa05786f6c7b2aca46a49cbf1dd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection URL: https://github.com/apache/flink/pull/10606#issuecomment-566547800 ## CI report: * 3be9ae695a857c1fcff5213a8bbbc765a0e51339 Travis:

[jira] [Comment Edited] (FLINK-15489) Cannot update jobmanager/taskmanager logs

2020-01-09 Thread Yadong Xie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011699#comment-17011699 ] Yadong Xie edited comment on FLINK-15489 at 1/9/20 11:08 AM: - Hi

[jira] [Updated] (FLINK-15489) Cannot update jobmanager/taskmanager logs

2020-01-09 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15489: - Attachment: screenshot-2.png > Cannot update jobmanager/taskmanager logs >

[jira] [Commented] (FLINK-15523) ConfigConstants generally excluded from japicmp

2020-01-09 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011723#comment-17011723 ] Andrey Zagrebin commented on FLINK-15523: - [~xintongsong] As I understand, it is a general

[GitHub] [flink] flinkbot edited a comment on issue #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection URL: https://github.com/apache/flink/pull/10606#issuecomment-566547800 ## CI report: * 3be9ae695a857c1fcff5213a8bbbc765a0e51339 Travis:

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011735#comment-17011735 ] Rui Li commented on FLINK-15533: Hi [~kkl0u], I tried your patch and as I expected, it solves the

[GitHub] [flink] flinkbot edited a comment on issue #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#issuecomment-572399586 ## CI report: * 1bdc001077b6c87a7b27598ed01d250d3d5c4fbf Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10810: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSink

2020-01-09 Thread GitBox
flinkbot edited a comment on issue #10810: [FLINK-14255][WIP][table] Introduce FileSystemStreamingSink URL: https://github.com/apache/flink/pull/10810#issuecomment-572529011 ## CI report: * 6699dae9f0822c7d65aa524f419b17632fe46fd5 Travis:

[jira] [Updated] (FLINK-15457) Remove outdated TODO in YarnEntrypointUtils

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15457: - Description: We have the following todo in the

[jira] [Updated] (FLINK-15457) Remove outdated TODO in YarnEntrypointUtils

2020-01-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15457: - Description: We have the following todo in the

[GitHub] [flink] flinkbot commented on issue #10813: [FLINK-15515][hive][doc] Document that Hive connector should be used …

2020-01-09 Thread GitBox
flinkbot commented on issue #10813: [FLINK-15515][hive][doc] Document that Hive connector should be used … URL: https://github.com/apache/flink/pull/10813#issuecomment-572540277 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot commented on issue #10811: [FLINK-15504] Allow output to stdout/stderr during execution of PackagedProgram

2020-01-09 Thread GitBox
flinkbot commented on issue #10811: [FLINK-15504] Allow output to stdout/stderr during execution of PackagedProgram URL: https://github.com/apache/flink/pull/10811#issuecomment-572540427 ## CI report: * 4ded7a2610974acbc983c9ca33965354ce2a1fa2 UNKNOWN Bot commands

[GitHub] [flink] flinkbot commented on issue #10812: [FLINK-15523][conf] Japicmp checks ConfigConstants

2020-01-09 Thread GitBox
flinkbot commented on issue #10812: [FLINK-15523][conf] Japicmp checks ConfigConstants URL: https://github.com/apache/flink/pull/10812#issuecomment-572540515 ## CI report: * c7f9c8ba8d128fac30651631f042d0994d77439b UNKNOWN Bot commands The @flinkbot bot supports

[jira] [Comment Edited] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011546#comment-17011546 ] Zili Chen edited comment on FLINK-15533 at 1/9/20 8:32 AM: --- [~lzljs3620320]

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011546#comment-17011546 ] Zili Chen commented on FLINK-15533: --- [~lzljs3620320] but how? I don't see a clear reason since that

[GitHub] [flink] KurtYoung commented on a change in pull request #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client

2020-01-09 Thread GitBox
KurtYoung commented on a change in pull request #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client URL: https://github.com/apache/flink/pull/10787#discussion_r364611593 ## File path: flink-table/flink-sql-client/conf/sql-client-defaults.yaml

[jira] [Commented] (FLINK-15500) "SQL Client end-to-end test for Kafka" failed in my local environment

2020-01-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011547#comment-17011547 ] Timo Walther commented on FLINK-15500: -- We discussed recently if we should include Avro

[GitHub] [flink] twalthr commented on a change in pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection

2020-01-09 Thread GitBox
twalthr commented on a change in pull request #10606: [FLINK-15009][table-common] Add a utility for creating type inference logic via reflection URL: https://github.com/apache/flink/pull/10606#discussion_r364619675 ## File path:

[jira] [Commented] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-09 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011567#comment-17011567 ] Yangze Guo commented on FLINK-15448: Hi, [~victor-wong], I am interested in this topic and would

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011566#comment-17011566 ] Rui Li commented on FLINK-15533: I set {{parallelism.default}} to 1 > Writing DataStream as text file

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-09 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011564#comment-17011564 ] Zili Chen commented on FLINK-15533: --- what is the value you set to {{parallelism.default}}? > Writing

[jira] [Commented] (FLINK-15500) "SQL Client end-to-end test for Kafka" failed in my local environment

2020-01-09 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011595#comment-17011595 ] Leonard Xu commented on FLINK-15500: Hi, [~twalthr] I think Including Avro dependency can

[jira] [Comment Edited] (FLINK-15500) "SQL Client end-to-end test for Kafka" failed in my local environment

2020-01-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011594#comment-17011594 ] Jark Wu edited comment on FLINK-15500 at 1/9/20 9:11 AM: - Hi [~twalthr], I think

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-09 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011596#comment-17011596 ] Till Rohrmann commented on FLINK-15527: --- Changed the affected components as this seems to be a

  1   2   3   4   5   >