[DISCUSS] Standard / Convention for common connector metrics

2019-01-30 Thread Becket Qin
Hi folks, I was trying to add some metrics to Kafka connectors and realized that right now Flink does not have a common metric definition for the connectors. This complicates the monitoring and operation because the monitoring / alerts need to be set case by case. To address this issue, I would l

[jira] [Created] (FLINK-11485) Migrate PojoSerializer to use new serialization compatibility abstractions

2019-01-30 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-11485: --- Summary: Migrate PojoSerializer to use new serialization compatibility abstractions Key: FLINK-11485 URL: https://issues.apache.org/jira/browse/FLINK-11485

[jira] [Created] (FLINK-11484) Blink java.util.concurrent.TimeoutException

2019-01-30 Thread pj (JIRA)
pj created FLINK-11484: -- Summary: Blink java.util.concurrent.TimeoutException Key: FLINK-11484 URL: https://issues.apache.org/jira/browse/FLINK-11484 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-11483) Improve StreamOperatorSnapshotRestoreTest with Parameterized

2019-01-30 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11483: Summary: Improve StreamOperatorSnapshotRestoreTest with Parameterized Key: FLINK-11483 URL: https://issues.apache.org/jira/browse/FLINK-11483 Project: Flink

[jira] [Created] (FLINK-11482) Implement GenericHiveMetastoreCatalog

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11482: --- Summary: Implement GenericHiveMetastoreCatalog Key: FLINK-11482 URL: https://issues.apache.org/jira/browse/FLINK-11482 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11481) Integrate HiveTableFactory with existing table factory discovery mechanism

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11481: --- Summary: Integrate HiveTableFactory with existing table factory discovery mechanism Key: FLINK-11481 URL: https://issues.apache.org/jira/browse/FLINK-11481 Project: Fli

[jira] [Created] (FLINK-11480) Create HiveTableFactory that creates TableSource/Sink from a Hive table

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11480: --- Summary: Create HiveTableFactory that creates TableSource/Sink from a Hive table Key: FLINK-11480 URL: https://issues.apache.org/jira/browse/FLINK-11480 Project: Flink

[jira] [Created] (FLINK-11479) Implement HiveCatalog

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11479: --- Summary: Implement HiveCatalog Key: FLINK-11479 URL: https://issues.apache.org/jira/browse/FLINK-11479 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-11478) Handle existing table registration via YAML file in the context of catalog support

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11478: --- Summary: Handle existing table registration via YAML file in the context of catalog support Key: FLINK-11478 URL: https://issues.apache.org/jira/browse/FLINK-11478 Proj

[jira] [Created] (FLINK-11477) Define catalog entries in SQL client YAML file and handle the creation and registration of those entries

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11477: --- Summary: Define catalog entries in SQL client YAML file and handle the creation and registration of those entries Key: FLINK-11477 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Created] (FLINK-11476) Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11476: --- Summary: Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema Key: FLINK-11476 URL: https://issues.apache.org/jira/browse/FLINK-11476 Projec

[jira] [Created] (FLINK-11475) Adapt existing InMemoryExternalCatalog to GenericInMemoryCatalog

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11475: --- Summary: Adapt existing InMemoryExternalCatalog to GenericInMemoryCatalog Key: FLINK-11475 URL: https://issues.apache.org/jira/browse/FLINK-11475 Project: Flink

[jira] [Created] (FLINK-11474) Add ReadableCatalog, ReadableWritableCatalog, and other related interfaces

2019-01-30 Thread Xuefu Zhang (JIRA)
Xuefu Zhang created FLINK-11474: --- Summary: Add ReadableCatalog, ReadableWritableCatalog, and other related interfaces Key: FLINK-11474 URL: https://issues.apache.org/jira/browse/FLINK-11474 Project: Fli

[jira] [Created] (FLINK-11473) Clarify Documenation on Latency Markers

2019-01-30 Thread Konstantin Knauf (JIRA)
Konstantin Knauf created FLINK-11473: Summary: Clarify Documenation on Latency Markers Key: FLINK-11473 URL: https://issues.apache.org/jira/browse/FLINK-11473 Project: Flink Issue Type: I

[jira] [Created] (FLINK-11472) KafkaITCase.testCancelingEmptyTopic failed on Travis

2019-01-30 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11472: - Summary: KafkaITCase.testCancelingEmptyTopic failed on Travis Key: FLINK-11472 URL: https://issues.apache.org/jira/browse/FLINK-11472 Project: Flink Issue

[jira] [Created] (FLINK-11471) Job is reported RUNNING prematurely for queued scheduling

2019-01-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11471: --- Summary: Job is reported RUNNING prematurely for queued scheduling Key: FLINK-11471 URL: https://issues.apache.org/jira/browse/FLINK-11471 Project: Flink Issue

[jira] [Created] (FLINK-11470) LocalEnvironment doesn't call FileSystem.initialize()

2019-01-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11470: --- Summary: LocalEnvironment doesn't call FileSystem.initialize() Key: FLINK-11470 URL: https://issues.apache.org/jira/browse/FLINK-11470 Project: Flink Issue Typ

[jira] [Created] (FLINK-11469) fix Tuning Checkpoints and Large State doc

2019-01-30 Thread shengjk1 (JIRA)
shengjk1 created FLINK-11469: Summary: fix Tuning Checkpoints and Large State doc Key: FLINK-11469 URL: https://issues.apache.org/jira/browse/FLINK-11469 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-11466) Implement LocalStandaloneKafkaResource

2019-01-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11466: Summary: Implement LocalStandaloneKafkaResource Key: FLINK-11466 URL: https://issues.apache.org/jira/browse/FLINK-11466 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-11467) Port Kafka Streaming end-to-end test

2019-01-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11467: Summary: Port Kafka Streaming end-to-end test Key: FLINK-11467 URL: https://issues.apache.org/jira/browse/FLINK-11467 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-11464) Implement DownloadCache

2019-01-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11464: Summary: Implement DownloadCache Key: FLINK-11464 URL: https://issues.apache.org/jira/browse/FLINK-11464 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11463) Rework end-to-end tests in Java

2019-01-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11463: Summary: Rework end-to-end tests in Java Key: FLINK-11463 URL: https://issues.apache.org/jira/browse/FLINK-11463 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-11468) Setup jUnit categories

2019-01-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11468: Summary: Setup jUnit categories Key: FLINK-11468 URL: https://issues.apache.org/jira/browse/FLINK-11468 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11465) Implement LocalStandaloneFlinkResource

2019-01-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-11465: Summary: Implement LocalStandaloneFlinkResource Key: FLINK-11465 URL: https://issues.apache.org/jira/browse/FLINK-11465 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-11462) "Powered by Flink" page does not display correctly on Firefox

2019-01-30 Thread Patrick Lucas (JIRA)
Patrick Lucas created FLINK-11462: - Summary: "Powered by Flink" page does not display correctly on Firefox Key: FLINK-11462 URL: https://issues.apache.org/jira/browse/FLINK-11462 Project: Flink

[jira] [Created] (FLINK-11461) Remove useless MockRecordWriter

2019-01-30 Thread zhijiang (JIRA)
zhijiang created FLINK-11461: Summary: Remove useless MockRecordWriter Key: FLINK-11461 URL: https://issues.apache.org/jira/browse/FLINK-11461 Project: Flink Issue Type: Task Components