[GitHub] [flink] flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-568440738 ## CI report: * 5a0d5d3d499347ca216e19175ff5f066a6d9b458 Travis: [SUCCESS](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-568687684 ## CI report: * f59106d121f9dd0fc40b23640ec2ad8a663d6020 Travis: [SUCCESS](https://t

[jira] [Created] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15566: -- Summary: Flink implicitly order the fields in PojoTypeInfo Key: FLINK-15566 URL: https://issues.apache.org/jira/browse/FLINK-15566 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014100#comment-17014100 ] Jeff Zhang commented on FLINK-15566: [~aljoscha] Could you take a look at this issue

[GitHub] [flink] dawidwys commented on issue #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible

2020-01-13 Thread GitBox
dawidwys commented on issue #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible URL: https://github.com/apache/flink/pull/10829#issuecomment-573548100 Hi @xintongsong, I am positive that in the docs we should always print only

[GitHub] [flink] cshuo commented on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`…

2020-01-13 Thread GitBox
cshuo commented on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`… URL: https://github.com/apache/flink/pull/10815#issuecomment-573548112 @flinkbot run travis This is an automated message

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-13 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014101#comment-17014101 ] Dawid Wysakowicz commented on FLINK-15431: -- It sounds like a good compromise fo

[GitHub] [flink] cshuo removed a comment on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`…

2020-01-13 Thread GitBox
cshuo removed a comment on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`… URL: https://github.com/apache/flink/pull/10815#issuecomment-573548112 @flinkbot run travis This is an automated

[GitHub] [flink] cshuo commented on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`…

2020-01-13 Thread GitBox
cshuo commented on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`… URL: https://github.com/apache/flink/pull/10815#issuecomment-573549673 > Tests are failed, please have a look. Hi, @wuchong , failed case fixed. --

[GitHub] [flink] dawidwys commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

2020-01-13 Thread GitBox
dawidwys commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-573549541 @wuchong I am not sure if an additional `Z` is such a hassle for users. I really think specifying inst

[GitHub] [flink] dawidwys edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

2020-01-13 Thread GitBox
dawidwys edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-573549541 @wuchong I am not sure if an additional `Z` (or explicit timezone) is such a hassle for users.

[GitHub] [flink] wangyang0918 commented on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-13 Thread GitBox
wangyang0918 commented on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-573550858 The failed tests are all unrelated with the changes of this PR. The three tests `e2e - container - ha

[GitHub] [flink] wuchong commented on issue #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client

2020-01-13 Thread GitBox
wuchong commented on issue #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client URL: https://github.com/apache/flink/pull/10787#issuecomment-573552269 Thanks for the reviewing @KurtYoung . The failed cases are not related to this PR, will merge it. --

[GitHub] [flink] flinkbot edited a comment on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`…

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`… URL: https://github.com/apache/flink/pull/10815#issuecomment-572566376 ## CI report: * 19a4290f709495491fe460037c8c31d106984ea8 Travis: [FAILURE](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: * 7d66fc50c8749017788386efb2908ae2087ad7f

[GitHub] [flink] dawidwys commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

2020-01-13 Thread GitBox
dawidwys commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-573553180 @link3280 Generally looks really good. Could you just update the remaining languages in the docs? (DDL

[jira] [Commented] (FLINK-15174) FLINK security using PKI mutual auth needs certificate pinning or Private CA

2020-01-13 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014111#comment-17014111 ] Konstantin Knauf commented on FLINK-15174: -- [~dasbh] [~johnlon] I would like to

[GitHub] [flink] flinkbot edited a comment on issue #10837: [FLINK-15541] Fix unstable case FlinkKinesisConsumerTest

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10837: [FLINK-15541] Fix unstable case FlinkKinesisConsumerTest URL: https://github.com/apache/flink/pull/10837#issuecomment-573544281 ## CI report: * 4d045d632eb72a162e5d56aa52a6819042d2f1aa Travis: [PENDING](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #10838: [hotfix][table-common] Simplify formatted exceptions

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10838: [hotfix][table-common] Simplify formatted exceptions URL: https://github.com/apache/flink/pull/10838#issuecomment-573544312 ## CI report: * 6d7cd665ed96239643ccbc81bafacc8fd0e12e80 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/

[jira] [Created] (FLINK-15567) Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread Jark Wu (Jira)
Jark Wu created FLINK-15567: --- Summary: Add documentation for INSERT statements for Flink SQL Key: FLINK-15567 URL: https://issues.apache.org/jira/browse/FLINK-15567 Project: Flink Issue Type: Task

[GitHub] [flink] zhuzhurk merged pull request #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-13 Thread GitBox
zhuzhurk merged pull request #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825 This is an automated message

[GitHub] [flink] wuchong opened a new pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread GitBox
wuchong opened a new pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839 ## What is the purpose of the change We missed to add documentation for INSERT statements which shoul

[GitHub] [flink] wuchong commented on issue #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread GitBox
wuchong commented on issue #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839#issuecomment-573556252 cc @JingsongLi This is an automat

[jira] [Updated] (FLINK-15567) Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15567: --- Labels: pull-request-available (was: ) > Add documentation for INSERT statements for Flink

[GitHub] [flink] wuchong merged pull request #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client

2020-01-13 Thread GitBox
wuchong merged pull request #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client URL: https://github.com/apache/flink/pull/10787 This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] flinkbot commented on issue #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread GitBox
flinkbot commented on issue #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839#issuecomment-573556957 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[GitHub] [flink] wangyang0918 edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-13 Thread GitBox
wangyang0918 edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-573550858 ``` 05:36:27.124 [ERROR] Failed to execute goal org.scalastyle:scalastyle-maven-plugin:1.0.0:c

