[jira] [Updated] (FLINK-14606) Simplify params of Execution#processFail

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14606: Fix Version/s: (was: 1.10.0) 1.11.0 > Simplify params of Execution#processFail >

[jira] [Updated] (FLINK-14234) All partition consumable events should be notified to SchedulingStrategy (SchedulerNG)

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14234: Fix Version/s: (was: 1.10.0) 1.11.0 > All partition consumable events should be

[jira] [Updated] (FLINK-14233) All task state changes should be notified to SchedulingStrategy (SchedulerNG)

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14233: Fix Version/s: (was: 1.10.0) 1.11.0 > All task state changes should be notified to

[jira] [Updated] (FLINK-14162) Unify SchedulerOperations#allocateSlotsAndDeploy implementation for all scheduling strategies

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14162: Fix Version/s: (was: 1.10.0) 1.11.0 > Unify

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

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992208#comment-16992208 ] Kurt Young commented on FLINK-13437: [~liyu] We will try to do this in 1.10 > Add Hive SQL E2E test

[jira] [Updated] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14032: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

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

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13437: -- Assignee: Jingsong Lee > Add Hive SQL E2E test > - > >

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

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13437: --- Fix Version/s: 1.10.0 > Add Hive SQL E2E test > - > > Key:

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

[jira] [Updated] (FLINK-13905) Separate checkpoint triggering into stages

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-13905: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change the fix version to 1.11.0 since we already

[jira] [Commented] (FLINK-14647) Improve the exception message when required property is not matched

2019-12-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992206#comment-16992206 ] Nicholas Jiang commented on FLINK-14647: [~jark]Yeah, my original intention was that

[jira] [Updated] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-13848: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change the fix version to 1.11.0 since we already

[jira] [Commented] (FLINK-15017) add a thrift server for Flink

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992202#comment-16992202 ] Kurt Young commented on FLINK-15017: cc [~godfreyhe]  [~docete] > add a thrift server for Flink >

[jira] [Updated] (FLINK-13876) Remove ExecutionConfig field from PojoSerializer

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-13876: -- Fix Version/s: (was: 1.10.0) 1.11.0 Affects Version/s: 1.10.0 Since we

[jira] [Commented] (FLINK-15122) Reusing record object in StreamTaskNetworkInput

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992201#comment-16992201 ] Jingsong Lee commented on FLINK-15122: -- [~pnowojski] Yes, will create a benchmark to show the

[jira] [Commented] (FLINK-13866) develop testing plan for many Hive versions that we support

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992199#comment-16992199 ] Yu Li commented on FLINK-13866: --- [~phoenixjiangnan] [~xuefuz] Are we still targeting this work at 1.10?

[jira] [Commented] (FLINK-13857) Remove remaining UdfAnalyzer configurations

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992198#comment-16992198 ] Yu Li commented on FLINK-13857: --- [~dwysakowicz] Just to confirm, are we still targeting at completing this

[GitHub] [flink] KarmaGYZ commented on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

2019-12-09 Thread GitBox
KarmaGYZ commented on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-563847973 @flinkbot run travis This is an automated

[jira] [Updated] (FLINK-13692) Make CompletedCheckpointStore backwards compatible?

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-13692: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

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

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13437: --- Fix Version/s: (was: 1.10.0) > Add Hive SQL E2E test > - > >

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

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992194#comment-16992194 ] Yu Li commented on FLINK-13437: --- [~ykt836] [~xuefuz] Could you help confirm whether we still target at

[jira] [Commented] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992192#comment-16992192 ] Yu Li commented on FLINK-13015: --- [~dwysakowicz] It seems to me the relative PR is closed with changes

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

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

2019-12-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992190#comment-16992190 ] Zhenqiu Huang commented on FLINK-14953: --- [~ykt836] Would you please help to merge this PR

[GitHub] [flink] flinkbot edited a comment on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark URL: https://github.com/apache/flink/pull/10504#issuecomment-563761500 ## CI report: * 64f397f5a4fdb5cf37119c1251e7a553d5c4da0f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#issuecomment-563692047 ## CI report: * 0a63ef8576f25cdec9fe106d7f69429fff6a4c7e Travis:

