[jira] [Commented] (FLINK-10514) change Tachyon to Alluxio

[ https://issues.apache.org/jira/browse/FLINK-10514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16642848#comment-16642848 ] vinoyang commented on FLINK-10514: -- hi [~yangxiaoshuo] , Usually you need to send an em

[jira] [Commented] (FLINK-10420) Create and drop view in sql client should check the view created based on the configuration.

[ https://issues.apache.org/jira/browse/FLINK-10420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16643614#comment-16643614 ] vinoyang commented on FLINK-10420: -- [~twalthr] What's your opinion? > Create and drop

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16643634#comment-16643634 ] vinoyang commented on FLINK-10114: -- [~Zentol] and [~pnowojski] can you give some sugges

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16644724#comment-16644724 ] vinoyang commented on FLINK-10114: -- [~kkl0u] In fact, I saw the PR of Parquet implement

[jira] [Created] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

vinoyang created FLINK-10527: Summary: Cleanup constant isNewMode in YarnTestBase Key: FLINK-10527 URL: https://issues.apache.org/jira/browse/FLINK-10527 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16645881#comment-16645881 ] vinoyang commented on FLINK-10527: -- cc [~till.rohrmann] and [~Tison] > Cleanup constan

[jira] [Updated] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10527: - Issue Type: Sub-task (was: Bug) Parent: FLINK-10392 > Cleanup constant isNewMode in YarnTestBas

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16647352#comment-16647352 ] vinoyang commented on FLINK-10534: -- Hi [~yeshan] Thank you for making this suggestion,

[jira] [Assigned] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10534: Assignee: vinoyang > Add idle timeout for a flink session cluster > -

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16647373#comment-16647373 ] vinoyang commented on FLINK-10534: -- [~isunjin] agree.  > Add idle timeout for a flink

[jira] [Assigned] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10534: Assignee: (was: vinoyang) > Add idle timeout for a flink session cluster > --

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16647379#comment-16647379 ] vinoyang commented on FLINK-10534: -- [~yeshan] It seems that you currently have no JIRA

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16647462#comment-16647462 ] vinoyang commented on FLINK-10534: -- [~yeshan] I believe he will see and give you permis

[jira] [Commented] (FLINK-9607) Support ParquetTableSink

[ https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649648#comment-16649648 ] vinoyang commented on FLINK-9607: - hi [~guibopan] , [~mingleizhang] has released this iss

[jira] [Assigned] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10251: Assignee: vinoyang > Handle oversized response messages in AkkaRpcActor > ---

[jira] [Created] (FLINK-10547) Remove LegacyCLI

vinoyang created FLINK-10547: Summary: Remove LegacyCLI Key: FLINK-10547 URL: https://issues.apache.org/jira/browse/FLINK-10547 Project: Flink Issue Type: Sub-task Reporter: vinoyang

[jira] [Created] (FLINK-10548) Remove LegacyStandaloneClusterDescriptor

vinoyang created FLINK-10548: Summary: Remove LegacyStandaloneClusterDescriptor Key: FLINK-10548 URL: https://issues.apache.org/jira/browse/FLINK-10548 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10550) Remove LegacyYarnClusterDescriptor

vinoyang created FLINK-10550: Summary: Remove LegacyYarnClusterDescriptor Key: FLINK-10550 URL: https://issues.apache.org/jira/browse/FLINK-10550 Project: Flink Issue Type: Sub-task R

[jira] [Commented] (FLINK-10547) Remove LegacyCLI

[ https://issues.apache.org/jira/browse/FLINK-10547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649842#comment-16649842 ] vinoyang commented on FLINK-10547: -- [~till.rohrmann] Can this class been removed? > Re

[jira] [Created] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

vinoyang created FLINK-10558: Summary: Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base Key: FLINK-10558 URL: https://issues.apache.org/jira/browse/FLINK-10558 Proje

[jira] [Commented] (FLINK-10246) Harden and separate MetricQueryService

[ https://issues.apache.org/jira/browse/FLINK-10246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651085#comment-16651085 ] vinoyang commented on FLINK-10246: -- [~till.rohrmann] Now the remaining two tasks of thi

[jira] [Commented] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651331#comment-16651331 ] vinoyang commented on FLINK-10251: -- hi [~Zentol] Regarding this oversize detection, do

[jira] [Assigned] (FLINK-10562) Relax (or document) table name constraints

[ https://issues.apache.org/jira/browse/FLINK-10562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10562: Assignee: vinoyang > Relax (or document) table name constraints > ---

[jira] [Created] (FLINK-10598) Maintain modern Kafka connector

vinoyang created FLINK-10598: Summary: Maintain modern Kafka connector Key: FLINK-10598 URL: https://issues.apache.org/jira/browse/FLINK-10598 Project: Flink Issue Type: Task Components

[jira] [Created] (FLINK-10599) Provide documentation for the modern kafka connector

vinoyang created FLINK-10599: Summary: Provide documentation for the modern kafka connector Key: FLINK-10599 URL: https://issues.apache.org/jira/browse/FLINK-10599 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

vinoyang created FLINK-10600: Summary: Provide End-to-end test cases for modern Kafka connectors Key: FLINK-10600 URL: https://issues.apache.org/jira/browse/FLINK-10600 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10599) Provide documentation for the modern kafka connector

[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654949#comment-16654949 ] vinoyang commented on FLINK-10599: -- [~aljoscha] and [~till.rohrmann] If I start this is

[jira] [Updated] (FLINK-8354) Flink Kafka connector ignores Kafka message headers

[ https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-8354: Issue Type: Sub-task (was: Bug) Parent: FLINK-10598 > Flink Kafka connector ignores Kafka message

[jira] [Updated] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-8500: Issue Type: Sub-task (was: Improvement) Parent: FLINK-10598 > Get the timestamp of the Kafka messa

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16656137#comment-16656137 ] vinoyang commented on FLINK-8500: - Hi,  if the modern kafka connector also has this issue

[jira] [Assigned] (FLINK-10603) Reduce kafka test duration

[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10603: Assignee: vinoyang > Reduce kafka test duration > -- > >

[jira] [Commented] (FLINK-7964) Add Apache Kafka 1.0/1.1 connectors

[ https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16656445#comment-16656445 ] vinoyang commented on FLINK-7964: - [~aljoscha] and [~Zentol] Since we already have the mo

[jira] [Created] (FLINK-10620) Remove the dependency on the version string literal.

vinoyang created FLINK-10620: Summary: Remove the dependency on the version string literal. Key: FLINK-10620 URL: https://issues.apache.org/jira/browse/FLINK-10620 Project: Flink Issue Type: Sub-

[jira] [Updated] (FLINK-10599) Provide documentation for the modern kafka connector

[ https://issues.apache.org/jira/browse/FLINK-10599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10599: - Component/s: Documentation > Provide documentation for the modern kafka connector >

[jira] [Commented] (FLINK-10603) Reduce kafka test duration

[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658177#comment-16658177 ] vinoyang commented on FLINK-10603: -- The reason for this issue is due to the increase in

[jira] [Comment Edited] (FLINK-10603) Reduce kafka test duration

[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658177#comment-16658177 ] vinoyang edited comment on FLINK-10603 at 10/21/18 11:33 AM: -

[jira] [Comment Edited] (FLINK-10603) Reduce kafka test duration

[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658177#comment-16658177 ] vinoyang edited comment on FLINK-10603 at 10/21/18 11:34 AM: -

[jira] [Assigned] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10624: Assignee: vinoyang > Extend SQL client end-to-end to test new KafkaTableSink > --

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16658464#comment-16658464 ] vinoyang commented on FLINK-10624: -- I created an umbrella issue FLINK-10598 to archive

[jira] [Assigned] (FLINK-10630) Update migration tests for Flink 1.6

[ https://issues.apache.org/jira/browse/FLINK-10630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10630: Assignee: vinoyang > Update migration tests for Flink 1.6 >

[jira] [Assigned] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10600: Assignee: vinoyang > Provide End-to-end test cases for modern Kafka connectors >

[jira] [Updated] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10624: - Issue Type: Sub-task (was: Task) Parent: FLINK-10598 > Extend SQL client end-to-end to test new

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16660523#comment-16660523 ] vinoyang commented on FLINK-10624: -- I am planning to start this issue, but I have a lit

[jira] [Updated] (FLINK-10425) taskmanager.host is not respected

[ https://issues.apache.org/jira/browse/FLINK-10425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10425: - Summary: taskmanager.host is not respected (was: taskmaster.host is not respected) > taskmanager.host

[jira] [Commented] (FLINK-10658) org.apache.flink.util.FlinkException: Releasing shared slot parent.

[ https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661669#comment-16661669 ] vinoyang commented on FLINK-10658: -- hi [~chauncy] When the SharedSlot is being released

[jira] [Commented] (FLINK-10658) org.apache.flink.util.FlinkException: Releasing shared slot parent.

[ https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16661682#comment-16661682 ] vinoyang commented on FLINK-10658: -- The behavior of releasing slots is usually triggere

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16662150#comment-16662150 ] vinoyang commented on FLINK-10600: -- [~pnowojski] Yes, I am doing it, I will try to impl

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16662157#comment-16662157 ] vinoyang commented on FLINK-10624: -- [~pnowojski] Where can I find the previous implemen

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16662188#comment-16662188 ] vinoyang commented on FLINK-10624: -- OK, I will take a deeper look at it. > Extend SQL

[jira] [Created] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module

vinoyang created FLINK-10922: Summary: Refactor the placement of the Flink Kafka connector end to end test module Key: FLINK-10922 URL: https://issues.apache.org/jira/browse/FLINK-10922 Project: Flink

[jira] [Commented] (FLINK-10849) The flink Metric has no data when two or more filter operators are used

[ https://issues.apache.org/jira/browse/FLINK-10849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691382#comment-16691382 ] vinoyang commented on FLINK-10849: -- [~Zentol] We have also encountered similar problems

[jira] [Commented] (FLINK-10849) The flink Metric has no data when two or more filter operators are used

[ https://issues.apache.org/jira/browse/FLINK-10849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691394#comment-16691394 ] vinoyang commented on FLINK-10849: -- [~Zentol] We found it to be in Flink 1.6.0. Maybe y

[jira] [Updated] (FLINK-10849) The flink Metric has no data when two or more filter operators are used

[ https://issues.apache.org/jira/browse/FLINK-10849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10849: - Attachment: FLINK-10849.png > The flink Metric has no data when two or more filter operators are used >

[jira] [Comment Edited] (FLINK-10849) The flink Metric has no data when two or more filter operators are used

[ https://issues.apache.org/jira/browse/FLINK-10849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691585#comment-16691585 ] vinoyang edited comment on FLINK-10849 at 11/19/18 11:36 AM: -

[jira] [Commented] (FLINK-10849) The flink Metric has no data when two or more filter operators are used

[ https://issues.apache.org/jira/browse/FLINK-10849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16691585#comment-16691585 ] vinoyang commented on FLINK-10849: -- Maybe I gave you the wrong message. What I see is t

[jira] [Created] (FLINK-10931) Exclude transitive dependence on Kafka-client

vinoyang created FLINK-10931: Summary: Exclude transitive dependence on Kafka-client Key: FLINK-10931 URL: https://issues.apache.org/jira/browse/FLINK-10931 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9461: --- Assignee: vinoyang > Disentangle flink-connector-kafka from flink-table and flink-json > ---

[jira] [Commented] (FLINK-10919) Flink binary distribution too large

[ https://issues.apache.org/jira/browse/FLINK-10919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692569#comment-16692569 ] vinoyang commented on FLINK-10919: -- [~till.rohrmann]  Currently, the typical pattern of

[jira] [Assigned] (FLINK-10929) Add support for Apache Arrow

[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10929: Assignee: vinoyang > Add support for Apache Arrow > > >

[jira] [Created] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector

vinoyang created FLINK-10940: Summary: Refactor the maven dependencies of Kafka 0.8 connector Key: FLINK-10940 URL: https://issues.apache.org/jira/browse/FLINK-10940 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692607#comment-16692607 ] vinoyang commented on FLINK-10892: -- [~dawidwys] is right. He gave an option based on th

[jira] [Closed] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-10892. Resolution: Not A Problem Release Note: We can set it via CLI option or API (AbstractYarnClusterDesc

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692669#comment-16692669 ] vinoyang commented on FLINK-10892: -- [~zjffdu] Flink on YARN is just one of the running

[jira] [Closed] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector

[ https://issues.apache.org/jira/browse/FLINK-10940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-10940. Resolution: Won't Fix Release Note: In-depth, Kafka 0.8 connector is indeed different from other ver

[jira] [Updated] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module

[ https://issues.apache.org/jira/browse/FLINK-10922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10922: - Fix Version/s: 1.7.0 > Refactor the placement of the Flink Kafka connector end to end test module >

[jira] [Commented] (FLINK-10892) Flink Yarn app name is hard coded

[ https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692715#comment-16692715 ] vinoyang commented on FLINK-10892: -- [~zjffdu] I have already said that Application is j

[jira] [Created] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

vinoyang created FLINK-10966: Summary: Optimize the release blocking logic in BarrierBuffer Key: FLINK-10966 URL: https://issues.apache.org/jira/browse/FLINK-10966 Project: Flink Issue Type: Impr

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16694933#comment-16694933 ] vinoyang commented on FLINK-10966: -- [~StephanEwen] [~till.rohrmann] and [~Zentol] What

[jira] [Assigned] (FLINK-10964) sql-client throws exception when pagin through finished batch query

[ https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10964: Assignee: vinoyang > sql-client throws exception when pagin through finished batch query > -

[jira] [Updated] (FLINK-10967) Update kafka dependency to 2.1.0

[ https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10967: - Issue Type: Sub-task (was: Bug) Parent: FLINK-10598 > Update kafka dependency to 2.1.0 > --

[jira] [Assigned] (FLINK-10969) expose API or metric for total number of keys stored in state backend

[ https://issues.apache.org/jira/browse/FLINK-10969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10969: Assignee: vinoyang > expose API or metric for total number of keys stored in state backend >

[jira] [Assigned] (FLINK-10970) expose metric for total state size in terms of bytes

[ https://issues.apache.org/jira/browse/FLINK-10970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10970: Assignee: vinoyang > expose metric for total state size in terms of bytes > -

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695609#comment-16695609 ] vinoyang commented on FLINK-10966: -- Hi [~zjwang] , answer your question: 1). For 1.5+

[jira] [Comment Edited] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16695609#comment-16695609 ] vinoyang edited comment on FLINK-10966 at 11/22/18 6:58 AM:

[jira] [Assigned] (FLINK-10452) Expose Additional Metrics to Reason about Statesize

[ https://issues.apache.org/jira/browse/FLINK-10452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10452: Assignee: vinoyang > Expose Additional Metrics to Reason about Statesize > --

[jira] [Commented] (FLINK-10929) Add support for Apache Arrow

[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696351#comment-16696351 ] vinoyang commented on FLINK-10929: -- Hi [~fhueske]  I believe that Flink Streaming will

[jira] [Created] (FLINK-10993) Bring bloomfilter as a public API

vinoyang created FLINK-10993: Summary: Bring bloomfilter as a public API Key: FLINK-10993 URL: https://issues.apache.org/jira/browse/FLINK-10993 Project: Flink Issue Type: New Feature C

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696450#comment-16696450 ] vinoyang commented on FLINK-10993: -- [~fhue...@gmail.com] [~trohrm...@apache.org] What d

[jira] [Updated] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-9461: Issue Type: Sub-task (was: Improvement) Parent: FLINK-10598 > Disentangle flink-connector-kafka fr

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696503#comment-16696503 ] vinoyang commented on FLINK-9461: - Hi all,  The discussion of this issue does not seem t

[jira] [Comment Edited] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696693#comment-16696693 ] vinoyang edited comment on FLINK-9461 at 11/23/18 11:44 AM: h

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16696693#comment-16696693 ] vinoyang commented on FLINK-9461: - hi [~twalthr]  Thank you for your explanation of the c

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698405#comment-16698405 ] vinoyang commented on FLINK-10993: -- [~StephanEwen] Thank you for agreeing with the mean

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698419#comment-16698419 ] vinoyang commented on FLINK-10966: -- [~StephanEwen] We found this problem online. The re

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698824#comment-16698824 ] vinoyang commented on FLINK-10993: -- [~fhueske] Yes, the goal of that issue looks very s

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700074#comment-16700074 ] vinoyang commented on FLINK-9461: - [~twalthr]   Here are some of the dependencies on _exp

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700293#comment-16700293 ] vinoyang commented on FLINK-10993: -- [~fhueske]  Yes, it is a meaningful feature to intr

[jira] [Commented] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700341#comment-16700341 ] vinoyang commented on FLINK-9461: - [~twalthr] To confirm a question, are the classes or m

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700574#comment-16700574 ] vinoyang commented on FLINK-10993: -- [~StephanEwen] Yes, I believe that it is not just a

[jira] [Created] (FLINK-11015) Remove deprecated methods and classes from all the Kafka connectors

vinoyang created FLINK-11015: Summary: Remove deprecated methods and classes from all the Kafka connectors Key: FLINK-11015 URL: https://issues.apache.org/jira/browse/FLINK-11015 Project: Flink

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700607#comment-16700607 ] vinoyang commented on FLINK-10993: -- Oh, [~StephanEwen]  I need to clarify, of course, I

[jira] [Updated] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11015: - Summary: Remove deprecated methods and classes about table from all the Kafka connectors (was: Remove d

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700660#comment-16700660 ] vinoyang commented on FLINK-10966: -- [~StephanEwen]  This scenario is in the standalone

[jira] [Comment Edited] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16700660#comment-16700660 ] vinoyang edited comment on FLINK-10966 at 11/27/18 4:39 PM:

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701732#comment-16701732 ] vinoyang commented on FLINK-10966: -- [~StephanEwen]  Yes, adding timeouts for blocking

[jira] [Commented] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701779#comment-16701779 ] vinoyang commented on FLINK-10966: -- [~StephanEwen]  You are right, the second option, i

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701783#comment-16701783 ] vinoyang commented on FLINK-10993: -- [~StephanEwen] In my opinion, the PR of FLINK-8601

[jira] [Assigned] (FLINK-11022) Update LICENSE and NOTICE files for older releases

[ https://issues.apache.org/jira/browse/FLINK-11022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11022: Assignee: vinoyang > Update LICENSE and NOTICE files for older releases > ---

[jira] [Assigned] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11023: Assignee: vinoyang > Update LICENSE and NOTICE files for flink-connectors > -

[jira] [Commented] (FLINK-10993) Bring bloomfilter as a public API

[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704340#comment-16704340 ] vinoyang commented on FLINK-10993: -- [~fhueske] yes, I looked the design document attach

  1   2   3   4   5   6   7   8   9   10   >