[jira] [Created] (FLINK-11987) Kafka producer occasionally throws NullpointerException

LIU Xiao created FLINK-11987: Summary: Kafka producer occasionally throws NullpointerException Key: FLINK-11987 URL: https://issues.apache.org/jira/browse/FLINK-11987 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-11982) org.apache.flink.table.api.NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797876#comment-16797876 ] pingle wang commented on FLINK-11982: - sorry, I use BatchEnv. StreamEnv support. so

[jira] [Commented] (FLINK-11982) org.apache.flink.table.api.NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797846#comment-16797846 ] pingle wang commented on FLINK-11982: - [~frank wang] so do you think this issue? >

[GitHub] [flink] chermenin commented on a change in pull request #8022: [FLINK-11968] [runtime] Fixed SingleElementIterator and removed duplicate

chermenin commented on a change in pull request #8022: [FLINK-11968] [runtime] Fixed SingleElementIterator and removed duplicate URL: https://github.com/apache/flink/pull/8022#discussion_r267627267 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/SingleElemen

[jira] [Assigned] (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 ] Louis Xu reassigned FLINK-8585: --- Assignee: Louis Xu (was: Bowen Li) > Efficiently handle read-only and non array ByteBuffers in > D

[GitHub] [flink] zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267622641 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] wuchong commented on a change in pull request #8022: [FLINK-11968] [runtime] Fixed SingleElementIterator and removed duplicate

wuchong commented on a change in pull request #8022: [FLINK-11968] [runtime] Fixed SingleElementIterator and removed duplicate URL: https://github.com/apache/flink/pull/8022#discussion_r267622518 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/SingleElementI

[GitHub] [flink] zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267620888 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267619685 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

zhijiangW commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267611334 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] zhijiangW commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186)

zhijiangW commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186) URL: https://github.com/apache/flink/pull/7938#issuecomment-475094356 After some further discussions with @azagrebin online, we reached an agreement for the current con

[jira] [Commented] (FLINK-11982) org.apache.flink.table.api.NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797735#comment-16797735 ] pingle wang commented on FLINK-11982: - I add flink-json jar and   /META-INF/services

[GitHub] [flink] klion26 commented on a change in pull request #8008: [FLINK-11963][History Server]Add time-based cleanup mechanism in history server

klion26 commented on a change in pull request #8008: [FLINK-11963][History Server]Add time-based cleanup mechanism in history server URL: https://github.com/apache/flink/pull/8008#discussion_r267608121 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonito

[jira] [Commented] (FLINK-11982) org.apache.flink.table.api.NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797728#comment-16797728 ] frank wang commented on FLINK-11982: it looks like you have not provide enough prope

[jira] [Assigned] (FLINK-11982) org.apache.flink.table.api.NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] frank wang reassigned FLINK-11982: -- Assignee: frank wang > org.apache.flink.table.api.NoMatchingTableFactoryException > -

[GitHub] [flink] klion26 commented on a change in pull request #8008: [FLINK-11963][History Server]Add time-based cleanup mechanism in history server

klion26 commented on a change in pull request #8008: [FLINK-11963][History Server]Add time-based cleanup mechanism in history server URL: https://github.com/apache/flink/pull/8008#discussion_r267607149 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonito

[GitHub] [flink] klion26 commented on issue #7921: [FLINK-11825][StateBackends] Resolve name clash of StateTTL TimeCharacteristic class

klion26 commented on issue #7921: [FLINK-11825][StateBackends] Resolve name clash of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921#issuecomment-475090093 thank you all for the review :) This

[jira] [Closed] (FLINK-11872) update lz4 license file