[jira] [Commented] (FLINK-15122) Reusing record object in StreamTaskNetworkInput

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992181#comment-16992181 ] Jark Wu commented on FLINK-15122: - In general object copy is very expensive. Providing a benchmark to

[GitHub] [flink] flinkbot commented on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread GitBox
flinkbot commented on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark URL: https://github.com/apache/flink/pull/10504#issuecomment-563761500 ## CI report: * 64f397f5a4fdb5cf37119c1251e7a553d5c4da0f UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#issuecomment-563692047 ## CI report: * 0a63ef8576f25cdec9fe106d7f69429fff6a4c7e Travis:

[jira] [Updated] (FLINK-14645) Data types defined in DDL will lose precision and nullability when converting to properties

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14645: Release Note: The {{TableSchema}} derived from properties now bridges to the default conversion class,

[jira] [Updated] (FLINK-14645) Data types defined in DDL will lose precision and nullability when converting to properties

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14645: Release Note: The TableSchema derived from properties now bridges to the default conversion class, i.e.

[GitHub] [flink] flinkbot commented on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread GitBox
flinkbot commented on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark URL: https://github.com/apache/flink/pull/10504#issuecomment-563751655 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-14649) Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14649: Release Note: Some indexed connector properties have been refactored to have a better experience in DDL

[jira] [Updated] (FLINK-15069) Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15069: --- Labels: pull-request-available (was: ) > Supplement the pipelined shuffle compression case

[GitHub] [flink] zhijiangW opened a new pull request #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread GitBox
zhijiangW opened a new pull request #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark URL: https://github.com/apache/flink/pull/10504 ## What is the purpose of the change *While reviewing the PR of introducing data compression for

[jira] [Created] (FLINK-15166) Shuffle data compression wrongly decrease the buffer reference count.

2019-12-09 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-15166: --- Summary: Shuffle data compression wrongly decrease the buffer reference count. Key: FLINK-15166 URL: https://issues.apache.org/jira/browse/FLINK-15166 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

[jira] [Updated] (FLINK-15070) Supplement cases of blocking partition with compression for benchmark

