[jira] [Commented] (FLINK-14268) YARN AM endless restarts when using wrong checkpoint path or wrong checkpoint

2020-03-16 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060673#comment-17060673 ] 葛聂 commented on FLINK-14268: I also encounter similar problems,the flink version is 1.7.2.

[GitHub] [flink] flinkbot edited a comment on issue #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up URL: https://github.com/apache/flink/pull/11419#issuecomment-599532494 ## CI report: * 07bb5b2438aa76c476376dbae6b683b972f1031b Tra

[jira] [Created] (FLINK-16628) Complex JSON sink into kafka error

2020-03-16 Thread jackray wang (Jira)
jackray wang created FLINK-16628: Summary: Complex JSON sink into kafka error Key: FLINK-16628 URL: https://issues.apache.org/jira/browse/FLINK-16628 Project: Flink Issue Type: Bug

[GitHub] [flink] leonardBang commented on a change in pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearc

2020-03-16 Thread GitBox
leonardBang commented on a change in pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#discussion_r393470372 ## File path: flink-end-to

[GitHub] [flink] leonardBang commented on a change in pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearc

2020-03-16 Thread GitBox
leonardBang commented on a change in pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#discussion_r393470405 ## File path: flink-end-to

[GitHub] [flink-statefun] tzulitai commented on issue #59: [FLINK-16603] Fix quickstart Maven archetype

2020-03-16 Thread GitBox
tzulitai commented on issue #59: [FLINK-16603] Fix quickstart Maven archetype URL: https://github.com/apache/flink-statefun/pull/59#issuecomment-599901903 Thanks for reviewing Igal! I've fixed the problem you mentioned - `src/main/resources` wasn't being filtered previously, now it shoul

[jira] [Commented] (FLINK-16585) Table program cannot be compiled.Cannot determine simple type name "com"

2020-03-16 Thread jinhai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060668#comment-17060668 ] jinhai commented on FLINK-16585: I haven't been able to reproduce this issue. Can you be

[jira] [Updated] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

