[jira] [Updated] (FLINK-11459) Presto S3 does not show errors due to missing credentials with minio

[ https://issues.apache.org/jira/browse/FLINK-11459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11459: Description: It seems that when using minio for S3-like storage and with mis-configurations such

[jira] [Closed] (FLINK-11266) Only release hadoop-free Flink

[ https://issues.apache.org/jira/browse/FLINK-11266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11266. Resolution: Fixed Release Note: Convenience binaries that include hadoop are no

[GitHub] GJL commented on a change in pull request #7525: [FLINK-11363][test] Check and remove TaskManagerConfigurationTest

GJL commented on a change in pull request #7525: [FLINK-11363][test] Check and remove TaskManagerConfigurationTest URL: https://github.com/apache/flink/pull/7525#discussion_r251869623 ## File path:

[jira] [Created] (FLINK-11457) PrometheusPushGatewayReporter either overwrites its own metrics or creates too may labels

Oscar Westra van Holthe - Kind created FLINK-11457: -- Summary: PrometheusPushGatewayReporter either overwrites its own metrics or creates too may labels Key: FLINK-11457 URL:

[GitHub] pnowojski edited a comment on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

pnowojski edited a comment on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer URL: https://github.com/apache/flink/pull/7405#issuecomment-458609356 Sorry, I forgot to respond to that part: > I have started to work on the last test

[jira] [Commented] (FLINK-11333) First-class support for Protobuf types with evolvable schema

[ https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755185#comment-16755185 ] Yun Tang commented on FLINK-11333: -- I planed to use avro-protobuf to extract Protobuf message's schema

[GitHub] jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#discussion_r251966785 ## File path:

[GitHub] jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

jgrier commented on a change in pull request #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#discussion_r251964188 ## File path:

[jira] [Commented] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755385#comment-16755385 ] JC commented on FLINK-2491: --- I also came across this problem trying exactly the same as [~canhuang] , i want

[GitHub] TisonKun commented on issue #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre…

TisonKun commented on issue #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre… URL: https://github.com/apache/flink/pull/7570#issuecomment-458574322 @pnowojski thanks for your advice! Address your comments. Also extract `MockStreamStatusMaintainer` to

[jira] [Created] (FLINK-11459) Presto S3 does not show errors due to missing credentials with minio

Nico Kruber created FLINK-11459: --- Summary: Presto S3 does not show errors due to missing credentials with minio Key: FLINK-11459 URL: https://issues.apache.org/jira/browse/FLINK-11459 Project: Flink

[jira] [Created] (FLINK-11453) Support SliceWindow with forwardable pane info

Rong Rong created FLINK-11453: - Summary: Support SliceWindow with forwardable pane info Key: FLINK-11453 URL: https://issues.apache.org/jira/browse/FLINK-11453 Project: Flink Issue Type:

[jira] [Created] (FLINK-11454) Support MergedStream operation

Rong Rong created FLINK-11454: - Summary: Support MergedStream operation Key: FLINK-11454 URL: https://issues.apache.org/jira/browse/FLINK-11454 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755180#comment-16755180 ] Edward Rojas commented on FLINK-11419: -- [~kkl0u] I created the PR, you can review it now >

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

pnowojski 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_r251924624 ## File path:

[GitHub] stevenzwu closed pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

stevenzwu closed pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020 This is an automated message from the Apache Git Service. To

[GitHub] stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020#issuecomment-458650005 @tzulitai thx. let me close this PR then. @tillrohrmann can submit a diff PR.

[jira] [Updated] (FLINK-11453) Support SliceStream with forwardable pane info

[ https://issues.apache.org/jira/browse/FLINK-11453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-11453: -- Summary: Support SliceStream with forwardable pane info (was: Support SliceWindow with forwardable

[jira] [Created] (FLINK-11455) Support evictor operations on slicing and merging operators

Rong Rong created FLINK-11455: - Summary: Support evictor operations on slicing and merging operators Key: FLINK-11455 URL: https://issues.apache.org/jira/browse/FLINK-11455 Project: Flink Issue

[jira] [Created] (FLINK-11456) Improve window operator with sliding window assigners

Rong Rong created FLINK-11456: - Summary: Improve window operator with sliding window assigners Key: FLINK-11456 URL: https://issues.apache.org/jira/browse/FLINK-11456 Project: Flink Issue Type:

[jira] [Created] (FLINK-11458) Ensure sink commit side-effects when cancelling with savepoint.

Kostas Kloudas created FLINK-11458: -- Summary: Ensure sink commit side-effects when cancelling with savepoint. Key: FLINK-11458 URL: https://issues.apache.org/jira/browse/FLINK-11458 Project: Flink

[jira] [Commented] (FLINK-11042) testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is an invalid test

[ https://issues.apache.org/jira/browse/FLINK-11042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755198#comment-16755198 ] Piotr Nowojski commented on FLINK-11042: I was waiting for someone to review my PR that drops

[jira] [Comment Edited] (FLINK-11042) testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is an invalid test

[ https://issues.apache.org/jira/browse/FLINK-11042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755198#comment-16755198 ] Piotr Nowojski edited comment on FLINK-11042 at 1/29/19 4:48 PM: - I am

[GitHub] tvielgouarin commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

tvielgouarin commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer URL: https://github.com/apache/flink/pull/7405#issuecomment-458604699 I've manage to make the migration test from FlinkKakfaProducer011 --> FlinkKafkaProducer work. I will

[GitHub] pnowojski commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

pnowojski commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer URL: https://github.com/apache/flink/pull/7405#issuecomment-458609356 Sorry, I forgot to respond to that part: > I have started to work on the last test

[GitHub] pnowojski commented on a change in pull request #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre…

pnowojski commented on a change in pull request #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre… URL: https://github.com/apache/flink/pull/7570#discussion_r251916174 ## File path:

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

pnowojski 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_r251922093 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252036898 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252018181 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r251979596 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252025737 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252035267 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252016959 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252016613 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252018047 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252033885 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252037449 ## File path:

[jira] [Comment Edited] (FLINK-10897) Support POJO state schema evolution

[ https://issues.apache.org/jira/browse/FLINK-10897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747409#comment-16747409 ] boshu Zheng edited comment on FLINK-10897 at 1/30/19 2:13 AM: -- I will try

[GitHub] jinglining commented on issue #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter

jinglining commented on issue #7582: [FLINK-11424][metrics]fix remove error type Gauge in DatadogHttpReporter URL: https://github.com/apache/flink/pull/7582#issuecomment-458785073 The Travis CI build failed， because of YarnFlinkResourceManagerTest which case is always fail recently。

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252026077 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r251984469 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252036720 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252027651 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252013399 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252014383 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252032139 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252028083 ## File path:

[GitHub] fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

fhueske commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r252026568 ## File path:

[GitHub] zhaijp opened a new pull request #7596: Release 1.7 sortPartition bug

zhaijp opened a new pull request #7596: Release 1.7 sortPartition bug URL: https://github.com/apache/flink/pull/7596 ### I found a bug when I use sortPartition public class WordCountExample { public static void main(String[] args) throws Exception { final

[GitHub] suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#discussion_r252025274 ## File path: docs/_includes/generated/mesos_configuration.html ## @@

[GitHub] suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#discussion_r252024051 ## File path:

[GitHub] suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#discussion_r252037753 ## File path: docs/_includes/generated/yarn_config_configuration.html

[GitHub] suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#discussion_r252039395 ## File path:

[GitHub] suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#discussion_r252038865 ## File path:

[GitHub] suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers

suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum TMs failure rate in ResourceManagers URL: https://github.com/apache/flink/pull/7356#discussion_r252025408 ## File path:

[GitHub] TisonKun commented on a change in pull request #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre…

TisonKun commented on a change in pull request #7570: [FLINK-11422] Prefer testing class to mock StreamTask in AbstractStre… URL: https://github.com/apache/flink/pull/7570#discussion_r252085826 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755576#comment-16755576 ] lining edited comment on FLINK-11380 at 1/30/19 2:12 AM: - I met this too. 

[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=16755576#comment-16755576 ] lining commented on FLINK-11380: I meet this too. https://api.travis-ci.org/v3/job/485210100/log.txt >

[GitHub] klion26 commented on issue #7596: Release 1.7 sortPartition bug

klion26 commented on issue #7596: Release 1.7 sortPartition bug URL: https://github.com/apache/flink/pull/7596#issuecomment-458785790 @zhaijp You can report bug using [JIRA](https://issues.apache.org/jira/projects/FLINK). Maybe you could close this pr.

[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_r252089234 ## File path:

[jira] [Commented] (FLINK-9054) IllegalStateException: Buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755630#comment-16755630 ] guchunhui commented on FLINK-9054: -- Hi,I also have this problem  with Flink 1.6. >

[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_r252105308 ## File path:

[GitHub] jinglining commented on a change in pull request #7567: [FLINK-11358][tests] Port LeaderChangeStateCleanupTest to new code base

jinglining commented on a change in pull request #7567: [FLINK-11358][tests] Port LeaderChangeStateCleanupTest to new code base URL: https://github.com/apache/flink/pull/7567#discussion_r252108778 ## File path:

[GitHub] wujinhu opened a new pull request #7599: [FLINK-11442] upgrade oss sdk version

wujinhu opened a new pull request #7599: [FLINK-11442] upgrade oss sdk version URL: https://github.com/apache/flink/pull/7599 ## What is the purpose of the change Upgrade oss sdk version to exclude org.json dependency https://issues.apache.org/jira/browse/FLINK-11442

[jira] [Updated] (FLINK-11442) Upgrade OSS SDK Version

[ https://issues.apache.org/jira/browse/FLINK-11442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11442: --- Labels: pull-request-available (was: ) > Upgrade OSS SDK Version > ---

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252128802 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252127263 ## File path: flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeSerializer.java

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252128586 ## File path:

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252128501 ## File path:

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252130677 ## File path:

[GitHub] Myasuka commented on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types

Myasuka commented on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types URL: https://github.com/apache/flink/pull/7598#issuecomment-458831260 CC @tzulitai would you please review this part of code?

[GitHub] Myasuka commented on issue #7595: [FLINK-11363][tests] Port TaskManagerConfigurationTest to new code base

Myasuka commented on issue #7595: [FLINK-11363][tests] Port TaskManagerConfigurationTest to new code base URL: https://github.com/apache/flink/pull/7595#issuecomment-458839395 LGTM +1 This is an automated message from the

[GitHub] wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version

wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version URL: https://github.com/apache/flink/pull/7599#issuecomment-458840957 @StefanRRichter Please help to review this PR, thanks :) This is an automated

[GitHub] Myasuka opened a new pull request #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types

Myasuka opened a new pull request #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types URL: https://github.com/apache/flink/pull/7598 ## What is the purpose of the change Support Protobuf types directly in Flink. Unlike the built-in avro serializer

[jira] [Updated] (FLINK-11333) First-class support for Protobuf types with evolvable schema

[ https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11333: --- Labels: pull-request-available (was: ) > First-class support for Protobuf types with

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252134315 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NullableSerializer.java

[GitHub] jinglining commented on a change in pull request #7567: [FLINK-11358][tests] Port LeaderChangeStateCleanupTest to new code base

jinglining commented on a change in pull request #7567: [FLINK-11358][tests] Port LeaderChangeStateCleanupTest to new code base URL: https://github.com/apache/flink/pull/7567#discussion_r252108778 ## File path:

[GitHub] wuchong commented on issue #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI

wuchong commented on issue #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI URL: https://github.com/apache/flink/pull/7450#issuecomment-458806492 Thank @XuQianJin-Stars and sorry for the late reply. The PR looks good to me now. Will merge this soon.

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

tzulitai commented on issue #7566: [FLINK-11328][core] Migrate NFAStateSerializer to new TypeSerializer interface URL: https://github.com/apache/flink/pull/7566#issuecomment-458822350 Thanks @dawidwys! I looked at all 3 commits; the refactoring part is also nice to have. The actual

[jira] [Commented] (FLINK-11450) Port and move TableSource and TableSink to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-11450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755713#comment-16755713 ] Dian Fu commented on FLINK-11450: -  [~twalthr] Sounds great. Will submit a PR ASAP. > Port and move

[GitHub] igalshilman commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

igalshilman commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252139840 ## File path:

[GitHub] igalshilman commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

igalshilman commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252139996 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252144982 ## File path:

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252145959 ## File path: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala

[GitHub] twalthr commented on a change in pull request #7587: [FLINK-11064] [table] Setup a new flink-table module structure

twalthr commented on a change in pull request #7587: [FLINK-11064] [table] Setup a new flink-table module structure URL: https://github.com/apache/flink/pull/7587#discussion_r252147236 ## File path: flink-table/flink-table-dist/pom.xml ## @@ -0,0 +1,103 @@ + +

[GitHub] XuQianJin-Stars commented on issue #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI

XuQianJin-Stars commented on issue #7450: [FLINK-11296][Table API & SQL] Support truncate in TableAPI URL: https://github.com/apache/flink/pull/7450#issuecomment-458809680 hi @wuchong Thank you very much. I know you are very busy. best qianjin

[GitHub] tzulitai edited a comment on issue #7566: [FLINK-11328][core] Migrate NFAStateSerializer to new TypeSerializer interface

tzulitai edited a comment on issue #7566: [FLINK-11328][core] Migrate NFAStateSerializer to new TypeSerializer interface URL: https://github.com/apache/flink/pull/7566#issuecomment-458822350 Thanks @dawidwys! I looked at all 3 commits; the refactoring part is also nice to have. The

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252132629 ## File path:

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252139206 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252140553 ## File path:

[jira] [Commented] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)"

[ https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755785#comment-16755785 ] Dian Fu commented on FLINK-11447: - Thanks [~dawidwys] for the sharing your thoughts. If we choose option

[jira] [Comment Edited] (FLINK-9054) IllegalStateException: Buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755630#comment-16755630 ] guchunhui edited comment on FLINK-9054 at 1/30/19 3:14 AM: --- Hi,I also have this

[jira] [Issue Comment Deleted] (FLINK-9054) IllegalStateException: Buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] guchunhui updated FLINK-9054: - Comment: was deleted (was: Hi,I also have this problem  with Flink 1.6. Do you solve this problem?) >

[GitHub] chensi2017 opened a new pull request #7597: fix wrong format

chensi2017 opened a new pull request #7597: fix wrong format URL: https://github.com/apache/flink/pull/7597 This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use

[GitHub] wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version

wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version URL: https://github.com/apache/flink/pull/7599#issuecomment-458821842 **Testing results:** [INFO] --- [INFO] T E S T S [INFO]

[jira] [Created] (FLINK-11460) Remove useless AcknowledgeStreamMockEnvironment

zhijiang created FLINK-11460: Summary: Remove useless AcknowledgeStreamMockEnvironment Key: FLINK-11460 URL: https://issues.apache.org/jira/browse/FLINK-11460 Project: Flink Issue Type: Task

[GitHub] tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

tzulitai commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252130677 ## File path:

[GitHub] igalshilman commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers

igalshilman commented on a change in pull request #7590: [FLINK-11329][core] Migrating CompositeSerializers URL: https://github.com/apache/flink/pull/7590#discussion_r252140569 ## File path:

[GitHub] Myasuka removed a comment on issue #7595: [FLINK-11363][tests] Port TaskManagerConfigurationTest to new code base

Myasuka removed a comment on issue #7595: [FLINK-11363][tests] Port TaskManagerConfigurationTest to new code base URL: https://github.com/apache/flink/pull/7595#issuecomment-458839395 LGTM +1 This is an automated message

[GitHub] zentol commented on issue #7533: [FLINK-11288][build] Add flink-ml-uber module

zentol commented on issue #7533: [FLINK-11288][build] Add flink-ml-uber module URL: https://github.com/apache/flink/pull/7533#issuecomment-458454069 @StephanEwen I also recall a discussion with @tillrohrmann about this very idea; IIRC `flink-ml` allows users to replace certain dependencies

  1   2   3   >