[jira] [Commented] (FLINK-9640) Checkpointing is aways aborted if any task has been finished

2018-06-28 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527141#comment-16527141 ] Hai Zhou commented on FLINK-9640: - CC [~StephanEwen], what do you think about this ticket? >

[jira] [Updated] (FLINK-9640) Checkpointing is aways aborted if any task has been finished

2018-06-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-9640: Description: steps to reproduce: 1. build a standalone flink cluster. 2. submit a test job like this

[jira] [Updated] (FLINK-9640) Checkpointing is aways aborted if any task has been finished

2018-06-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-9640: Affects Version/s: (was: 1.3.2) > Checkpointing is aways aborted if any task has been finished >

[jira] [Created] (FLINK-9640) Checkpointing is aways aborted if any task has been finished

2018-06-21 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-9640: --- Summary: Checkpointing is aways aborted if any task has been finished Key: FLINK-9640 URL: https://issues.apache.org/jira/browse/FLINK-9640 Project: Flink Issue

[jira] [Commented] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-05 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501359#comment-16501359 ] Hai Zhou commented on FLINK-9525: - After adding this missing file in the {{flink-hadoop-fs}} module, and

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-05 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-9525: Description: if flink job dependencies includes `hadoop-common` and `hadoop-hdfs`, will throw runtime

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-05 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-9525: Description: if flink job dependencies includes `hadoop-common` and `hadoop-hdfs`, will throw runtime

[jira] [Created] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-05 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-9525: --- Summary: Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Key: FLINK-9525 URL: https://issues.apache.org/jira/browse/FLINK-9525 Project: Flink

[jira] [Created] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

2018-06-01 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-9498: --- Summary: Disable dependency convergence for "flink-end-to-end-tests" Key: FLINK-9498 URL: https://issues.apache.org/jira/browse/FLINK-9498 Project: Flink Issue Type:

[jira] [Closed] (FLINK-7952) Add metrics for counting logging events

2018-04-23 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7952. --- Resolution: Won't Fix > Add metrics for counting logging events > >

[jira] [Commented] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge

2018-04-22 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447268#comment-16447268 ] Hai Zhou commented on FLINK-9233: - [~StephanEwen], I saw this {{IllegalArgumentException: Illegal value

[jira] [Commented] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge

2018-04-22 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447234#comment-16447234 ] Hai Zhou commented on FLINK-9233: - I am not quite sure that upgrading the rocksdb version to 5.9 or higher

[jira] [Created] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge

2018-04-22 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-9233: --- Summary: Merging state may cause runtime exception when windows trigger onMerge Key: FLINK-9233 URL: https://issues.apache.org/jira/browse/FLINK-9233 Project: Flink

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

2018-04-22 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447205#comment-16447205 ] Hai Zhou commented on FLINK-9091: - +1. > Failure while enforcing releasability in building flink-json

[jira] [Commented] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE

2018-04-22 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447140#comment-16447140 ] Hai Zhou commented on FLINK-9032: - Hi [~aljoscha], [~till.rohrmann] , what do you think about this? >

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-04-22 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16447110#comment-16447110 ] Hai Zhou commented on FLINK-9231: - hi [~triones], This ticket is assigned to you and you can work for it

[jira] [Assigned] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-04-22 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-9231: --- Assignee: Triones Deng > Enable SO_REUSEADDR on listen sockets >

[jira] [Assigned] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-18 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-9212: --- Assignee: Hai Zhou > Port SubtasksAllAccumulatorsHandler to new REST endpoint >

[jira] [Commented] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE

2018-03-26 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16415050#comment-16415050 ] Hai Zhou commented on FLINK-9032: - [~Zentol] , What do you think about this ticket? > Deprecate

[jira] [Assigned] (FLINK-9090) Replace UUID.randomUUID with deterministic PRNG

2018-03-26 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-9090: --- Assignee: Hai Zhou > Replace UUID.randomUUID with deterministic PRNG >

[jira] [Assigned] (FLINK-9088) Upgrade Nifi connector dependency to 1.6.0

2018-03-26 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-9088: --- Assignee: Hai Zhou > Upgrade Nifi connector dependency to 1.6.0 >

[jira] [Assigned] (FLINK-9091) Failure while enforcing releasability in building flink-json module

