[GitHub] tillrohrmann commented on a change in pull request #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base

tillrohrmann commented on a change in pull request #7524: [FLINK-11351][tests] Port JobManagerCleanupITCase to new code base URL: https://github.com/apache/flink/pull/7524#discussion_r250190914 ## File path:

[jira] [Commented] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749952#comment-16749952 ] Till Rohrmann commented on FLINK-11380: --- Another instance:

[jira] [Updated] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-10707: --- Component/s: Webfrontend > Improve Cluster Overview in Flink Dashboard >

[jira] [Updated] (FLINK-11389) Incorrectly use job information when call getSerializedTaskInformation in class TaskDeploymentDescriptor

[ https://issues.apache.org/jira/browse/FLINK-11389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11389: --- Component/s: Distributed Coordination > Incorrectly use job information when call

[jira] [Commented] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

[ https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749907#comment-16749907 ] Elias Levy commented on FLINK-11249: I believe that the open transactions are maintained.  The

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

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanxiaobin updated FLINK-8500: -- Summary: Get the timestamp of the Kafka message from kafka consumer (was: Get the timestamp of the

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

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749861#comment-16749861 ] yanxiaobin commented on FLINK-8500: --- I have changed the title. > Get the timestamp of the Kafka

[GitHub] libenchao opened a new pull request #7569: [hotfix] [javadocs] fix typo in JobManagerRunner

libenchao opened a new pull request #7569: [hotfix] [javadocs] fix typo in JobManagerRunner URL: https://github.com/apache/flink/pull/7569 Fix Typo in JobManagerRunner. This is an automated message from the Apache Git

[GitHub] hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-456771220 @pnowojski Thanks again for the suggestions. I have updated the pr and rebased to the master. Thank you.

[GitHub] NicoK commented on issue #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

NicoK commented on issue #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#issuecomment-456762259 FYI: I rebased the proposed changes to `master` (squashing some fixups) and adapted the commits

[jira] [Updated] (FLINK-11417) Make access to ExecutionGraph single threaded from JobMaster main thread

[ https://issues.apache.org/jira/browse/FLINK-11417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11417: --- Labels: pull-request-available (was: ) > Make access to ExecutionGraph single threaded

[GitHub] StefanRRichter opened a new pull request #7568: [FLINK-11417] Make access to ExecutionGraph single threaded from JobMaster main thread

StefanRRichter opened a new pull request #7568: [FLINK-11417] Make access to ExecutionGraph single threaded from JobMaster main thread URL: https://github.com/apache/flink/pull/7568 ## What is the purpose of the change The PR makes the interaction/modifiations to the

[jira] [Created] (FLINK-11417) Make access to ExecutionGraph single threaded from JobMaster main thread

Stefan Richter created FLINK-11417: -- Summary: Make access to ExecutionGraph single threaded from JobMaster main thread Key: FLINK-11417 URL: https://issues.apache.org/jira/browse/FLINK-11417

[jira] [Commented] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749776#comment-16749776 ] Congxian Qiu commented on FLINK-11352: -- Hi, [~till.rohrmann]  I did not find any existing test case

[jira] [Comment Edited] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749776#comment-16749776 ] Congxian Qiu edited comment on FLINK-11352 at 1/23/19 10:26 AM: Hi,

[jira] [Comment Edited] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749776#comment-16749776 ] Congxian Qiu edited comment on FLINK-11352 at 1/23/19 10:25 AM: Hi,

[jira] [Updated] (FLINK-11413) Reporter filtering using "metrics.reporters" broken on Java 9+

[ https://issues.apache.org/jira/browse/FLINK-11413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11413: - Fix Version/s: 1.8.0 1.7.2 1.6.4 > Reporter

[jira] [Commented] (FLINK-11413) Reporter filtering using "metrics.reporters" broken on Java 9+

[ https://issues.apache.org/jira/browse/FLINK-11413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749775#comment-16749775 ] Chesnay Schepler commented on FLINK-11413: -- JDK reference:

[jira] [Assigned] (FLINK-11413) Reporter filtering using "metrics.reporters" broken on Java 9+

[ https://issues.apache.org/jira/browse/FLINK-11413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11413: Assignee: Matthieu Bonneviot > Reporter filtering using "metrics.reporters"

[jira] [Updated] (FLINK-11413) Reporter filtering using "metrics.reporters" broken on Java 9+

[ https://issues.apache.org/jira/browse/FLINK-11413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11413: - Summary: Reporter filtering using "metrics.reporters" broken on Java 9+ (was:

[jira] [Updated] (FLINK-11413) MetricReporter: "metrics.reporters" configuration has to be provided for reporters to be taken into account

[ https://issues.apache.org/jira/browse/FLINK-11413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11413: - Issue Type: Sub-task (was: Bug) Parent: FLINK-8033 > MetricReporter:

[jira] [Updated] (FLINK-11413) MetricReporter: "metrics.reporters" configuration has to be provided for reporters to be taken into account

[ https://issues.apache.org/jira/browse/FLINK-11413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11413: - Component/s: Metrics > MetricReporter: "metrics.reporters" configuration has to be

[jira] [Updated] (FLINK-11413) MetricReporter: "metrics.reporters" configuration has to be provided for reporters to be taken into account

[ https://issues.apache.org/jira/browse/FLINK-11413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11413: - Affects Version/s: 1.6.3 > MetricReporter: "metrics.reporters" configuration has to be

[jira] [Created] (FLINK-11416) DISTINCT on a JOIN inside of an UNION is not working

Elias Saalmann created FLINK-11416: -- Summary: DISTINCT on a JOIN inside of an UNION is not working Key: FLINK-11416 URL: https://issues.apache.org/jira/browse/FLINK-11416 Project: Flink

[jira] [Updated] (FLINK-11358) Check and port LeaderChangeStateCleanupTest to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11358: --- Labels: pull-request-available (was: ) > Check and port LeaderChangeStateCleanupTest to

[GitHub] Fokko commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic

Fokko commented on issue #7487: [FLINK-11321] Clarify NPE on fetching nonexistent topic URL: https://github.com/apache/flink/pull/7487#issuecomment-456743169 @tzulitai Any further thoughts? This is an automated message from

[GitHub] Fokko commented on issue #7488: [FLINK-11322] Use try-with-resource on FlinkKafkaConsumer010

Fokko commented on issue #7488: [FLINK-11322] Use try-with-resource on FlinkKafkaConsumer010 URL: https://github.com/apache/flink/pull/7488#issuecomment-456743048 @tzulitai thoughts? This is an automated message from the

[GitHub] Fokko commented on issue #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink

Fokko commented on issue #7508: [hotfix][docs] Add example for the BulkFormat of the StreamingFileSink URL: https://github.com/apache/flink/pull/7508#issuecomment-456742540 @dawidwys any thoughts? This is an automated

[jira] [Commented] (FLINK-11401) Allow compression on ParquetBulkWriter

[ https://issues.apache.org/jira/browse/FLINK-11401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749744#comment-16749744 ] Fokko Driesprong commented on FLINK-11401: -- Thanks for the comment [~StephanEwen] The

[GitHub] zhijiangW commented on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition

zhijiangW commented on issue #7549: [FLINK-11403][network] Remove ResultPartitionConsumableNotifier from ResultPartition URL: https://github.com/apache/flink/pull/7549#issuecomment-456741456 FYI, next I would remove `owningTaskName`, `JobID` and `TaskActions` from the constructor of

[GitHub] tillrohrmann opened a new pull request #7567: [FLINK-11358][tests] Port LeaderChangeStateCleanupTest to new code base

tillrohrmann opened a new pull request #7567: [FLINK-11358][tests] Port LeaderChangeStateCleanupTest to new code base URL: https://github.com/apache/flink/pull/7567 ## What is the purpose of the change This commit pots the LeaderChangeStateCleanupTest to the new code base. The new

[jira] [Updated] (FLINK-11415) Introduce JobMasterServiceFactor for JobManagerRunner

[ https://issues.apache.org/jira/browse/FLINK-11415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11415: --- Labels: pull-request-available (was: ) > Introduce JobMasterServiceFactor for

[GitHub] dawidwys commented on issue #7566: [FLINK-11328][core] Migrate NFAStateSerializer to new TypeSerializer interface

dawidwys commented on issue #7566: [FLINK-11328][core] Migrate NFAStateSerializer to new TypeSerializer interface URL: https://github.com/apache/flink/pull/7566#issuecomment-456740632 Hi @tzulitai @igalshilman could you have a look?

[GitHub] dawidwys opened a new pull request #7566: [FLINK-11328][core] Migrate NFAStateSerializer to new TypeSerializer interface

dawidwys opened a new pull request #7566: [FLINK-11328][core] Migrate NFAStateSerializer to new TypeSerializer interface URL: https://github.com/apache/flink/pull/7566 ## What is the purpose of the change This PR adds `NFAStateSerializerSnapshot` corresponding to

[jira] [Updated] (FLINK-11400) JobManagerRunner does not wait for suspension of JobMaster

[ https://issues.apache.org/jira/browse/FLINK-11400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11400: --- Labels: pull-request-available (was: ) > JobManagerRunner does not wait for suspension of

[GitHub] tillrohrmann opened a new pull request #7565: [FLINK-11400] Linearize leadership operations in JobManagerRunner

tillrohrmann opened a new pull request #7565: [FLINK-11400] Linearize leadership operations in JobManagerRunner URL: https://github.com/apache/flink/pull/7565 ## What is the purpose of the change Introduce a leadershipOperation future in the JobManagerRunner. This future is

[GitHub] tillrohrmann opened a new pull request #7564: [FLINK-11415] Introduce JobMasterServiceFactory

tillrohrmann opened a new pull request #7564: [FLINK-11415] Introduce JobMasterServiceFactory URL: https://github.com/apache/flink/pull/7564 ## What is the purpose of the change The JobMasterServiceFactory controls how the JobMasterService is constructed by the JobManagerRunner.

[jira] [Created] (FLINK-11415) Introduce JobMasterServiceFactor for JobManagerRunner

Till Rohrmann created FLINK-11415: - Summary: Introduce JobMasterServiceFactor for JobManagerRunner Key: FLINK-11415 URL: https://issues.apache.org/jira/browse/FLINK-11415 Project: Flink

[jira] [Updated] (FLINK-11414) Introduce JobMasterService interface for the JobManagerRunner

[ https://issues.apache.org/jira/browse/FLINK-11414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11414: --- Labels: pull-request-available (was: ) > Introduce JobMasterService interface for the

[GitHub] tillrohrmann opened a new pull request #7563: [FLINK-11414] Introduce JobMasterService interface

tillrohrmann opened a new pull request #7563: [FLINK-11414] Introduce JobMasterService interface URL: https://github.com/apache/flink/pull/7563 ## What is the purpose of the change For a better separation of concerns in the JobManagerRunner, this commit introduces a

[jira] [Created] (FLINK-11414) Introduce JobMasterService interface for the JobManagerRunner

Till Rohrmann created FLINK-11414: - Summary: Introduce JobMasterService interface for the JobManagerRunner Key: FLINK-11414 URL: https://issues.apache.org/jira/browse/FLINK-11414 Project: Flink

[jira] [Closed] (FLINK-11328) Migrate all parameterless serializers / TypeSerializerSingleton's to use new serializer snapshot abstractions

[ https://issues.apache.org/jira/browse/FLINK-11328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-11328. --- Resolution: Fixed > Migrate all parameterless serializers /

[jira] [Commented] (FLINK-11328) Migrate all parameterless serializers / TypeSerializerSingleton's to use new serializer snapshot abstractions

[ https://issues.apache.org/jira/browse/FLINK-11328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749722#comment-16749722 ] Tzu-Li (Gordon) Tai commented on FLINK-11328: - Merged for 1.8.0:

[GitHub] hequn8128 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

hequn8128 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r250115847 ## File path:

[GitHub] hequn8128 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

hequn8128 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r250115350 ## File path:

[GitHub] igalshilman commented on a change in pull request #7562: [FLINK-11329][core] Migrate CRowSerializerConfigSnapshot to new TypeSerializerSnapshot interface

igalshilman commented on a change in pull request #7562: [FLINK-11329][core] Migrate CRowSerializerConfigSnapshot to new TypeSerializerSnapshot interface URL: https://github.com/apache/flink/pull/7562#discussion_r250113361 ## File path:

[jira] [Updated] (FLINK-11390) Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base

[ https://issues.apache.org/jira/browse/FLINK-11390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11390: --- Component/s: YARN > Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new

[GitHub] asfgit closed pull request #7553: [FLINK-11328] [core] Migrate all parameterless serializers to use new serialization compatibility API

asfgit closed pull request #7553: [FLINK-11328] [core] Migrate all parameterless serializers to use new serialization compatibility API URL: https://github.com/apache/flink/pull/7553 This is an automated message from the

[jira] [Updated] (FLINK-11394) Job UI is not rendered in case of slow back-end

[ https://issues.apache.org/jira/browse/FLINK-11394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11394: --- Component/s: Webfrontend > Job UI is not rendered in case of slow back-end >

[jira] [Updated] (FLINK-11401) Allow compression on ParquetBulkWriter

[ https://issues.apache.org/jira/browse/FLINK-11401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11401: --- Component/s: Batch Connectors and Input/Output Formats > Allow compression on

[jira] [Updated] (FLINK-11396) MetricStore creates significant GC pressure

[ https://issues.apache.org/jira/browse/FLINK-11396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11396: --- Component/s: Metrics > MetricStore creates significant GC pressure >

[jira] [Updated] (FLINK-11408) ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge

[ https://issues.apache.org/jira/browse/FLINK-11408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11408: --- Component/s: DataStream API > ContinuousProcessingTimeTrigger: NPE on clear() and state is

[GitHub] azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r250110054 ## File path:

[GitHub] tzulitai commented on issue #7553: [FLINK-11328] [core] Migrate all parameterless serializers to use new serialization compatibility API

tzulitai commented on issue #7553: [FLINK-11328] [core] Migrate all parameterless serializers to use new serialization compatibility API URL: https://github.com/apache/flink/pull/7553#issuecomment-456727820 Merging ... This

[jira] [Updated] (FLINK-11409) Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces

[ https://issues.apache.org/jira/browse/FLINK-11409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11409: --- Component/s: DataStream API > Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure

[jira] [Updated] (FLINK-11411) Failover regions number of RestartPipelinedRegionStrategy not show in LOG due to incorrect parameter

[ https://issues.apache.org/jira/browse/FLINK-11411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11411: --- Component/s: Scheduler Distributed Coordination > Failover regions number

[jira] [Updated] (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 ] Robert Metzger updated FLINK-11022: --- Component/s: Build System > Update LICENSE and NOTICE files for older releases >

[GitHub] dawidwys commented on issue #7562: [FLINK-11329][core] Migrate CRowSerializerConfigSnapshot to new TypeSerializerSnapshot interface

dawidwys commented on issue #7562: [FLINK-11329][core] Migrate CRowSerializerConfigSnapshot to new TypeSerializerSnapshot interface URL: https://github.com/apache/flink/pull/7562#issuecomment-456722994 @tzulitai @igalshilman Could you have a look?

[jira] [Updated] (FLINK-11329) Migrate all remaining composite serializers to use new serializer snapshot abstraction

[ https://issues.apache.org/jira/browse/FLINK-11329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11329: --- Labels: pull-request-available (was: ) > Migrate all remaining composite serializers to

[GitHub] dawidwys opened a new pull request #7562: [FLINK-11329][core] Migrate CRowSerializerConfigSnapshot to new TypeSerializerSnapshot interface

dawidwys opened a new pull request #7562: [FLINK-11329][core] Migrate CRowSerializerConfigSnapshot to new TypeSerializerSnapshot interface URL: https://github.com/apache/flink/pull/7562 ## What is the purpose of the change This PR migrates `CRowSerializerConfigSnapshot` to the new

[GitHub] fhueske commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template.

fhueske commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#discussion_r250102149 ## File path: .github/PULL_REQUEST_TEMPLATE.md ## @@ -70,3 +70,15 @@ This change

[GitHub] NicoK commented on issue #7445: [FLINK-11154][network] bump Netty to 4.1.32

NicoK commented on issue #7445: [FLINK-11154][network] bump Netty to 4.1.32 URL: https://github.com/apache/flink/pull/7445#issuecomment-456717099 @zhijiangW can you also have a quick look and verify that this upgrade is not interrupting anything?

[jira] [Created] (FLINK-11413) MetricReporter: "metrics.reporters" configuration has to be provided for reporters to be taken into account

Matthieu Bonneviot created FLINK-11413: -- Summary: MetricReporter: "metrics.reporters" configuration has to be provided for reporters to be taken into account Key: FLINK-11413 URL:

[GitHub] GJL commented on issue #7529: [hotfix] [blob] Generalize usage of NoOpTransientBlobService

GJL commented on issue #7529: [hotfix] [blob] Generalize usage of NoOpTransientBlobService URL: https://github.com/apache/flink/pull/7529#issuecomment-456709001 #7528 is about util classes, not singletons. A singleton instance needs to be instantiated. A util class is is a set of static

[jira] [Created] (FLINK-11412) Remove legacy MesosFlinkResourceManager

TisonKun created FLINK-11412: Summary: Remove legacy MesosFlinkResourceManager Key: FLINK-11412 URL: https://issues.apache.org/jira/browse/FLINK-11412 Project: Flink Issue Type: Sub-task

<    1   2