[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE

[jira] [Updated] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-14370: - Fix Version/s: 1.8.2 1.9.2 1.10.0 >

[jira] [Closed] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-14370. Release Note: The fix has been pushed master, release-1.8 and release-1.9. Closing the Jira

[jira] [Commented] (FLINK-14135) Introduce vectorized orc InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-14135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961696#comment-16961696 ] Jark Wu commented on FLINK-14135: - I assinged this ticket to you [~lzljs3620320] > Introduce vectorized

[jira] [Assigned] (FLINK-14549) Bring more detail by using logicalType rather than conversionClass in exception msg

[ https://issues.apache.org/jira/browse/FLINK-14549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14549: --- Assignee: Leonard Xu > Bring more detail by using logicalType rather than conversionClass in >

[jira] [Assigned] (FLINK-14135) Introduce vectorized orc InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-14135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14135: --- Assignee: Jingsong Lee > Introduce vectorized orc InputFormat for blink runtime >

[GitHub] [flink] flinkbot edited a comment on issue #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

flinkbot edited a comment on issue #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#issuecomment-546552903 ## CI report: * 8c5fd072d4a8665c5d89a9b920b9c699baabed00 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint.

flinkbot edited a comment on issue #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint. URL: https://github.com/apache/flink/pull/9986#issuecomment-545891630 ## CI report: * 593bf42620faf09c1accbd692494646194e3d574 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint.

flinkbot edited a comment on issue #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint. URL: https://github.com/apache/flink/pull/9986#issuecomment-545891630 ## CI report: * 593bf42620faf09c1accbd692494646194e3d574 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS

[jira] [Commented] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961671#comment-16961671 ] Zili Chen commented on FLINK-10435: --- I think the fix provided by [~fly_in_gis] is valid. Here is

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE

[GitHub] [flink] wangyang0918 commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint.

wangyang0918 commented on a change in pull request #9986: [FLINK-10933][kubernetes] Implement KubernetesSessionClusterEntrypoint. URL: https://github.com/apache/flink/pull/9986#discussion_r339889492 ## File path:

[jira] [Commented] (FLINK-14135) Introduce vectorized orc InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-14135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961663#comment-16961663 ] Jingsong Lee commented on FLINK-14135: -- [~jark] Can you assign this ticket to me? > Introduce

[GitHub] [flink] flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#issuecomment-546868067 ## CI report: * 8c3d1a58bd358493197697e07b9d6542bf29e59a : FAILURE

[GitHub] [flink] haodang commented on issue #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

haodang commented on issue #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#issuecomment-547247064 Thank you very much @wuchong for the suggestions! I'll add in the test.

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE

[jira] [Comment Edited] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961652#comment-16961652 ] shengjk1 edited comment on FLINK-7289 at 10/29/19 3:55 AM: --- Thanks [~yunta] and

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961652#comment-16961652 ] shengjk1 commented on FLINK-7289: - Thanks [~yunta] and [~mikekap]. I have solved it. As Mike Kaplinskiy

[jira] [Assigned] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-10435: - Assignee: Yang Wang > Client sporadically hangs after Ctrl + C >

[GitHub] [flink] haodang commented on a change in pull request #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

haodang commented on a change in pull request #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#discussion_r339884830 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

TisonKun commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#discussion_r339884112 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java

[GitHub] [flink] haodang removed a comment on issue #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

haodang removed a comment on issue #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#issuecomment-547243583 Thank you very much for the suggestions @wuchong! They all sound good and I'll

[GitHub] [flink] haodang commented on issue #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

haodang commented on issue #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#issuecomment-547243583 Thank you very much for the suggestions @wuchong! They all sound good and I'll incorporate

[jira] [Commented] (FLINK-11835) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961644#comment-16961644 ] Yun Tang commented on FLINK-11835: -- Another instance but with different stack

[jira] [Comment Edited] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961638#comment-16961638 ] Congxian Qiu(klion26) edited comment on FLINK-14544 at 10/29/19 3:36 AM:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

wangyang0918 commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#discussion_r339882058 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java

[jira] [Commented] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961638#comment-16961638 ] Congxian Qiu(klion26) commented on FLINK-14544: --- from the log, found that the

[jira] [Updated] (FLINK-14550) can't use proctime attribute when register datastream for table and exist nested fields

[ https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-14550: -- Description: *_The data schame :_*   final String schemaString = "

[jira] [Updated] (FLINK-14550) can't use proctime attribute when register datastream for table and exist nested fields

[ https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-14550: -- Description: *_The data schame :_*   final String schemaString = "

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE

[jira] [Created] (FLINK-14550) can't use proctime attribute when register datastream for table and exist nested fields

hehuiyuan created FLINK-14550: - Summary: can't use proctime attribute when register datastream for table and exist nested fields Key: FLINK-14550 URL: https://issues.apache.org/jira/browse/FLINK-14550

[GitHub] [flink] flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

flinkbot edited a comment on issue #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#issuecomment-546868067 ## CI report: * 8c3d1a58bd358493197697e07b9d6542bf29e59a : FAILURE

[jira] [Commented] (FLINK-14424) Create tpc-ds end to end test to support all tpc-ds queries

[ https://issues.apache.org/jira/browse/FLINK-14424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961625#comment-16961625 ] Leonard Xu commented on FLINK-14424: [~wind_ljy] Yes，just like that tpch has done。 > Create tpc-ds

[GitHub] [flink] zhuzhurk edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

zhuzhurk edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-532262379 > How do you configure the `FastRestartPipelinedRegionStrategy`? The PR is updated to enable

[jira] [Commented] (FLINK-14126) Elasticsearch Xpack Machine Learning doesn't support ARM

[ https://issues.apache.org/jira/browse/FLINK-14126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961620#comment-16961620 ] wangxiyuan commented on FLINK-14126: Error log: org.elasticsearch.bootstrap.StartupException:

[GitHub] [flink] lirui-apache commented on a change in pull request #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

lirui-apache commented on a change in pull request #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#discussion_r339872502 ## File path:

[jira] [Commented] (FLINK-14549) Bring more detail by using logicalType rather than conversionClass in exception msg

[ https://issues.apache.org/jira/browse/FLINK-14549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961612#comment-16961612 ] Jark Wu commented on FLINK-14549: - +1 to do this. Do you want to do this? [~Leonard Xu] > Bring more

[GitHub] [flink] lirui-apache commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

lirui-apache commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#issuecomment-547229352 @bowenli86 Thanks for the review and merge :) This

[jira] [Commented] (FLINK-14537) Improve influxdb reporter performance for kafka source/sink

[ https://issues.apache.org/jira/browse/FLINK-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961608#comment-16961608 ] Yun Tang commented on FLINK-14537: -- [~ouyangwuli] Why not use grafana but influxdb cli to query

[GitHub] [flink] TisonKun commented on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

TisonKun commented on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-547228392 > , Thanks for your clarification. I see the concern.

[GitHub] [flink] TisonKun edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

TisonKun edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-547228392 Thanks for your clarification. I see the concern.

[jira] [Updated] (FLINK-14374) Enable RegionFailoverITCase to pass with scheduler NG

[ https://issues.apache.org/jira/browse/FLINK-14374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14374: Description: RegionFailoverITCase currently fails with scheduler NG. The failure cause is that it's using

[jira] [Issue Comment Deleted] (FLINK-14424) Create tpc-ds end to end test to support all tpc-ds queries

[ https://issues.apache.org/jira/browse/FLINK-14424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-14424: --- Comment: was deleted (was: A quick ask, are you going to create a new tpc-ds module and put it into

[GitHub] [flink] TisonKun commented on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

TisonKun commented on issue #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#issuecomment-547225702 > > Thanks for opening this pull request @wangyang0918 ! Generally it looks good. I have one question: > > What if

[GitHub] [flink] TisonKun commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C

TisonKun commented on a change in pull request #10010: [FLINK-10435][yarn]Client sporadically hangs after Ctrl + C URL: https://github.com/apache/flink/pull/10010#discussion_r339868479 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java

[jira] [Commented] (FLINK-14537) Improve influxdb reporter performance for kafka source/sink

[ https://issues.apache.org/jira/browse/FLINK-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961599#comment-16961599 ] ouyangwulin commented on FLINK-14537: - [~wind_ljy],I always use influxdb cli, `show measurements`

[jira] [Closed] (FLINK-12668) Introduce fromParallelElements for generating DataStreamSource

[ https://issues.apache.org/jira/browse/FLINK-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao closed FLINK-12668. -- Fix Version/s: (was: 1.10.0) Resolution: Invalid > Introduce fromParallelElements for

[jira] [Closed] (FLINK-13854) Support Aggregating in Join and CoGroup

[ https://issues.apache.org/jira/browse/FLINK-13854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao closed FLINK-13854. -- Resolution: Invalid > Support Aggregating in Join and CoGroup >

[GitHub] [flink] flinkbot edited a comment on issue #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy

flinkbot edited a comment on issue #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy URL: https://github.com/apache/flink/pull/10021#issuecomment-547177459 ## CI report: * d345162a7060b40731d4210eb17b0062be4a69ea : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099 ## CI report: * 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS

[jira] [Closed] (FLINK-14397) Failed to run Hive UDTF with array arguments

[ https://issues.apache.org/jira/browse/FLINK-14397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-14397. Fix Version/s: 1.10.0 Resolution: Fixed master: e18320b76047af4e15297e3e89b6c46ef3dae9bf > Failed

[GitHub] [flink] bowenli86 commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

bowenli86 commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#issuecomment-547192410 @lirui-apache thanks for reminding me. merged now

[jira] [Updated] (FLINK-14397) Failed to run Hive UDTF with array arguments

[ https://issues.apache.org/jira/browse/FLINK-14397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14397: - Affects Version/s: 1.10.0 1.9.0 > Failed to run Hive UDTF with array arguments >

[GitHub] [flink] asfgit closed pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

asfgit closed pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] bowenli86 commented on a change in pull request #9962: [FLINK-14218][table] support precise function reference in FunctionCatalog

bowenli86 commented on a change in pull request #9962: [FLINK-14218][table] support precise function reference in FunctionCatalog URL: https://github.com/apache/flink/pull/9962#discussion_r339838103 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099 ## CI report: * 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy

flinkbot edited a comment on issue #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy URL: https://github.com/apache/flink/pull/10021#issuecomment-547177459 ## CI report: * d345162a7060b40731d4210eb17b0062be4a69ea : PENDING

[GitHub] [flink] kl0u commented on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

kl0u commented on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-547181779 Thanks for the review @TisonKun ! I integrated your comments, apart from the one for the

[GitHub] [flink] flinkbot commented on issue #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy

flinkbot commented on issue #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy URL: https://github.com/apache/flink/pull/10021#issuecomment-547177459 ## CI report: * d345162a7060b40731d4210eb17b0062be4a69ea : UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #10019: [hotfix][docs] REST label in SSL figure was rotated out of view

flinkbot edited a comment on issue #10019: [hotfix][docs] REST label in SSL figure was rotated out of view URL: https://github.com/apache/flink/pull/10019#issuecomment-546974174 ## CI report: * b45e285f780c93fee41118c45bdad54812909a99 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy

flinkbot commented on issue #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy URL: https://github.com/apache/flink/pull/10021#issuecomment-547174745 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] nryanov opened a new pull request #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy

nryanov opened a new pull request #10021: [hotfix][typo] Rename withNewBucketAssignerAnd[Rolling]Policy URL: https://github.com/apache/flink/pull/10021 ## What is the purpose of the change There are two existing methods in StreamingFileSink: withRollingPolicy and withBucketAssigner

[GitHub] [flink] flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions

flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#issuecomment-544551169 ## CI report: * 2cf1a8e029da523cdf2df9504f4d6f44da31ceb1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10019: [hotfix][docs] REST label in SSL figure was rotated out of view

flinkbot edited a comment on issue #10019: [hotfix][docs] REST label in SSL figure was rotated out of view URL: https://github.com/apache/flink/pull/10019#issuecomment-546974174 ## CI report: * b45e285f780c93fee41118c45bdad54812909a99 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099 ## CI report: * 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions

flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#issuecomment-544551169 ## CI report: * 2cf1a8e029da523cdf2df9504f4d6f44da31ceb1 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10019: [hotfix][docs] REST label in SSL figure was rotated out of view

flinkbot edited a comment on issue #10019: [hotfix][docs] REST label in SSL figure was rotated out of view URL: https://github.com/apache/flink/pull/10019#issuecomment-546974174 ## CI report: * b45e285f780c93fee41118c45bdad54812909a99 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions

flinkbot edited a comment on issue #9960: [FLINK-14476] Extend PartitionTracker to support promotions URL: https://github.com/apache/flink/pull/9960#issuecomment-544551169 ## CI report: * 2cf1a8e029da523cdf2df9504f4d6f44da31ceb1 : SUCCESS

[GitHub] [flink] alpinegizmo commented on a change in pull request #10019: [hotfix][docs] REST label in SSL figure was rotated out of view

alpinegizmo commented on a change in pull request #10019: [hotfix][docs] REST label in SSL figure was rotated out of view URL: https://github.com/apache/flink/pull/10019#discussion_r339782523 ## File path: docs/fig/ssl_internal_external.svg ## @@ -1,22 +1,4 @@

[GitHub] [flink] zentol commented on a change in pull request #10019: [hotfix][docs] REST label in SSL figure was rotated out of view

zentol commented on a change in pull request #10019: [hotfix][docs] REST label in SSL figure was rotated out of view URL: https://github.com/apache/flink/pull/10019#discussion_r339778653 ## File path: docs/fig/ssl_internal_external.svg ## @@ -1,22 +1,4 @@

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099 ## CI report: * 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

flinkbot edited a comment on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-545348099 ## CI report: * 07d3f11426dbdcc4fd961641da0a573914926aca : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#issuecomment-542997479 ## CI report: * c7e058ec893217ef5c8c3cf3ae5e893a7ccf4b8f : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

flinkbot edited a comment on issue #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#issuecomment-542997479 ## CI report: * c7e058ec893217ef5c8c3cf3ae5e893a7ccf4b8f : SUCCESS

[GitHub] [flink] xuefuz commented on a change in pull request #9962: [FLINK-14218][table] support precise function reference in FunctionCatalog

xuefuz commented on a change in pull request #9962: [FLINK-14218][table] support precise function reference in FunctionCatalog URL: https://github.com/apache/flink/pull/9962#discussion_r339711107 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1

xuefuz commented on a change in pull request #9995: [FLINK-14526][hive] Support Hive version 1.1.0 and 1.1.1 URL: https://github.com/apache/flink/pull/9995#discussion_r339701308 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

zhuzhurk commented on a change in pull request #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#discussion_r339683817 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

zhuzhurk commented on a change in pull request #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#discussion_r339682440 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

zhuzhurk commented on a change in pull request #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#discussion_r339682365 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

TisonKun commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#discussion_r339674656 ## File path:

[GitHub] [flink] TisonKun commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

TisonKun commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#discussion_r339676856 ## File path:

[jira] [Commented] (FLINK-14537) Improve influxdb reporter performance for kafka source/sink

[ https://issues.apache.org/jira/browse/FLINK-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961243#comment-16961243 ] Yun Tang commented on FLINK-14537: -- I think the main cause is due to many unnecessary tags, which is

[jira] [Comment Edited] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961208#comment-16961208 ] Congxian Qiu(klion26) edited comment on FLINK-14544 at 10/28/19 4:47 PM:

[GitHub] [flink] TisonKun commented on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

TisonKun commented on issue #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#issuecomment-547033503 Thanks for your update @kl0u ! Sorry for replying late. I will give it a review now.

[GitHub] [flink] KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

KurtYoung commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339658621 ## File path:

[jira] [Commented] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961208#comment-16961208 ] Congxian Qiu(klion26) commented on FLINK-14544: --- >From the given log,  If I understand

[jira] [Comment Edited] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961208#comment-16961208 ] Congxian Qiu(klion26) edited comment on FLINK-14544 at 10/28/19 4:14 PM:

[GitHub] [flink] GJL commented on issue #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph

GJL commented on issue #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10014#issuecomment-547021122 @yanghua I will take a look tomorrow. This is an automated message

[GitHub] [flink] GJL commented on a change in pull request #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler

GJL commented on a change in pull request #9920: [FLINK-14389][runtime] Restore task state before restarting tasks in DefaultScheduler URL: https://github.com/apache/flink/pull/9920#discussion_r339654176 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10020: [FLINK-12147] [metrics] Update influxdb-java to remove writes of invalid values to InfluxDB

flinkbot edited a comment on issue #10020: [FLINK-12147] [metrics] Update influxdb-java to remove writes of invalid values to InfluxDB URL: https://github.com/apache/flink/pull/10020#issuecomment-546974232 ## CI report: * 02beb6ed94e7b27fd3ff9242a0669138828a55cb : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

flinkbot edited a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-546907883 ## CI report: * 0af01dfef17a8ebcafd92137f87a96023258e124 : SUCCESS

[GitHub] [flink] yanghua commented on issue #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph

yanghua commented on issue #10014: [FLINK-12526] Remove STATE_UPDATER in ExecutionGraph URL: https://github.com/apache/flink/pull/10014#issuecomment-547016198 @GJL The Travis is green now. Anything need to be changed, please let me know, thanks~

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339647504 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339647504 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

dawidwys commented on a change in pull request #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#discussion_r339647504 ## File path:

[GitHub] [flink] ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-547015390 @pnowojski , wow! The issue has been opened over 4 years. It really surprises me. Thanks for detailed

[GitHub] [flink] ifndef-SleePy commented on issue #9885: [FLINK-14344][checkpointing] Snapshots master hook state asynchronously

ifndef-SleePy commented on issue #9885: [FLINK-14344][checkpointing] Snapshots master hook state asynchronously URL: https://github.com/apache/flink/pull/9885#issuecomment-547011917 @pnowojski , thanks for reminding. Will rebase master later. Regarding to the dependences of

  1   2   3   4   >