[jira] [Commented] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684860#comment-16684860 ] ASF GitHub Bot commented on FLINK-10848: suez1224 opened a new pull request #7078:

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684912#comment-16684912 ] ASF GitHub Bot commented on FLINK-10624: twalthr commented on issue #6927: [FLINK-10624] Extend

[jira] [Created] (FLINK-10860) java.lang.ArrayIndexOutOfBoundsException Error reading state

2018-11-13 Thread JC (JIRA)
JC created FLINK-10860: -- Summary: java.lang.ArrayIndexOutOfBoundsException Error reading state Key: FLINK-10860 URL: https://issues.apache.org/jira/browse/FLINK-10860 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

2018-11-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684903#comment-16684903 ] Timo Walther commented on FLINK-10826: -- Travis still failed:

[jira] [Created] (FLINK-10858) Create Angular Scaffold in Flink Dashboard

2018-11-13 Thread Yadong Xie (JIRA)
Yadong Xie created FLINK-10858: -- Summary: Create Angular Scaffold in Flink Dashboard Key: FLINK-10858 URL: https://issues.apache.org/jira/browse/FLINK-10858 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684968#comment-16684968 ] ASF GitHub Bot commented on FLINK-10634: zentol commented on issue #7056:

[GitHub] pnowojski opened a new pull request #7084: [FLINK-10861][e2e] Do not fail stop_kafka_cluster if a process terminates before we kill it

2018-11-13 Thread GitBox
pnowojski opened a new pull request #7084: [FLINK-10861][e2e] Do not fail stop_kafka_cluster if a process terminates before we kill it URL: https://github.com/apache/flink/pull/7084 This is a simple end-to-end test change to harden the test. Example problem:

[GitHub] kl0u commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

2018-11-13 Thread GitBox
kl0u commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream URL: https://github.com/apache/flink/pull/6608#issuecomment-438182663 Hi @art4ul ! There is already an open PR for that issue and it is this one:

[jira] [Commented] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684888#comment-16684888 ] ASF GitHub Bot commented on FLINK-10203: kl0u commented on issue #6608: [FLINK-10203]Support

[GitHub] twalthr commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread GitBox
twalthr commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-438189527 @yanghua I agree with @pnowojski. We should test Kafka and Elastic but we don't need to test them together. The

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684950#comment-16684950 ] ASF GitHub Bot commented on FLINK-10624: pnowojski commented on issue #6927: [FLINK-10624]

[jira] [Commented] (FLINK-10859) Queryable state (rocksdb) end-to-end test fails on Travis

2018-11-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684961#comment-16684961 ] Timo Walther commented on FLINK-10859: -- The heavy deployment test also fails with a similar

[GitHub] maqingxiang commented on a change in pull request #7083: [hotfix][flink-runtime] modify maxAttempts when find a unique file name for the spilling channel

2018-11-13 Thread GitBox
maqingxiang commented on a change in pull request #7083: [hotfix][flink-runtime] modify maxAttempts when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7083#discussion_r232977700 ## File path:

[jira] [Commented] (FLINK-10861) Kafka e2e test fails during tearing down

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684995#comment-16684995 ] ASF GitHub Bot commented on FLINK-10861: pnowojski opened a new pull request #7084:

[jira] [Updated] (FLINK-10861) Kafka e2e test fails during tearing down

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10861: --- Labels: pull-request-available (was: ) > Kafka e2e test fails during tearing down >

[GitHub] suez1224 closed pull request #7078: [FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success

2018-11-13 Thread GitBox
suez1224 closed pull request #7078: [FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success URL: https://github.com/apache/flink/pull/7078 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below

[GitHub] suez1224 opened a new pull request #7078: [FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success

2018-11-13 Thread GitBox
suez1224 opened a new pull request #7078: [FLINK-10848][YARN] properly remove YARN ContainerRequest upon container allocation success URL: https://github.com/apache/flink/pull/7078 ## What is the purpose of the change Properly remove YARN ContainerRequest upon container allocation

[jira] [Commented] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684859#comment-16684859 ] ASF GitHub Bot commented on FLINK-10848: suez1224 closed pull request #7078: [FLINK-10848][YARN]