[ https://issues.apache.org/jira/browse/FLINK-11872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11872. -- Resolution: Fixed Fix Version/s: 1.9.0 fixed in 5bd7ed4364497577709e9225f0522adb0b428e7a > upd

[GitHub] [flink] KurtYoung merged pull request #7952: [FLINK-11872][table-runtime-blink] update lz4 license file.

KurtYoung merged pull request #7952: [FLINK-11872][table-runtime-blink] update lz4 license file. URL: https://github.com/apache/flink/pull/7952 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8027: [FLINK-11972] [docs] Add necessary notes about running streaming bucketing e2e test in README

sunjincheng121 commented on a change in pull request #8027: [FLINK-11972] [docs] Add necessary notes about running streaming bucketing e2e test in README URL: https://github.com/apache/flink/pull/8027#discussion_r267589148 ## File path: flink-end-to-end-tests/README.md ##

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797646#comment-16797646 ] Yu Li commented on FLINK-11972: --- Checked and confirmed with hadoop 2.6.5 the same test pas

[jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11972: --- Labels: pull-request-available (was: ) > The classpath is missing the `flink-shaded-hadoop2

[GitHub] [flink] flinkbot commented on issue #8027: [FLINK-11972] [docs] Add necessary notes about running streaming bucketing e2e test in README

flinkbot commented on issue #8027: [FLINK-11972] [docs] Add necessary notes about running streaming bucketing e2e test in README URL: https://github.com/apache/flink/pull/8027#issuecomment-475058251 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help t

[GitHub] [flink] carp84 opened a new pull request #8027: [FLINK-11972] [docs] Add necessary notes about running streaming bucketing e2e test in README

carp84 opened a new pull request #8027: [FLINK-11972] [docs] Add necessary notes about running streaming bucketing e2e test in README URL: https://github.com/apache/flink/pull/8027 ## What is the purpose of the change * Add necessary notes to make it easier for running streaming buck

[jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Attachment: screenshot-1.png > The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0

[jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11972: Attachment: image-2019-03-21-06-26-49-787.png > The classpath is missing the `flink-shaded-hadoop2

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797614#comment-16797614 ] Yu Li commented on FLINK-11972: --- I tried the streaming bucket case on two environments, Ma

[GitHub] [flink] flinkbot commented on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear…

flinkbot commented on issue #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear… URL: https://github.com/apache/flink/pull/8026#issuecomment-475049828 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] npav commented on issue #3977: [FLINK-5490] Not allowing sinks to be cleared when getting the execut…

npav commented on issue #3977: [FLINK-5490] Not allowing sinks to be cleared when getting the execut… URL: https://github.com/apache/flink/pull/3977#issuecomment-475049924 Included the fix + test in https://github.com/apache/flink/pull/8026 -

[GitHub] [flink] npav opened a new pull request #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear…

npav opened a new pull request #8026: [FLINK-5490] prevent ContextEnvironment#getExecutionPlan() from clear… URL: https://github.com/apache/flink/pull/8026 …ing the sinks ## What is the purpose of the change This pull request prevents ContextEnvironment#getExecutionPlan() from

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797561#comment-16797561 ] sunjincheng commented on FLINK-11972: - Sounds good! > The classpath is missing the

[jira] [Commented] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797516#comment-16797516 ] sunjincheng commented on FLINK-11971: - Thanks for taking this JIRA. [~hequn8128]! Du

[jira] [Comment Edited] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797528#comment-16797528 ] Yu Li edited comment on FLINK-11972 at 3/20/19 8:37 PM: bq. I ap

[jira] [Assigned] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-11972: - Assignee: Yu Li > The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR > durin

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797528#comment-16797528 ] Yu Li commented on FLINK-11972: --- bq. I appreciate if you want to take this ticket and fix

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797524#comment-16797524 ] sunjincheng commented on FLINK-11972: - Hi [~carp84] Thanks for your feedback! and do

[jira] [Closed] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11971. --- Resolution: Fixed Fix Version/s: 1.9.0 1.8.0 Release Note: Fix kuberne

[GitHub] [flink] asfgit closed pull request #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

asfgit closed pull request #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024 This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on issue #7952: [FLINK-11872][table-runtime-blink] update lz4 license file.

flinkbot edited a comment on issue #7952: [FLINK-11872][table-runtime-blink] update lz4 license file. URL: https://github.com/apache/flink/pull/7952#issuecomment-471516150 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[jira] [Commented] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.

[ https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797504#comment-16797504 ] Yu Li commented on FLINK-11972: --- There's another necessity to run the {{test_streaming_buc

[GitHub] [flink] flinkbot edited a comment on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

flinkbot edited a comment on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-474882848 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pu

[GitHub] [flink] sunjincheng121 commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

sunjincheng121 commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-475005137 @flinkbot approve all This is an automated message from the

[GitHub] [flink] sunjincheng121 commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

sunjincheng121 commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-475004941 Thanks for the quick fix @aljoscha! It works well from my local ENV(iMac) Merging... Best, Jincheng -

[GitHub] [flink] azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267514203 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267510295 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267511422 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267513101 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] flinkbot edited a comment on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

flinkbot edited a comment on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-474882848 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pu

[GitHub] [flink] sunjincheng121 edited a comment on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

sunjincheng121 edited a comment on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-474994662 Thank you @aljoscha @dawidwys @hequn8128 I am checking the change now... -

[GitHub] [flink] sunjincheng121 commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

sunjincheng121 commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-474994662 Thank you @aljoscha @dawidwys I am checking the change now... ---

[GitHub] [flink] sunjincheng121 commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

sunjincheng121 commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-474994359 @flinkbot approve description @flinkbot approve consensus

[GitHub] [flink] zentol merged pull request #7914: [FLINK-11786][travis] Merge cron branches into master

zentol merged pull request #7914: [FLINK-11786][travis] Merge cron branches into master URL: https://github.com/apache/flink/pull/7914 This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Issue Comment Deleted] (FLINK-11984) StreamingFileSink docs do not mention S3 savepoint caveats.

[ https://issues.apache.org/jira/browse/FLINK-11984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Grier updated FLINK-11984: Comment: was deleted (was: [~kkl0u] What are the S3 savepoint caveats?) > StreamingFileSink docs

[jira] [Commented] (FLINK-11984) StreamingFileSink docs do not mention S3 savepoint caveats.

[ https://issues.apache.org/jira/browse/FLINK-11984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797404#comment-16797404 ] Jamie Grier commented on FLINK-11984: - [~kkl0u] What are the S3 savepoint caveats?

[GitHub] [flink] flinkbot commented on issue #8025: [docs] fix typos in Task class

flinkbot commented on issue #8025: [docs] fix typos in Task class URL: https://github.com/apache/flink/pull/8025#issuecomment-474943155 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this co

[GitHub] [flink] linuxhadoop opened a new pull request #8025: [docs] fix typos in Task class

linuxhadoop opened a new pull request #8025: [docs] fix typos in Task class URL: https://github.com/apache/flink/pull/8025 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] npav commented on issue #3977: [FLINK-5490] Not allowing sinks to be cleared when getting the execut…

npav commented on issue #3977: [FLINK-5490] Not allowing sinks to be cleared when getting the execut… URL: https://github.com/apache/flink/pull/3977#issuecomment-474941597 What's the status of this? I ran into the same issue and found out this bug independently as well. Is someone working

[GitHub] [flink] npav edited a comment on issue #3977: [FLINK-5490] Not allowing sinks to be cleared when getting the execut…

npav edited a comment on issue #3977: [FLINK-5490] Not allowing sinks to be cleared when getting the execut… URL: https://github.com/apache/flink/pull/3977#issuecomment-474941597 What's the status of this? I ran into the same issue and discovered this bug independently as well. Is someone

[jira] [Created] (FLINK-11986) Add micro benchmark for state operations

Yu Li created FLINK-11986: - Summary: Add micro benchmark for state operations Key: FLINK-11986 URL: https://issues.apache.org/jira/browse/FLINK-11986 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-11986) Add micro benchmark for state operations

[ https://issues.apache.org/jira/browse/FLINK-11986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-11986: -- Component/s: Runtime / State Backends > Add micro benchmark for state operations > ---

[GitHub] [flink] dawidwys merged pull request #8017: [hotfix][table] Introduced UnresolvedFieldReference & ResolvedFieldReference expressions

dawidwys merged pull request #8017: [hotfix][table] Introduced UnresolvedFieldReference & ResolvedFieldReference expressions URL: https://github.com/apache/flink/pull/8017 This is an automated message from the Apache Git S

[GitHub] [flink] aljoscha commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

aljoscha commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-474905652 cc @sunjincheng121 This is an automated message from the Apache G

[jira] [Comment Edited] (FLINK-11965) Provide a REST API for flink to submit plain SQL flink jobs.

[ https://issues.apache.org/jira/browse/FLINK-11965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797286#comment-16797286 ] chenminghua edited comment on FLINK-11965 at 3/20/19 3:54 PM:

[jira] [Commented] (FLINK-11965) Provide a REST API for flink to submit plain SQL flink jobs.

[ https://issues.apache.org/jira/browse/FLINK-11965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797286#comment-16797286 ] chenminghua commented on FLINK-11965: - Timo Walther,Thank you for your attention!  

[jira] [Commented] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797275#comment-16797275 ] Hequn Cheng commented on FLINK-11971: - [~sunjincheng121] Thanks for looking into the

[GitHub] [flink] azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment

azagrebin commented on a change in pull request #7822: [FLINK-11726][network] Refactor the creation of ResultPartition and InputGate into NetworkEnvironment URL: https://github.com/apache/flink/pull/7822#discussion_r267402197 ## File path: flink-runtime/src/main/java/org/apache/fli

[GitHub] [flink] flinkbot commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

flinkbot commented on issue #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024#issuecomment-474882848 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull requ

[jira] [Updated] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error

[ https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11971: --- Labels: pull-request-available (was: ) > Fix `Command: start_kubernetes_if_not_ruunning fai

[GitHub] [flink] aljoscha opened a new pull request #8024: [FLINK-11971] Fix kubernetes check in end-to-end test

aljoscha opened a new pull request #8024: [FLINK-11971] Fix kubernetes check in end-to-end test URL: https://github.com/apache/flink/pull/8024 @dawidwys You originally added this. Do you think this simpler check would work as well? @hequn8128 Sorry for taking this issue, but I quick

[jira] [Assigned] (FLINK-11431) Akka dependency not compatible with java 9 or above

[ https://issues.apache.org/jira/browse/FLINK-11431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11431: Assignee: Chesnay Schepler > Akka dependency not compatible with java 9 or above

[jira] [Created] (FLINK-11985) Remove ignored command line parameter from yarn_setup.md

Guowei Ma created FLINK-11985: - Summary: Remove ignored command line parameter from yarn_setup.md Key: FLINK-11985 URL: https://issues.apache.org/jira/browse/FLINK-11985 Project: Flink Issue Type

[GitHub] [flink] azagrebin commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186)

azagrebin commented on issue #7938: [FLINK-10941] Keep slots which contain unconsumed result partitions (on top of #7186) URL: https://github.com/apache/flink/pull/7938#issuecomment-474868838 Thanks for review @zhijiangW and @QiLuo-BD ! As discussed, I agree that consumer confirmatio

[GitHub] [flink] sunhaibotb commented on a change in pull request #7959: [FLINK-11876] Introduce new InputSelectable, BoundedOneInput and BoundedMultiInput interfaces

sunhaibotb commented on a change in pull request #7959: [FLINK-11876] Introduce new InputSelectable, BoundedOneInput and BoundedMultiInput interfaces URL: https://github.com/apache/flink/pull/7959#discussion_r267379312 ## File path: flink-streaming-java/src/main/java/org/apache/fli

[jira] [Closed] (FLINK-11825) Resolve name clash of StateTTL TimeCharacteristic class

[ https://issues.apache.org/jira/browse/FLINK-11825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11825. Resolution: Fixed Fixed on master in 6a66f7acf370e12ad65ee24293ed47d2c5db225c > Resolve n

[GitHub] [flink] aljoscha commented on issue #7921: [FLINK-11825][StateBackends] Resolve name clash of StateTTL TimeCharacteristic class

aljoscha commented on issue #7921: [FLINK-11825][StateBackends] Resolve name clash of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921#issuecomment-474862257 Thanks for your contribution! I merged this. ---

[GitHub] [flink] aljoscha closed pull request #7921: [FLINK-11825][StateBackends] Resolve name clash of StateTTL TimeCharacteristic class

aljoscha closed pull request #7921: [FLINK-11825][StateBackends] Resolve name clash of StateTTL TimeCharacteristic class URL: https://github.com/apache/flink/pull/7921 This is an automated message from the Apache Git Service

[jira] [Assigned] (FLINK-11985) Remove ignored command line parameter from yarn_setup.md

[ https://issues.apache.org/jira/browse/FLINK-11985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-11985: - Assignee: Guowei Ma > Remove ignored command line parameter from yarn_setup.md > --

[GitHub] [flink] flinkbot edited a comment on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type

flinkbot edited a comment on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#issuecomment-472607121 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] [flink] rmetzger commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type

rmetzger commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#issuecomment-474857889 @suez1224 I'm sorry that the @flinkbot didn't know that you are a committer of Flink. I've updated the config and restarte

[GitHub] [flink] flinkbot edited a comment on issue #7980: [FLINK-11913] Shadding cassandra driver dependencies in cassandra conector

flinkbot edited a comment on issue #7980: [FLINK-11913] Shadding cassandra driver dependencies in cassandra conector URL: https://github.com/apache/flink/pull/7980#issuecomment-472641520 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type

flinkbot edited a comment on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#issuecomment-472607121 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] [flink] rmetzger commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type

rmetzger commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#issuecomment-474850989 @flinkbot approve description consensus This is an automated

[jira] [Commented] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

[ https://issues.apache.org/jira/browse/FLINK-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16797209#comment-16797209 ] Robert Metzger commented on FLINK-11910: +1 I think this is a valid feature requ

[GitHub] [flink] flinkbot edited a comment on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

flinkbot edited a comment on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#issuecomment-470507137 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] zentol commented on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#issuecomment-474849580 @flinkbot approve-until consensus This is an aut

[GitHub] [flink] rmetzger commented on issue #7980: [FLINK-11913] Shadding cassandra driver dependencies in cassandra conector

rmetzger commented on issue #7980: [FLINK-11913] Shadding cassandra driver dependencies in cassandra conector URL: https://github.com/apache/flink/pull/7980#issuecomment-474849469 @flinkbot attention @zentol This is an autom

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267351817 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServ

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267356838 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQ

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267349122 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQ

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267357099 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQ

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267353233 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/metrics/MetricRegist

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267352698 ## File path: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskMan

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267354546 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/TestingRe

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267357433 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQ

[GitHub] [flink] rmetzger merged pull request #8013: Minor example typo fix

rmetzger merged pull request #8013: Minor example typo fix URL: https://github.com/apache/flink/pull/8013 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink] flinkbot edited a comment on issue #8013: Minor example typo fix

flinkbot edited a comment on issue #8013: Minor example typo fix URL: https://github.com/apache/flink/pull/8013#issuecomment-474627783 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this com

[GitHub] [flink] rmetzger commented on issue #8013: Minor example typo fix

rmetzger commented on issue #8013: Minor example typo fix URL: https://github.com/apache/flink/pull/8013#issuecomment-474847205 @flinkbot approve all Thanks a lot for the PR. I'll merge it right away! This is an automat

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r267347589 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegist

[GitHub] [flink] vthinkxie commented on issue #8016: [FLINK-10705][web]: Rework Flink Web Dashboard

vthinkxie commented on issue #8016: [FLINK-10705][web]: Rework Flink Web Dashboard URL: https://github.com/apache/flink/pull/8016#issuecomment-474846099 Hi @rmetzger Thanks a lot for your comments! > Problems I encountered: > > * Scrolling in this area I marked blue leads

[jira] [Resolved] (FLINK-11980) Improve efficiency of iterating KeySelectionListener on notification

[ https://issues.apache.org/jira/browse/FLINK-11980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter resolved FLINK-11980. Resolution: Fixed Fix Version/s: 1.9.0 1.8.0 Merged in: master:

  1   2   3   >