2018-03-26 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-9091: --- Assignee: Hai Zhou > Failure while enforcing releasability in building flink-json module >

[jira] [Commented] (FLINK-9068) Website documentation issue - html tag visible on screen

2018-03-23 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16412385#comment-16412385 ] Hai Zhou commented on FLINK-9068: - It seems I can't find you inside the Assignee search box, you may need

[jira] [Commented] (FLINK-9068) Website documentation issue - html tag visible on screen

2018-03-23 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16412380#comment-16412380 ] Hai Zhou commented on FLINK-9068: - Thank you [~shankarganesh1234], found this typo issue, are you

[jira] [Updated] (FLINK-9064) Add Scaladocs link to documentation

2018-03-23 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-9064: Issue Type: Improvement (was: Bug) > Add Scaladocs link to documentation >

[jira] [Created] (FLINK-9033) Replace usages of deprecated TASK_MANAGER_NUM_TASK_SLOTS

2018-03-20 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-9033: --- Summary: Replace usages of deprecated TASK_MANAGER_NUM_TASK_SLOTS Key: FLINK-9033 URL: https://issues.apache.org/jira/browse/FLINK-9033 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE

2018-03-20 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-9032: Component/s: Configuration > Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE >

[jira] [Created] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE

2018-03-20 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-9032: --- Summary: Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE Key: FLINK-9032 URL: https://issues.apache.org/jira/browse/FLINK-9032 Project: Flink Issue

[jira] [Assigned] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics

2017-09-16 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-7624: --- Assignee: (was: Hai Zhou) > Add kafka-topic for "KafkaProducer" metrics >

[jira] [Closed] (FLINK-7625) typo in docs metrics sections

2017-09-16 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7625. --- Resolution: Fixed > typo in docs metrics sections > -- > > Key:

[jira] [Closed] (FLINK-7494) No license headers in ".travis.yml" file

2017-09-16 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7494. --- Resolution: Fixed Fix Version/s: 1.4.0 > No license headers in ".travis.yml" file >

[jira] [Created] (FLINK-7626) Add some metric description about checkpoints

2017-09-14 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7626: --- Summary: Add some metric description about checkpoints Key: FLINK-7626 URL: https://issues.apache.org/jira/browse/FLINK-7626 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7625) typo in docs metrics sections

2017-09-14 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7625: --- Summary: typo in docs metrics sections Key: FLINK-7625 URL: https://issues.apache.org/jira/browse/FLINK-7625 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics

2017-09-14 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7624: --- Summary: Add kafka-topic for "KafkaProducer" metrics Key: FLINK-7624 URL: https://issues.apache.org/jira/browse/FLINK-7624 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-2428) Clean up unused properties in StreamConfig

2017-09-11 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-2428. --- Resolution: Fixed > Clean up unused properties in StreamConfig > -- >

[jira] [Commented] (FLINK-3542) FlinkKafkaConsumer09 cannot handle changing number of partitions

2017-09-11 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16162054#comment-16162054 ] Hai Zhou commented on FLINK-3542: - [~till.rohrmann] In flink 1.3.x, FlinkKafkaConsumer08 also have this

[jira] [Commented] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests

2017-09-11 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16161119#comment-16161119 ] Hai Zhou commented on FLINK-6444: - I already have an idea. When I am not busy with work;), I will go to

[jira] [Assigned] (FLINK-7562) uploaded jars sort by upload-time on dashboard page

2017-09-09 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-7562: --- Assignee: Hai Zhou > uploaded jars sort by upload-time on dashboard page >

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2017-09-08 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16159312#comment-16159312 ] Hai Zhou commented on FLINK-7608: - Hi [~rmetzger], in

[jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric

2017-09-08 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7608: --- Summary: LatencyGauge change to histogram metric Key: FLINK-7608 URL: https://issues.apache.org/jira/browse/FLINK-7608 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7608) LatencyGauge change to histogram metric

2017-09-08 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7608: Description: I used slf4jReporter[https://issues.apache.org/jira/browse/FLINK-4831] to export metrics the

[jira] [Created] (FLINK-7604) Add OpenTSDB metrics reporter

2017-09-08 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7604: --- Summary: Add OpenTSDB metrics reporter Key: FLINK-7604 URL: https://issues.apache.org/jira/browse/FLINK-7604 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-7594) Add a SQL CLI client

2017-09-07 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16156954#comment-16156954 ] Hai Zhou commented on FLINK-7594: - [~wheat9] That sounds great. +1 BTW, If Alibaba and Huawei to share

[jira] [Commented] (FLINK-4831) Implement a slf4j metric reporter

2017-09-05 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153866#comment-16153866 ] Hai Zhou commented on FLINK-4831: - I recently read *dropwizard metric*, i seem to have some ideas. >

[jira] [Assigned] (FLINK-4831) Implement a slf4j metric reporter

2017-09-05 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-4831: --- Assignee: Hai Zhou > Implement a slf4j metric reporter > - > >

[jira] [Commented] (FLINK-7585) SimpleCounter not thread safe

2017-09-05 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153798#comment-16153798 ] Hai Zhou commented on FLINK-7585: - Hi [~Zentol], SimpleCounter is not thread safe. Whether we need to

[jira] [Created] (FLINK-7585) SimpleCounter not thread safe

2017-09-05 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7585: --- Summary: SimpleCounter not thread safe Key: FLINK-7585 URL: https://issues.apache.org/jira/browse/FLINK-7585 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

2017-09-04 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16153060#comment-16153060 ] Hai Zhou commented on FLINK-7573: - Hi [~mingleizhang], Maybe you need to know first: TCP protocol

[jira] [Assigned] (FLINK-3831) flink-streaming-java

2017-09-04 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-3831: --- Assignee: Hai Zhou Environment: Apache Maven 3.3.9, Java version: 1.8.0_144 Description:

[jira] [Created] (FLINK-7577) flink-core

2017-09-04 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7577: --- Summary: flink-core Key: FLINK-7577 URL: https://issues.apache.org/jira/browse/FLINK-7577 Project: Flink Issue Type: Sub-task Components: Build System

[jira] [Assigned] (FLINK-3828) flink-runtime

2017-09-04 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-3828: --- Assignee: Hai Zhou Environment: Apache Maven 3.3.9, Java version: 1.8.0_144 Description:

[jira] [Created] (FLINK-7574) flink-clients

2017-09-04 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7574: --- Summary: flink-clients Key: FLINK-7574 URL: https://issues.apache.org/jira/browse/FLINK-7574 Project: Flink Issue Type: Sub-task Components: Build System

[jira] [Assigned] (FLINK-3827) Flink modules include unused dependencies

2017-09-04 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-3827: --- Assignee: Hai Zhou > Flink modules include unused dependencies >

[jira] [Commented] (FLINK-3827) Flink modules include unused dependencies

2017-09-04 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152285#comment-16152285 ] Hai Zhou commented on FLINK-3827: - Hi [~till.rohrmann], I found via {{mvn dependency:analyze}} that many

[jira] [Commented] (FLINK-3862) Restructure community website

2017-09-03 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16152077#comment-16152077 ] Hai Zhou commented on FLINK-3862: - Hi [~fhue...@gmail.com], Flink IRC channel looks not active, maybe we

[jira] [Assigned] (FLINK-6347) Migrate from Java serialization for MessageAcknowledgingSourceBase's state

2017-09-03 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-6347: --- Assignee: Hai Zhou > Migrate from Java serialization for MessageAcknowledgingSourceBase's state >

[jira] [Assigned] (FLINK-6344) Migrate from Java serialization for BucketingSink's state

2017-09-03 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-6344: --- Assignee: Hai Zhou > Migrate from Java serialization for BucketingSink's state >

[jira] [Commented] (FLINK-4831) Implement a slf4j metric reporter

2017-09-03 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16151947#comment-16151947 ] Hai Zhou commented on FLINK-4831: - Hi [~Zentol], I checked your code, it's very good. but, I do not know

[jira] [Commented] (FLINK-7284) Verify compile time and runtime version of Hadoop

2017-09-03 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16151928#comment-16151928 ] Hai Zhou commented on FLINK-7284: - similar issue: https://issues.apache.org/jira/browse/FLINK-2581 >

[jira] [Commented] (FLINK-7570) Fix broken link on faq page

2017-09-01 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16150915#comment-16150915 ] Hai Zhou commented on FLINK-7570: - PR: https://github.com/apache/flink-web/pull/83 > Fix broken link on

[jira] [Created] (FLINK-7570) Fix broken link on faq page

2017-09-01 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7570: --- Summary: Fix broken link on faq page Key: FLINK-7570 URL: https://issues.apache.org/jira/browse/FLINK-7570 Project: Flink Issue Type: Bug Components:

[jira] [Assigned] (FLINK-5944) Flink should support reading Snappy Files

2017-09-01 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-5944: --- Assignee: (was: Hai Zhou) > Flink should support reading Snappy Files >

[jira] [Assigned] (FLINK-5944) Flink should support reading Snappy Files

2017-09-01 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-5944: --- Assignee: Hai Zhou > Flink should support reading Snappy Files >

[jira] [Created] (FLINK-7562) uploaded jars sort by upload-time on dashboard page

2017-08-30 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7562: --- Summary: uploaded jars sort by upload-time on dashboard page Key: FLINK-7562 URL: https://issues.apache.org/jira/browse/FLINK-7562 Project: Flink Issue Type: Wish

[jira] [Assigned] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

2017-08-30 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-7547: --- Assignee: Hai Zhou > o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable >

[jira] [Updated] (FLINK-7560) Add Reset button for Plan Visualizer Page

2017-08-30 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7560: Description: in http://flink.apache.org/visualizer/ page. I wish add a 'Reset' button at : {code:java}

[jira] [Updated] (FLINK-7560) Add Reset button for Plan Visualizer Page

2017-08-30 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7560: Attachment: screenshot-1.png > Add Reset button for Plan Visualizer Page >

[jira] [Updated] (FLINK-7560) Add Reset button for Plan Visualizer Page

2017-08-30 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7560: Description: in http://flink.apache.org/visualizer/ page. I wish add a 'Reset' button at :

[jira] [Updated] (FLINK-7560) Add Reset button for Plan Visualizer Page

2017-08-30 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7560: Description: in http://flink.apache.org/visualizer/ page. I wish add a 'Reset' button at :

[jira] [Created] (FLINK-7560) Add Reset button for Plan Visualizer Page

2017-08-30 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7560: --- Summary: Add Reset button for Plan Visualizer Page Key: FLINK-7560 URL: https://issues.apache.org/jira/browse/FLINK-7560 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-7559) Typo in flink-quickstart pom.xml

2017-08-30 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7559: --- Summary: Typo in flink-quickstart pom.xml Key: FLINK-7559 URL: https://issues.apache.org/jira/browse/FLINK-7559 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7555) Use flink-shaded-guava-18 to replace guava dependencies

2017-08-29 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7555: --- Summary: Use flink-shaded-guava-18 to replace guava dependencies Key: FLINK-7555 URL: https://issues.apache.org/jira/browse/FLINK-7555 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7555) Use flink-shaded-guava-18 to replace guava dependencies

2017-08-29 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7555: Description: After [#issue FLINK-6982|https://issues.apache.org/jira/browse/FLINK-6982], I still find 40

[jira] [Updated] (FLINK-7555) Use flink-shaded-guava-18 to replace guava dependencies

2017-08-29 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7555: Environment: (was: After [#issue FLINK-6982|https://issues.apache.org/jira/browse/FLINK-6982], I still

[jira] [Closed] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case

2017-08-29 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7297. --- Resolution: Fixed > Instable Kafka09ProducerITCase.testCustomPartitioning test case >

[jira] [Closed] (FLINK-7376) Cleanup options class and test classes in flink-clients

2017-08-29 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7376. --- Resolution: Won't Fix > Cleanup options class and test classes in flink-clients >

[jira] [Assigned] (FLINK-7376) Cleanup options class and test classes in flink-clients

2017-08-29 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-7376: --- Assignee: Hai Zhou > Cleanup options class and test classes in flink-clients >

[jira] [Commented] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

2017-08-29 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16145186#comment-16145186 ] Hai Zhou commented on FLINK-7547: - HI [~elevy]. I will give a PR to fix it. >

[jira] [Assigned] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-08-29 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-7438: --- Assignee: Hai Zhou > Some classes are eclipsed by classes in package scala >

[jira] [Assigned] (FLINK-6860) update Apache Beam in page Ecosystem

2017-08-28 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-6860: --- Assignee: Hai Zhou > update Apache Beam in page Ecosystem > > >

[jira] [Updated] (FLINK-7537) Add InfluxDB Sink for Flink Streaming

2017-08-26 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7537: Description: InfluxDBSink via implementation RichSinkFunction.

[jira] [Closed] (FLINK-7538) Add InfluxDB Sink for Flink Streaming

2017-08-26 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7538. --- Resolution: Invalid > Add InfluxDB Sink for Flink Streaming > - > >

[jira] [Created] (FLINK-7538) Add InfluxDB Sink for Flink Streaming

2017-08-26 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7538: --- Summary: Add InfluxDB Sink for Flink Streaming Key: FLINK-7538 URL: https://issues.apache.org/jira/browse/FLINK-7538 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-7537) Add InfluxDB Sink for Flink Streaming

2017-08-26 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7537: --- Summary: Add InfluxDB Sink for Flink Streaming Key: FLINK-7537 URL: https://issues.apache.org/jira/browse/FLINK-7537 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-7536) Add MongoDB Source/Sink for Flink Streaming

2017-08-26 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7536: --- Summary: Add MongoDB Source/Sink for Flink Streaming Key: FLINK-7536 URL: https://issues.apache.org/jira/browse/FLINK-7536 Project: Flink Issue Type: Wish

[jira] [Updated] (FLINK-7510) Move some connectors to Apache Bahir

2017-08-25 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7510: Description: Hi Flink community: Flink is really a great stream processing framework, provides a number of

[jira] [Updated] (FLINK-7510) Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink

2017-08-25 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7510: Description: * flink-connectors *flink-connectors/flink-connector-twitter* &

[jira] [Created] (FLINK-7510) Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink

2017-08-25 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7510: --- Summary: Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink Key: FLINK-7510 URL: https://issues.apache.org/jira/browse/FLINK-7510 Project: Flink

[jira] [Updated] (FLINK-7510) Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink

2017-08-25 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7510: Description: * flink-connectors *flink-connectors/flink-connector-twitter* & *

[jira] [Created] (FLINK-7494) No license headers in ".travis.yml" file

2017-08-23 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7494: --- Summary: No license headers in ".travis.yml" file Key: FLINK-7494 URL: https://issues.apache.org/jira/browse/FLINK-7494 Project: Flink Issue Type: Wish

[jira] [Commented] (FLINK-4422) Convert all time interval measurements to System.nanoTime()

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16136194#comment-16136194 ] Hai Zhou commented on FLINK-4422: - Hi [~StephanEwen], This is still a issue? If yes, I would like to work

[jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135084#comment-16135084 ] Hai Zhou commented on FLINK-7438: - Hi [~aljoscha] I would like to work on this issue.:D > Some classes

[jira] [Comment Edited] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135076#comment-16135076 ] Hai Zhou edited comment on FLINK-7438 at 8/21/17 12:01 PM: --- I think the reason

[jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135076#comment-16135076 ] Hai Zhou commented on FLINK-7438: - I think the reason for this problem is

[jira] [Commented] (FLINK-7484) com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 5

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16135046#comment-16135046 ] Hai Zhou commented on FLINK-7484: - Hi [~shashank734] Can you upload your code? >

[jira] [Closed] (FLINK-7382) Broken links in `Apache Flink Documentation` page

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou closed FLINK-7382. --- > Broken links in `Apache Flink Documentation` page > -- > >

[jira] [Assigned] (FLINK-7382) Broken links in `Apache Flink Documentation` page

2017-08-21 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou reassigned FLINK-7382: --- Assignee: Hai Zhou > Broken links in `Apache Flink Documentation` page >

[jira] [Commented] (FLINK-7447) Hope add more committer information to "Community & Project Info" page.

2017-08-16 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128502#comment-16128502 ] Hai Zhou commented on FLINK-7447: - [~Zentol] >From the standpoint of the contributor, I still think that

[jira] [Comment Edited] (FLINK-7447) Hope add more committer information to "Community & Project Info" page.

2017-08-16 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128409#comment-16128409 ] Hai Zhou edited comment on FLINK-7447 at 8/16/17 6:47 AM: -- @gregho It benefits

[jira] [Commented] (FLINK-7447) Hope add more committer information to "Community & Project Info" page.

2017-08-16 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128409#comment-16128409 ] Hai Zhou commented on FLINK-7447: - @gregho It benefits the contributor easy to contact the committer to

  1   2   >