[jira] [Commented] (FLINK-15581) SpillingResettableMutableObjectIterator data overflow

2020-01-13 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014911#comment-17014911 ] Benchao Li commented on FLINK-15581: Hi [~pnowojski], I noticed that [~caojian0613] has already

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

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014909#comment-17014909 ] Jingsong Lee commented on FLINK-11899: -- Hi [~hpeter], another way is re-writing readers instead of

[jira] [Assigned] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-15549: -- Assignee: caojian0613 > integer overflow in SpillingResettableMutableObjectIterator

[jira] [Updated] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15549: --- Affects Version/s: 1.6.4 1.7.2 1.8.3

[jira] [Closed] (FLINK-15581) SpillingResettableMutableObjectIterator data overflow

2020-01-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15581. -- Resolution: Duplicate > SpillingResettableMutableObjectIterator data overflow >

[jira] [Updated] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

2020-01-13 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15549: --- Component/s: (was: Runtime / Task) API / DataSet > integer overflow in

[jira] [Created] (FLINK-15581) SpillingResettableMutableObjectIterator data overflow

2020-01-13 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-15581: -- Summary: SpillingResettableMutableObjectIterator data overflow Key: FLINK-15581 URL: https://issues.apache.org/jira/browse/FLINK-15581 Project: Flink

[GitHub] [flink] flinkbot commented on issue #10849: [hotfix] [javadocs] fix typo in KafkaTopicPartitionStateWithPunctuatedWatermarks class introduction

2020-01-13 Thread GitBox
flinkbot commented on issue #10849: [hotfix] [javadocs] fix typo in KafkaTopicPartitionStateWithPunctuatedWatermarks class introduction URL: https://github.com/apache/flink/pull/10849#issuecomment-574047859 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] guliziduo opened a new pull request #10849: [hotfix] [javadocs] fix typo in KafkaTopicPartitionStateWithPunctuatedWatermarks class introduction

2020-01-13 Thread GitBox
guliziduo opened a new pull request #10849: [hotfix] [javadocs] fix typo in KafkaTopicPartitionStateWithPunctuatedWatermarks class introduction URL: https://github.com/apache/flink/pull/10849 ## What is the purpose of the change fix typo in