[jira] [Resolved] (FLINK-15495) Set default planner for SQL Client to Blink planner

2020-01-13 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15495. - Resolution: Fixed 1.11.0: 0274258685cb1b230625676d5b1b44ff9886e3a8 1.10.0: 415ab57e0bd39096fe5132cbf8c9d

[jira] [Updated] (FLINK-15522) Misleading root cause exception when cancelling the job

2020-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15522: Affects Version/s: 1.9.1 > Misleading root cause exception when cancelling the job > -

[GitHub] [flink] wangyang0918 edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-13 Thread GitBox
wangyang0918 edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-573550858 ``` 05:36:27.122 [INFO] --

[jira] [Closed] (FLINK-15522) Misleading root cause exception when cancelling the job

2020-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-15522. --- Fix Version/s: 1.11.0 1.10.0 1.9.2 Resolution: Fixed Fixed via:

[GitHub] [flink] wangyang0918 commented on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-13 Thread GitBox
wangyang0918 commented on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-573558614 @flinkbot run travis This is an automat

[jira] [Updated] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15566: --- Description: I don't know why flink would do that, but this cause my user defined function behavior

[jira] [Updated] (FLINK-15566) Flink implicitly order the fields in PojoTypeInfo

2020-01-13 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15566: --- Description: I don't know why flink would do that, but this cause my user defined function behavior

[jira] [Updated] (FLINK-15444) Make the component AbstractInvokable in CheckpointBarrierHandler NonNull

2020-01-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15444: --- Labels: pull-request-available (was: ) > Make the component AbstractInvokable in Checkpoint

[GitHub] [flink] zhijiangW opened a new pull request #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull

2020-01-13 Thread GitBox
zhijiangW opened a new pull request #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull URL: https://github.com/apache/flink/pull/10840 ## What is the purpose of the change *The current component `AbstractInvokable` in `CheckpointBa

[jira] [Commented] (FLINK-15559) Missing {{site.baseurl}} in some docs

2020-01-13 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014123#comment-17014123 ] Jark Wu commented on FLINK-15559: - Why the links are broken because of changing base_url

[jira] [Commented] (FLINK-15565) Incompatible types of expression and result type thrown in codegen

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014124#comment-17014124 ] Jingsong Lee commented on FLINK-15565: -- [~ykt836] [~jark] can you assign this to me

[jira] [Created] (FLINK-15568) RestartPipelinedRegionStrategy: not ensure the EXACTLY_ONCE semantics

2020-01-13 Thread Andrew.D.lin (Jira)
Andrew.D.lin created FLINK-15568: Summary: RestartPipelinedRegionStrategy: not ensure the EXACTLY_ONCE semantics Key: FLINK-15568 URL: https://issues.apache.org/jira/browse/FLINK-15568 Project: Flink

[jira] [Updated] (FLINK-15568) RestartPipelinedRegionStrategy: not ensure the EXACTLY_ONCE semantics, in 1.8 versions

2020-01-13 Thread Andrew.D.lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew.D.lin updated FLINK-15568: - Summary: RestartPipelinedRegionStrategy: not ensure the EXACTLY_ONCE semantics, in 1.8 versions

[jira] [Updated] (FLINK-15568) RestartPipelinedRegionStrategy: not ensure the EXACTLY_ONCE semantics

