[jira] [Created] (FLINK-6313) Some words was spelled wrong and incorrect LOG.error without print

mingleizhang created FLINK-6313: --- Summary: Some words was spelled wrong and incorrect LOG.error without print Key: FLINK-6313 URL: https://issues.apache.org/jira/browse/FLINK-6313 Project: Flink

[jira] [Created] (FLINK-6351) Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

mingleizhang created FLINK-6351: --- Summary: Refactoring YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class Key: FLINK-6351 URL:

[jira] [Created] (FLINK-7302) Failed to run CorrelateITCase class under windows environment

mingleizhang created FLINK-7302: --- Summary: Failed to run CorrelateITCase class under windows environment Key: FLINK-7302 URL: https://issues.apache.org/jira/browse/FLINK-7302 Project: Flink

[jira] [Created] (FLINK-7162) Tests should not write outside 'target' directory.

mingleizhang created FLINK-7162: --- Summary: Tests should not write outside 'target' directory. Key: FLINK-7162 URL: https://issues.apache.org/jira/browse/FLINK-7162 Project: Flink Issue Type:

[jira] [Created] (FLINK-7139) Refine currentTimeMillis to nanoTime

mingleizhang created FLINK-7139: --- Summary: Refine currentTimeMillis to nanoTime Key: FLINK-7139 URL: https://issues.apache.org/jira/browse/FLINK-7139 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7134) Remove hadoop1.x code in mapreduce.utils.HadoopUtils

mingleizhang created FLINK-7134: --- Summary: Remove hadoop1.x code in mapreduce.utils.HadoopUtils Key: FLINK-7134 URL: https://issues.apache.org/jira/browse/FLINK-7134 Project: Flink Issue Type:

[jira] [Created] (FLINK-7094) Update outdated doc release 1.2 to latest stable release 1.3

mingleizhang created FLINK-7094: --- Summary: Update outdated doc release 1.2 to latest stable release 1.3 Key: FLINK-7094 URL: https://issues.apache.org/jira/browse/FLINK-7094 Project: Flink

[jira] [Created] (FLINK-7104) AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call

mingleizhang created FLINK-7104: --- Summary: AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call Key: FLINK-7104 URL: https://issues.apache.org/jira/browse/FLINK-7104

[jira] [Created] (FLINK-7114) Remove the hardcoded way in flink

mingleizhang created FLINK-7114: --- Summary: Remove the hardcoded way in flink Key: FLINK-7114 URL: https://issues.apache.org/jira/browse/FLINK-7114 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7121) Remove the hardcoded way in core

mingleizhang created FLINK-7121: --- Summary: Remove the hardcoded way in core Key: FLINK-7121 URL: https://issues.apache.org/jira/browse/FLINK-7121 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7118) Remove hadoop1.x code in HadoopUtils

mingleizhang created FLINK-7118: --- Summary: Remove hadoop1.x code in HadoopUtils Key: FLINK-7118 URL: https://issues.apache.org/jira/browse/FLINK-7118 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7120) Remove the hardcoded way in Utils

mingleizhang created FLINK-7120: --- Summary: Remove the hardcoded way in Utils Key: FLINK-7120 URL: https://issues.apache.org/jira/browse/FLINK-7120 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7119) Remove the hardcoded way in HadoopUtils

mingleizhang created FLINK-7119: --- Summary: Remove the hardcoded way in HadoopUtils Key: FLINK-7119 URL: https://issues.apache.org/jira/browse/FLINK-7119 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

mingleizhang created FLINK-6381: --- Summary: Unnecessary synchronizing object in BucketingSink Key: FLINK-6381 URL: https://issues.apache.org/jira/browse/FLINK-6381 Project: Flink Issue Type:

[jira] [Created] (FLINK-6991) Inaccessible link under Gelly document

mingleizhang created FLINK-6991: --- Summary: Inaccessible link under Gelly document Key: FLINK-6991 URL: https://issues.apache.org/jira/browse/FLINK-6991 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6934) Consider moving LRUCache class

mingleizhang created FLINK-6934: --- Summary: Consider moving LRUCache class Key: FLINK-6934 URL: https://issues.apache.org/jira/browse/FLINK-6934 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6932) Update the inaccessible Dataflow Model paper link

mingleizhang created FLINK-6932: --- Summary: Update the inaccessible Dataflow Model paper link Key: FLINK-6932 URL: https://issues.apache.org/jira/browse/FLINK-6932 Project: Flink Issue Type:

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