[jira] [Comment Edited] (FLINK-10705) Rework Flink Web Dashboard

2018-11-13 Thread Yadong Xie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684904#comment-16684904 ] Yadong Xie edited comment on FLINK-10705 at 11/13/18 9:12 AM: -- The new 

[jira] [Updated] (FLINK-10859) Queryable state (rocksdb) end-to-end test fails on Travis

2018-11-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10859: - Attachment: queryable_logs.txt > Queryable state (rocksdb) end-to-end test fails on Travis >

[jira] [Updated] (FLINK-10859) Queryable state (rocksdb) end-to-end test fails on Travis

2018-11-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10859: - Affects Version/s: 1.7.0 > Queryable state (rocksdb) end-to-end test fails on Travis >

[GitHub] zhijiangW commented on a change in pull request #7083: [hotfix][flink-runtime] modify maxAttempts when find a unique file name for the spilling channel

2018-11-13 Thread GitBox
zhijiangW commented on a change in pull request #7083: [hotfix][flink-runtime] modify maxAttempts when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7083#discussion_r232929174 ## File path:

[jira] [Created] (FLINK-10861) Kafka e2e test fails during tearing down

2018-11-13 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-10861: -- Summary: Kafka e2e test fails during tearing down Key: FLINK-10861 URL: https://issues.apache.org/jira/browse/FLINK-10861 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-10705) Rework Flink Web Dashboard

2018-11-13 Thread Yadong Xie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yadong Xie reassigned FLINK-10705: -- Assignee: Yadong Xie (was: Fabian Wollert) > Rework Flink Web Dashboard >

[GitHub] 1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

2018-11-13 Thread GitBox
1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r232961776 ## File path:

[GitHub] yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread GitBox
yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-438201782 @twalthr @pnowojski Thank you for your suggestion. It seems that I also misunderstood the original meaning of

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684954#comment-16684954 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on issue #6927: [FLINK-10624] Extend

[GitHub] zentol commented on issue #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

2018-11-13 Thread GitBox
zentol commented on issue #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056#issuecomment-438207344 The test passed in the linked build. The second build encountered a timeout since the cache hat do be rebuilt, the first

[jira] [Updated] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10419: -- Fix Version/s: 1.6.3 1.5.6 > ClassNotFoundException while deserializing

[jira] [Updated] (FLINK-10863) Assign uids to all operators

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10863: --- Labels: pull-request-available (was: ) > Assign uids to all operators >

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685074#comment-16685074 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on issue #6927: [FLINK-10624] Extend

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685038#comment-16685038 ] ASF GitHub Bot commented on FLINK-10419: tillrohrmann commented on a change in pull request

[GitHub] StefanRRichter opened a new pull request #7085: [FLINK-10863][tests] Assign UIDs to all operators in DataStreamAllrou…

2018-11-13 Thread GitBox
StefanRRichter opened a new pull request #7085: [FLINK-10863][tests] Assign UIDs to all operators in DataStreamAllrou… URL: https://github.com/apache/flink/pull/7085 …ndTestProgram ## What is the purpose of the change This PR assigns UIDs to all operators in

[jira] [Commented] (FLINK-10863) Assign uids to all operators

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685063#comment-16685063 ] ASF GitHub Bot commented on FLINK-10863: StefanRRichter opened a new pull request #7085:

[jira] [Commented] (FLINK-10859) Queryable state (rocksdb) end-to-end test fails on Travis

2018-11-13 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685061#comment-16685061 ] Stefan Richter commented on FLINK-10859: I think all problems of this sort are related to

[GitHub] twalthr opened a new pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

2018-11-13 Thread GitBox
twalthr opened a new pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087 ## What is the purpose of the change This PR makes the versioning of a Kafka table factory more flexible. It still

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685165#comment-16685165 ] ASF GitHub Bot commented on FLINK-10843: twalthr opened a new pull request #7087: [FLINK-10843]

[jira] [Updated] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10843: --- Labels: pull-request-available (was: ) > Make Kafka version definition more flexible for

[GitHub] StefanRRichter commented on issue #7075: [FLINK-10764][tests] Add ITCase for checkpoint path entropy injection.