2020-01-13 Thread Andrew.D.lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew.D.lin updated FLINK-15568: - Description: In 1.8* versions, FailoverRegion.java restart method  not restore from latest chec

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

2020-01-13 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014126#comment-17014126 ] Kostas Kloudas commented on FLINK-15533: Thanks for the feedback [~lirui]! I ope

[GitHub] [flink] flinkbot commented on issue #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull

2020-01-13 Thread GitBox
flinkbot commented on issue #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull URL: https://github.com/apache/flink/pull/10840#issuecomment-573561483 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I he

[jira] [Commented] (FLINK-15565) Incompatible types of expression and result type thrown in codegen

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014128#comment-17014128 ] Jingsong Lee commented on FLINK-15565: -- The bug is: In {{ExpressionConverter}}, we

[jira] [Updated] (FLINK-15565) Incompatible types of expression and result type thrown in codegen

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15565: - Priority: Critical (was: Major) > Incompatible types of expression and result type thrown in co

[GitHub] [flink] flinkbot edited a comment on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`…

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`… URL: https://github.com/apache/flink/pull/10815#issuecomment-572566376 ## CI report: * 19a4290f709495491fe460037c8c31d106984ea8 Travis: [FAILURE](https://travis-ci.c

[GitHub] [flink] JingsongLi opened a new pull request #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt, SmallInt literals between Flink and Calcite

2020-01-13 Thread GitBox
JingsongLi opened a new pull request #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt,SmallInt literals between Flink and Calcite URL: https://github.com/apache/flink/pull/10841 ## What is the purpose of the change In ExpressionConverter, we convert Flin

[jira] [Updated] (FLINK-15565) Incompatible types of expression and result type thrown in codegen

2020-01-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15565: --- Labels: pull-request-available (was: ) > Incompatible types of expression and result type t

[GitHub] [flink] flinkbot commented on issue #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull

2020-01-13 Thread GitBox
flinkbot commented on issue #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull URL: https://github.com/apache/flink/pull/10840#issuecomment-573563119 ## CI report: * 61e9e675667e05e44e9c4b5ffd7565f60aec6d62 UNKNOWN B

[GitHub] [flink] flinkbot edited a comment on issue #10837: [FLINK-15541] Fix unstable case FlinkKinesisConsumerTest

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10837: [FLINK-15541] Fix unstable case FlinkKinesisConsumerTest URL: https://github.com/apache/flink/pull/10837#issuecomment-573544281 ## CI report: * 4d045d632eb72a162e5d56aa52a6819042d2f1aa Travis: [SUCCESS](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot commented on issue #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread GitBox
flinkbot commented on issue #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839#issuecomment-573563076 ## CI report: * c5595ea0c994dcf664cb68ec45a6f500e705a3b7 UNKNOWN Bot commands

[GitHub] [flink] flinkbot commented on issue #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt, SmallInt literals between Flink and Calcite

2020-01-13 Thread GitBox
flinkbot commented on issue #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt,SmallInt literals between Flink and Calcite URL: https://github.com/apache/flink/pull/10841#issuecomment-573564277 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Created] (FLINK-15569) Incorrect sample code in udf document

2020-01-13 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15569: -- Summary: Incorrect sample code in udf document Key: FLINK-15569 URL: https://issues.apache.org/jira/browse/FLINK-15569 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-14837) Support Function DDL in TableEnvironment