2019-12-09 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-15070: - Summary: Supplement cases of blocking partition with compression for benchmark (was: Supplement the

[jira] [Updated] (FLINK-15070) Supplement the case of blocking partition with compression for benchmark

2019-12-09 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-15070: - Description: ATM the benchmark only covers the case of pipelined partition used in streaming job, so

[jira] [Updated] (FLINK-15070) Supplement the case of blocking partition with compression for benchmark

2019-12-09 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-15070: - Summary: Supplement the case of blocking partition with compression for benchmark (was: Supplement the

[GitHub] [flink] flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 Travis:

[jira] [Updated] (FLINK-15069) Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-15069: - Description: While reviewing the [PR|

[GitHub] [flink] flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#issuecomment-563692047 ## CI report: * 0a63ef8576f25cdec9fe106d7f69429fff6a4c7e Travis:

[jira] [Updated] (FLINK-15069) Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-15069: - Summary: Supplement the pipelined shuffle compression case for benchmark (was: Supplement the

[jira] [Assigned] (FLINK-15069) Supplement the compression case for benchmark

2019-12-09 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-15069: Assignee: zhijiang > Supplement the compression case for benchmark >

[GitHub] [flink] danny0405 commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
danny0405 commented on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563718341 @kl0u @aljoscha I have rebase and split this PR into 3 commits, and my travis test passes

[jira] [Assigned] (FLINK-15137) Improve schema derivation for Avro format

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15137: --- Assignee: Jark Wu > Improve schema derivation for Avro format >

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

[jira] [Updated] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15141: Fix Version/s: 1.10.0 > Using decimal type in a sink table, the result returns a not match >

[jira] [Assigned] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15141: --- Assignee: Jark Wu > Using decimal type in a sink table, the result returns a not match >

[GitHub] [flink] KurtYoung commented on a change in pull request #10494: [FLINK-13438][hive] Support date type in Hive

2019-12-09 Thread GitBox
KurtYoung commented on a change in pull request #10494: [FLINK-13438][hive] Support date type in Hive URL: https://github.com/apache/flink/pull/10494#discussion_r355831171 ## File path:

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

2019-12-09 Thread GitBox
wsry 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_r355830724 ## File path:

[jira] [Assigned] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15123: --- Assignee: godfrey he > remove uniqueKeys from FlinkStatistic in blink planner >

[jira] [Commented] (FLINK-13410) Csv input format does not support LocalDate

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992152#comment-16992152 ] Jark Wu commented on FLINK-13410: - Does this problem still exist? Should we fix it in 1.10.0? > Csv

[jira] [Commented] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992153#comment-16992153 ] Jark Wu commented on FLINK-15123: - Assigned to you [~godfreyhe]. > remove uniqueKeys from

[GitHub] [flink] lirui-apache commented on a change in pull request #10494: [FLINK-13438][hive] Support date type in Hive

2019-12-09 Thread GitBox
lirui-apache commented on a change in pull request #10494: [FLINK-13438][hive] Support date type in Hive URL: https://github.com/apache/flink/pull/10494#discussion_r355829871 ## File path:

[jira] [Commented] (FLINK-14647) Improve the exception message when required property is not matched

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992150#comment-16992150 ] Jark Wu commented on FLINK-14647: - My gut feeling is that we should expose {{String connectorType()}}

[GitHub] [flink] flinkbot commented on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

2019-12-09 Thread GitBox
flinkbot commented on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#issuecomment-563692047 ## CI report: * 0a63ef8576f25cdec9fe106d7f69429fff6a4c7e UNKNOWN Bot commands The @flinkbot

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

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14953: - Fix Version/s: 1.10.0 > Parquet table source should use schema type to build FilterPredicate >

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

2019-12-09 Thread GitBox
wsry 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_r355829457 ## File path:

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

2019-12-09 Thread Feng Jiajie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Description: I have a streaming job configured with periodically checkpoint, but after one week

[jira] [Commented] (FLINK-14604) Bump commons-cli to 1.4

2019-12-09 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992145#comment-16992145 ] Wei Zhong commented on FLINK-14604: --- Due to the adjustment to FLIP-78 is accepted, close this Jira. >

[jira] [Closed] (FLINK-14604) Bump commons-cli to 1.4

2019-12-09 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-14604. - Resolution: Won't Fix > Bump commons-cli to 1.4 > --- > > Key:

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

2019-12-09 Thread Feng Jiajie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Description: I have a streaming job configured with periodically checkpoint, but after one week

[GitHub] [flink] flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

[GitHub] [flink] flinkbot commented on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

2019-12-09 Thread GitBox
flinkbot commented on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#issuecomment-563673149 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-15137) Improve schema derivation for Avro format

2019-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15137: --- Labels: pull-request-available (was: ) > Improve schema derivation for Avro format >

[GitHub] [flink] wuchong opened a new pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

2019-12-09 Thread GitBox
wuchong opened a new pull request #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503 ## What is the purpose of the change Support schema derivation for Avro format and also enables schema derivation as

[jira] [Updated] (FLINK-12160) Support to ship user config files on kubernetes

2019-12-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-12160: -- Description: When deploying flink cluster on Yarn, `yarnShip` cli option could be used to ship user

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

[jira] [Assigned] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-11899: -- Assignee: Zhenqiu Huang (was: Jingsong Lee) > Introduce vectorized parquet InputFormat for

[jira] [Commented] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992136#comment-16992136 ] Kurt Young commented on FLINK-11899: Thanks [~ZhenqiuHuang], will assign to you. BTW we have already

[jira] [Commented] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-12-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992133#comment-16992133 ] Zhenqiu Huang commented on FLINK-11899: --- [~lzljs3620320][~ykt836] As I am maintaining

[jira] [Updated] (FLINK-12160) Support to ship user config files on kubernetes

2019-12-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-12160: -- Summary: Support to ship user config files on kubernetes (was: Support for transferring user config

[GitHub] [flink] flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 Travis:

[jira] [Commented] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

2019-12-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992128#comment-16992128 ] Xintong Song commented on FLINK-15103: -- True, I was also discussing this issue with [~yunta], who

[jira] [Comment Edited] (FLINK-15017) add a thrift server for Flink

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992126#comment-16992126 ] Kurt Young edited comment on FLINK-15017 at 12/10/19 2:31 AM: -- I think this

[jira] [Commented] (FLINK-15017) add a thrift server for Flink

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992126#comment-16992126 ] Kurt Young commented on FLINK-15017: I think this is a good addition to Flink SQL. We have to take

[jira] [Closed] (FLINK-15164) Introduce ParquetColumnarRowSplitReader to parquet format

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15164. Resolution: Duplicate > Introduce ParquetColumnarRowSplitReader to parquet format >

[jira] [Commented] (FLINK-15164) Introduce ParquetColumnarRowSplitReader to parquet format

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992123#comment-16992123 ] Jingsong Lee commented on FLINK-15164: -- Hi [~ZhenqiuHuang], this is duplicated with 

[jira] [Commented] (FLINK-14815) Expose network metric in IOMetricsInfo

2019-12-09 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992120#comment-16992120 ] lining commented on FLINK-14815: [~pnowojski] could you review it? > Expose network metric in

[GitHub] [flink] walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-09 Thread GitBox
walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#discussion_r355814299 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-09 Thread GitBox
walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#discussion_r355814399 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-09 Thread GitBox
walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#discussion_r355814412 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-09 Thread GitBox
walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#discussion_r355814236 ## File path:

[GitHub] [flink] walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-12-09 Thread GitBox
walterddr commented on a change in pull request #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#discussion_r355814170 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 Travis:

[GitHub] [flink] walterddr commented on a change in pull request #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

2019-12-09 Thread GitBox
walterddr commented on a change in pull request #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#discussion_r355813464 ## File path:

[jira] [Commented] (FLINK-15129) Return JobClient instead of JobClient Future from executeAsync()

2019-12-09 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992116#comment-16992116 ] Jeff Zhang commented on FLINK-15129: Return JobClient directly make more sense for me. > Return

[GitHub] [flink] KarmaGYZ commented on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

2019-12-09 Thread GitBox
KarmaGYZ commented on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-563578121 Thanks for the review @azagrebin . Addressed.

[GitHub] [flink] flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:

[jira] [Updated] (FLINK-15052) Test transformation.clear() in sqlClient

2019-12-09 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15052: --- Summary: Test transformation.clear() in sqlClient (was: sql client doesn't clear previous job

[GitHub] [flink] flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#issuecomment-563465099 ## CI report: * 0904024ed3b34e27bc8e98c92b162024d5f40d95 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#issuecomment-563465099 ## CI report: * 0904024ed3b34e27bc8e98c92b162024d5f40d95 Travis:

[GitHub] [flink] tweise commented on a change in pull request #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded

2019-12-09 Thread GitBox
tweise commented on a change in pull request #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded URL: https://github.com/apache/flink/pull/10285#discussion_r355724390 ## File path: flink-connectors/flink-connector-kinesis/pom.xml

[GitHub] [flink] flinkbot commented on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

2019-12-09 Thread GitBox
flinkbot commented on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#issuecomment-563465099 ## CI report: * 0904024ed3b34e27bc8e98c92b162024d5f40d95 UNKNOWN Bot commands

[GitHub] [flink] tweise commented on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded

2019-12-09 Thread GitBox
tweise commented on issue #10285: [FLINK-14896] [flink-kinesis-connector] Set jackson and guava dependency to flink-shaded URL: https://github.com/apache/flink/pull/10285#issuecomment-563465284 Unfortunately there is a high probability of jackson libraries conflicting with older versions

[GitHub] [flink] flinkbot commented on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

2019-12-09 Thread GitBox
flinkbot commented on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#issuecomment-563457964 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

<    1   2   3   4   5   6   7   8   >