mingleizhang created FLINK-7573: --- Summary: Introduce Http protocol connector for Elasticsearch2 Key: FLINK-7573 URL: https://issues.apache.org/jira/browse/FLINK-7573 Project: Flink Issue Type:

[jira] [Created] (FLINK-8199) Annotation for Elasticsearch connector

mingleizhang created FLINK-8199: --- Summary: Annotation for Elasticsearch connector Key: FLINK-8199 URL: https://issues.apache.org/jira/browse/FLINK-8199 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8276) Annotation for Kafka connector

mingleizhang created FLINK-8276: --- Summary: Annotation for Kafka connector Key: FLINK-8276 URL: https://issues.apache.org/jira/browse/FLINK-8276 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9411) Support parquet rolling sink writer

mingleizhang created FLINK-9411: --- Summary: Support parquet rolling sink writer Key: FLINK-9411 URL: https://issues.apache.org/jira/browse/FLINK-9411 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9609) Add bucket ready notification mechanism for BucketingSink when checkpoint complete

mingleizhang created FLINK-9609: --- Summary: Add bucket ready notification mechanism for BucketingSink when checkpoint complete Key: FLINK-9609 URL: https://issues.apache.org/jira/browse/FLINK-9609

[jira] [Created] (FLINK-9605) Support KafkaProtoBufTableSink

mingleizhang created FLINK-9605: --- Summary: Support KafkaProtoBufTableSink Key: FLINK-9605 URL: https://issues.apache.org/jira/browse/FLINK-9605 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9606) Support ParquetTableSource

mingleizhang created FLINK-9606: --- Summary: Support ParquetTableSource Key: FLINK-9606 URL: https://issues.apache.org/jira/browse/FLINK-9606 Project: Flink Issue Type: New Feature

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

mingleizhang created FLINK-9607: --- Summary: Support ParquetTableSink Key: FLINK-9607 URL: https://issues.apache.org/jira/browse/FLINK-9607 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9604) Support KafkaProtoBufTableSource

mingleizhang created FLINK-9604: --- Summary: Support KafkaProtoBufTableSource Key: FLINK-9604 URL: https://issues.apache.org/jira/browse/FLINK-9604 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9650) Support Protocol Buffers formats

mingleizhang created FLINK-9650: --- Summary: Support Protocol Buffers formats Key: FLINK-9650 URL: https://issues.apache.org/jira/browse/FLINK-9650 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9651) Add a Kafka table source factory with Protobuf format support

mingleizhang created FLINK-9651: --- Summary: Add a Kafka table source factory with Protobuf format support Key: FLINK-9651 URL: https://issues.apache.org/jira/browse/FLINK-9651 Project: Flink

[jira] [Created] (FLINK-9614) Improve the error message for Compiler#compile

mingleizhang created FLINK-9614: --- Summary: Improve the error message for Compiler#compile Key: FLINK-9614 URL: https://issues.apache.org/jira/browse/FLINK-9614 Project: Flink Issue Type:

[jira] [Created] (FLINK-8907) Unable to start the process by start-cluster.sh

mingleizhang created FLINK-8907: --- Summary: Unable to start the process by start-cluster.sh Key: FLINK-8907 URL: https://issues.apache.org/jira/browse/FLINK-8907 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable

mingleizhang created FLINK-9230: --- Summary: WebFrontendITCase.testStopYarn is unstable Key: FLINK-9230 URL: https://issues.apache.org/jira/browse/FLINK-9230 Project: Flink Issue Type:

[jira] [Created] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh

mingleizhang created FLINK-9224: --- Summary: Add Bucketing e2e test script to run-pre-commit-tests.sh Key: FLINK-9224 URL: https://issues.apache.org/jira/browse/FLINK-9224 Project: Flink Issue

[jira] [Created] (FLINK-9226) Add Bucketing e2e test script to run-nightly-tests.sh

mingleizhang created FLINK-9226: --- Summary: Add Bucketing e2e test script to run-nightly-tests.sh Key: FLINK-9226 URL: https://issues.apache.org/jira/browse/FLINK-9226 Project: Flink Issue

[jira] [Created] (FLINK-9092) End to end test for elasticsearch2.x

mingleizhang created FLINK-9092: --- Summary: End to end test for elasticsearch2.x Key: FLINK-9092 URL: https://issues.apache.org/jira/browse/FLINK-9092 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-9625) Enrich the error information to user

mingleizhang created FLINK-9625: --- Summary: Enrich the error information to user Key: FLINK-9625 URL: https://issues.apache.org/jira/browse/FLINK-9625 Project: Flink Issue Type: Improvement