2020-01-13 Thread Xianxun Ye (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014141#comment-17014141 ] Xianxun Ye commented on FLINK-14837: Is there a development plan for this issue? Wi

[jira] [Created] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-15570: --- Summary: Support inserting into non-empty csv tables Key: FLINK-15570 URL: https://issues.apache.org/jira/browse/FLINK-15570 Project: Flink Issue Type: Improve

[jira] [Updated] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-15570: Description: Currently we only support inserting into empty csv tables. It would be nice for a ne

[jira] [Comment Edited] (FLINK-15559) Missing {{site.baseurl}} in some docs

2020-01-13 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014144#comment-17014144 ] Benchao Li edited comment on FLINK-15559 at 1/13/20 9:19 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`…

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10815: [FLINK-15537][table-planner-blink] Type of keys should be `BinaryRow`… URL: https://github.com/apache/flink/pull/10815#issuecomment-572566376 ## CI report: * 19a4290f709495491fe460037c8c31d106984ea8 Travis: [FAILURE](https://travis-ci.c

[jira] [Updated] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-15570: Description: Currently we only support inserting into empty csv tables. It would be nice for a ne

[jira] [Updated] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-15570: Labels: Usability (was: ) > Support inserting into non-empty csv tables > ---

[jira] [Commented] (FLINK-15559) Missing {{site.baseurl}} in some docs

2020-01-13 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014144#comment-17014144 ] Benchao Li commented on FLINK-15559: The reason is following: Currently {{build_doc

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

2020-01-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014147#comment-17014147 ] Yuan Mei commented on FLINK-14163: --   Synced up with [~zjwang] offline.    In genera

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

2020-01-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014147#comment-17014147 ] Yuan Mei edited comment on FLINK-14163 at 1/13/20 9:20 AM: ---  

[jira] [Commented] (FLINK-15556) Add a switch for PushProjectIntoTableSourceScanRule

2020-01-13 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014148#comment-17014148 ] godfrey he commented on FLINK-15556: [~jark], I think if the query only contains one

[GitHub] [flink] flinkbot edited a comment on issue #10838: [hotfix][table-common] Simplify formatted exceptions

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10838: [hotfix][table-common] Simplify formatted exceptions URL: https://github.com/apache/flink/pull/10838#issuecomment-573544312 ## CI report: * 6d7cd665ed96239643ccbc81bafacc8fd0e12e80 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] zhijiangW merged pull request #10735: [hotfix][runtime] Fix variable name typos in TaskInformation.java and…

2020-01-13 Thread GitBox
zhijiangW merged pull request #10735: [hotfix][runtime] Fix variable name typos in TaskInformation.java and… URL: https://github.com/apache/flink/pull/10735 This is an automated message from the Apache Git Service. To respon

[jira] [Closed] (FLINK-15562) Unable to create walk through project

2020-01-13 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15562. Resolution: Not A Problem The issue is mentioned in the documentation. > Unable to create

[GitHub] [flink] flinkbot commented on issue #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt, SmallInt literals between Flink and Calcite

2020-01-13 Thread GitBox
flinkbot commented on issue #10841: [FLINK-15565][table-planner-blink] Fix error conversion of TinyInt,SmallInt literals between Flink and Calcite URL: https://github.com/apache/flink/pull/10841#issuecomment-573572659 ## CI report: * d3abca3b9c9ca0ad030f7e208843502d14ff13a5 UNKNO

[GitHub] [flink] flinkbot edited a comment on issue #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839#issuecomment-573563076 ## CI report: * c5595ea0c994dcf664cb68ec45a6f500e705a3b7 Travis: [PENDING](https://t

[GitHub] [flink] flinkbot edited a comment on issue #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull URL: https://github.com/apache/flink/pull/10840#issuecomment-573563119 ## CI report: * 61e9e675667e05e44e9c4b5ffd7565f60aec6d62 Travis: [PEN

[jira] [Commented] (FLINK-15562) Unable to create walk through project

2020-01-13 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014152#comment-17014152 ] Yangze Guo commented on FLINK-15562: Hi, [~chesnay], I think it will benefit the use

[jira] [Updated] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-15570: Priority: Major (was: Minor) > Support inserting into non-empty csv tables >

[jira] [Created] (FLINK-15571) Create a Redis Streams Connector for Flink

2020-01-13 Thread Tugdual Grall (Jira)
Tugdual Grall created FLINK-15571: - Summary: Create a Redis Streams Connector for Flink Key: FLINK-15571 URL: https://issues.apache.org/jira/browse/FLINK-15571 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-568440738 ## CI report: * 5a0d5d3d499347ca216e19175ff5f066a6d9b458 Travis: [SUCCESS](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-568687684 ## CI report: * f59106d121f9dd0fc40b23640ec2ad8a663d6020 Travis: [SUCCESS](https://t

[GitHub] [flink] jrthe42 closed pull request #6301: [FLINK-9794] [jdbc] JDBCOutputFormat does not consider idle connection and multithreads synchronization

2020-01-13 Thread GitBox
jrthe42 closed pull request #6301: [FLINK-9794] [jdbc] JDBCOutputFormat does not consider idle connection and multithreads synchronization URL: https://github.com/apache/flink/pull/6301 This is an automated message from the

[GitHub] [flink] jrthe42 closed pull request #6847: [FLINK-10553] [sql] Unified sink and source table name in SQL statement

2020-01-13 Thread GitBox
jrthe42 closed pull request #6847: [FLINK-10553] [sql] Unified sink and source table name in SQL statement URL: https://github.com/apache/flink/pull/6847 This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] jrthe42 closed pull request #6666: [FLINK-10290] [table] Fix conversion error in StreamScan and BatchScan

2020-01-13 Thread GitBox
jrthe42 closed pull request #: [FLINK-10290] [table] Fix conversion error in StreamScan and BatchScan URL: https://github.com/apache/flink/pull/ This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] GJL closed pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-13 Thread GitBox
GJL closed pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-15488) Cannot start a taskmanger if using logback