2020-03-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-16601: -- Summary: Correct the way to get Endpoint address for NodePort rest Service (was: Corret the way to ge

[jira] [Commented] (FLINK-15871) Support to start sidecar container

2020-03-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060667#comment-17060667 ] Yang Wang commented on FLINK-15871: --- If the K8s cluster is multi-tenant and different

[GitHub] [flink] wuchong commented on a change in pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-16 Thread GitBox
wuchong commented on a change in pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#discussion_r393466630 ## File path: flink-end-to-end

[GitHub] [flink] wuchong commented on a change in pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7

2020-03-16 Thread GitBox
wuchong commented on a change in pull request #11396: [FLINK-16170][connectors/elasticsearch]SearchTemplateRequest ClassNotFoundException when use flink-sql-connector-elasticsearch7 URL: https://github.com/apache/flink/pull/11396#discussion_r393466783 ## File path: flink-end-to-end

[jira] [Commented] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

2020-03-16 Thread jackray wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060665#comment-17060665 ] jackray wang commented on FLINK-16627: -- if i add a where like "where svt is not nul

[jira] [Commented] (FLINK-16602) Rework the Service design for Kubernetes deployment

2020-03-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060662#comment-17060662 ] Canbin Zheng commented on FLINK-16602: -- Yes, you are right [~fly_in_gis]. Glad to r

[jira] [Commented] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

2020-03-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060661#comment-17060661 ] Jark Wu commented on FLINK-16627: - I think user still need the record even if svt is nul

[GitHub] [flink] hequn8128 commented on a change in pull request #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported

2020-03-16 Thread GitBox
hequn8128 commented on a change in pull request #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported URL: https://github.com/apache/flink/pull/11414#discussion_r393463005 ## File path: flink-python/pyflink/table/types.py ## @@

[jira] [Closed] (FLINK-16623) add the shorthand 'desc' for describe on sql client

2020-03-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16623. -- Resolution: Fixed merge to master: 9242daf12ae858db9cab9ec72bdbeaa61e37a948 > add the shorthand 'desc

[GitHub] [flink] KurtYoung merged pull request #11422: [FLINK-16623]add the shorthand 'desc' for describe on sql client

2020-03-16 Thread GitBox
KurtYoung merged pull request #11422: [FLINK-16623]add the shorthand 'desc' for describe on sql client URL: https://github.com/apache/flink/pull/11422 This is an automated message from the Apache Git Service. To respond to t

[jira] [Assigned] (FLINK-16623) add the shorthand 'desc' for describe on sql client

2020-03-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16623: -- Assignee: Jun Zhang > add the shorthand 'desc' for describe on sql client >

[GitHub] [flink] flinkbot edited a comment on issue #11422: [FLINK-16623]add the shorthand 'desc' for describe on sql client

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11422: [FLINK-16623]add the shorthand 'desc' for describe on sql client URL: https://github.com/apache/flink/pull/11422#issuecomment-599831571 ## CI report: * fba4e15d49dfa5610fa26744978d147e52f933c9 Travis: [PENDING](https://travis-ci.com/git

[GitHub] [flink] flinkbot edited a comment on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#issuecomment-599866509 ## CI report: * a891d89757f7432a095de20c361faeee98f31ff6 Travis: [SUCC

[jira] [Closed] (FLINK-16617) Automatic Any unpacking is broken with type deduction.

2020-03-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16617. --- Fix Version/s: statefun-1.1 Resolution: Fixed Fixed in master via fc5276f7130

[GitHub] [flink] dianfu commented on issue #11420: [FLINK-16565][python][ml] Make Pipeline Json compitable between Java and Python if all PipelineStages are Java ones

2020-03-16 Thread GitBox
dianfu commented on issue #11420: [FLINK-16565][python][ml] Make Pipeline Json compitable between Java and Python if all PipelineStages are Java ones URL: https://github.com/apache/flink/pull/11420#issuecomment-599895287 @hequn8128 Thanks for the PR. LGTM. -

[GitHub] [flink-statefun] tzulitai closed pull request #60: [FLINK-16617][py] Use Protobuf DESCRIPTOR instead of class

2020-03-16 Thread GitBox
tzulitai closed pull request #60: [FLINK-16617][py] Use Protobuf DESCRIPTOR instead of class URL: https://github.com/apache/flink-statefun/pull/60 This is an automated message from the Apache Git Service. To respond to the m

[jira] [Commented] (FLINK-16602) Rework the Service design for Kubernetes deployment

2020-03-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060658#comment-17060658 ] Yang Wang commented on FLINK-16602: --- Aha, i think we are on the same page now. We stil

[GitHub] [flink-statefun] tzulitai commented on issue #60: [FLINK-16617][py] Use Protobuf DESCRIPTOR instead of class

2020-03-16 Thread GitBox
tzulitai commented on issue #60: [FLINK-16617][py] Use Protobuf DESCRIPTOR instead of class URL: https://github.com/apache/flink-statefun/pull/60#issuecomment-599894845 Thanks for fixing this @igalshilman! +1, LGTM. Merging this ... --

[jira] [Comment Edited] (FLINK-15641) Support to start init container

2020-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060654#comment-17060654 ] ouyangwulin edited comment on FLINK-15641 at 3/17/20, 6:00 AM: ---

[jira] [Commented] (FLINK-15641) Support to start init container

2020-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060654#comment-17060654 ] ouyangwulin commented on FLINK-15641: - [~fly_in_gis]  As flink on k8s ,not native. I

[jira] [Commented] (FLINK-16345) Computed column can not refer time attribute column

2020-03-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060653#comment-17060653 ] Jark Wu commented on FLINK-16345: - Hi [~danny0405], I guess you may misunderstood this i

[GitHub] [flink] KurtYoung commented on issue #11422: [FLINK-16623]add the shorthand 'desc' for describe on sql client

2020-03-16 Thread GitBox
KurtYoung commented on issue #11422: [FLINK-16623]add the shorthand 'desc' for describe on sql client URL: https://github.com/apache/flink/pull/11422#issuecomment-599891872 @flinkbot run travis This is an automated message fr

[jira] [Closed] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

2020-03-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16627. -- Resolution: Invalid > when insert into kafkas ,how can i remove the keys with null values of json > --

[jira] [Commented] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

2020-03-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060651#comment-17060651 ] Kurt Young commented on FLINK-16627: BTW, such issue should be reported to user mail

[jira] [Commented] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

2020-03-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060650#comment-17060650 ] Kurt Young commented on FLINK-16627: why don't add a "where svt is not null" before

[jira] [Commented] (FLINK-15871) Support to start sidecar container

2020-03-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060649#comment-17060649 ] ouyangwulin commented on FLINK-15871: - [~felixzheng]   >  As collect logs, I think

[GitHub] [flink] flinkbot edited a comment on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#issuecomment-599866509 ## CI report: * a891d89757f7432a095de20c361faeee98f31ff6 Travis: [PEND

[GitHub] [flink] flinkbot edited a comment on issue #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up URL: https://github.com/apache/flink/pull/11419#issuecomment-599532494 ## CI report: * 07bb5b2438aa76c476376dbae6b683b972f1031b Tra

[jira] [Updated] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

2020-03-16 Thread jackray wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackray wang updated FLINK-16627: - Description: {code:java} //sql CREATE TABLE sink_kafka ( subtype STRING , svt STRING ) WITH (……)

[jira] [Updated] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

2020-03-16 Thread jackray wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackray wang updated FLINK-16627: - Description: {code:java} //sql {code} CREATE TABLE sink_kafka ( subtype STRING , svt STRING ) WI

[jira] [Updated] (FLINK-16627) when insert into kafkas ,how can i remove the keys with null values of json

2020-03-16 Thread jackray wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackray wang updated FLINK-16627: - Description: {code:java} //代码占位符 {code} CREATE TABLE sink_kafka ( subtype STRING , svt STRING )

[jira] [Updated] (FLINK-16626) Exception encountered when cancelling a job in yarn per-job mode

2020-03-16 Thread chaiyongqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chaiyongqiang updated FLINK-16626: -- Summary: Exception encountered when cancelling a job in yarn per-job mode (was: Exception nco

[jira] [Updated] (FLINK-16626) Exception ncountered when cancelling a job in yarn per-job mode

2020-03-16 Thread chaiyongqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chaiyongqiang updated FLINK-16626: -- Summary: Exception ncountered when cancelling a job in yarn per-job mode (was: Exception Enco

[jira] [Updated] (FLINK-16413) Reduce hive source parallelism when limit push down

2020-03-16 Thread Jun Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Zhang updated FLINK-16413: -- Affects Version/s: 1.10.0 > Reduce hive source parallelism when limit push down >

[jira] [Comment Edited] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode

2020-03-16 Thread chaiyongqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060639#comment-17060639 ] chaiyongqiang edited comment on FLINK-16626 at 3/17/20, 5:12 AM: -

[jira] [Commented] (FLINK-16345) Computed column can not refer time attribute column

2020-03-16 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060640#comment-17060640 ] Danny Chen commented on FLINK-16345: I think the right place to fix is the SqlToOpe

[jira] [Commented] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode

2020-03-16 Thread chaiyongqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060639#comment-17060639 ] chaiyongqiang commented on FLINK-16626: --- In my opinion, when the client call an ca

[jira] [Created] (FLINK-16627) when insert into kafka ,how can i remove the keys with null value of json

2020-03-16 Thread jackray wang (Jira)
jackray wang created FLINK-16627: Summary: when insert into kafka ,how can i remove the keys with null value of json Key: FLINK-16627 URL: https://issues.apache.org/jira/browse/FLINK-16627 Project: Fl

[GitHub] [flink] danny0405 commented on a change in pull request #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
danny0405 commented on a change in pull request #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#discussion_r393446325 ## File path: flink-table/flink-table-planner-blink/src/main

[jira] [Updated] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode

2020-03-16 Thread chaiyongqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chaiyongqiang updated FLINK-16626: -- Description: When executing the following command to stop a flink job with yarn per-job mode,

[jira] [Created] (FLINK-16626) Exception Encountered when cancelling a job in yarn per-job mode

2020-03-16 Thread chaiyongqiang (Jira)
chaiyongqiang created FLINK-16626: - Summary: Exception Encountered when cancelling a job in yarn per-job mode Key: FLINK-16626 URL: https://issues.apache.org/jira/browse/FLINK-16626 Project: Flink

[GitHub] [flink] danny0405 commented on a change in pull request #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
danny0405 commented on a change in pull request #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#discussion_r393441467 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] godfreyhe commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-16 Thread GitBox
godfreyhe commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-599874222 > > Thanks for update @danny0405, LGTM > > I do not check the plans which are out of order > > Thanks, i re-check

[GitHub] [flink] danny0405 commented on a change in pull request #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
danny0405 commented on a change in pull request #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#discussion_r393441467 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] flinkbot edited a comment on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#issuecomment-599850246 ## CI report: * 852afb6cec29f1cb7a218406abda63e9e845270c Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up URL: https://github.com/apache/flink/pull/11419#issuecomment-599532494 ## CI report: * 94667cef9d5bc40d460b223f9e26667de7b0bc7f Tra

[GitHub] [flink] danny0405 commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

2020-03-16 Thread GitBox
danny0405 commented on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-599870394 > Thanks for update @danny0405, LGTM > > I do not check the plans which are out of order Thanks, i re-checked

[GitHub] [flink] flinkbot edited a comment on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#issuecomment-599866509 ## CI report: * a891d89757f7432a095de20c361faeee98f31ff6 Travis: [PEND

[GitHub] [flink] flinkbot edited a comment on issue #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up URL: https://github.com/apache/flink/pull/11419#issuecomment-599532494 ## CI report: * 94667cef9d5bc40d460b223f9e26667de7b0bc7f Tra

[jira] [Comment Edited] (FLINK-15871) Support to start sidecar container

2020-03-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060620#comment-17060620 ] Canbin Zheng edited comment on FLINK-15871 at 3/17/20, 4:20 AM: --

[jira] [Comment Edited] (FLINK-15871) Support to start sidecar container

2020-03-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060620#comment-17060620 ] Canbin Zheng edited comment on FLINK-15871 at 3/17/20, 4:19 AM: --

[jira] [Commented] (FLINK-15871) Support to start sidecar container

2020-03-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060620#comment-17060620 ] Canbin Zheng commented on FLINK-15871: -- Hi, [~fly_in_gis]! The init container is a

[GitHub] [flink] flinkbot commented on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
flinkbot commented on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#issuecomment-599866509 ## CI report: * a891d89757f7432a095de20c361faeee98f31ff6 UNKNOWN Bo

[GitHub] [flink] flinkbot edited a comment on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#issuecomment-599850246 ## CI report: * 852afb6cec29f1cb7a218406abda63e9e845270c Travis: [PENDING](https://travis-ci.c

[GitHub] [flink] wuchong commented on issue #11243: [FLINK-16308] [docs] Fix Maven download links for SQL connectors.

2020-03-16 Thread GitBox
wuchong commented on issue #11243: [FLINK-16308] [docs] Fix Maven download links for SQL connectors. URL: https://github.com/apache/flink/pull/11243#issuecomment-599866299 +1 to use a constant in _config.yaml. This is an aut

[jira] [Commented] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the Tab

2020-03-16 Thread gkgkgk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060619#comment-17060619 ] gkgkgk commented on FLINK-16622: [~jark]And this code is in class "org.apache.flink.api.

[jira] [Commented] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the Tab

2020-03-16 Thread gkgkgk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060616#comment-17060616 ] gkgkgk commented on FLINK-16622: [~jark]Yes, I noticed this usage. But I'm used to defin

[GitHub] [flink] libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#discussion_r393429324 ## File path: docs/dev/table/streaming/dynamic_tables.zh.md ## @@ -159,31 +1

[GitHub] [flink] libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#discussion_r393417505 ## File path: docs/dev/table/streaming/dynamic_tables.zh.md ## @@ -22,135 +2

[GitHub] [flink] libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#discussion_r393429690 ## File path: docs/dev/table/streaming/dynamic_tables.zh.md ## @@ -159,31 +1

[GitHub] [flink] libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#discussion_r393417143 ## File path: docs/dev/table/streaming/dynamic_tables.zh.md ## @@ -22,135 +2

[GitHub] [flink] libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#discussion_r393416283 ## File path: docs/dev/table/streaming/dynamic_tables.zh.md ## @@ -22,135 +2

[GitHub] [flink] libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
libenchao commented on a change in pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#discussion_r393430860 ## File path: docs/dev/table/streaming/dynamic_tables.zh.md ## @@ -159,31 +1

[GitHub] [flink] flinkbot commented on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
flinkbot commented on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#issuecomment-599863561 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I hel

[GitHub] [flink] flinkbot edited a comment on issue #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported URL: https://github.com/apache/flink/pull/11414#issuecomment-599442876 ## CI report: * 6223ae638613048a8f2df11b2fadc9f0165b9121 Travis: [FAILURE

[jira] [Updated] (FLINK-16345) Computed column can not refer time attribute column

2020-03-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16345: --- Labels: pull-request-available (was: ) > Computed column can not refer time attribute colum

[GitHub] [flink] wuchong opened a new pull request #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
wuchong opened a new pull request #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424 ## What is the purpose of the change If a computed column refers a rowtime column (the

[GitHub] [flink] wuchong commented on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column

2020-03-16 Thread GitBox
wuchong commented on issue #11424: [FLINK-16345][table-planner-blink] Fix computed column can not refer row time attribute column URL: https://github.com/apache/flink/pull/11424#issuecomment-599863194 cc @danny0405 This is a

[jira] [Commented] (FLINK-16602) Rework the Service design for Kubernetes deployment

2020-03-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060607#comment-17060607 ] Canbin Zheng commented on FLINK-16602: -- Hi, Yang Wang! I know your concern. > Abou

[GitHub] [flink] flinkbot edited a comment on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406#issuecomment-599442456 ## CI report: * 232be62cfaf1b950038abe82b212674216519a1a

[GitHub] [flink] flinkbot edited a comment on issue #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11414: [FLINK-16606][python] Throw exceptions for the data types which are not currently supported URL: https://github.com/apache/flink/pull/11414#issuecomment-599442876 ## CI report: * 6223ae638613048a8f2df11b2fadc9f0165b9121 Travis: [PENDING

[GitHub] [flink] hequn8128 commented on issue #11420: [FLINK-16565][python][ml] Make Pipeline Json compitable between Java and Python if all PipelineStages are Java ones

2020-03-16 Thread GitBox
hequn8128 commented on issue #11420: [FLINK-16565][python][ml] Make Pipeline Json compitable between Java and Python if all PipelineStages are Java ones URL: https://github.com/apache/flink/pull/11420#issuecomment-599857707 CC @becketqin @dianfu @walterddr

[jira] [Assigned] (FLINK-16092) Translate "Overview" page of "Functions" into Chinese

2020-03-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16092: --- Assignee: zhule > Translate "Overview" page of "Functions" into Chinese >

[jira] [Commented] (FLINK-15871) Support to start sidecar container

2020-03-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060598#comment-17060598 ] Yang Wang commented on FLINK-15871: --- Indeed, pod template support is useful for some u

[jira] [Commented] (FLINK-16622) Type ARRAY of table field 'id' does not match with the physical type LEGACY('ARRAY', 'ANY<[Ljava.lang.String;, rO0ABXNyAD......>') of the 'id' field of the Tab

2020-03-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060599#comment-17060599 ] Jark Wu commented on FLINK-16622: - Hi [~gkgkgk], if you are using 1.10, then you don't n

[GitHub] [flink] flinkbot edited a comment on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#issuecomment-599850246 ## CI report: * 852afb6cec29f1cb7a218406abda63e9e845270c Travis: [PENDING](https://travis-ci.c

[GitHub] [flink] JingsongLi commented on a change in pull request #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up

2020-03-16 Thread GitBox
JingsongLi commented on a change in pull request #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up URL: https://github.com/apache/flink/pull/11419#discussion_r393421211 ## File path: flink-table/flink-table-planner-bl

[GitHub] [flink] wuchong commented on a change in pull request #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up

2020-03-16 Thread GitBox
wuchong commented on a change in pull request #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up URL: https://github.com/apache/flink/pull/11419#discussion_r393419470 ## File path: flink-table/flink-table-planner-blink

[jira] [Closed] (FLINK-16454) Update the copyright year in NOTICE files

2020-03-16 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16454. Resolution: Fixed Merged in master: 4035f03a1de24b7e292466e9fa0a0de9cb10f358 Merged in release-1.10: 38b8

[GitHub] [flink] zhijiangW merged pull request #11417: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

2020-03-16 Thread GitBox
zhijiangW merged pull request #11417: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11417 This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] JingsongLi commented on a change in pull request #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up

2020-03-16 Thread GitBox
JingsongLi commented on a change in pull request #11419: [FLINK-16047][table-planner-blink] Fix Blink planner produces wrong aggregate results with state clean up URL: https://github.com/apache/flink/pull/11419#discussion_r393415695 ## File path: flink-table/flink-table-planner-bl

[GitHub] [flink] zhijiangW commented on issue #11417: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

2020-03-16 Thread GitBox
zhijiangW commented on issue #11417: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11417#issuecomment-599850694 back-port from #11412 which was already approved before, so merging.

[GitHub] [flink] zhijiangW merged pull request #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

2020-03-16 Thread GitBox
zhijiangW merged pull request #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11416 This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] zhijiangW commented on issue #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

2020-03-16 Thread GitBox
zhijiangW commented on issue #11416: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11416#issuecomment-599850387 back-port from #11412 which was already approved before, so merging.

[GitHub] [flink] flinkbot commented on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
flinkbot commented on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#issuecomment-599850246 ## CI report: * 852afb6cec29f1cb7a218406abda63e9e845270c UNKNOWN Bot commands The @fli

[GitHub] [flink] flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11421: [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack URL: https://github.com/apache/flink/pull/11421#issuecomment-599826019 ## CI report: * ce674a7530f5a1dae64aa226148a92ad58b2be76 Travis: [SUCCESS](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11406: [FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY URL: https://github.com/apache/flink/pull/11406#issuecomment-599442456 ## CI report: * 232be62cfaf1b950038abe82b212674216519a1a

[GitHub] [flink] JingsongLi merged pull request #11405: [FLINK-16413]Reduce hive source parallelism when limit push down

2020-03-16 Thread GitBox
JingsongLi merged pull request #11405: [FLINK-16413]Reduce hive source parallelism when limit push down URL: https://github.com/apache/flink/pull/11405 This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-16602) Rework the Service design for Kubernetes deployment

2020-03-16 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060590#comment-17060590 ] Yang Wang commented on FLINK-16602: --- > About the deployer The deployer means an exter

[GitHub] [flink] flinkbot commented on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
flinkbot commented on issue #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423#issuecomment-599848985 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[GitHub] [flink] zhijiangW merged pull request #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

2020-03-16 Thread GitBox
zhijiangW merged pull request #11412: [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files URL: https://github.com/apache/flink/pull/11412 This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] CrazyTomatoOo opened a new pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "…

2020-03-16 Thread GitBox
CrazyTomatoOo opened a new pull request #11423: [Flink-16083][chinese-translation]Translate "Dynamic Table" page of "… URL: https://github.com/apache/flink/pull/11423 …Streaming Concepts" into Chinese ## What is the purpose of the change This pull request is to translate "Dyna

[GitHub] [flink] flinkbot edited a comment on issue #11422: [FLINK-16623]add the shorthand 'desc' for describe on sql client

2020-03-16 Thread GitBox
flinkbot edited a comment on issue #11422: [FLINK-16623]add the shorthand 'desc' for describe on sql client URL: https://github.com/apache/flink/pull/11422#issuecomment-599831571 ## CI report: * fba4e15d49dfa5610fa26744978d147e52f933c9 Travis: [CANCELED](https://travis-ci.com/gi

  1   2   3   4   >