2018-11-13 Thread GitBox
StefanRRichter commented on issue #7075: [FLINK-10764][tests] Add ITCase for checkpoint path entropy injection. URL: https://github.com/apache/flink/pull/7075#issuecomment-438261706 Nice test, LGTM  This is an automated

[jira] [Commented] (FLINK-10842) Waiting loops are broken in e2e/common.sh

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685178#comment-16685178 ] ASF GitHub Bot commented on FLINK-10842: twalthr commented on a change in pull request #7073:

[jira] [Closed] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

2018-11-13 Thread ambition (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition closed FLINK-10818. Resolution: Fixed > RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not >

[GitHub] pnowojski commented on issue #7084: [FLINK-10861][e2e] Do not fail stop_kafka_cluster if a process terminates before we kill it

2018-11-13 Thread GitBox
pnowojski commented on issue #7084: [FLINK-10861][e2e] Do not fail stop_kafka_cluster if a process terminates before we kill it URL: https://github.com/apache/flink/pull/7084#issuecomment-438223753 Thanks for the review. I will wait for green travis.

[jira] [Commented] (FLINK-10861) Kafka e2e test fails during tearing down

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685035#comment-16685035 ] ASF GitHub Bot commented on FLINK-10861: pnowojski commented on issue #7084: [FLINK-10861][e2e]

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685152#comment-16685152 ] ASF GitHub Bot commented on FLINK-10624: twalthr commented on issue #6927: [FLINK-10624] Extend

[GitHub] twalthr edited a comment on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread GitBox
twalthr edited a comment on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-438255104 Thanks for the update @yanghua. A first look at the changes looked good to me. I will take care of merging

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685153#comment-16685153 ] ASF GitHub Bot commented on FLINK-10624: twalthr edited a comment on issue #6927: [FLINK-10624]

[jira] [Commented] (FLINK-10764) Add S3 entropy injection end-to-end/IT test

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685172#comment-16685172 ] ASF GitHub Bot commented on FLINK-10764: StefanRRichter commented on issue #7075:

[jira] [Commented] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

2018-11-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685030#comment-16685030 ] Timo Walther commented on FLINK-10826: -- [~till.rohrmann] I think we should run it in the nightly

[jira] [Updated] (FLINK-10858) Create Angular Scaffold in Flink Dashboard

2018-11-13 Thread Yadong Xie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yadong Xie updated FLINK-10858: --- Description: Init new angular dashboard which including: # Angular Scaffold # Basic Layout #

[jira] [Created] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription

2018-11-13 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-10862: -- Summary: REST API does not show program descriptions of "simple" ProgramDescription Key: FLINK-10862 URL: https://issues.apache.org/jira/browse/FLINK-10862

[GitHub] twalthr commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread GitBox
twalthr commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-438255104 Thanks for the update @yanghua. A first look at the changes looks good to me. I will take care of merging this.

[jira] [Reopened] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

2018-11-13 Thread ambition (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition reopened FLINK-10818: -- > RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not > enough free slots

[jira] [Comment Edited] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

2018-11-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685030#comment-16685030 ] Timo Walther edited comment on FLINK-10826 at 11/13/18 10:53 AM: -

[GitHub] tillrohrmann commented on a change in pull request #7082: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

2018-11-13 Thread GitBox
tillrohrmann commented on a change in pull request #7082: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7082#discussion_r232988684 ## File path:

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685040#comment-16685040 ] ASF GitHub Bot commented on FLINK-10419: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685039#comment-16685039 ] ASF GitHub Bot commented on FLINK-10419: tillrohrmann commented on a change in pull request

[jira] [Created] (FLINK-10863) Assign uids to all operators

2018-11-13 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10863: -- Summary: Assign uids to all operators Key: FLINK-10863 URL: https://issues.apache.org/jira/browse/FLINK-10863 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4719) KryoSerializer random exception

2018-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-4719. - Resolution: Fixed Fix Version/s: 1.3.3 > KryoSerializer random exception >

[jira] [Closed] (FLINK-5988) Show start-cluster.sh failures

2018-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-5988. - Resolution: Fixed Fix Version/s: 1.3.3 > Show start-cluster.sh failures >

[jira] [Closed] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

2018-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-5353. - > Elasticsearch Sink loses well-formed documents when there are malformed > documents >

[jira] [Closed] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation

2018-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-3348. - > taskmanager.memory.off-heap missing bc documentation >

[GitHub] azagrebin commented on issue #6989: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination

2018-11-13 Thread GitBox
azagrebin commented on issue #6989: [FLINK-10455][Kafka Tx] Close transactional producers in case of failure and termination URL: https://github.com/apache/flink/pull/6989#issuecomment-438239819 cc @pnowojski This is an

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685084#comment-16685084 ] ASF GitHub Bot commented on FLINK-10455: azagrebin commented on issue #6989: [FLINK-10455][Kafka

[jira] [Created] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

2018-11-13 Thread wujinhu (JIRA)
wujinhu created FLINK-10865: --- Summary: Implement Flink's own Aliyun OSS filesystem Key: FLINK-10865 URL: https://issues.apache.org/jira/browse/FLINK-10865 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

2018-11-13 Thread wujinhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wujinhu updated FLINK-10865: Issue Type: New Feature (was: Improvement) > Implement Flink's own Aliyun OSS filesystem >

[GitHub] zhijiangW commented on a change in pull request #7083: [hotfix][flink-runtime] modify maxAttempts when find a unique file name for the spilling channel

2018-11-13 Thread GitBox
zhijiangW commented on a change in pull request #7083: [hotfix][flink-runtime] modify maxAttempts when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7083#discussion_r232981388 ## File path:

[jira] [Commented] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

2018-11-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685016#comment-16685016 ] Till Rohrmann commented on FLINK-10826: --- Maybe it is not a good idea to run the heavy-deployment

[GitHub] tillrohrmann commented on a change in pull request #7082: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

2018-11-13 Thread GitBox
tillrohrmann commented on a change in pull request #7082: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7082#discussion_r232989225 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #7082: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

2018-11-13 Thread GitBox
tillrohrmann commented on a change in pull request #7082: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7082#discussion_r232988398 ## File path:

[GitHub] vthinkxie opened a new pull request #7086: [FLINK-10858] Create Angular Scaffold in Flink Dashboard

2018-11-13 Thread GitBox
vthinkxie opened a new pull request #7086: [FLINK-10858] Create Angular Scaffold in Flink Dashboard URL: https://github.com/apache/flink/pull/7086 ## What is the purpose of the change This pull request start to move the Flink Dashboard from angular 1.x to Angular latest

[jira] [Commented] (FLINK-10858) Create Angular Scaffold in Flink Dashboard

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685066#comment-16685066 ] ASF GitHub Bot commented on FLINK-10858: vthinkxie opened a new pull request #7086:

[jira] [Updated] (FLINK-10858) Create Angular Scaffold in Flink Dashboard

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10858: --- Labels: pull-request-available (was: ) > Create Angular Scaffold in Flink Dashboard >

[jira] [Updated] (FLINK-10858) Create Angular Scaffold in Flink Dashboard

2018-11-13 Thread Yadong Xie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yadong Xie updated FLINK-10858: --- Description: Init new angular dashboard which including: * Angular Scaffold (create

[GitHub] yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread GitBox
yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-438237291 @pnowojski Can you quickly take a look at whether the latest changes meet your requirements?

[jira] [Created] (FLINK-10864) Support multiple Main classes per jar

2018-11-13 Thread Flavio Pompermaier (JIRA)
Flavio Pompermaier created FLINK-10864: -- Summary: Support multiple Main classes per jar Key: FLINK-10864 URL: https://issues.apache.org/jira/browse/FLINK-10864 Project: Flink Issue

[jira] [Commented] (FLINK-7930) Support periodic jobs with state that gets restored and persisted in a savepoint

2018-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685073#comment-16685073 ] Flavio Pompermaier commented on FLINK-7930: --- If I'm not wrong this is possible in the latest

[GitHub] twalthr commented on a change in pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh

2018-11-13 Thread GitBox
twalthr commented on a change in pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh URL: https://github.com/apache/flink/pull/7073#discussion_r233032688 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -412,17 +417,20 @@

[jira] [Commented] (FLINK-10842) Waiting loops are broken in e2e/common.sh

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685179#comment-16685179 ] ASF GitHub Bot commented on FLINK-10842: twalthr commented on a change in pull request #7073:

[GitHub] twalthr commented on a change in pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh

2018-11-13 Thread GitBox
twalthr commented on a change in pull request #7073: [FLINK-10842][E2E tests] fix broken waiting loops in common.sh URL: https://github.com/apache/flink/pull/7073#discussion_r233032145 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -401,7 +406,7 @@

[jira] [Commented] (FLINK-10705) Rework Flink Web Dashboard

2018-11-13 Thread Yadong Xie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684904#comment-16684904 ] Yadong Xie commented on FLINK-10705: The new dashboard has about 10,000 lines of code. In order to

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684949#comment-16684949 ] ASF GitHub Bot commented on FLINK-7155: --- 1u0 commented on a change in pull request #6976:

[GitHub] 1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB

2018-11-13 Thread GitBox
1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new metrics reporter to InfluxDB URL: https://github.com/apache/flink/pull/6976#discussion_r232960478 ## File path:

[GitHub] pnowojski commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread GitBox
pnowojski commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-438201077 In this case in the end we need 3 test files: 1. Kafka tests in separate files (for 0.10 and 2.0). 2. Main

[jira] [Created] (FLINK-10859) Queryable state (rocksdb) end-to-end test fails on Travis

2018-11-13 Thread Timo Walther (JIRA)
Timo Walther created FLINK-10859: Summary: Queryable state (rocksdb) end-to-end test fails on Travis Key: FLINK-10859 URL: https://issues.apache.org/jira/browse/FLINK-10859 Project: Flink

[jira] [Commented] (FLINK-7155) Add Influxdb metrics reporter

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684952#comment-16684952 ] ASF GitHub Bot commented on FLINK-7155: --- 1u0 commented on a change in pull request #6976:

[GitHub] dawidwys commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

2018-11-13 Thread GitBox
dawidwys commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233048167 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685246#comment-16685246 ] ASF GitHub Bot commented on FLINK-10625: dawidwys commented on a change in pull request #7070:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685241#comment-16685241 ] ASF GitHub Bot commented on FLINK-10625: dawidwys commented on a change in pull request #7070:

[GitHub] yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread GitBox
yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-438278306 I have reorganized commits to facilitate merging. This change has been validated on my own Travis (misc is out of

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685258#comment-16685258 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on issue #6927: [FLINK-10624] Extend

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

2018-11-13 Thread GitBox
twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233057636 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[jira] [Commented] (FLINK-10625) Add MATCH_RECOGNIZE documentation

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685293#comment-16685293 ] ASF GitHub Bot commented on FLINK-10625: twalthr commented on a change in pull request #7070:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

2018-11-13 Thread GitBox
twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r233059298 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[jira] [Closed] (FLINK-10863) Assign uids to all operators

2018-11-13 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10863. -- Resolution: Fixed Merged in: master: 31176d5 release-1.7: 44777b6 release-1.6: 76d7fb1

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685412#comment-16685412 ] ASF GitHub Bot commented on FLINK-10843: pnowojski commented on a change in pull request #7087:

[GitHub] pnowojski commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

2018-11-13 Thread GitBox
pnowojski commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233098151 ## File path:

[GitHub] pnowojski commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

2018-11-13 Thread GitBox
pnowojski commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233090756 ## File path:

[GitHub] pnowojski commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible

2018-11-13 Thread GitBox
pnowojski commented on a change in pull request #7087: [FLINK-10843] [connectors] Make Kafka table factory versioning more flexible URL: https://github.com/apache/flink/pull/7087#discussion_r233089061 ## File path:

[jira] [Commented] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory

2018-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685414#comment-16685414 ] ASF GitHub Bot commented on FLINK-10843: pnowojski commented on a change in pull request #7087:

[GitHub] dawidwys closed pull request #7082: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint

2018-11-13 Thread GitBox
dawidwys closed pull request #7082: [FLINK-10419] Using DeclineCheckpoint message class when invoking RPC declineCheckpoint URL: https://github.com/apache/flink/pull/7082 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

  1   2   >