[GitHub] [flink] flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546787757 ## CI report: * 4b0f9efdc169d3b6375d469cd3512e87e98f0f19 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#issuecomment-546868067 ## CI report: * 8c3d1a58bd358493197697e07b9d6542bf29e59a : FAILURE

[GitHub] [flink] flinkbot commented on issue #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph

flinkbot commented on issue #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10014#issuecomment-546878835 ## CI report: * 2a6e23acb701fdffa30ad1425d0c3e399f4b4b40 : UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE

[GitHub] [flink] wuchong commented on a change in pull request #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

wuchong commented on a change in pull request #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#discussion_r339464902 ## File path:

[GitHub] [flink] kl0u edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

kl0u edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-546876357 Hi @TisonKun ! Thanks for the comments, I integrated them. Now for your question, I

[GitHub] [flink] kl0u commented on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

kl0u commented on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-546876357 Hi @TisonKun ! Thanks for the comments, I integrated them. Now for your question, I understand

[jira] [Commented] (FLINK-14545) Resuming Externalized Checkpoint (file, async, scale down) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960897#comment-16960897 ] Till Rohrmann commented on FLINK-14545: --- The logging statement just says that there is no Hadoop

[jira] [Updated] (FLINK-14545) Resuming Externalized Checkpoint (file, async, scale down) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14545: -- Priority: Critical (was: Major) > Resuming Externalized Checkpoint (file, async, scale down)

[jira] [Updated] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14544: -- Priority: Critical (was: Major) > Resuming Externalized Checkpoint after terminal failure

[GitHub] [flink] flinkbot edited a comment on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

flinkbot edited a comment on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#issuecomment-545056164 ## CI report: * 754bf46eea690059abc1919dd43d6e38f0d94c15 : SUCCESS

[jira] [Created] (FLINK-14546) Support map type in flink-json

Benchao Li created FLINK-14546: -- Summary: Support map type in flink-json Key: FLINK-14546 URL: https://issues.apache.org/jira/browse/FLINK-14546 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module

flinkbot edited a comment on issue #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module URL: https://github.com/apache/flink/pull/10011#issuecomment-546837548 ## CI report: * 63f52077e68e47edc8b897efa4bcd860bf1e8e2e : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

flinkbot commented on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#issuecomment-546868067 ## CI report: * 8c3d1a58bd358493197697e07b9d6542bf29e59a : UNKNOWN

[GitHub] [flink] kl0u commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

kl0u commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#discussion_r339470136 ## File path:

[GitHub] [flink] flinkbot commented on issue #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph

flinkbot commented on issue #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10014#issuecomment-546867032 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Created] (FLINK-14545) Resuming Externalized Checkpoint (file, async, scale down) end-to-end test fails on travis

Yu Li created FLINK-14545: - Summary: Resuming Externalized Checkpoint (file, async, scale down) end-to-end test fails on travis Key: FLINK-14545 URL: https://issues.apache.org/jira/browse/FLINK-14545

[jira] [Updated] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph

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

[GitHub] [flink] yanghua opened a new pull request #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph

yanghua opened a new pull request #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10014 ## What is the purpose of the change *This pull request removed STATE_UPDATER in ExecutionGraph* ## Brief change log -

[jira] [Created] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

Yu Li created FLINK-14544: - Summary: Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis Key: FLINK-14544 URL: https://issues.apache.org/jira/browse/FLINK-14544

[GitHub] [flink] flinkbot edited a comment on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

flinkbot edited a comment on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#issuecomment-545056164 ## CI report: * 754bf46eea690059abc1919dd43d6e38f0d94c15 : SUCCESS

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960880#comment-16960880 ] chen yong commented on FLINK-14531: --- @[~gyfora]       Thanks for your reply!We implement a kafka

[GitHub] [flink] kl0u commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions.

kl0u commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions. URL: https://github.com/apache/flink/pull/9976#discussion_r339461822 ## File path: flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ##

[GitHub] [flink] kl0u commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions.

kl0u commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions. URL: https://github.com/apache/flink/pull/9976#discussion_r339461108 ## File path: flink-core/src/main/java/org/apache/flink/configuration/StructuredOptionsSplitter.java

[GitHub] [flink] flinkbot commented on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

flinkbot commented on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#issuecomment-546858383 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13869: --- Labels: pull-request-available (was: ) > Hive functions can not work in blink planner

[GitHub] [flink] flinkbot edited a comment on issue #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters

flinkbot edited a comment on issue #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters URL: https://github.com/apache/flink/pull/10012#issuecomment-546847435 ## CI report: * 9f6d627dbc8321bededaffaf36d1ee956b79ead6 : PENDING

[GitHub] [flink] JingsongLi opened a new pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

JingsongLi opened a new pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013 ## What is the purpose of the change Fix "Hive functions can not work in blink planner

[GitHub] [flink] flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546787757 ## CI report: * 4b0f9efdc169d3b6375d469cd3512e87e98f0f19 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#issuecomment-546323476 ## CI report: * 5f0728f214a49413f94ef838a9e40dda023ebb8b : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE

[jira] [Assigned] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14539: --- Assignee: Kevin Zhang > Unique key metadata should be ketp when using concat or concat_ws in some

[jira] [Comment Edited] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960875#comment-16960875 ] Kevin Zhang edited comment on FLINK-14539 at 10/28/19 9:06 AM: --- Thanks for

[GitHub] [flink] becketqin commented on issue #9824: [FLINK-14302] [kafka] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enab

becketqin commented on issue #9824: [FLINK-14302] [kafka] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS URL: https://github.com/apache/flink/pull/9824#issuecomment-546855274 @tony810430 Sorry for the

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960875#comment-16960875 ] Kevin Zhang commented on FLINK-14539: - Thanks for your opinions[~jark][~danny0405]. Actually I've

[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960876#comment-16960876 ] Jiangjie Qin commented on FLINK-14370: -- I've checked in the patch to master, will backport Piotr's

[GitHub] [flink] dawidwys commented on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#issuecomment-546854430 I tried to address all your comments @KurtYoung @JingsongLi @bowenli86 Could you have another look?

[jira] [Comment Edited] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960873#comment-16960873 ] Jark Wu edited comment on FLINK-14539 at 10/28/19 9:01 AM: --- Hi [~danny0405], I

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960873#comment-16960873 ] Jark Wu commented on FLINK-14539: - Hi [~danny0405], the I think the reason to use {{RexBiVisitor}}

[GitHub] [flink] becketqin closed pull request #9912: [FLINK-14370][kafka][test-stability] Fix the cascading failure in kaProducerTestBase.

becketqin closed pull request #9912: [FLINK-14370][kafka][test-stability] Fix the cascading failure in kaProducerTestBase. URL: https://github.com/apache/flink/pull/9912 This is an automated message from the Apache Git

[GitHub] [flink] becketqin commented on issue #9912: [FLINK-14370][kafka][test-stability] Fix the cascading failure in kaProducerTestBase.

becketqin commented on issue #9912: [FLINK-14370][kafka][test-stability] Fix the cascading failure in kaProducerTestBase. URL: https://github.com/apache/flink/pull/9912#issuecomment-546852484 Merged to master. 96640cad3d770756cb6e70c73b25bd4269065775

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960862#comment-16960862 ] Danny Chen commented on FLINK-14539: Nice catch [~KevinZwx], you should use RexVisitor instead of

[GitHub] [flink] flinkbot commented on issue #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters

flinkbot commented on issue #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters URL: https://github.com/apache/flink/pull/10012#issuecomment-546847435 ## CI report: * 9f6d627dbc8321bededaffaf36d1ee956b79ead6 : UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] lirui-apache commented on a change in pull request #9962: [FLINK-14218][table] support precise function reference in FunctionCatalog

lirui-apache commented on a change in pull request #9962: [FLINK-14218][table] support precise function reference in FunctionCatalog URL: https://github.com/apache/flink/pull/9962#discussion_r33934 ## File path:

[GitHub] [flink] lirui-apache commented on a change in pull request #9962: [FLINK-14218][table] support precise function reference in FunctionCatalog

lirui-apache commented on a change in pull request #9962: [FLINK-14218][table] support precise function reference in FunctionCatalog URL: https://github.com/apache/flink/pull/9962#discussion_r339434024 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module

flinkbot edited a comment on issue #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module URL: https://github.com/apache/flink/pull/10011#issuecomment-546837548 ## CI report: * 63f52077e68e47edc8b897efa4bcd860bf1e8e2e : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

flinkbot edited a comment on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546787757 ## CI report: * 4b0f9efdc169d3b6375d469cd3512e87e98f0f19 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE

[jira] [Commented] (FLINK-14542) YarnConfiguration initialization problem

[ https://issues.apache.org/jira/browse/FLINK-14542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960860#comment-16960860 ] lisen commented on FLINK-14542: --- Hi [~wind_ljy] ，I added a UDF, the resource contains the yarn.site

[GitHub] [flink] flinkbot edited a comment on issue #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

flinkbot edited a comment on issue #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733#issuecomment-533547601 ## CI report: * ea3d0cd6da22ebd2846bf0f3a2fa1d9f21964675 : SUCCESS

[GitHub] [flink] wuchong commented on a change in pull request #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

wuchong commented on a change in pull request #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#discussion_r339445914 ## File path:

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960856#comment-16960856 ] Gyula Fora commented on FLINK-14531: Hi! Thanks for starting the discussion, we have built a Kafka

[jira] [Commented] (FLINK-14542) YarnConfiguration initialization problem

[ https://issues.apache.org/jira/browse/FLINK-14542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960853#comment-16960853 ] Jiayi Liao commented on FLINK-14542: [~Echo Lee] I think this is expected. Can you tell us how this

[GitHub] [flink] flinkbot commented on issue #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters

flinkbot commented on issue #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters URL: https://github.com/apache/flink/pull/10012#issuecomment-546841159 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339441722 ## File path:

[GitHub] [flink] pnowojski closed pull request #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

pnowojski closed pull request #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853 This is an automated message from the Apache Git Service. To

[GitHub] [flink] pnowojski commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

pnowojski commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-546840587 Closing, I've squashed the commits and merged it to master. Thanks for the contribution @ifndef-SleePy

[GitHub] [flink] wangyang0918 commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

wangyang0918 commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#discussion_r339440907 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java

[jira] [Closed] (FLINK-13904) Avoid competition between different rounds of checkpoint triggering

[ https://issues.apache.org/jira/browse/FLINK-13904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-13904. -- Resolution: Fixed Merged to master as 8543334..beb3fb0 > Avoid competition between different

[GitHub] [flink] zzchun opened a new pull request #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters

zzchun opened a new pull request #10012: [hotfix][typo] fix typo in ContaineredTaskManagerParameters URL: https://github.com/apache/flink/pull/10012 ## What is the purpose of the change fix typo in ContaineredTaskManagerParameters ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE

[GitHub] [flink] wangyang0918 commented on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

wangyang0918 commented on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-546838734 > Thanks for opening this pull request @wangyang0918 ! Generally it looks good. I have one question: > > What

[jira] [Commented] (FLINK-14344) Snapshot master hook state asynchronously

[ https://issues.apache.org/jira/browse/FLINK-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960847#comment-16960847 ] Piotr Nowojski commented on FLINK-14344: [~SleePy], as far as me and [~trohrmann] are aware, the

[GitHub] [flink] flinkbot commented on issue #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module

flinkbot commented on issue #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module URL: https://github.com/apache/flink/pull/10011#issuecomment-546837548 ## CI report: * 63f52077e68e47edc8b897efa4bcd860bf1e8e2e : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#issuecomment-546323476 ## CI report: * 5f0728f214a49413f94ef838a9e40dda023ebb8b : SUCCESS

[GitHub] [flink] JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

JingsongLi commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339436930 ## File path:

[jira] [Created] (FLINK-14543) Support partition for temporary table

Jingsong Lee created FLINK-14543: Summary: Support partition for temporary table Key: FLINK-14543 URL: https://issues.apache.org/jira/browse/FLINK-14543 Project: Flink Issue Type: Sub-task

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339436274 ## File path:

[jira] [Comment Edited] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960843#comment-16960843 ] Jark Wu edited comment on FLINK-14539 at 10/28/19 8:01 AM: --- Hi [~KevinZwx], I

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16960843#comment-16960843 ] Jark Wu commented on FLINK-14539: - Hi [~KevinZwx], I think RexBiVisitor is fine. Some thoughts from my

[GitHub] [flink] flinkbot commented on issue #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module

flinkbot commented on issue #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module URL: https://github.com/apache/flink/pull/10011#issuecomment-546832997 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] pnowojski commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

pnowojski commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-546832298 > The order of commit history on this Github PR (at-least in my Chrome) is not same with my private branch

[jira] [Updated] (FLINK-14267) Introduce RowCsvOutputFormat to new CSV module

[ https://issues.apache.org/jira/browse/FLINK-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14267: --- Labels: pull-request-available (was: ) > Introduce RowCsvOutputFormat to new CSV module >

[GitHub] [flink] JingsongLi opened a new pull request #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module

JingsongLi opened a new pull request #10011: [FLINK-14267][table] Introduce RowCsvOutputFormat to new CSV module URL: https://github.com/apache/flink/pull/10011 # What is the purpose of the change Now, we have an old CSV, but that is not standard CSV support. we should support the

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339425618 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339422940 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339431711 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

flinkbot edited a comment on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546558980 ## CI report: * 74748e2c09f1b2b0b9bfb3c1850cd71696d30df8 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

flinkbot edited a comment on issue #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#issuecomment-546323476 ## CI report: * 5f0728f214a49413f94ef838a9e40dda023ebb8b : SUCCESS

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339430273 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

flinkbot edited a comment on issue #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733#issuecomment-533547601 ## CI report: * ea3d0cd6da22ebd2846bf0f3a2fa1d9f21964675 : SUCCESS

[GitHub] [flink] pnowojski commented on a change in pull request #9912: [FLINK-14370][kafka][test-stability] Fix the cascading failure in kaProducerTestBase.

pnowojski commented on a change in pull request #9912: [FLINK-14370][kafka][test-stability] Fix the cascading failure in kaProducerTestBase. URL: https://github.com/apache/flink/pull/9912#discussion_r339430003 ## File path:

[GitHub] [flink] gyfora commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

gyfora commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#discussion_r339429351 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java

[GitHub] [flink] gyfora commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

gyfora commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#discussion_r339429351 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339427857 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339427857 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339427016 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339426445 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339426468 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339426086 ## File path:

[GitHub] [flink] docete commented on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

docete commented on issue #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#issuecomment-546824345 @wuchong @JingsongLi Thanks for your review. Please have another look.

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339425618 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions.

wuchong commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions. URL: https://github.com/apache/flink/pull/9976#discussion_r339425139 ## File path: flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ##

[GitHub] [flink] wuchong commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions.

wuchong commented on a change in pull request #9976: [FLINK-14493][core] Introduce data types to ConfigOptions. URL: https://github.com/apache/flink/pull/9976#discussion_r339425139 ## File path: flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ##

<    1   2   3   4   >