[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-574046614 Thank you for the update @link3280 . Will merge it later today.

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

2020-01-13 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014906#comment-17014906 ] Zhenqiu Huang commented on FLINK-11899: --- [~lzljs3620320] I want to leverage existing

[GitHub] [flink] flinkbot edited a comment on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services.

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services. URL: https://github.com/apache/flink/pull/10845#issuecomment-573736294 ## CI report: * 0942cb8b913ba50ecf8d7ca28832c4c92bf78e6c Travis:

[jira] [Commented] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-13 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014903#comment-17014903 ] Terry Wang commented on FLINK-15552: Hi, [~jark]. I'm sure about it. As for SQL CLI e2e tests,

[jira] [Commented] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

2020-01-13 Thread Benoit Hanotte (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014902#comment-17014902 ] Benoit Hanotte commented on FLINK-15577: [~ykt836] yes, I'll have a look at both >

[jira] [Updated] (FLINK-15249) Improve PipelinedRegions calculation with Union Set

2020-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15249: Attachment: RegionFailoverPerfTest.java > Improve PipelinedRegions calculation with Union Set >

[jira] [Commented] (FLINK-15249) Improve PipelinedRegions calculation with Union Set

2020-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014900#comment-17014900 ] Zhu Zhu commented on FLINK-15249: - Hi [~nppoly], I tried your patch with a testing topology. The result

[GitHub] [flink] flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-560291002 ## CI report: * 5a9b8cc32f275d416e8358ee148ad4daff2626ba Travis:

[GitHub] [flink] AHeise commented on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services.

2020-01-13 Thread GitBox
AHeise commented on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services. URL: https://github.com/apache/flink/pull/10845#issuecomment-574032048 @flinkbot run travis This is an automated message

[GitHub] [flink] AHeise commented on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services.

2020-01-13 Thread GitBox
AHeise commented on issue #10845: [FLINK-15355][plugins] Classloader avoids loading unrelated services. URL: https://github.com/apache/flink/pull/10845#issuecomment-574032079 @flinkbot run azure This is an automated message

[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=17014886#comment-17014886 ] Yuan Mei commented on FLINK-14163: --   Thanks [~azagrebin] and [~zhuzh]! I do not have a strong opinion

[GitHub] [flink] KarmaGYZ commented on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_…

2020-01-13 Thread GitBox
KarmaGYZ commented on issue #10668: [hotfix] Align the parameter pattern of retry_times with retry_times_… URL: https://github.com/apache/flink/pull/10668#issuecomment-574025389 Kindly ping @tillrohrmann This is an

[GitHub] [flink] flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-560291002 ## CI report: * 5a9b8cc32f275d416e8358ee148ad4daff2626ba Travis:

[jira] [Assigned] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

2020-01-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15577: -- Assignee: Benoit Hanotte > WindowAggregate RelNodes missing Window specs in digest >

[jira] [Commented] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

2020-01-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014876#comment-17014876 ] Kurt Young commented on FLINK-15577: [~b.hanotte] Thanks for the fix, looks like blink planner also

[jira] [Commented] (FLINK-15579) Can not use jdbc connector on Blink batch mode

2020-01-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014875#comment-17014875 ] Kurt Young commented on FLINK-15579: So you want to use JDBC as a batch sink? > Can not use jdbc

[jira] [Updated] (FLINK-15579) Can not use jdbc connector on Blink batch mode

2020-01-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15579: --- Issue Type: Improvement (was: Bug) > Can not use jdbc connector on Blink batch mode >

[jira] [Commented] (FLINK-15576) remove isTemporary property from CatalogFunction API

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014874#comment-17014874 ] Jingsong Lee commented on FLINK-15576: -- Hi [~phoenixjiangnan], looks like it is just an internal

[jira] [Updated] (FLINK-15579) Can not use jdbc connector on Blink batch mode

2020-01-13 Thread Shu Li Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shu Li Zheng updated FLINK-15579: - Affects Version/s: 1.9.0 1.9.1 > Can not use jdbc connector on Blink

[GitHub] [flink] flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-560291002 ## CI report: * 5a9b8cc32f275d416e8358ee148ad4daff2626ba Travis:

[GitHub] [flink] Li-Aihua commented on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

2020-01-13 Thread GitBox
Li-Aihua commented on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-574011447 > I'm not convinced that the `PerformanceTestJobBase` is the right approach. Could you

[jira] [Created] (FLINK-15580) Add baseurl to docs/build_docs.sh

2020-01-13 Thread Benchao Li (Jira)
Benchao Li created FLINK-15580: -- Summary: Add baseurl to docs/build_docs.sh Key: FLINK-15580 URL: https://issues.apache.org/jira/browse/FLINK-15580 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#issuecomment-570066854 ## CI report: * 4b605068e32d3eb15a51f838ed29918d1224959a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#issuecomment-573958003 ## CI report: * a3f83df73af74cf8509f084e860ab88e63129ac8 Travis:

[jira] [Comment Edited] (FLINK-15579) Can not use jdbc connector on Blink batch mode

2020-01-13 Thread Shu Li Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014848#comment-17014848 ] Shu Li Zheng edited comment on FLINK-15579 at 1/14/20 4:42 AM: --- [~ykt836]

[jira] [Updated] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

2020-01-13 Thread Benoit Hanotte (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit Hanotte updated FLINK-15577: --- Description: The RelNode's digest (AbstractRelNode.getDigest()), along with its RowType, is

[GitHub] [flink] flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#issuecomment-570066854 ## CI report: * 4b605068e32d3eb15a51f838ed29918d1224959a Travis:

[jira] [Commented] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

2020-01-13 Thread Benoit Hanotte (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014856#comment-17014856 ] Benoit Hanotte commented on FLINK-15577: Hi [~ykt836], yes, I'll push a PR today >

[jira] [Commented] (FLINK-15579) Can not use jdbc connector on Blink batch mode

2020-01-13 Thread Shu Li Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014848#comment-17014848 ] Shu Li Zheng commented on FLINK-15579: -- [~ykt836]Could you assign this bug to me? I would like to

[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:

[GitHub] [flink] flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572552628 ## CI report: * a814428b99636921abf55ab089e664cec9d13876 Travis:

[jira] [Updated] (FLINK-15579) Can not use jdbc connector on Blink batch mode

2020-01-13 Thread Shu Li Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shu Li Zheng updated FLINK-15579: - Description: Because JDBCTableSourceSinkFactory.createStreamTableSink() create

[jira] [Updated] (FLINK-15579) Can not use jdbc connector on Blink batch mode

2020-01-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15579: --- Component/s: Table SQL / Planner > Can not use jdbc connector on Blink batch mode >

[jira] [Created] (FLINK-15579) Can not use jdbc connector on Blink batch mode

2020-01-13 Thread Shu Li Zheng (Jira)
Shu Li Zheng created FLINK-15579: Summary: Can not use jdbc connector on Blink batch mode Key: FLINK-15579 URL: https://issues.apache.org/jira/browse/FLINK-15579 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#issuecomment-570066854 ## CI report: * 4b605068e32d3eb15a51f838ed29918d1224959a Travis:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#discussion_r366143207 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#discussion_r366142860 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#discussion_r366143882 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

2020-01-13 Thread GitBox
zhuzhurk commented on a change in pull request #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#discussion_r366143327 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#issuecomment-573958003 ## CI report: * a3f83df73af74cf8509f084e860ab88e63129ac8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572552628 ## CI report: * a814428b99636921abf55ab089e664cec9d13876 Travis:

[jira] [Commented] (FLINK-13590) flink-on-yarn sometimes could create many little files that are xxx-taskmanager-conf.yaml

2020-01-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014847#comment-17014847 ] Yang Wang commented on FLINK-13590: --- [~gjy] It we do not want to backport to 1.7. Then this ticket

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

2020-01-13 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014845#comment-17014845 ] Zhu Zhu commented on FLINK-14163: - +1 to fix it with a simple check first. As long as we are call

[GitHub] [flink] JingsongLi commented on a change in pull request #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API

2020-01-13 Thread GitBox
JingsongLi commented on a change in pull request #10846: [FLINK-15576] remove isTemporary property from CatalogFunction API URL: https://github.com/apache/flink/pull/10846#discussion_r366139545 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

2020-01-13 Thread GitBox
wuchong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#discussion_r366136972 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#issuecomment-570066854 ## CI report: * 4b605068e32d3eb15a51f838ed29918d1224959a Travis:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e…

2020-01-13 Thread GitBox
KarmaGYZ commented on a change in pull request #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e… URL: https://github.com/apache/flink/pull/10746#discussion_r366138517 ## File path: flink-end-to-end-tests/test-scripts/common_mesos_docker.sh ##

[jira] [Commented] (FLINK-12362) Remove legacy container number config option for Flink on yarn

2020-01-13 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014840#comment-17014840 ] liupengcheng commented on FLINK-12362: -- [~trohrmann] [~yanghua] I still wondering how to set the a

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

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014838#comment-17014838 ] Jingsong Lee commented on FLINK-11899: -- [~hpeter] Why share so much? What is your plan? IMO, Orc

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

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

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

2020-01-13 Thread GitBox
wuchong merged pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839 This is an automated message from the Apache Git Service.

[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-573980423 Thanks @JingsongLi , Merging... This

[GitHub] [flink] flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#issuecomment-573958003 ## CI report: * a3f83df73af74cf8509f084e860ab88e63129ac8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl URL: https://github.com/apache/flink/pull/10844#issuecomment-573736138 ## CI report: * a356df63a802f15c8a1e6982cf68c51da30b454c Travis:

[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:

[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:

[jira] [Comment Edited] (FLINK-15469) UpsertStreamTableSink should support new type system

2020-01-13 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014828#comment-17014828 ] Zhenghua Gao edited comment on FLINK-15469 at 1/14/20 3:15 AM: --- Hi

[GitHub] [flink] flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572552628 ## CI report: * a814428b99636921abf55ab089e664cec9d13876 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10784: [FLINK-15494] Fix time field index wrong in LogicalWindowAggregateRul…

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10784: [FLINK-15494] Fix time field index wrong in LogicalWindowAggregateRul… URL: https://github.com/apache/flink/pull/10784#issuecomment-571473399 ## CI report: * d0e5cb3e0d2cc118c98cd91e0470c5123219d1ec Travis:

[jira] [Updated] (FLINK-15469) UpsertStreamTableSink should support new type system

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15469: - Issue Type: Improvement (was: New Feature) > UpsertStreamTableSink should support new type

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

2020-01-13 Thread GitBox
JingsongLi 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-573978938 LGTM This is an automated message

[jira] [Commented] (FLINK-15469) UpsertStreamTableSink should support new type system

2020-01-13 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014828#comment-17014828 ] Zhenghua Gao commented on FLINK-15469: -- Hi [~lzljs3620320], after re-think the whole thing, we

[jira] [Resolved] (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:all-tabpanel ] Jark Wu resolved FLINK-15559. - Fix Version/s: 1.10.0 Resolution: Fixed 1.11.0: dd05f44d7d2b9bf6ea151489b66dc9cd2bd64eed 1.10.0:

[GitHub] [flink] gaoyunhaii commented on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-13 Thread GitBox
gaoyunhaii commented on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#issuecomment-573978662 Hi @zhijiangW very thanks for the review! I have updated the PR according to the comments.

[GitHub] [flink] gaoyunhaii commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-13 Thread GitBox
gaoyunhaii commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#discussion_r366134565 ## File path:

[GitHub] [flink] JingsongLi commented on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

2020-01-13 Thread GitBox
JingsongLi commented on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-573978365 ping @wuchong This is an automated message from the

[GitHub] [flink] wuchong merged pull request #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl

2020-01-13 Thread GitBox
wuchong merged pull request #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl URL: https://github.com/apache/flink/pull/10844 This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-15511) export org.apache.flink.table.api.TableException when flink 1.10 connect hive

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15511. Resolution: Invalid > export org.apache.flink.table.api.TableException when flink 1.10 connect

[jira] [Commented] (FLINK-15497) Streaming TopN operator doesn't reduce outputs when rank number is not required

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014827#comment-17014827 ] Jingsong Lee commented on FLINK-15497: -- [~jinyu.zj] Please click "start in-progress", thanks. >

[jira] [Commented] (FLINK-15511) export org.apache.flink.table.api.TableException when flink 1.10 connect hive

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014826#comment-17014826 ] Jingsong Lee commented on FLINK-15511: -- Since this is not a bug. I linked this to FLINK-15533 and

[jira] [Updated] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15527: - Fix Version/s: (was: 1.10.0) 1.11.0 > can not control the number of

[GitHub] [flink] gaoyunhaii commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-13 Thread GitBox
gaoyunhaii commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#discussion_r366133522 ## File path:

[GitHub] [flink] libenchao commented on a change in pull request #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl

2020-01-13 Thread GitBox
libenchao commented on a change in pull request #10844: [FLINK-15559][docs] Fix broken links due to missing baseurl URL: https://github.com/apache/flink/pull/10844#discussion_r366133539 ## File path: docs/release-notes/flink-1.8.md ## @@ -200,7 +200,7 @@ The

[GitHub] [flink] gaoyunhaii commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-13 Thread GitBox
gaoyunhaii commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#discussion_r366133442 ## File path:

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

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

[jira] [Comment Edited] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

2020-01-13 Thread Andrew.D.lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014810#comment-17014810 ] Andrew.D.lin edited comment on FLINK-15307 at 1/14/20 3:01 AM: --- Hi 

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

2020-01-13 Thread GitBox
wuchong merged 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 This is an automated message

[jira] [Comment Edited] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

2020-01-13 Thread Andrew.D.lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014810#comment-17014810 ] Andrew.D.lin edited comment on FLINK-15307 at 1/14/20 2:56 AM: --- Hi 

[jira] [Commented] (FLINK-14684) Add Pinterest to Chinese Powered By page

2020-01-13 Thread Jiawei Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014823#comment-17014823 ] Jiawei Wu commented on FLINK-14684: --- [~jark] great! Thanks for that. > Add Pinterest to Chinese

[jira] [Commented] (FLINK-15505) flink-clients test failing on Red Hat 7.6 PowerPC Linux

2020-01-13 Thread wangxiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014820#comment-17014820 ] wangxiyuan commented on FLINK-15505: [~fly_in_gis]   1.8.3 doesn't contain my change, for example: 

[GitHub] [flink] JingsongLi commented on a change in pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread GitBox
JingsongLi commented on a change in pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839#discussion_r366131547 ## File path: docs/dev/table/sql/insert.md ## @@ -125,20 +125,28

[GitHub] [flink] KarmaGYZ edited a comment on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e…

2020-01-13 Thread GitBox
KarmaGYZ edited a comment on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e… URL: https://github.com/apache/flink/pull/10746#issuecomment-573974153 > will we always run into permission issues Sorry, I'm not sure about this. At least so far, I

[GitHub] [flink] KarmaGYZ commented on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e…

2020-01-13 Thread GitBox
KarmaGYZ commented on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e… URL: https://github.com/apache/flink/pull/10746#issuecomment-573974153 > will we always run into permission issues Sorry, I'm not sure about this. At least so far, I could not

[GitHub] [flink] flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#issuecomment-573958003 ## CI report: * a3f83df73af74cf8509f084e860ab88e63129ac8 Travis:

[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:

[GitHub] [flink] flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest

2020-01-13 Thread GitBox
flinkbot edited a comment on issue #10814: [FLINK-15434][Tests]Fix unstable tests in JobMasterTest URL: https://github.com/apache/flink/pull/10814#issuecomment-572552628 ## CI report: * a814428b99636921abf55ab089e664cec9d13876 Travis:

[jira] [Commented] (FLINK-15546) Obscure error message from ScalarOperatorGens::generateCast

2020-01-13 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014818#comment-17014818 ] Zhenghua Gao commented on FLINK-15546: -- {code:java} case (from, to) => throw new

[jira] [Commented] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy

2020-01-13 Thread Andrew.D.lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014810#comment-17014810 ] Andrew.D.lin commented on FLINK-15307: -- [~zhuzh] sorry, I missed it, Let me modify it > Subclasses

[jira] [Commented] (FLINK-15505) flink-clients test failing on Red Hat 7.6 PowerPC Linux

2020-01-13 Thread wangxiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014805#comment-17014805 ] wangxiyuan commented on FLINK-15505: Oh, let me check it for ppc64le > flink-clients test failing

[jira] [Commented] (FLINK-15574) DataType to LogicalType conversion issue

2020-01-13 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014804#comment-17014804 ] Zhenghua Gao commented on FLINK-15574: -- HI [~b.hanotte], a reason to keep this deprecated

[GitHub] [flink] JingsongLi commented on a change in pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL

2020-01-13 Thread GitBox
JingsongLi commented on a change in pull request #10839: [FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL URL: https://github.com/apache/flink/pull/10839#discussion_r366125955 ## File path: docs/dev/table/sql/insert.md ## @@ -0,0 +1,173 @@

  1   2   3   4   5   >