[jira] [Assigned] (FLINK-15169) Errors happen in the scheduling of DefaultScheduler is not shown in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-15169: Assignee: Gary Yao (was: Zhu Zhu) > Errors happen in the scheduling of DefaultScheduler is not s

[jira] [Assigned] (FLINK-15169) Errors happen in the scheduling of DefaultScheduler is not shown in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-15169: Assignee: Gary Yao > Errors happen in the scheduling of DefaultScheduler is not shown in WebUI >

[jira] [Assigned] (FLINK-15169) Errors happen in the scheduling of DefaultScheduler is not shown in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-15169: Assignee: Zhu Zhu (was: Gary Yao) > Errors happen in the scheduling of DefaultScheduler is not s

[jira] [Assigned] (FLINK-15168) Exception is thrown when using kafka source connector with flink planner

[ https://issues.apache.org/jira/browse/FLINK-15168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-15168: Assignee: Dawid Wysakowicz (was: Zhenghua Gao) > Exception is thrown when using

[GitHub] [flink] flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e Travis: [SUCCES

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r356444335 ## File path: flink-runtime/src/test/java/org/apache/flink/runt

[jira] [Commented] (FLINK-13197) Verify querying Hive's view in Flink

[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993269#comment-16993269 ] Dawid Wysakowicz commented on FLINK-13197: -- Good idea [~lirui] Thank you > Ver

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r356442618 ## File path: flink-runtime/src/main/java/org/apache/flink/runt

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r356441741 ## File path: flink-runtime/src/main/java/org/apache/flink/runt

[GitHub] [flink] flinkbot edited a comment on issue #10525: [hotfix][doc] refine docs for catalog APIs

flinkbot edited a comment on issue #10525: [hotfix][doc] refine docs for catalog APIs URL: https://github.com/apache/flink/pull/10525#issuecomment-564411337 ## CI report: * d99fa27649e4ee125b0d53ce173ad1e21e88fd0e Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/140

[GitHub] [flink] flinkbot edited a comment on issue #10522: [FLINK-15153]Service selector needs to contain jobmanager component label(Backport to 1.10)

flinkbot edited a comment on issue #10522: [FLINK-15153]Service selector needs to contain jobmanager component label(Backport to 1.10) URL: https://github.com/apache/flink/pull/10522#issuecomment-564348907 ## CI report: * 137c5df8e1bfffa09a00d7d7515c8b09d961753a Travis: [CANCELE

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

[jira] [Commented] (FLINK-15192) consider split 'SQL' page into multiple sub pages for better clarity

[ https://issues.apache.org/jira/browse/FLINK-15192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993268#comment-16993268 ] Jingsong Lee commented on FLINK-15192: -- +1. I kind of like hive's name: * Data De

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r356429397 ## File path: flink-runtime/src/main/java/org/apache/flink/runt

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r356435083 ## File path: flink-runtime/src/main/java/org/apache/flink/runt

[GitHub] [flink] flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e Travis: [SUCCES

[jira] [Commented] (FLINK-15192) consider split 'SQL' page into multiple sub pages for better clarity

[ https://issues.apache.org/jira/browse/FLINK-15192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993261#comment-16993261 ] Jark Wu commented on FLINK-15192: - +1 for this. I'm also frustrated by current SQL page,

[GitHub] [flink] flinkbot edited a comment on issue #10434: [FLINK-15072][client] executeAsync in ContextEnvironment from CliFrontend cause unexpected exception

flinkbot edited a comment on issue #10434: [FLINK-15072][client] executeAsync in ContextEnvironment from CliFrontend cause unexpected exception URL: https://github.com/apache/flink/pull/10434#issuecomment-562048009 ## CI report: * 3657f8be3e9a8eb83712a9eeafe0bc8e3c182c95 Travis:

[GitHub] [flink] wangyang0918 commented on issue #10522: [FLINK-15153]Service selector needs to contain jobmanager component label(Backport to 1.10)

wangyang0918 commented on issue #10522: [FLINK-15153]Service selector needs to contain jobmanager component label(Backport to 1.10) URL: https://github.com/apache/flink/pull/10522#issuecomment-564412859 @flinkbot run travis T

[jira] [Commented] (FLINK-15191) Fix can't create table source for Kafka if watermark or computed column is defined

[ https://issues.apache.org/jira/browse/FLINK-15191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993258#comment-16993258 ] Leonard Xu commented on FLINK-15191: [~jark] thanks, [~lzljs3620320] I think so, I’l

[jira] [Commented] (FLINK-15191) Fix can't create table source for Kafka if watermark or computed column is defined

[ https://issues.apache.org/jira/browse/FLINK-15191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993257#comment-16993257 ] Jingsong Lee commented on FLINK-15191: -- I mark it blocker since I think watermark a

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

[jira] [Updated] (FLINK-15191) Fix can't create table source for Kafka if watermark or computed column is defined

[ https://issues.apache.org/jira/browse/FLINK-15191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15191: - Priority: Blocker (was: Major) > Fix can't create table source for Kafka if watermark or comput

[GitHub] [flink] flinkbot commented on issue #10525: [hotfix][doc] refine docs for catalog APIs

flinkbot commented on issue #10525: [hotfix][doc] refine docs for catalog APIs URL: https://github.com/apache/flink/pull/10525#issuecomment-564411337 ## CI report: * d99fa27649e4ee125b0d53ce173ad1e21e88fd0e UNKNOWN Bot commands The @flinkbot bot supports the follow

[GitHub] [flink] flinkbot edited a comment on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

flinkbot edited a comment on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#issuecomment-564108895 ## CI report: * 9a0046d4b1d5b28907b617e5f82dab114ee97a31 Travis: [FAILURE](https://tra

[jira] [Created] (FLINK-15192) consider split 'SQL' page into multiple sub pages for better clarity

Bowen Li created FLINK-15192: Summary: consider split 'SQL' page into multiple sub pages for better clarity Key: FLINK-15192 URL: https://issues.apache.org/jira/browse/FLINK-15192 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10501: [FLINK-15139][table sql / client]misc end to end test failed cause loss jars in converting to jobgraph

flinkbot edited a comment on issue #10501: [FLINK-15139][table sql / client]misc end to end test failed cause loss jars in converting to jobgraph URL: https://github.com/apache/flink/pull/10501#issuecomment-563307886 ## CI report: * 88033844e8102c06281586898f8641dd4cba3a3c Travi

[jira] [Assigned] (FLINK-15191) Fix can't create table source for Kafka if watermark or computed column is defined

[ https://issues.apache.org/jira/browse/FLINK-15191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15191: --- Assignee: Leonard Xu > Fix can't create table source for Kafka if watermark or computed column is

[GitHub] [flink] leonardBang commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector

leonardBang commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector URL: https://github.com/apache/flink/pull/10514#discussion_r356430441 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot commented on issue #10525: [hotfix][doc] refine docs for catalog APIs

flinkbot commented on issue #10525: [hotfix][doc] refine docs for catalog APIs URL: https://github.com/apache/flink/pull/10525#issuecomment-564408399 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We wi

[GitHub] [flink] bowenli86 commented on issue #10525: [hotfix][doc] refine docs for catalog APIs

bowenli86 commented on issue #10525: [hotfix][doc] refine docs for catalog APIs URL: https://github.com/apache/flink/pull/10525#issuecomment-564407989 @xuefuz @lirui-apache @JingsongLi @zjuwangg This is an automated message f

[GitHub] [flink] bowenli86 opened a new pull request #10525: [hotfix][doc] refine docs for catalog APIs

bowenli86 opened a new pull request #10525: [hotfix][doc] refine docs for catalog APIs URL: https://github.com/apache/flink/pull/10525 ## What is the purpose of the change refine docs for new Catalog APIs in case users want to programmatically manipulate catalog objects ## Br

[GitHub] [flink] flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e Travis: [SUCCES

[jira] [Commented] (FLINK-15153) Service selector needs to contain jobmanager component label

[ https://issues.apache.org/jira/browse/FLINK-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993252#comment-16993252 ] Dian Fu commented on FLINK-15153: - Thanks. Just noticed that PR. (y) > Service selector

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r356424126 ## File path: flink-runtime/src/main/java/org/apache/flink/runt

[GitHub] [flink] wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356428513 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/f

[GitHub] [flink] wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356428371 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/

[jira] [Created] (FLINK-15191) Fix can't create table source for Kafka if watermark or computed column is defined

Jark Wu created FLINK-15191: --- Summary: Fix can't create table source for Kafka if watermark or computed column is defined Key: FLINK-15191 URL: https://issues.apache.org/jira/browse/FLINK-15191 Project: Fli

[jira] [Commented] (FLINK-15153) Service selector needs to contain jobmanager component label

[ https://issues.apache.org/jira/browse/FLINK-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993251#comment-16993251 ] Yang Wang commented on FLINK-15153: --- [~dian.fu] Thanks for your kindly reminding. I ha

[jira] [Commented] (FLINK-14953) Parquet table source should use schema type to build FilterPredicate

[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993249#comment-16993249 ] Dian Fu commented on FLINK-14953: - [~lzljs3620320] You're right. I missed it. Thanks for

[jira] [Updated] (FLINK-14958) ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

[ https://issues.apache.org/jira/browse/FLINK-14958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14958: -- Fix Version/s: 1.11.0 > ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

[jira] [Updated] (FLINK-14958) ProgramTargetDescriptor#jobID can be of type JobID

[ https://issues.apache.org/jira/browse/FLINK-14958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14958: -- Summary: ProgramTargetDescriptor#jobID can be of type JobID (was: ProgramTargetDescriptor#jobID possi

[jira] [Commented] (FLINK-14958) ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

[ https://issues.apache.org/jira/browse/FLINK-14958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993248#comment-16993248 ] Zili Chen commented on FLINK-14958: --- [~dian.fu] this is a minor code refactor that I d

[jira] [Updated] (FLINK-14958) ProgramTargetDescriptor#jobID can be of type JobID

[ https://issues.apache.org/jira/browse/FLINK-14958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14958: -- Priority: Minor (was: Major) > ProgramTargetDescriptor#jobID can be of type JobID > -

[jira] [Commented] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes

[ https://issues.apache.org/jira/browse/FLINK-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993247#comment-16993247 ] ouyangwulin commented on FLINK-14172: - Please assign this to me > Implement KubeCli

[GitHub] [flink] JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector

JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector URL: https://github.com/apache/flink/pull/10514#discussion_r356425513 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/

[GitHub] [flink] flinkbot edited a comment on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

flinkbot edited a comment on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#issuecomment-564108895 ## CI report: * 9a0046d4b1d5b28907b617e5f82dab114ee97a31 Travis: [FAILURE](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #10501: [FLINK-15139][table sql / client]misc end to end test failed cause loss jars in converting to jobgraph

flinkbot edited a comment on issue #10501: [FLINK-15139][table sql / client]misc end to end test failed cause loss jars in converting to jobgraph URL: https://github.com/apache/flink/pull/10501#issuecomment-563307886 ## CI report: * 88033844e8102c06281586898f8641dd4cba3a3c Travi

[jira] [Commented] (FLINK-15139) misc end to end test failed cause loss jars in converting to jobgraph

[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993243#comment-16993243 ] Leonard Xu commented on FLINK-15139: [~liyu] Yes，it‘s a blocker issue. I had submitt

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r356424126 ## File path: flink-runtime/src/main/java/org/apache/flink/runt

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r356424126 ## File path: flink-runtime/src/main/java/org/apache/flink/runt

[jira] [Commented] (FLINK-15179) Kubernetes should not have a CustomCommandLine.

[ https://issues.apache.org/jira/browse/FLINK-15179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993241#comment-16993241 ] Yang Wang commented on FLINK-15179: --- Hi, [~kkl0u] Does `AbstractCustomCommandLine` wil

[GitHub] [flink] JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356423681 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apac

[jira] [Created] (FLINK-15190) add documentation for DDL in FLIP-69

Bowen Li created FLINK-15190: Summary: add documentation for DDL in FLIP-69 Key: FLINK-15190 URL: https://issues.apache.org/jira/browse/FLINK-15190 Project: Flink Issue Type: Task Compo

[GitHub] [flink] rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain stri

rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r356423342 ## File path: flink-strea

[GitHub] [flink] wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356423176 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/

[jira] [Commented] (FLINK-14953) Parquet table source should use schema type to build FilterPredicate

[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993240#comment-16993240 ] Jingsong Lee commented on FLINK-14953: -- [~dian.fu] I can find in 1.10 branch: [FLIN

[jira] [Created] (FLINK-15189) add documentation for catalog view and hive view

Bowen Li created FLINK-15189: Summary: add documentation for catalog view and hive view Key: FLINK-15189 URL: https://issues.apache.org/jira/browse/FLINK-15189 Project: Flink Issue Type: Task

[jira] [Comment Edited] (FLINK-14958) ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

[ https://issues.apache.org/jira/browse/FLINK-14958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993238#comment-16993238 ] Dian Fu edited comment on FLINK-14958 at 12/11/19 6:30 AM: --- Hi

[jira] [Commented] (FLINK-14958) ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

[ https://issues.apache.org/jira/browse/FLINK-14958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993238#comment-16993238 ] Dian Fu commented on FLINK-14958: - Hi [~tison], the fix version isn't set. Just a remind

[GitHub] [flink] rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain stri

rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r356422203 ## File path: flink-strea

[GitHub] [flink] wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

wuchong commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356422121 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/f

[jira] [Commented] (FLINK-14953) Parquet table source should use schema type to build FilterPredicate

[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993235#comment-16993235 ] Dian Fu commented on FLINK-14953: - Hi [~ykt836], the 1.10 release branch has been cut ye

[jira] [Commented] (FLINK-15153) Service selector needs to contain jobmanager component label

[ https://issues.apache.org/jira/browse/FLINK-15153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993234#comment-16993234 ] Dian Fu commented on FLINK-15153: - Hi [~zjwang], the 1.10 release branch has been cut ye

[GitHub] [flink] rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain stri

rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r356420318 ## File path: flink-strea

[GitHub] [flink] rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain stri

rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r356420318 ## File path: flink-strea

[GitHub] [flink] hequn8128 commented on a change in pull request #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API

hequn8128 commented on a change in pull request #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API URL: https://github.com/apache/flink/pull/10515#discussion_r356418038 ## File path: docs/dev/table/sourceSinks.md ##

[GitHub] [flink] flinkbot edited a comment on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

flinkbot edited a comment on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#issuecomment-564108895 ## CI report: * 9a0046d4b1d5b28907b617e5f82dab114ee97a31 Travis: [FAILURE](https://tra

[GitHub] [flink] hequn8128 commented on a change in pull request #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API

hequn8128 commented on a change in pull request #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API URL: https://github.com/apache/flink/pull/10515#discussion_r356419153 ## File path: docs/dev/table/sourceSinks.md ##

[jira] [Commented] (FLINK-15135) Adding e2e tests for Flink's Mesos integration

[ https://issues.apache.org/jira/browse/FLINK-15135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993228#comment-16993228 ] Yangze Guo commented on FLINK-15135: As the first step, I'd like to just build the f

[GitHub] [flink] hequn8128 commented on a change in pull request #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API

hequn8128 commented on a change in pull request #10515: [FLINK-14007][python][docs] Add documentation for how to use Java user-defined source/sink in Python API URL: https://github.com/apache/flink/pull/10515#discussion_r356418038 ## File path: docs/dev/table/sourceSinks.md ##

[GitHub] [flink] flinkbot edited a comment on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

flinkbot edited a comment on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493#issuecomment-563111006 ## CI report: * a79225d75a53240951a4378380ff2aac457c1278 Tr

[GitHub] [flink] JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356416161 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apach

[jira] [Comment Edited] (FLINK-15135) Adding e2e tests for Flink's Mesos integration

[ https://issues.apache.org/jira/browse/FLINK-15135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993226#comment-16993226 ] Yangze Guo edited comment on FLINK-15135 at 12/11/19 6:03 AM:

[jira] [Commented] (FLINK-15135) Adding e2e tests for Flink's Mesos integration

[ https://issues.apache.org/jira/browse/FLINK-15135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993226#comment-16993226 ] Yangze Guo commented on FLINK-15135: Hi, [~trohrmann]. I'm willing to working on thi

[GitHub] [flink] flinkbot edited a comment on issue #10434: [FLINK-15072][client] executeAsync in ContextEnvironment from CliFrontend cause unexpected exception

flinkbot edited a comment on issue #10434: [FLINK-15072][client] executeAsync in ContextEnvironment from CliFrontend cause unexpected exception URL: https://github.com/apache/flink/pull/10434#issuecomment-562048009 ## CI report: * 3657f8be3e9a8eb83712a9eeafe0bc8e3c182c95 Travis:

[GitHub] [flink] JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356415385 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apach

[GitHub] [flink] JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356414653 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apach

[GitHub] [flink] JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356413957 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apach

[GitHub] [flink] JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

JingsongLi commented on a change in pull request #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#discussion_r356413683 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apac

[GitHub] [flink] JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector

JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector URL: https://github.com/apache/flink/pull/10514#discussion_r356411359 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/

[GitHub] [flink] JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector

JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector URL: https://github.com/apache/flink/pull/10514#discussion_r356411828 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/

[GitHub] [flink] JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector

JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector URL: https://github.com/apache/flink/pull/10514#discussion_r356412063 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/

[GitHub] [flink] JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector

JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector URL: https://github.com/apache/flink/pull/10514#discussion_r356412983 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/

[GitHub] [flink] JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector

JingsongLi commented on a change in pull request #10514: [FLINK-15167][sql-client] SQL CLI library option doesn't work for Hive connector URL: https://github.com/apache/flink/pull/10514#discussion_r356411620 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/

[GitHub] [flink] flinkbot edited a comment on issue #10522: [FLINK-15153]Service selector needs to contain jobmanager component label(Backport to 1.10)

flinkbot edited a comment on issue #10522: [FLINK-15153]Service selector needs to contain jobmanager component label(Backport to 1.10) URL: https://github.com/apache/flink/pull/10522#issuecomment-564348907 ## CI report: * 137c5df8e1bfffa09a00d7d7515c8b09d961753a Travis: [CANCELE

[jira] [Assigned] (FLINK-14952) Yarn containers can exceed physical memory limits when using BoundedBlockingSubpartition.

[ https://issues.apache.org/jira/browse/FLINK-14952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-14952: Assignee: zhijiang > Yarn containers can exceed physical memory limits when using > BoundedBlock

[GitHub] [flink] wuchong commented on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed

wuchong commented on issue #10518: [FLINK-15124][table] Fix types with precision defined in DDL can't be executed URL: https://github.com/apache/flink/pull/10518#issuecomment-564390222 Hi @JingsongLi , @danny0405 , I have updated the PR, please have another look. -

[jira] [Assigned] (FLINK-15140) Shuffle data compression does not work with BroadcastRecordWriter.

[ https://issues.apache.org/jira/browse/FLINK-15140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-15140: Assignee: Yingjie Cao > Shuffle data compression does not work with BroadcastRecordWriter. >

[jira] [Commented] (FLINK-14952) Yarn containers can exceed physical memory limits when using BoundedBlockingSubpartition.

[ https://issues.apache.org/jira/browse/FLINK-14952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993207#comment-16993207 ] zhijiang commented on FLINK-14952: -- As [~kevin.cyj] mentioned above, the current blocki

[GitHub] [flink] flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e Travis: [SUCCES

[jira] [Created] (FLINK-15188) add builder for catalog objects

Bowen Li created FLINK-15188: Summary: add builder for catalog objects Key: FLINK-15188 URL: https://issues.apache.org/jira/browse/FLINK-15188 Project: Flink Issue Type: Task Components

[GitHub] [flink] flinkbot edited a comment on issue #10434: [FLINK-15072][client] executeAsync in ContextEnvironment from CliFrontend cause unexpected exception

flinkbot edited a comment on issue #10434: [FLINK-15072][client] executeAsync in ContextEnvironment from CliFrontend cause unexpected exception URL: https://github.com/apache/flink/pull/10434#issuecomment-562048009 ## CI report: * 3657f8be3e9a8eb83712a9eeafe0bc8e3c182c95 Travis:

[jira] [Commented] (FLINK-13437) Add Hive SQL E2E test

[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993202#comment-16993202 ] Yu Li commented on FLINK-13437: --- [~Terry1897] I'd like to help but only assignee of the is

[GitHub] [flink] flinkbot edited a comment on issue #10522: [FLINK-15153]Service selector needs to contain jobmanager component label(Backport to 1.10)

flinkbot edited a comment on issue #10522: [FLINK-15153]Service selector needs to contain jobmanager component label(Backport to 1.10) URL: https://github.com/apache/flink/pull/10522#issuecomment-564348907 ## CI report: * 137c5df8e1bfffa09a00d7d7515c8b09d961753a Travis: [CANCELE

[GitHub] [flink] flinkbot edited a comment on issue #10501: [FLINK-15139][table sql / client]misc end to end test failed cause loss jars in converting to jobgraph

flinkbot edited a comment on issue #10501: [FLINK-15139][table sql / client]misc end to end test failed cause loss jars in converting to jobgraph URL: https://github.com/apache/flink/pull/10501#issuecomment-563307886 ## CI report: * 88033844e8102c06281586898f8641dd4cba3a3c Travi

[GitHub] [flink] flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e Travis: [SUCCES

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 Travis: [CANCELE

[GitHub] [flink] flinkbot edited a comment on issue #10524: [hotfix][doc] update Hive doc

flinkbot edited a comment on issue #10524: [hotfix][doc] update Hive doc URL: https://github.com/apache/flink/pull/10524#issuecomment-564373940 ## CI report: * 8245ff2b8a069c227013ffe04001d6f0778e7979 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/140539604) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times

flinkbot edited a comment on issue #10523: [FLINK-15073][sql-client] SQL-CLI fails to run same query multiple times URL: https://github.com/apache/flink/pull/10523#issuecomment-564363476 ## CI report: * afdfe7941439eeec090d3123319c74ecb7fb21ee Travis: [FAILURE](https://travis-ci

  1   2   3   4   5   6   7   >