[jira] [Commented] (FLINK-19121) Avoid accessing HDFS frequently in HiveBulkWriterFactory

[ https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241314#comment-17241314 ] CloseRiver commented on FLINK-19121: [~lzljs3620320],If we use flink BulkWriter,we s

[jira] [Comment Edited] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

[ https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237947#comment-17237947 ] CloseRiver edited comment on FLINK-20236 at 11/24/20, 8:17 AM: ---

[jira] [Commented] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

[ https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237947#comment-17237947 ] CloseRiver commented on FLINK-20236: [~lirui]，I build under the root directory. I tr

[jira] [Commented] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

[ https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237886#comment-17237886 ] CloseRiver commented on FLINK-20236: My maven version is 3.6.3,i'll try it again usi

[jira] [Commented] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

[ https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237812#comment-17237812 ] CloseRiver commented on FLINK-20236: [~lirui],I build from the source and output jar

[jira] [Commented] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

[ https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237301#comment-17237301 ] CloseRiver commented on FLINK-20236: Hi [~lirui],it is also in hive-exec.jar. I put

[jira] [Commented] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

[ https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237099#comment-17237099 ] CloseRiver commented on FLINK-20236: Hi [~trohrmann],i didn't verify 1.12-SNAPSHOT,s

[jira] [Commented] (FLINK-19345) In Table File Sink, introduce streaming sink compaction

[ https://issues.apache.org/jira/browse/FLINK-19345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235444#comment-17235444 ] CloseRiver commented on FLINK-19345: I have seen the code,the big file will be just

[jira] [Commented] (FLINK-19345) In Table File Sink, introduce streaming sink compaction

[ https://issues.apache.org/jira/browse/FLINK-19345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235378#comment-17235378 ] CloseRiver commented on FLINK-19345: Hi [~lzljs3620320],if the temp file is big enou

[jira] [Created] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

CloseRiver created FLINK-20236: -- Summary: flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar Key: FLINK-20236 URL: https://issues.apache.org/jira/browse/FLINK-20236 Project: Flink

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225824#comment-17225824 ] CloseRiver commented on FLINK-19937: [~lzljs3620320],please assign the rest JDBC,Hba

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225799#comment-17225799 ] CloseRiver commented on FLINK-19937: [~neighborhood],ok i'll take a look and update 

[jira] [Commented] (FLINK-19941) Support sink parallelism configuration to Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-19941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225312#comment-17225312 ] CloseRiver commented on FLINK-19941: Hi [~lzljs3620320],I've submit a pr,have a look

[jira] [Updated] (FLINK-19941) Support sink parallelism configuration to Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-19941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CloseRiver updated FLINK-19941: --- Labels: pull-request-available (was: ) > Support sink parallelism configuration to Kafka connector

[jira] [Commented] (FLINK-19941) Support sink parallelism configuration to Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-19941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225194#comment-17225194 ] CloseRiver commented on FLINK-19941: [~lzljs3620320],I'll from kafka first.plz assig

[jira] [Created] (FLINK-19947) Support sink parallelism configuration to Print connector

CloseRiver created FLINK-19947: -- Summary: Support sink parallelism configuration to Print connector Key: FLINK-19947 URL: https://issues.apache.org/jira/browse/FLINK-19947 Project: Flink Issue T

[jira] [Created] (FLINK-19945) Support sink parallelism configuration to FileSystem connector

CloseRiver created FLINK-19945: -- Summary: Support sink parallelism configuration to FileSystem connector Key: FLINK-19945 URL: https://issues.apache.org/jira/browse/FLINK-19945 Project: Flink I

[jira] [Created] (FLINK-19946) Support sink parallelism configuration to Hbase connector

CloseRiver created FLINK-19946: -- Summary: Support sink parallelism configuration to Hbase connector Key: FLINK-19946 URL: https://issues.apache.org/jira/browse/FLINK-19946 Project: Flink Issue T

[jira] [Created] (FLINK-19944) Support sink parallelism configuration to Hive connector

CloseRiver created FLINK-19944: -- Summary: Support sink parallelism configuration to Hive connector Key: FLINK-19944 URL: https://issues.apache.org/jira/browse/FLINK-19944 Project: Flink Issue Ty

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225192#comment-17225192 ] CloseRiver commented on FLINK-19937: Got it. > Support sink parallelism option for

[jira] [Created] (FLINK-19943) Support sink parallelism configuration to ElasticSearch connector

CloseRiver created FLINK-19943: -- Summary: Support sink parallelism configuration to ElasticSearch connector Key: FLINK-19943 URL: https://issues.apache.org/jira/browse/FLINK-19943 Project: Flink

[jira] [Created] (FLINK-19942) Support sink parallelism configuration to JDBC connector

CloseRiver created FLINK-19942: -- Summary: Support sink parallelism configuration to JDBC connector Key: FLINK-19942 URL: https://issues.apache.org/jira/browse/FLINK-19942 Project: Flink Issue Ty

[jira] [Updated] (FLINK-19942) Support sink parallelism configuration to JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-19942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CloseRiver updated FLINK-19942: --- Component/s: Connectors / JDBC > Support sink parallelism configuration to JDBC connector >

[jira] [Created] (FLINK-19941) Support sink parallelism configuration to Kafka connector

CloseRiver created FLINK-19941: -- Summary: Support sink parallelism configuration to Kafka connector Key: FLINK-19941 URL: https://issues.apache.org/jira/browse/FLINK-19941 Project: Flink Issue T

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225185#comment-17225185 ] CloseRiver commented on FLINK-19937: [~lzljs3620320],i notice that Hive and FileSyst

[jira] [Comment Edited] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225168#comment-17225168 ] CloseRiver edited comment on FLINK-19937 at 11/3/20, 7:06 AM:

[jira] [Comment Edited] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225168#comment-17225168 ] CloseRiver edited comment on FLINK-19937 at 11/3/20, 6:58 AM:

[jira] [Commented] (FLINK-19937) Support sink parallelism option for all connectors

[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225168#comment-17225168 ] CloseRiver commented on FLINK-19937: Hi,[~neighborhood],[~lzljs3620320] Is all the

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224434#comment-17224434 ] CloseRiver commented on FLINK-18846: [~lzljs3620320],Yes now that the problem will n

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224431#comment-17224431 ] CloseRiver commented on FLINK-18846: Yes ,i just found that [~lzljs3620320]. > Set

[jira] [Comment Edited] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224428#comment-17224428 ] CloseRiver edited comment on FLINK-18846 at 11/2/20, 5:54 AM:

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224428#comment-17224428 ] CloseRiver commented on FLINK-18846: [~jark]，The filesystem sink operator is a disca

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224409#comment-17224409 ] CloseRiver commented on FLINK-18846: Thx [~zhuqi] [~jark],I want to take this, Coul

[jira] [Commented] (FLINK-18846) Set a meaningful operator name for the filesystem sink

[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224401#comment-17224401 ] CloseRiver commented on FLINK-18846: Hi [~zhuqi],are you still working on this issue

[jira] [Commented] (FLINK-19762) Selecting Job-ID and TaskManager-ID in web UI covers more than the ID

[ https://issues.apache.org/jira/browse/FLINK-19762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223544#comment-17223544 ] CloseRiver commented on FLINK-19762: [~mapohl]，i have updated the pr.plz have a chec

[jira] [Updated] (FLINK-19762) Selecting Job-ID and TaskManager-ID in web UI covers more than the ID

[ https://issues.apache.org/jira/browse/FLINK-19762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CloseRiver updated FLINK-19762: --- Attachment: image-2020-10-30-16-12-17-038.png > Selecting Job-ID and TaskManager-ID in web UI covers

[jira] [Commented] (FLINK-19762) Selecting Job-ID and TaskManager-ID in web UI covers more than the ID

[ https://issues.apache.org/jira/browse/FLINK-19762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223486#comment-17223486 ] CloseRiver commented on FLINK-19762: [~mapohl],Of course,is here? !image-2020-10-30-

[jira] [Updated] (FLINK-19762) Selecting Job-ID in web UI covers more than the ID

[ https://issues.apache.org/jira/browse/FLINK-19762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CloseRiver updated FLINK-19762: --- Attachment: image-2020-10-29-20-32-39-368.png > Selecting Job-ID in web UI covers more than the ID >

[jira] [Commented] (FLINK-19762) Selecting Job-ID in web UI covers more than the ID

[ https://issues.apache.org/jira/browse/FLINK-19762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222864#comment-17222864 ] CloseRiver commented on FLINK-19762: [~mapohl],I mean the same format is double-clic

[jira] [Commented] (FLINK-19762) Selecting Job-ID in web UI covers more than the ID

[ https://issues.apache.org/jira/browse/FLINK-19762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222761#comment-17222761 ] CloseRiver commented on FLINK-19762: hi [~mapohl],i want to fix it.BTW, Start Time/E

[jira] [Closed] (FLINK-19817) Is FileSystem source unsupported?

[ https://issues.apache.org/jira/browse/FLINK-19817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] CloseRiver closed FLINK-19817. -- Resolution: Not A Problem > Is FileSystem source unsupported? > - > >

[jira] [Commented] (FLINK-19817) Is FileSystem source unsupported?

[ https://issues.apache.org/jira/browse/FLINK-19817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221980#comment-17221980 ] CloseRiver commented on FLINK-19817: Thx for your explanation [~lzljs3620320].It is

[jira] [Commented] (FLINK-19817) Is FileSystem source unsupported?

[ https://issues.apache.org/jira/browse/FLINK-19817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221339#comment-17221339 ] CloseRiver commented on FLINK-19817: Tkx for your remind [~lzljs3620320] ,you are ri

[jira] [Commented] (FLINK-19817) Is FileSystem source unsupported?

[ https://issues.apache.org/jira/browse/FLINK-19817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221185#comment-17221185 ] CloseRiver commented on FLINK-19817: hi [~lzljs3620320],this is my sql   {code:java

[jira] [Created] (FLINK-19817) Is FileSystem source unsupported?

CloseRiver created FLINK-19817: -- Summary: Is FileSystem source unsupported? Key: FLINK-19817 URL: https://issues.apache.org/jira/browse/FLINK-19817 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-19631) Comments of DecodingFormatFactory is not clear

[ https://issues.apache.org/jira/browse/FLINK-19631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213732#comment-17213732 ] CloseRiver commented on FLINK-19631: Hi [~lzljs3620320],I want to take this,can you

[jira] [Commented] (FLINK-19619) Test failed in Azure For EmulatedPubSubSourceTest

[ https://issues.apache.org/jira/browse/FLINK-19619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213521#comment-17213521 ] CloseRiver commented on FLINK-19619: +1,my pr met the same azure failures. https://

[jira] [Commented] (FLINK-19456) sql client execute insert sql with comment ahead

[ https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17211635#comment-17211635 ] CloseRiver commented on FLINK-19456: [~jark],could you assign to me ? > sql client

[jira] [Commented] (FLINK-19456) sql client execute insert sql with comment ahead

[ https://issues.apache.org/jira/browse/FLINK-19456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204589#comment-17204589 ] CloseRiver commented on FLINK-19456: Hi [~linld],[~jark] I think we should skip the

[jira] [Commented] (FLINK-19444) flink 1.11 sql group by tumble Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered

[ https://issues.apache.org/jira/browse/FLINK-19444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203730#comment-17203730 ] CloseRiver commented on FLINK-19444: Hi [~johnhuster],window should be defined on  e

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17203088#comment-17203088 ] CloseRiver commented on FLINK-18850: [~libenchao],sorry for late reply,recently have

[jira] [Commented] (FLINK-19336) EncodingUtils#encodeObjectToString should propagate inner exception

[ https://issues.apache.org/jira/browse/FLINK-19336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200043#comment-17200043 ] CloseRiver commented on FLINK-19336: hi [~libenchao],I want to take this,plz assign

[jira] [Commented] (FLINK-19321) CollectSinkFunction does not define serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-19321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199367#comment-17199367 ] CloseRiver commented on FLINK-19321: i got it,could you assign to me.[~fhueske] > C

[jira] [Comment Edited] (FLINK-19321) CollectSinkFunction does not define serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-19321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199360#comment-17199360 ] CloseRiver edited comment on FLINK-19321 at 9/21/20, 12:40 PM: ---

[jira] [Commented] (FLINK-19321) CollectSinkFunction does not define serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-19321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199360#comment-17199360 ] CloseRiver commented on FLINK-19321: [~fhueske],I want to take this. BTW,is there re

[jira] [Commented] (FLINK-19281) LIKE cannot recognize full table path

[ https://issues.apache.org/jira/browse/FLINK-19281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198100#comment-17198100 ] CloseRiver commented on FLINK-19281: I think ,we should use `sqlTableLike.getSourceT

[jira] [Commented] (FLINK-19133) User provided kafka partitioners are not initialized correctly

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197631#comment-17197631 ] CloseRiver commented on FLINK-19133: [~dwysakowicz],yes you are right,i have just ve

[jira] [Commented] (FLINK-19133) User provided kafka partitioners are not initialized correctly

[ https://issues.apache.org/jira/browse/FLINK-19133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17197580#comment-17197580 ] CloseRiver commented on FLINK-19133: [~dwysakowicz],does flink sql has this problem?