2020-01-13 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-15488. Resolution: Fixed 1.10: 6c886ade7c02840423552025f5d5da535ae40d02 master: d76f2166396e3758c08851d024e2c23c8

[jira] [Created] (FLINK-15572) Function DDL is not compliant with FLIP-64

2020-01-13 Thread Timo Walther (Jira)
Timo Walther created FLINK-15572: Summary: Function DDL is not compliant with FLIP-64 Key: FLINK-15572 URL: https://issues.apache.org/jira/browse/FLINK-15572 Project: Flink Issue Type: Bug

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

2020-01-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014147#comment-17014147 ] Yuan Mei edited comment on FLINK-14163 at 1/13/20 9:58 AM: ---  

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

2020-01-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014147#comment-17014147 ] Yuan Mei edited comment on FLINK-14163 at 1/13/20 9:59 AM: ---  

[GitHub] [flink] carp84 merged pull request #10805: [FLINK-15529] [docs] Update upgrade compatibility table in operations doc for 1.10.0

2020-01-13 Thread GitBox
carp84 merged pull request #10805: [FLINK-15529] [docs] Update upgrade compatibility table in operations doc for 1.10.0 URL: https://github.com/apache/flink/pull/10805 This is an automated message from the Apache Git Service

[jira] [Commented] (FLINK-15572) Function DDL is not compliant with FLIP-64

2020-01-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014182#comment-17014182 ] Timo Walther commented on FLINK-15572: -- CC [~phoenixjiangnan] > Function DDL is no

[jira] [Commented] (FLINK-15565) Incompatible types of expression and result type thrown in codegen

2020-01-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014186#comment-17014186 ] Kurt Young commented on FLINK-15565: [~lzljs3620320] I've assigned to you. > Incomp

[jira] [Assigned] (FLINK-15565) Incompatible types of expression and result type thrown in codegen

2020-01-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15565: -- Assignee: Jingsong Lee > Incompatible types of expression and result type thrown in codegen >

[jira] [Commented] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014190#comment-17014190 ] Kurt Young commented on FLINK-15570: This is duplicated with FLINK-15066? > Support

[jira] [Updated] (FLINK-15417) Remove the docker volume or mount when starting Mesos e2e cluster

2020-01-13 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15417: - Issue Type: Bug (was: Test) > Remove the docker volume or mount when starting Mesos e2e cluster > -

[GitHub] [flink] twalthr commented on issue #10838: [hotfix][table-common] Simplify formatted exceptions

2020-01-13 Thread GitBox
twalthr commented on issue #10838: [hotfix][table-common] Simplify formatted exceptions URL: https://github.com/apache/flink/pull/10838#issuecomment-573595958 I'm fine with a builder approach. This also allows us to include error codes and other properties (such as severity) in the future.

[GitHub] [flink] zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r365723610 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/ex

[GitHub] [flink] zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r365729537 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/ex

[GitHub] [flink] zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r365732020 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/ex

[jira] [Updated] (FLINK-15387) Expose missing RocksDB properties out via RocksDBNativeMetricOptions

2020-01-13 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15387: - Fix Version/s: (was: 1.11.0) > Expose missing RocksDB properties out via RocksDBNativeMetricOptions

[jira] [Updated] (FLINK-15522) Misleading root cause exception when cancelling the job

2020-01-13 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15522: - Fix Version/s: (was: 1.11.0) > Misleading root cause exception when cancelling the job > ---

[GitHub] [flink] zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r365721185 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/sh

[GitHub] [flink] zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r365720350 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/ex

[jira] [Commented] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

2020-01-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014209#comment-17014209 ] Till Rohrmann commented on FLINK-15355: --- Another instance of the problem: https:/

[jira] [Comment Edited] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

2020-01-13 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014209#comment-17014209 ] Till Rohrmann edited comment on FLINK-15355 at 1/13/20 10:40 AM: -

[jira] [Closed] (FLINK-15570) Support inserting into non-empty csv tables

2020-01-13 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-15570. --- Resolution: Duplicate > Support inserting into non-empty csv tables > --

  1   2   3   4   5   >