[jira] [Comment Edited] (FLINK-10074) Allowable number of checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580624#comment-16580624 ] Thomas Weise edited comment on FLINK-10074 at 8/15/18 4:09 AM: ---

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580699#comment-16580699 ] Thomas Weise commented on FLINK-10074: -- [~yanghua] this is what I meant also, I updated my comment

[jira] [Comment Edited] (FLINK-10074) Allowable number of checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580624#comment-16580624 ] Thomas Weise edited comment on FLINK-10074 at 8/15/18 4:07 AM: ---

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580687#comment-16580687 ] vinoyang commented on FLINK-10074: -- [~thw] I personally prefer that once JM failover, the counter will

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580677#comment-16580677 ] ASF GitHub Bot commented on FLINK-8532: --- Guibo-Pan commented on issue #6544: [FLINK-8532]

[GitHub] Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#issuecomment-413082655 cc @tillrohrmann could you help review this?

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580627#comment-16580627 ] vinoyang commented on FLINK-: - [~walterddr] I don't know if this is the SQL standard Scalar function,

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580624#comment-16580624 ] Thomas Weise commented on FLINK-10074: -- [~till.rohrmann] it is probably unreasonably hard to do for

[jira] [Assigned] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

[ https://issues.apache.org/jira/browse/FLINK-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8953: - Assignee: (was: Renjie Liu) > Resolve unresolved field references in FieldComputer

[jira] [Commented] (FLINK-10101) Mesos web ui url is missing.

[ https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580531#comment-16580531 ] ASF GitHub Bot commented on FLINK-10101: liurenjie1024 commented on issue #6522:

[GitHub] liurenjie1024 commented on issue #6522: [FLINK-10101][mesos] Add web ui url for mesos.

liurenjie1024 commented on issue #6522: [FLINK-10101][mesos] Add web ui url for mesos. URL: https://github.com/apache/flink/pull/6522#issuecomment-413045382 @GJL I've fixed your comments. This is an automated message from

[jira] [Commented] (FLINK-9488) Create common entry point for master and workers

[ https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580468#comment-16580468 ] Prithvi Raj commented on FLINK-9488: I'm not sure whether this is the right place to ask, but how

[jira] [Commented] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580343#comment-16580343 ] ASF GitHub Bot commented on FLINK-10022: NicoK closed pull request #6551:

[GitHub] NicoK closed pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers

NicoK closed pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers URL: https://github.com/apache/flink/pull/6551 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:

[jira] [Updated] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

[ https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10042: --- Labels: pull-request-available (was: ) > Extract snapshot algorithms from inner classes

[jira] [Commented] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

[ https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580284#comment-16580284 ] ASF GitHub Bot commented on FLINK-10042: StefanRRichter commented on issue #6556:

[jira] [Commented] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes

[ https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580283#comment-16580283 ] ASF GitHub Bot commented on FLINK-10042: StefanRRichter opened a new pull request #6556:

[GitHub] StefanRRichter commented on issue #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

StefanRRichter commented on issue #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes URL: https://github.com/apache/flink/pull/6556#issuecomment-412980594 CC @azagrebin

[GitHub] StefanRRichter opened a new pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

StefanRRichter opened a new pull request #6556: FLINK-10042][state] Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes URL: https://github.com/apache/flink/pull/6556 ## What is the purpose of the change This PR is part 2 in the

[GitHub] walterddr commented on a change in pull request #6508: [Flink-10079] [table] Automatically register sink table from external catalogs

walterddr commented on a change in pull request #6508: [Flink-10079] [table] Automatically register sink table from external catalogs URL: https://github.com/apache/flink/pull/6508#discussion_r210052280 ## File path:

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580197#comment-16580197 ] Rong Rong commented on FLINK-: -- I do not have access to the newest SQL 2016 standard, but is

[jira] [Commented] (FLINK-10079) Automatically register sink table from external catalogs

[ https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580192#comment-16580192 ] Rong Rong commented on FLINK-10079: --- I agree we should either make the documentation more consistent,

[jira] [Assigned] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-10145: - Assignee: Guibo Pan > Add replace supported in TableAPI and SQL >

[jira] [Commented] (FLINK-10101) Mesos web ui url is missing.

[ https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580143#comment-16580143 ] ASF GitHub Bot commented on FLINK-10101: GJL commented on a change in pull request #6522:

[GitHub] GJL commented on a change in pull request #6522: [FLINK-10101][mesos] Add web ui url for mesos.

GJL commented on a change in pull request #6522: [FLINK-10101][mesos] Add web ui url for mesos. URL: https://github.com/apache/flink/pull/6522#discussion_r210040604 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java

[jira] [Commented] (FLINK-10101) Mesos web ui url is missing.

[ https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580142#comment-16580142 ] ASF GitHub Bot commented on FLINK-10101: GJL commented on a change in pull request #6522:

[jira] [Commented] (FLINK-10101) Mesos web ui url is missing.

[ https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580141#comment-16580141 ] ASF GitHub Bot commented on FLINK-10101: GJL commented on a change in pull request #6522:

[GitHub] GJL commented on a change in pull request #6522: [FLINK-10101][mesos] Add web ui url for mesos.

GJL commented on a change in pull request #6522: [FLINK-10101][mesos] Add web ui url for mesos. URL: https://github.com/apache/flink/pull/6522#discussion_r210037022 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java

[GitHub] GJL commented on a change in pull request #6522: [FLINK-10101][mesos] Add web ui url for mesos.

GJL commented on a change in pull request #6522: [FLINK-10101][mesos] Add web ui url for mesos. URL: https://github.com/apache/flink/pull/6522#discussion_r210036352 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java

[jira] [Comment Edited] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators

[ https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578793#comment-16578793 ] Rong Rong edited comment on FLINK-10019 at 8/14/18 5:39 PM: Dug a little

[GitHub] GJL commented on a change in pull request #6550: [FLINK-10137][YARN] Log completed containers.

GJL commented on a change in pull request #6550: [FLINK-10137][YARN] Log completed containers. URL: https://github.com/apache/flink/pull/6550#discussion_r210040202 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ## @@ -323,9 +323,10

[jira] [Commented] (FLINK-10137) YARN: Log completed Containers

[ https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580127#comment-16580127 ] ASF GitHub Bot commented on FLINK-10137: GJL commented on a change in pull request #6550:

[jira] [Commented] (FLINK-10137) YARN: Log completed Containers

[ https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580126#comment-16580126 ] ASF GitHub Bot commented on FLINK-10137: GJL commented on a change in pull request #6550:

[GitHub] GJL commented on a change in pull request #6550: [FLINK-10137][YARN] Log completed containers.

GJL commented on a change in pull request #6550: [FLINK-10137][YARN] Log completed containers. URL: https://github.com/apache/flink/pull/6550#discussion_r210040202 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ## @@ -323,9 +323,10

[jira] [Created] (FLINK-10145) Add replace supported in TableAPI and SQL

Guibo Pan created FLINK-10145: - Summary: Add replace supported in TableAPI and SQL Key: FLINK-10145 URL: https://issues.apache.org/jira/browse/FLINK-10145 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9101: - Fix Version/s: (was: 1.6.0) 1.7.0 1.6.1 >

[jira] [Reopened] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis

[ https://issues.apache.org/jira/browse/FLINK-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-9101: -- It failed again: https://api.travis-ci.org/v3/job/415961618/log.txt >

[jira] [Commented] (FLINK-10137) YARN: Log completed Containers

[ https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580017#comment-16580017 ] ASF GitHub Bot commented on FLINK-10137: yanghua commented on a change in pull request #6550:

[GitHub] yanghua commented on a change in pull request #6550: [FLINK-10137][YARN] Log completed containers.

yanghua commented on a change in pull request #6550: [FLINK-10137][YARN] Log completed containers. URL: https://github.com/apache/flink/pull/6550#discussion_r210015723 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ## @@ -323,9

[jira] [Commented] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

[ https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580010#comment-16580010 ] ASF GitHub Bot commented on FLINK-10144: yanghua commented on issue #6554: [FLINK-10144]delete

[GitHub] yanghua commented on issue #6554: [FLINK-10144]delete unused import akka.actor.ActorRef in TaskManagerMessages.scala

yanghua commented on issue #6554: [FLINK-10144]delete unused import akka.actor.ActorRef in TaskManagerMessages.scala URL: https://github.com/apache/flink/pull/6554#issuecomment-412928276 the change is OK, but is it worth to open a PR to do this little fix? cc @zentol

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

[ https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580001#comment-16580001 ] ASF GitHub Bot commented on FLINK-9850: --- yanghua commented on issue #6367: [FLINK-9850] Add a

[GitHub] yanghua commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

yanghua commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#issuecomment-412926404 cc @pnowojski updated This is an

[jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability

[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579950#comment-16579950 ] Jonathan Miles commented on FLINK-9061: --- Is the PR still being considered for merging? We seem to

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

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-8577: --- Description: Api will looks like: {code:java} DataStream[(String, Long, Int)] input = ??? // upsert

[jira] [Comment Edited] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579899#comment-16579899 ] Hequn Cheng edited comment on FLINK-8545 at 8/14/18 3:20 PM: - [~pnowojski]

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

[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579945#comment-16579945 ] Hequn Cheng commented on FLINK-8577: A simple design

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579907#comment-16579907 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski commented on issue #6417: [FLINK-9913][runtime]

[GitHub] pnowojski commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

pnowojski commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#issuecomment-412900643 One possible bad news. I have run benchmarks as defined in

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579899#comment-16579899 ] Hequn Cheng commented on FLINK-8545: [~pnowojski] Great to have your response. The

[jira] [Commented] (FLINK-9831) Too many open files for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579888#comment-16579888 ] Sayat Satybaldiyev commented on FLINK-9831: --- I've setup

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579867#comment-16579867 ] ASF GitHub Bot commented on FLINK-9899: --- glaksh100 commented on issue #6409: [FLINK-9899][Kinesis

[GitHub] glaksh100 commented on issue #6409: [FLINK-9899][Kinesis Connector] Add comprehensive per-shard metrics to ShardConsumer

glaksh100 commented on issue #6409: [FLINK-9899][Kinesis Connector] Add comprehensive per-shard metrics to ShardConsumer URL: https://github.com/apache/flink/pull/6409#issuecomment-412888671 @zentol @tzulitai Can you take a look at this and merge if it looks good?

[jira] [Commented] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579855#comment-16579855 ] ASF GitHub Bot commented on FLINK-10022: zentol commented on a change in pull request #6551:

[jira] [Commented] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579857#comment-16579857 ] ASF GitHub Bot commented on FLINK-10022: zentol commented on a change in pull request #6551:

[jira] [Commented] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579856#comment-16579856 ] ASF GitHub Bot commented on FLINK-10022: zentol commented on a change in pull request #6551:

[GitHub] zentol commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers

zentol commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers URL: https://github.com/apache/flink/pull/6551#discussion_r209965354 ## File path:

[GitHub] zentol commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers

zentol commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers URL: https://github.com/apache/flink/pull/6551#discussion_r209965189 ## File path:

[GitHub] zentol commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers

zentol commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers URL: https://github.com/apache/flink/pull/6551#discussion_r209965405 ## File path:

[jira] [Commented] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

[ https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579840#comment-16579840 ] chengjie.wu commented on FLINK-10144: - [~Zentol],[~lsy] I have opened a new pull request for this

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579836#comment-16579836 ] ASF GitHub Bot commented on FLINK-8532: --- Guibo-Pan commented on issue #6544: [FLINK-8532]

[GitHub] Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#issuecomment-412878869 @bowenli86 I agree that test case should be more robust, and I have updated it.

[jira] [Commented] (FLINK-10142) Reduce synchronization overhead for credit notifications

[ https://issues.apache.org/jira/browse/FLINK-10142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579833#comment-16579833 ] ASF GitHub Bot commented on FLINK-10142: NicoK opened a new pull request #6555:

[jira] [Updated] (FLINK-10142) Reduce synchronization overhead for credit notifications

[ https://issues.apache.org/jira/browse/FLINK-10142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10142: --- Labels: pull-request-available (was: ) > Reduce synchronization overhead for credit

[GitHub] NicoK opened a new pull request #6555: [FLINK-10142][network] reduce locking around credit notification

NicoK opened a new pull request #6555: [FLINK-10142][network] reduce locking around credit notification URL: https://github.com/apache/flink/pull/6555 ## What is the purpose of the change When credit-based flow control was introduced, we also added some checks and optimisations for

[jira] [Commented] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

[ https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579809#comment-16579809 ] dalongliu commented on FLINK-10144: --- [~Zentol] can you assign this issue to [~wucj],he want to

[jira] [Commented] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

[ https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579794#comment-16579794 ] ASF GitHub Bot commented on FLINK-10144: wchengjie opened a new pull request #6554:

[jira] [Updated] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

[ https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10144: --- Labels: pull-request-available (was: ) > No unused import "import akka.actor.ActorRef" in

[GitHub] wchengjie opened a new pull request #6554: [FLINK-10144]delete unused import akka.actor.ActorRef in TaskManagerMessages.scala

wchengjie opened a new pull request #6554: [FLINK-10144]delete unused import akka.actor.ActorRef in TaskManagerMessages.scala URL: https://github.com/apache/flink/pull/6554 ## What is the purpose of the change *This pull request aim to delete an useless import `import

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

[ https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579783#comment-16579783 ] ASF GitHub Bot commented on FLINK-9850: --- pnowojski edited a comment on issue #6367: [FLINK-9850]

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

[ https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579782#comment-16579782 ] ASF GitHub Bot commented on FLINK-9850: --- pnowojski commented on issue #6367: [FLINK-9850] Add a

[GitHub] pnowojski edited a comment on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski edited a comment on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#issuecomment-412868964 Yes exactly. More precisely as I wrote in one of the previous comments, this `TaskOutputWriter`

[GitHub] pnowojski commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#issuecomment-412868964 Yes exactly. More precisely as I wrote in one of the previous comments, this `TaskOutputWriter`

[jira] [Commented] (FLINK-10119) JsonRowDeserializationSchema deserialize kafka message

[ https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579779#comment-16579779 ] buptljy commented on FLINK-10119: - [~twalthr] Okay, I am going to add two optional properties. 1.

[jira] [Commented] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579760#comment-16579760 ] ASF GitHub Bot commented on FLINK-10022: NicoK commented on a change in pull request #6551:

[GitHub] NicoK commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers

NicoK commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers URL: https://github.com/apache/flink/pull/6551#discussion_r209937737 ## File path:

[jira] [Commented] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579758#comment-16579758 ] ASF GitHub Bot commented on FLINK-10022: NicoK commented on a change in pull request #6551:

[GitHub] NicoK commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers

NicoK commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers URL: https://github.com/apache/flink/pull/6551#discussion_r209937737 ## File path:

[jira] [Created] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages"

dalongliu created FLINK-10144: - Summary: No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages" Key: FLINK-10144 URL:

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579743#comment-16579743 ] ASF GitHub Bot commented on FLINK-8290: --- azagrebin commented on issue #5304: [FLINK-8290]Modify

[GitHub] azagrebin commented on issue #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8

azagrebin commented on issue #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 URL: https://github.com/apache/flink/pull/5304#issuecomment-412856931 LGTM  This is an automated message from the

[jira] [Updated] (FLINK-10141) Reduce lock contention introduced with 1.5

[ https://issues.apache.org/jira/browse/FLINK-10141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10141: --- Labels: pull-request-available (was: ) > Reduce lock contention introduced with 1.5 >

[jira] [Commented] (FLINK-10141) Reduce lock contention introduced with 1.5

[ https://issues.apache.org/jira/browse/FLINK-10141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579739#comment-16579739 ] ASF GitHub Bot commented on FLINK-10141: NicoK opened a new pull request #6553:

[GitHub] NicoK opened a new pull request #6553: [FLINK-10141][network] optimisations reducing lock contention

NicoK opened a new pull request #6553: [FLINK-10141][network] optimisations reducing lock contention URL: https://github.com/apache/flink/pull/6553 ## What is the purpose of the change With the changes around introducing credit-based flow control as well as the low latency changes,

[jira] [Commented] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579737#comment-16579737 ] ASF GitHub Bot commented on FLINK-10022: zentol commented on a change in pull request #6551:

[GitHub] zentol commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers

zentol commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers URL: https://github.com/apache/flink/pull/6551#discussion_r209932565 ## File path:

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

[ https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579732#comment-16579732 ] ASF GitHub Bot commented on FLINK-9850: --- yanghua commented on issue #6367: [FLINK-9850] Add a

[GitHub] yanghua commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

yanghua commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#issuecomment-412854540 @pnowojski fixed some issues you just mentioned, will refactor `PrintSinkFunction ` and

[jira] [Updated] (FLINK-6810) Add a set of built-in scalar functions to Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6810: Description: In this JIRA, we will create some sub-tasks for adding specific scalar functions

[jira] [Updated] (FLINK-6810) Add a set of built-in scalar functions to Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6810: Description: In this JIRA, we will create some sub-tasks for adding specific scalar functions

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579726#comment-16579726 ] Piotr Nowojski commented on FLINK-8545: --- This `AppendStreamTable` would still carry on deletes

[jira] [Updated] (FLINK-6810) Add a set of built-in scalar functions to Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-6810: Summary: Add a set of built-in scalar functions to Table API & SQL (was: Add Some built-in Scalar

[jira] [Commented] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file

[ https://issues.apache.org/jira/browse/FLINK-10130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579710#comment-16579710 ] Paul Lin commented on FLINK-10130: -- It could be solved by [HDFS name

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579706#comment-16579706 ] ASF GitHub Bot commented on FLINK-7205: --- asfgit closed pull request #6381: [FLINK-7205] [table] Add

[GitHub] asfgit closed pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

asfgit closed pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381 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

[jira] [Resolved] (FLINK-7205) Add UUID supported in TableAPI/SQL

[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-7205. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed in 1.7.0:

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579701#comment-16579701 ] ASF GitHub Bot commented on FLINK-9013: --- dawidwys commented on a change in pull request #6294:

[GitHub] dawidwys commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe…

dawidwys commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe… URL: https://github.com/apache/flink/pull/6294#discussion_r209925707 ## File path:

[jira] [Commented] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579695#comment-16579695 ] ASF GitHub Bot commented on FLINK-10022: NicoK commented on a change in pull request #6551:

[GitHub] NicoK commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers

NicoK commented on a change in pull request #6551: [FLINK-10022][network][metrics] add metrics for input/output buffers URL: https://github.com/apache/flink/pull/6551#discussion_r209923936 ## File path:

  1   2   3   >