[jira] [Closed] (FLINK-8572) Flink1.4 version of the document on the left menu click can not jump, the left drop-down menu can not be pulled

[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8572. --- Resolution: Not A Problem > Flink1.4 version of the document on the left menu click can not ju

[jira] [Reopened] (FLINK-8572) Flink1.4 version of the document on the left menu click can not jump, the left drop-down menu can not be pulled

[ https://issues.apache.org/jira/browse/FLINK-8572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-8572: - > Flink1.4 version of the document on the left menu click can not jump, the > left drop-down

[jira] [Commented] (FLINK-8573) Print JobID for failed jobs

[ https://issues.apache.org/jira/browse/FLINK-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355113#comment-16355113 ] mingleizhang commented on FLINK-8573: - I will take a look on this soon. > Print JobID

[jira] [Created] (FLINK-8574) Add timestamps to travis logging messages

Chesnay Schepler created FLINK-8574: --- Summary: Add timestamps to travis logging messages Key: FLINK-8574 URL: https://issues.apache.org/jira/browse/FLINK-8574 Project: Flink Issue Type: Imp

[jira] [Updated] (FLINK-8575) BackPressureStatsTrackerITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8575: Labels: test-stability (was: ) > BackPressureStatsTrackerITCase unstable >

[jira] [Created] (FLINK-8575) BackPressureStatsTrackerITCase unstable

Chesnay Schepler created FLINK-8575: --- Summary: BackPressureStatsTrackerITCase unstable Key: FLINK-8575 URL: https://issues.apache.org/jira/browse/FLINK-8575 Project: Flink Issue Type: Bug

[GitHub] flink pull request #5419: [FLINK-8574][travis] Add timestamp to logging mess...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5419 [FLINK-8574][travis] Add timestamp to logging messages With this PR logging statements on travis also include a timestamp( e.g. `09:00:27.972`). This allows us to better judge how long each part of b

[jira] [Commented] (FLINK-8574) Add timestamps to travis logging messages

[ https://issues.apache.org/jira/browse/FLINK-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355176#comment-16355176 ] ASF GitHub Bot commented on FLINK-8574: --- GitHub user zentol opened a pull request:

[GitHub] flink issue #5393: [FLINK-8516] Allow for custom hash function for shard to ...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5393 @tweise ok, I think I can agree on your last comment. > Should I add a (trivial) unit test that asserts that isThisSubtaskShouldSubscribeTo applies modulus to assigner returned value that f

[GitHub] flink issue #5400: [FLINK-8547][network] Implement CheckpointBarrierHandler ...

Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/5400 @pnowojski , I have submitted a separate commit to address above comments. ---

[jira] [Commented] (FLINK-8516) FlinkKinesisConsumer does not balance shards over subtasks

[ https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355190#comment-16355190 ] ASF GitHub Bot commented on FLINK-8516: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-8547) Implement CheckpointBarrierHandler not to spill data for exactly-once based on credit-based flow control

[ https://issues.apache.org/jira/browse/FLINK-8547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355191#comment-16355191 ] ASF GitHub Bot commented on FLINK-8547: --- Github user zhijiangW commented on the issu

[jira] [Created] (FLINK-8576) Log message for QueryableState loading failure too verbose

Chesnay Schepler created FLINK-8576: --- Summary: Log message for QueryableState loading failure too verbose Key: FLINK-8576 URL: https://issues.apache.org/jira/browse/FLINK-8576 Project: Flink

[jira] [Assigned] (FLINK-8569) Provide a hook to override the default KeyGroupRangeAssignment

[ https://issues.apache.org/jira/browse/FLINK-8569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8569: - Assignee: Stefan Richter > Provide a hook to override the default KeyGroupRangeAssignment

[jira] [Assigned] (FLINK-8569) Provide a hook to override the default KeyGroupRangeAssignment

[ https://issues.apache.org/jira/browse/FLINK-8569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8569: - Assignee: (was: Stefan Richter) > Provide a hook to override the default KeyGroupRang

[jira] [Assigned] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8571: - Assignee: Stefan Richter > Provide an enhanced KeyedStream implementation to use ForwardP

[jira] [Commented] (FLINK-8576) Log message for QueryableState loading failure too verbose

[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355212#comment-16355212 ] ASF GitHub Bot commented on FLINK-8576: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5420: [FLINK-8576][QS] Reduce verbosity when classes can...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5420 [FLINK-8576][QS] Reduce verbosity when classes can't be found This PR reduces the verbosity of DEBUG logging messages when the flink-queryable-state-runtime jar is not on the classpath. Instead of th

[jira] [Updated] (FLINK-8575) BackPressureStatsTrackerITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8575: Description: https://travis-ci.org/apache/flink/jobs/338212141 https://travis-ci.org/apache/

[GitHub] flink pull request #5418: [FLINK-8553] switch flink-metrics-datadog to async...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5418#discussion_r166564479 --- Diff: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java --- @@ -94,4 +96,22 @@ public void close(

[jira] [Commented] (FLINK-8553) switch flink-metrics-datadog to async mode

[ https://issues.apache.org/jira/browse/FLINK-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355217#comment-16355217 ] ASF GitHub Bot commented on FLINK-8553: --- Github user zentol commented on a diff in t

[GitHub] flink issue #5316: [FLINK-8022][kafka-tests] Disable at-least-once tests for...

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/5316 Thanks! ---

[jira] [Commented] (FLINK-8022) Kafka at-least-once tests fail occasionally

[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355222#comment-16355222 ] ASF GitHub Bot commented on FLINK-8022: --- Github user pnowojski commented on the issu

[jira] [Updated] (FLINK-8575) BackPressureStatsTrackerITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8575: - Priority: Critical (was: Major) > BackPressureStatsTrackerITCase unstable > -

[GitHub] flink pull request #5421: [FLINK-8573] [client] Add more information for pri...

GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5421 [FLINK-8573] [client] Add more information for printing JobID for fai… ## What is the purpose of the change *Print JobID for failed jobs* ## Brief change log Add job

[jira] [Commented] (FLINK-8573) Print JobID for failed jobs

[ https://issues.apache.org/jira/browse/FLINK-8573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355266#comment-16355266 ] ASF GitHub Bot commented on FLINK-8573: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #5336: (release-1.4) [FLINK-8419] [kafka] Register metric...

Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/5336 ---

[jira] [Commented] (FLINK-8419) Kafka consumer's offset metrics are not registered for dynamically discovered partitions

[ https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355288#comment-16355288 ] ASF GitHub Bot commented on FLINK-8419: --- Github user tzulitai closed the pull reques

[jira] [Created] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

Hequn Cheng created FLINK-8577: -- Summary: Implement proctime DataStream to Table upsert conversion. Key: FLINK-8577 URL: https://issues.apache.org/jira/browse/FLINK-8577 Project: Flink Issue Typ

[jira] [Created] (FLINK-8578) Implement rowtime DataStream to Table upsert conversion.

Hequn Cheng created FLINK-8578: -- Summary: Implement rowtime DataStream to Table upsert conversion. Key: FLINK-8578 URL: https://issues.apache.org/jira/browse/FLINK-8578 Project: Flink Issue Type

[GitHub] flink issue #5357: [hotfix][JobGraph] Eliminate the conditions of parallelis...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5357 @maqingxiang You are correct that the parallelism check is redundant, but that doesn't automatically mean that it should be removed. This change imo hurts readability as the basic parallelism

[jira] [Created] (FLINK-8579) Support deletion flag for DataStream to Table upsert conversion.

Hequn Cheng created FLINK-8579: -- Summary: Support deletion flag for DataStream to Table upsert conversion. Key: FLINK-8579 URL: https://issues.apache.org/jira/browse/FLINK-8579 Project: Flink I

[jira] [Created] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job

Arnaud Linz created FLINK-8580: -- Summary: No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job Key: FLINK-8580 URL: https://issues.apache.or

[jira] [Updated] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job

[ https://issues.apache.org/jira/browse/FLINK-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-8580: --- Description: Hello, I am using Flink 1.3.2 and I’m struggling to achieve something that should be si

[GitHub] flink issue #5357: [hotfix][JobGraph] Eliminate the conditions of parallelis...

Github user maqingxiang commented on the issue: https://github.com/apache/flink/pull/5357 Thanks for your review @zentol I got it. ---

[GitHub] flink pull request #5357: [hotfix][JobGraph] Eliminate the conditions of par...

Github user maqingxiang closed the pull request at: https://github.com/apache/flink/pull/5357 ---

[jira] [Updated] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job

[ https://issues.apache.org/jira/browse/FLINK-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8580: Component/s: (was: Job-Submission) YARN Client > No ea

[jira] [Updated] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job

[ https://issues.apache.org/jira/browse/FLINK-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8580: Component/s: Job-Submission > No easy way (or issues when trying?) to handle multiple yarn s

[jira] [Comment Edited] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355322#comment-16355322 ] Chesnay Schepler edited comment on FLINK-8543 at 2/7/18 11:12 AM: --

[jira] [Comment Edited] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355322#comment-16355322 ] Chesnay Schepler edited comment on FLINK-8543 at 2/7/18 11:12 AM: --

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355322#comment-16355322 ] Chesnay Schepler commented on FLINK-8543: - [~aljoscha][~kkl0u] Could it be that a

[jira] [Assigned] (FLINK-8575) BackPressureStatsTrackerITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8575: --- Assignee: Gary Yao > BackPressureStatsTrackerITCase unstable > --

[jira] [Commented] (FLINK-8385) Fix exceptions in AbstractEventTimeWindowCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-8385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355328#comment-16355328 ] Chesnay Schepler commented on FLINK-8385: - [~srichter] can this issue be closed? I

[jira] [Closed] (FLINK-8385) Fix exceptions in AbstractEventTimeWindowCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-8385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8385. - Resolution: Fixed Merged in  b32b835. > Fix exceptions in AbstractEventTimeWindowCheckpointingITC

[GitHub] flink pull request #5422: [FLINK-8575][runtime] BackPressureStatsTrackerITCa...

GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5422 [FLINK-8575][runtime] BackPressureStatsTrackerITCase unstable ## What is the purpose of the change *This fixes BackPressureStatsTrackerITCase unstability.* ## Brief change log

[jira] [Commented] (FLINK-8575) BackPressureStatsTrackerITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355337#comment-16355337 ] ASF GitHub Bot commented on FLINK-8575: --- GitHub user GJL opened a pull request:

[jira] [Updated] (FLINK-8018) RMQ does not support disabling queueDeclare, when the user has no declaration permissions, it cannot connect

[ https://issues.apache.org/jira/browse/FLINK-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8018: Fix Version/s: (was: 1.5.0) > RMQ does not support disabling queueDeclare, when the user

[jira] [Closed] (FLINK-8018) RMQ does not support disabling queueDeclare, when the user has no declaration permissions, it cannot connect

[ https://issues.apache.org/jira/browse/FLINK-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8018. --- Resolution: Not A Problem It is already possible to disable the queue declaration by overridin

[jira] [Created] (FLINK-8581) Improve performance for low latency network

Piotr Nowojski created FLINK-8581: - Summary: Improve performance for low latency network Key: FLINK-8581 URL: https://issues.apache.org/jira/browse/FLINK-8581 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-8582) Introduce BufferConsumer concept

Piotr Nowojski created FLINK-8582: - Summary: Introduce BufferConsumer concept Key: FLINK-8582 URL: https://issues.apache.org/jira/browse/FLINK-8582 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8583) Pass BufferConsumer to subpartitions

Piotr Nowojski created FLINK-8583: - Summary: Pass BufferConsumer to subpartitions Key: FLINK-8583 URL: https://issues.apache.org/jira/browse/FLINK-8583 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8584) Handle read-only buffers in DataInputDeserializer

Piotr Nowojski created FLINK-8584: - Summary: Handle read-only buffers in DataInputDeserializer Key: FLINK-8584 URL: https://issues.apache.org/jira/browse/FLINK-8584 Project: Flink Issue Type:

[jira] [Updated] (FLINK-8585) Efficiently handle read-only and non array ByteBuffers in DataInputDeserializer

[ https://issues.apache.org/jira/browse/FLINK-8585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-8585: -- Summary: Efficiently handle read-only and non array ByteBuffers in DataInputDeserializer (was:

[jira] [Created] (FLINK-8585) Efficiently handle read-only buffers in DataInputDeserializer

Piotr Nowojski created FLINK-8585: - Summary: Efficiently handle read-only buffers in DataInputDeserializer Key: FLINK-8585 URL: https://issues.apache.org/jira/browse/FLINK-8585 Project: Flink

[jira] [Commented] (FLINK-8585) Efficiently handle read-only and non array ByteBuffers in DataInputDeserializer

[ https://issues.apache.org/jira/browse/FLINK-8585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355413#comment-16355413 ] Piotr Nowojski commented on FLINK-8585: --- # FLINK-8584 was a quick inefficient fix fo

[jira] [Created] (FLINK-8586) Drop SpilledSubpartitionViewTest

Piotr Nowojski created FLINK-8586: - Summary: Drop SpilledSubpartitionViewTest Key: FLINK-8586 URL: https://issues.apache.org/jira/browse/FLINK-8586 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8587) Drop unused AdaptiveSpanningRecordDeserializer

Piotr Nowojski created FLINK-8587: - Summary: Drop unused AdaptiveSpanningRecordDeserializer Key: FLINK-8587 URL: https://issues.apache.org/jira/browse/FLINK-8587 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-8588) Handle sliced buffers in RecordDeserializer

Piotr Nowojski created FLINK-8588: - Summary: Handle sliced buffers in RecordDeserializer Key: FLINK-8588 URL: https://issues.apache.org/jira/browse/FLINK-8588 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-8589) Add data polling method to InputGate

Piotr Nowojski created FLINK-8589: - Summary: Add data polling method to InputGate Key: FLINK-8589 URL: https://issues.apache.org/jira/browse/FLINK-8589 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8590) Drop ResultPartitionWriter#writeBufferToAllSubpartitions method

Piotr Nowojski created FLINK-8590: - Summary: Drop ResultPartitionWriter#writeBufferToAllSubpartitions method Key: FLINK-8590 URL: https://issues.apache.org/jira/browse/FLINK-8590 Project: Flink

[jira] [Created] (FLINK-8591) Handle unfinished BufferConsumers in subpartitions

Piotr Nowojski created FLINK-8591: - Summary: Handle unfinished BufferConsumers in subpartitions Key: FLINK-8591 URL: https://issues.apache.org/jira/browse/FLINK-8591 Project: Flink Issue Type

[jira] [Closed] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast.

[ https://issues.apache.org/jira/browse/FLINK-8345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8345. - Resolution: Fixed Merged with 26918c953287c7940120dfcfcc10dd5a42beaf81 > Iterate over keyed state

[jira] [Closed] (FLINK-8522) DefaultOperatorStateBackend writes data in checkpoint that is never read.

[ https://issues.apache.org/jira/browse/FLINK-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8522. - Resolution: Fixed Merged with 44211e346f43c931b6eb7106314a1686e25585d9 > DefaultOperatorStateBack

[jira] [Closed] (FLINK-8446) Add support for multiple broadcast states.

[ https://issues.apache.org/jira/browse/FLINK-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8446. - Resolution: Fixed Merged at 28768235068039e4ff50c5235ab79c54410b4ec0 > Add support for multiple b

[jira] [Closed] (FLINK-4940) Add support for broadcast state

[ https://issues.apache.org/jira/browse/FLINK-4940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4940. - Resolution: Fixed Merged at 484fedd4e649ec3adc4f55f090b71f9d7dbaa961 and  484fedd4e649ec3adc4f55f0

[jira] [Commented] (FLINK-4940) Add support for broadcast state

[ https://issues.apache.org/jira/browse/FLINK-4940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355435#comment-16355435 ] Kostas Kloudas commented on FLINK-4940: --- Sorry, meant to write:   Merged at 484fed

[jira] [Closed] (FLINK-3659) Add ConnectWithBroadcast Operation

[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-3659. - Resolution: Fixed Merged at 484fedd4e649ec3adc4f55f090b71f9d7dbaa961 and c6c17befe54d55755ebaf160

[jira] [Created] (FLINK-8592) LatencyMetric scope should include operator names

Chesnay Schepler created FLINK-8592: --- Summary: LatencyMetric scope should include operator names Key: FLINK-8592 URL: https://issues.apache.org/jira/browse/FLINK-8592 Project: Flink Issue T

[jira] [Created] (FLINK-8593) Latency metric docs are outdated

Chesnay Schepler created FLINK-8593: --- Summary: Latency metric docs are outdated Key: FLINK-8593 URL: https://issues.apache.org/jira/browse/FLINK-8593 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355468#comment-16355468 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr] and [~fhueske], it's still a questi

[jira] [Commented] (FLINK-8564) Support SELECT DISTINCT without aggregation functions

[ https://issues.apache.org/jira/browse/FLINK-8564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355492#comment-16355492 ] Hequn Cheng commented on FLINK-8564: OK, we need to adapt the \{{producesUpdates}} fun

[jira] [Closed] (FLINK-8189) move flink-statebackend-rocksdb out of flink-contrib

[ https://issues.apache.org/jira/browse/FLINK-8189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8189. --- Resolution: Duplicate > move flink-statebackend-rocksdb out of flink-contrib > ---

[jira] [Created] (FLINK-8594) Make producesUpdates in DataStreamGroupAggregate return false if it is a distinct group by without state retention configuration

Hequn Cheng created FLINK-8594: -- Summary: Make producesUpdates in DataStreamGroupAggregate return false if it is a distinct group by without state retention configuration Key: FLINK-8594 URL: https://issues.apache.o

[jira] [Created] (FLINK-8595) Include table source factory services in flink-table jar

Timo Walther created FLINK-8595: --- Summary: Include table source factory services in flink-table jar Key: FLINK-8595 URL: https://issues.apache.org/jira/browse/FLINK-8595 Project: Flink Issue Ty

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355511#comment-16355511 ] Xingcan Cui commented on FLINK-8538: If I understood correctly, maybe we should create

[GitHub] flink pull request #5423: Low latency network changes

GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/5423 Low latency network changes This big PR depends on #4552 and #5314. Main purpose of this change is to increase network throughput/performance in low latency cases (benchmark results will be poste

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355523#comment-16355523 ] Timo Walther commented on FLINK-8538: - [~xccui] the nice thing about the SPI is that a

[jira] [Commented] (FLINK-8582) Introduce BufferConsumer concept

[ https://issues.apache.org/jira/browse/FLINK-8582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355524#comment-16355524 ] ASF GitHub Bot commented on FLINK-8582: --- GitHub user pnowojski opened a pull request

[jira] [Commented] (FLINK-8564) Support SELECT DISTINCT without aggregation functions

[ https://issues.apache.org/jira/browse/FLINK-8564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355526#comment-16355526 ] Fabian Hueske commented on FLINK-8564: -- Yes, that would be possible. However, I'm uns

[jira] [Commented] (FLINK-8594) Make producesUpdates in DataStreamGroupAggregate return false if it is a distinct group by without state retention configuration

[ https://issues.apache.org/jira/browse/FLINK-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355530#comment-16355530 ] Fabian Hueske commented on FLINK-8594: -- Copying my comment from FLINK-8564 Yes, that

[jira] [Comment Edited] (FLINK-8594) Make producesUpdates in DataStreamGroupAggregate return false if it is a distinct group by without state retention configuration

[ https://issues.apache.org/jira/browse/FLINK-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355530#comment-16355530 ] Fabian Hueske edited comment on FLINK-8594 at 2/7/18 2:37 PM: --

[jira] [Resolved] (FLINK-8595) Include table source factory services in flink-table jar

[ https://issues.apache.org/jira/browse/FLINK-8595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8595. - Resolution: Fixed Fixed in 1.5.0: b2fc8b427eb03a40df232f481c908eb7bf48b7b8 > Include table source

[jira] [Updated] (FLINK-8595) Include table source factory services in flink-table jar

[ https://issues.apache.org/jira/browse/FLINK-8595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8595: Fix Version/s: 1.5.0 > Include table source factory services in flink-table jar > --

[jira] [Created] (FLINK-8596) Custom command line code does not correctly catch errors

Aljoscha Krettek created FLINK-8596: --- Summary: Custom command line code does not correctly catch errors Key: FLINK-8596 URL: https://issues.apache.org/jira/browse/FLINK-8596 Project: Flink

[GitHub] flink pull request #5424: FLINK-8571] [DataStream] Introduce utility functio...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/5424 FLINK-8571] [DataStream] Introduce utility function that reinterprets a data stream as keyed stream ## What is the purpose of the change This change introduces a utility function (`

[GitHub] flink issue #5424: FLINK-8571] [DataStream] Introduce utility function that ...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5424 CC @aljoscha ---

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355608#comment-16355608 ] ASF GitHub Bot commented on FLINK-8571: --- Github user StefanRRichter commented on the

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355606#comment-16355606 ] ASF GitHub Bot commented on FLINK-8571: --- GitHub user StefanRRichter opened a pull re

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355643#comment-16355643 ] Aljoscha Krettek commented on FLINK-8543: - I thought this shouldn't be possible be

[jira] [Created] (FLINK-8597) Add examples for Connected Streams with Broadcast State.

Kostas Kloudas created FLINK-8597: - Summary: Add examples for Connected Streams with Broadcast State. Key: FLINK-8597 URL: https://issues.apache.org/jira/browse/FLINK-8597 Project: Flink Issu

[jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata.

[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355668#comment-16355668 ] Aljoscha Krettek commented on FLINK-7760: - I believe [~StephanEwen] found the reas

[jira] [Commented] (FLINK-7760) Restore failing from external checkpointing metadata.

[ https://issues.apache.org/jira/browse/FLINK-7760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355676#comment-16355676 ] Shashank Agarwal commented on FLINK-7760: - Sure I’ll checkout by weekend. I’ll be

[GitHub] flink pull request #5425: [FLINK-8456] Add Scala API for Connected Streams w...

GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/5425 [FLINK-8456] Add Scala API for Connected Streams with Broadcast State. R @aljoscha You can merge this pull request into a Git repository by running: $ git pull https://github.com/kl0u/flink broad

[jira] [Commented] (FLINK-8456) Add Scala API for Connected Streams with Broadcast State.

[ https://issues.apache.org/jira/browse/FLINK-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355750#comment-16355750 ] ASF GitHub Bot commented on FLINK-8456: --- GitHub user kl0u opened a pull request:

[jira] [Created] (FLINK-8598) Intermittent test failure of BackPressureStatsTrackerITCase.testBackPressuredProducer

Bowen Li created FLINK-8598: --- Summary: Intermittent test failure of BackPressureStatsTrackerITCase.testBackPressuredProducer Key: FLINK-8598 URL: https://issues.apache.org/jira/browse/FLINK-8598 Project: F

[jira] [Updated] (FLINK-8598) Intermittent test failure of BackPressureStatsTrackerITCase.testBackPressuredProducer

[ https://issues.apache.org/jira/browse/FLINK-8598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8598: Description: I've intermittently run into unit test failures in travisci: {code:java} Tests run: 1, Failur

[GitHub] flink pull request #5426: [FLINK-8362] [elasticsearch] Shade all ES connecto...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5426 [FLINK-8362] [elasticsearch] Shade all ES connector dependencies ## What is the purpose of the change This is an extended version of Nico's work in #5243. This version additionally

[jira] [Commented] (FLINK-8362) Shade Elasticsearch dependencies away

[ https://issues.apache.org/jira/browse/FLINK-8362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355835#comment-16355835 ] ASF GitHub Bot commented on FLINK-8362: --- GitHub user tzulitai opened a pull request:

[jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355877#comment-16355877 ] Monal Daxini commented on FLINK-8571: - Thanks Stefan for the quick turn around time!

[jira] [Closed] (FLINK-8598) Intermittent test failure of BackPressureStatsTrackerITCase.testBackPressuredProducer

[ https://issues.apache.org/jira/browse/FLINK-8598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8598. --- Resolution: Duplicate Fix Version/s: (was: 1.5.0) > Intermittent test failure of >

  1   2   >