[jira] [Resolved] (FLINK-10509) Drop flink-storm

[ https://issues.apache.org/jira/browse/FLINK-10509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10509. --- Resolution: Fixed Fixed via 2294cddac1674fbd760f75429c9e60c571826de9 > Drop flink-storm >

[jira] [Commented] (FLINK-11304) Typo in time attributes doc

[ https://issues.apache.org/jira/browse/FLINK-11304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740117#comment-16740117 ] Yangze Guo commented on FLINK-11304: Sorry, you should apply for the Flink contribution permission

[jira] [Commented] (FLINK-11296) Support truncate in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-11296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740110#comment-16740110 ] Jark Wu commented on FLINK-11296: - Hi [~x1q1j1], thanks for your work. I just notice that we already

[GitHub] KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc

KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247019832 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -284,9 +284,9 @@ public class

[GitHub] KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc

KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247020384 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -317,9 +317,9 @@ class UserActionSource

[GitHub] KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc

KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247020179 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -284,9 +284,9 @@ public class

[GitHub] KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc

KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247019718 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -284,9 +284,9 @@ public class

[jira] [Comment Edited] (FLINK-11304) Typo in time attributes doc

[ https://issues.apache.org/jira/browse/FLINK-11304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740004#comment-16740004 ] Jaryzhen edited comment on FLINK-11304 at 1/11/19 7:09 AM: --- Hey, [~karmagyz]

[jira] [Updated] (FLINK-11305) Allow developer to test flink without building the whole flink project

[ https://issues.apache.org/jira/browse/FLINK-11305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-11305: --- Description: As a flink developer, each time I make some changes in flink, I would like to test it

[GitHub] JaryZhen commented on issue #7466: [hotfix][docs] Fix typo in time attributes doc

JaryZhen commented on issue #7466: [hotfix][docs] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#issuecomment-453398124 OK, I do it right now. This is an automated message from the Apache Git

[GitHub] KarmaGYZ commented on issue #7466: [hotfix][docs] Fix typo in time attributes doc

KarmaGYZ commented on issue #7466: [hotfix][docs] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#issuecomment-453397446 Sorry for the misunderstanding @JaryZhen . I think we should also change the `getRowtimeAttribute` to `getRowtimeAttributeDescriptors`

[GitHub] intsmaze commented on issue #7464: Update state.md

intsmaze commented on issue #7464: Update state.md URL: https://github.com/apache/flink/pull/7464#issuecomment-453396857 Ok, I will commit it to master branch later。 This is an automated message from the Apache Git Service.

[GitHub] intsmaze closed pull request #7464: Update state.md

intsmaze closed pull request #7464: Update state.md URL: https://github.com/apache/flink/pull/7464 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork),

[GitHub] JaryZhen commented on issue #7466: [hotfix][docs] Fix typo in time attributes doc

JaryZhen commented on issue #7466: [hotfix][docs] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#issuecomment-453396068 Here I talk about is **DefinedRowtimeAttribute** should be **DefinedRowtimeAttributes**

[GitHub] intsmaze opened a new pull request #7467: Update state.md

intsmaze opened a new pull request #7467: Update state.md URL: https://github.com/apache/flink/pull/7467 Offset is Long type, the default value is null, and executing offset+=1 in Java 1.8.x will throw a NullPointerException ## What is the purpose of the change

[jira] [Updated] (FLINK-11305) Allow developer to test flink without building the whole flink project

[ https://issues.apache.org/jira/browse/FLINK-11305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-11305: --- Description: As a flink developer, each time I make some changes in flink, I would like to test it

[jira] [Assigned] (FLINK-11305) Allow developer to test flink without building the whole flink project

[ https://issues.apache.org/jira/browse/FLINK-11305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-11305: -- Assignee: Jeff Zhang > Allow developer to test flink without building the whole flink

[jira] [Created] (FLINK-11305) Allow developer to test flink without building the whole flink project

Jeff Zhang created FLINK-11305: -- Summary: Allow developer to test flink without building the whole flink project Key: FLINK-11305 URL: https://issues.apache.org/jira/browse/FLINK-11305 Project: Flink

[GitHub] JaryZhen opened a new pull request #7466: [hotfix][docs] Fix typo in time attributes doc

JaryZhen opened a new pull request #7466: [hotfix][docs] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466 ## What is the purpose of the change This pull request fix typo in time attributes doc ## Brief change log fix typo in

[jira] [Commented] (FLINK-11253) Incorrect way to stop yarn session described in yarn_setup document

[ https://issues.apache.org/jira/browse/FLINK-11253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740081#comment-16740081 ] Tao Yang commented on FLINK-11253: -- Hi, [~till.rohrmann]. Could you kindly give me the contributor

[GitHub] sunjincheng121 commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S…

sunjincheng121 commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S… URL: https://github.com/apache/flink/pull/7403#discussion_r247010124 ## File path:

[jira] [Commented] (FLINK-11082) Increase backlog only if it is available for consumption

[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740056#comment-16740056 ] zhijiang commented on FLINK-11082: -- Consider another issue you mentioned, I think the higher CPU and

[jira] [Comment Edited] (FLINK-11304) Typo in time attributes doc

[ https://issues.apache.org/jira/browse/FLINK-11304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740004#comment-16740004 ] Jaryzhen edited comment on FLINK-11304 at 1/11/19 5:33 AM: --- Hey,

[jira] [Updated] (FLINK-11304) Typo in time attributes doc

[ https://issues.apache.org/jira/browse/FLINK-11304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaryzhen updated FLINK-11304: - Description: *DefinedRowtimeAttribute* should be *DefinedRowtimeAttributes*, both in java and scala

[GitHub] zhijiangW commented on issue #7438: [FLINK-11282][network] Merge StreamRecordWriter into RecordWriter

zhijiangW commented on issue #7438: [FLINK-11282][network] Merge StreamRecordWriter into RecordWriter URL: https://github.com/apache/flink/pull/7438#issuecomment-453380144 @pnowojski , I have submitted the fixup commit for addressing above comments.

[jira] [Assigned] (FLINK-11220) Can not Select row time field in JOIN query

[ https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-11220: --- Assignee: Dian Fu > Can not Select row time field in JOIN query >

[jira] [Commented] (FLINK-11220) Can not Select row time field in JOIN query

[ https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740028#comment-16740028 ] Dian Fu commented on FLINK-11220: - Thanks a lot for the discussion. +1 to the solution of improving

[GitHub] KarmaGYZ opened a new pull request #7465: [hotfix][docs] Add note for state schema evolution in upgrading doc

KarmaGYZ opened a new pull request #7465: [hotfix][docs] Add note for state schema evolution in upgrading doc URL: https://github.com/apache/flink/pull/7465 ## What is the purpose of the change This PR add note for state schema evolution in upgrading doc ## Brief change log

[jira] [Commented] (FLINK-11304) Typo in time attributes doc

[ https://issues.apache.org/jira/browse/FLINK-11304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740004#comment-16740004 ] Jaryzhen commented on FLINK-11304: -- Hey, Anyone who can assign this to me? > Typo in time attributes

[jira] [Created] (FLINK-11304) Typo in time attributes doc

Jaryzhen created FLINK-11304: Summary: Typo in time attributes doc Key: FLINK-11304 URL: https://issues.apache.org/jira/browse/FLINK-11304 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-11082) Increase backlog only if it is available for consumption

[ https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739998#comment-16739998 ] zhijiang commented on FLINK-11082: -- [~pnowojski], thanks for replies! It might not make sense to

[GitHub] sunhaibotb commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S…

sunhaibotb commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S… URL: https://github.com/apache/flink/pull/7403#discussion_r246994962 ## File path:

[GitHub] intsmaze opened a new pull request #7464: Update state.md

intsmaze opened a new pull request #7464: Update state.md URL: https://github.com/apache/flink/pull/7464 ## What is the purpose of the change *invoke(Object) is deprecated, Use invoke(Object, Context) instead of it in the document * ## Brief change log

[GitHub] eaglewatcherwb opened a new pull request #7461: Rename configuration options of queryable-state from query.x to queryable-state.x

eaglewatcherwb opened a new pull request #7461: Rename configuration options of queryable-state from query.x to queryable-state.x URL: https://github.com/apache/flink/pull/7461 ## What is the purpose of the change Rename configuration options of queryable-state from

[GitHub] sunhaibotb commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S…

sunhaibotb commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S… URL: https://github.com/apache/flink/pull/7403#discussion_r246991737 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S…

sunjincheng121 commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S… URL: https://github.com/apache/flink/pull/7403#discussion_r246987401 ## File path:

[GitHub] sunjincheng121 commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S…

sunjincheng121 commented on a change in pull request #7403: [FLINK-11256] Replace the reference of StreamNode object with ID in S… URL: https://github.com/apache/flink/pull/7403#discussion_r246986459 ## File path:

[jira] [Commented] (FLINK-11253) Incorrect way to stop yarn session described in yarn_setup document

[ https://issues.apache.org/jira/browse/FLINK-11253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739950#comment-16739950 ] Tao Yang commented on FLINK-11253: -- Thanks [~till.rohrmann] for the review and commit. > Incorrect way

[GitHub] yt526 commented on a change in pull request #7414: [FLINK-11253] Add shutdown hook for yarn session client in attached mode

yt526 commented on a change in pull request #7414: [FLINK-11253] Add shutdown hook for yarn session client in attached mode URL: https://github.com/apache/flink/pull/7414#discussion_r246985655 ## File path:

[jira] [Commented] (FLINK-9700) Document FlinkKafkaProducer behaviour for Kafka versions > 0.11

[ https://issues.apache.org/jira/browse/FLINK-9700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739914#comment-16739914 ] leesf commented on FLINK-9700: -- [~pnowojski], ok, what we discussed in this ticket is documented in [kafka

[jira] [Created] (FLINK-11303) Utilizing Kafka headers for serialization and deserialization

Allen Wang created FLINK-11303: -- Summary: Utilizing Kafka headers for serialization and deserialization Key: FLINK-11303 URL: https://issues.apache.org/jira/browse/FLINK-11303 Project: Flink

[GitHub] AlphaGarden edited a comment on issue #7312: [FLINK-11169][runtime] fix the problem of not being reloaded for jobmanager's…

AlphaGarden edited a comment on issue #7312: [FLINK-11169][runtime] fix the problem of not being reloaded for jobmanager's… URL: https://github.com/apache/flink/pull/7312#issuecomment-453243892 > I think we can add a new internal field `shouldSetCacheHeaders` (or something like this) and

[GitHub] AlphaGarden commented on issue #7312: [FLINK-11169][runtime] fix the problem of not being reloaded for jobmanager's…

AlphaGarden commented on issue #7312: [FLINK-11169][runtime] fix the problem of not being reloaded for jobmanager's… URL: https://github.com/apache/flink/pull/7312#issuecomment-453243892 > I think we can add a new internal field `shouldSetCacheHeaders` (or something like this) and when

[jira] [Updated] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues

[ https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11187: --- Labels: pull-request-available (was: ) > StreamingFileSink with S3 backend transient

[jira] [Commented] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues

[ https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739662#comment-16739662 ] Addison Higham commented on FLINK-11187: PR opened here:

[GitHub] addisonj opened a new pull request #7460: [FLINK-11187] [s3] Use file over stream for writes

addisonj opened a new pull request #7460: [FLINK-11187] [s3] Use file over stream for writes URL: https://github.com/apache/flink/pull/7460 ## What is the purpose of the change This changes the S3AccessHelper API to take a file instead of an input stream. This allows

[GitHub] GJL commented on a change in pull request #7441: [FLINK-11156][tests, runtime] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9

GJL commented on a change in pull request #7441: [FLINK-11156][tests, runtime] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9 URL: https://github.com/apache/flink/pull/7441#discussion_r246861639 ## File path:

[GitHub] GJL commented on a change in pull request #7441: [FLINK-11156][tests, runtime] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9

GJL commented on a change in pull request #7441: [FLINK-11156][tests, runtime] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9 URL: https://github.com/apache/flink/pull/7441#discussion_r246861687 ## File path:

[GitHub] GJL commented on a change in pull request #7441: [FLINK-11156][tests, runtime] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9

GJL commented on a change in pull request #7441: [FLINK-11156][tests, runtime] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9 URL: https://github.com/apache/flink/pull/7441#discussion_r246861416 ## File path:

[GitHub] HuangZhenQiu commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager

HuangZhenQiu commented on a change in pull request #7356: [FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager URL: https://github.com/apache/flink/pull/7356#discussion_r246860798 ## File path:

[jira] [Resolved] (FLINK-11253) Incorrect way to stop yarn session described in yarn_setup document

[ https://issues.apache.org/jira/browse/FLINK-11253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-11253. --- Resolution: Fixed Fix Version/s: 1.8.0 Fixed via

[GitHub] tillrohrmann opened a new pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

tillrohrmann opened a new pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459 ## What is the purpose of the change Introduce WebOptions.METRIC_FETCHER_UPDATE_INTERVAL configuration option to configure

[GitHub] asfgit closed pull request #7414: [FLINK-11253] Add shutdown hook for yarn session client in attached mode

asfgit closed pull request #7414: [FLINK-11253] Add shutdown hook for yarn session client in attached mode URL: https://github.com/apache/flink/pull/7414 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Updated] (FLINK-11302) FlinkS3FileSystem uses an incorrect path for temporary files.

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

[GitHub] art4ul opened a new pull request #7458: [FLINK-11302] FlinkS3FileSystem uses an incorrect path for temporary files.

art4ul opened a new pull request #7458: [FLINK-11302] FlinkS3FileSystem uses an incorrect path for temporary files. URL: https://github.com/apache/flink/pull/7458 ## What is the purpose of the change This pull request fixes the bug

[jira] [Updated] (FLINK-11302) FlinkS3FileSystem uses an incorrect path for temporary files.

[ https://issues.apache.org/jira/browse/FLINK-11302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artsem Semianenka updated FLINK-11302: -- Description: I'm running the Flink job which stores the parquet files on S3. For that

[GitHub] dawidwys commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation

dawidwys commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation URL: https://github.com/apache/flink/pull/7258#issuecomment-453135673 +1, merging when my travis gives green

[GitHub] linyiqun commented on issue #7457: [FLINK-11297][docs] Add a doc link of jobmanager ha details.

linyiqun commented on issue #7457: [FLINK-11297][docs] Add a doc link of jobmanager ha details. URL: https://github.com/apache/flink/pull/7457#issuecomment-453134175 Also fix a minor bug of section rendering. This is an

[jira] [Updated] (FLINK-11297) Add a doc link of jobmanager ha details

[ https://issues.apache.org/jira/browse/FLINK-11297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11297: --- Labels: pull-request-available (was: ) > Add a doc link of jobmanager ha details >

[GitHub] linyiqun opened a new pull request #7457: [FLINK-11297][docs] Add a doc link of jobmanager ha details.

linyiqun opened a new pull request #7457: [FLINK-11297][docs] Add a doc link of jobmanager ha details. URL: https://github.com/apache/flink/pull/7457 Add a doc link of jobmanager ha details. This is a document change so no test needed to add.

[GitHub] wangxlong edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

wangxlong edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-453126852 Besides the 'select proctime' case, windowStart and windowEnd fields also have this

[GitHub] wangxlong edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

wangxlong edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-453126852 Besides the 'select proctime' case, windowStart and windowEnd fields also have this

[GitHub] wangxlong commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime()

wangxlong commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp is inconsistent with currentProcessingTime() URL: https://github.com/apache/flink/pull/7180#issuecomment-453126852 Besides the 'select proctime' case, windowStart and windowEnd fields also have this problem

[jira] [Commented] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739476#comment-16739476 ] Chesnay Schepler commented on FLINK-11301: -- The linked build finished successfully. > Travis

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246361402 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246774009 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246775496 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246428260 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246419067 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246774607 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246785880 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246427849 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246379055 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246422514 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246771871 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246378044 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246785747 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

StefanRRichter commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r246772202 ## File path:

[jira] [Created] (FLINK-11302) FlinkS3FileSystem uses an incorrect path for temporary files.

Artsem Semianenka created FLINK-11302: - Summary: FlinkS3FileSystem uses an incorrect path for temporary files. Key: FLINK-11302 URL: https://issues.apache.org/jira/browse/FLINK-11302 Project:

[jira] [Closed] (FLINK-2606) Extend StormFileSpout to handle HDFS

[ https://issues.apache.org/jira/browse/FLINK-2606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2606. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Closed] (FLINK-2836) Cyclic Topologies not supported

[ https://issues.apache.org/jira/browse/FLINK-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2836. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Closed] (FLINK-2588) Implement KillOptions

[ https://issues.apache.org/jira/browse/FLINK-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2588. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Updated] (FLINK-7359) flink-storm should update ComponentConfiguration to stormConfig

[ https://issues.apache.org/jira/browse/FLINK-7359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7359: Component/s: (was: flink-contrib) Storm Compatibility > flink-storm

[jira] [Closed] (FLINK-7359) flink-storm should update ComponentConfiguration to stormConfig

[ https://issues.apache.org/jira/browse/FLINK-7359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7359. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Updated] (FLINK-7359) flink-storm should update ComponentConfiguration to stormConfig

[ https://issues.apache.org/jira/browse/FLINK-7359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7359: -- Labels: pull-request-available (was: ) > flink-storm should update ComponentConfiguration to

[GitHub] zentol closed pull request #3615: [FLINK-2720] support flink-storm metrics

zentol closed pull request #3615: [FLINK-2720] support flink-storm metrics URL: https://github.com/apache/flink/pull/3615 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull

[GitHub] zentol closed pull request #4467: [FLINK-7359] flink-storm should update ComponentConfiguration to stor…

zentol closed pull request #4467: [FLINK-7359] flink-storm should update ComponentConfiguration to stor… URL: https://github.com/apache/flink/pull/4467 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Closed] (FLINK-3117) Storm Tick Tuples are not supported

[ https://issues.apache.org/jira/browse/FLINK-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3117. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. > Storm

[jira] [Closed] (FLINK-3144) [storm] LocalCluster prints nothing without a configured logger

[ https://issues.apache.org/jira/browse/FLINK-3144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3144. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. >

[jira] [Closed] (FLINK-2571) Add task hooks support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2571. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. > Add

[GitHub] zentol commented on issue #3615: [FLINK-2720] support flink-storm metrics

zentol commented on issue #3615: [FLINK-2720] support flink-storm metrics URL: https://github.com/apache/flink/pull/3615#issuecomment-453108081 The storm-compatibility layer will be removed in FLINK-10509. Closing this PR.

[jira] [Closed] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility

[ https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2720. --- Resolution: Won't Fix The storm-compatibility layer will be removed in FLINK-10509. > Add

[GitHub] zentol commented on issue #4467: [FLINK-7359] flink-storm should update ComponentConfiguration to stor…

zentol commented on issue #4467: [FLINK-7359] flink-storm should update ComponentConfiguration to stor… URL: https://github.com/apache/flink/pull/4467#issuecomment-453108058 The storm-compatibility layer will be removed in FLINK-10509. Closing this PR.

[GitHub] zentol opened a new pull request #7456: [FLINK-11289][examples] Rework examples to account for licensing

zentol opened a new pull request #7456: [FLINK-11289][examples] Rework examples to account for licensing URL: https://github.com/apache/flink/pull/7456 ## What is the purpose of the change This PR adds separate fat-jar modules for the twitter and state-machine examples so that we

[jira] [Updated] (FLINK-11289) Rework example module structure to account for licensing

[ https://issues.apache.org/jira/browse/FLINK-11289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11289: --- Labels: pull-request-available (was: ) > Rework example module structure to account for

[GitHub] zentol closed pull request #7444: [FLINK-11289][examples] Rework examples to account for licensing

zentol closed pull request #7444: [FLINK-11289][examples] Rework examples to account for licensing URL: https://github.com/apache/flink/pull/7444 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance:

[GitHub] dawidwys commented on issue #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution …

dawidwys commented on issue #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution … URL: https://github.com/apache/flink/pull/7436#issuecomment-453101329 Thanks for the contribution @eaglewatcherwb . I don't think we should introduce incompatibilities with that

[GitHub] zentol commented on issue #7444: [FLINK-11289][examples] Rework examples to account for licensing

zentol commented on issue #7444: [FLINK-11289][examples] Rework examples to account for licensing URL: https://github.com/apache/flink/pull/7444#issuecomment-453099291 There's an issue with the NOTICE file merging for these modules, will re-open once i found the cause.

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

hequn8128 edited a comment on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-453096853 @pnowojski Thanks a lot for the view. I have updated the PR according to your suggestions. Mainly

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

hequn8128 commented on issue #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#issuecomment-453096853 @pnowojski Thanks a lot for the view. I have updated the PR according to your suggestions. Mainly include

  1   2   >