[
https://issues.apache.org/jira/browse/FLINK-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10123.
-
Resolution: Fixed
Fixed via e307f9217d8a009e471f3cd203cf2247073776b7
> Use ExecutorThreadFactor
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580765#comment-16580765
]
ASF GitHub Bot commented on FLINK-6895:
---
buptljy commented on a change in pull requ
buptljy commented on a change in pull request #6359: [FLINK-6895][table]Add
STR_TO_DATE supported in SQL
URL: https://github.com/apache/flink/pull/6359#discussion_r210181419
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/StrToDateCallG
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580750#comment-16580750
]
vinoyang commented on FLINK-10074:
--
[~thw] OK, That's fine, then I will be ready to sta
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580624#comment-16580624
]
Thomas Weise edited comment on FLINK-10074 at 8/15/18 4:09 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580699#comment-16580699
]
Thomas Weise commented on FLINK-10074:
--
[~yanghua] this is what I meant also, I upd
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580624#comment-16580624
]
Thomas Weise edited comment on FLINK-10074 at 8/15/18 4:07 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580687#comment-16580687
]
vinoyang commented on FLINK-10074:
--
[~thw] I personally prefer that once JM failover, t
[
https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580677#comment-16580677
]
ASF GitHub Bot commented on FLINK-8532:
---
Guibo-Pan commented on issue #6544: [FLINK
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?
-
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580627#comment-16580627
]
vinoyang commented on FLINK-:
-
[~walterddr] I don't know if this is the SQL standard
[
https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580624#comment-16580624
]
Thomas Weise commented on FLINK-10074:
--
[~till.rohrmann] it is probably unreasonabl
[
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 expressio
[
https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580531#comment-16580531
]
ASF GitHub Bot commented on FLINK-10101:
liurenjie1024 commented on issue #6522:
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 the
[
https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580468#comment-16580468
]
Prithvi Raj commented on FLINK-9488:
I'm not sure whether this is the right place to
[
https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580343#comment-16580343
]
ASF GitHub Bot commented on FLINK-10022:
NicoK closed pull request #6551: [FLINK
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:
[
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 int
[
https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580284#comment-16580284
]
ASF GitHub Bot commented on FLINK-10042:
StefanRRichter commented on issue #6556
[
https://issues.apache.org/jira/browse/FLINK-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580283#comment-16580283
]
ASF GitHub Bot commented on FLINK-10042:
StefanRRichter opened a new pull reques
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
---
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 refactoring/d
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:
flink-libraries/flink-table/src/main/scala/org/apache/flink/tabl
[
https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580197#comment-16580197
]
Rong Rong commented on FLINK-:
--
I do not have access to the newest SQL 2016 standard
[
https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580192#comment-16580192
]
Rong Rong commented on FLINK-10079:
---
I agree we should either make the documentation m
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580143#comment-16580143
]
ASF GitHub Bot commented on FLINK-10101:
GJL commented on a change in pull reque
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
##
[
https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580142#comment-16580142
]
ASF GitHub Bot commented on FLINK-10101:
GJL commented on a change in pull reque
[
https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580141#comment-16580141
]
ASF GitHub Bot commented on FLINK-10101:
GJL commented on a change in pull reque
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
##
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
##
[
https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16578793#comment-16578793
]
Rong Rong edited comment on FLINK-10019 at 8/14/18 5:39 PM:
[
https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580127#comment-16580127
]
ASF GitHub Bot commented on FLINK-10137:
GJL commented on a change in pull reque
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 @
[
https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580126#comment-16580126
]
ASF GitHub Bot commented on FLINK-10137:
GJL commented on a change in pull reque
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 @
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
[
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
> HAQueryableSt
[
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
> HAQueryableStateRocksDBBacke
[
https://issues.apache.org/jira/browse/FLINK-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580017#comment-16580017
]
ASF GitHub Bot commented on FLINK-10137:
yanghua commented on a change in pull r
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 +323,
[
https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580010#comment-16580010
]
ASF GitHub Bot commented on FLINK-10144:
yanghua commented on issue #6554: [FLIN
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
[
https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16580001#comment-16580001
]
ASF GitHub Bot commented on FLINK-9850:
---
yanghua commented on issue #6367: [FLINK-9
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 automate
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579950#comment-16579950
]
Jonathan Miles commented on FLINK-9061:
---
Is the PR still being considered for mergi
[
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 w
[
https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579899#comment-16579899
]
Hequn Cheng edited comment on FLINK-8545 at 8/14/18 3:20 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579945#comment-16579945
]
Hequn Cheng commented on FLINK-8577:
A simple design
[doc|https://docs.google.com/do
[
https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579907#comment-16579907
]
ASF GitHub Bot commented on FLINK-9913:
---
pnowojski commented on issue #6417: [FLINK
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
https://github.com/dataArtisans/flink-benchmarks
[
https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579899#comment-16579899
]
Hequn Cheng commented on FLINK-8545:
[~pnowojski]
Great to have your response. The {{
[
https://issues.apache.org/jira/browse/FLINK-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579888#comment-16579888
]
Sayat Satybaldiyev commented on FLINK-9831:
---
I've setup PredefinedOptions.SPINN
[
https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579867#comment-16579867
]
ASF GitHub Bot commented on FLINK-9899:
---
glaksh100 commented on issue #6409: [FLINK
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?
-
[
https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579855#comment-16579855
]
ASF GitHub Bot commented on FLINK-10022:
zentol commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579857#comment-16579857
]
ASF GitHub Bot commented on FLINK-10022:
zentol commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579856#comment-16579856
]
ASF GitHub Bot commented on FLINK-10022:
zentol commented on a change in pull re
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:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/util/Mutable
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:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IOMetrics.
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:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics
[
https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579840#comment-16579840
]
chengjie.wu commented on FLINK-10144:
-
[~Zentol],[~lsy] I have opened a new pull req
[
https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579836#comment-16579836
]
ASF GitHub Bot commented on FLINK-8532:
---
Guibo-Pan commented on issue #6544: [FLINK
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.
-
[
https://issues.apache.org/jira/browse/FLINK-10142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579833#comment-16579833
]
ASF GitHub Bot commented on FLINK-10142:
NicoK opened a new pull request #6555:
[
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 notific
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
[
https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579809#comment-16579809
]
dalongliu commented on FLINK-10144:
---
[~Zentol] can you assign this issue to [~wucj],he
[
https://issues.apache.org/jira/browse/FLINK-10144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579794#comment-16579794
]
ASF GitHub Bot commented on FLINK-10144:
wchengjie opened a new pull request #65
[
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 c
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
akka.actor.Act
[
https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579783#comment-16579783
]
ASF GitHub Bot commented on FLINK-9850:
---
pnowojski edited a comment on issue #6367:
[
https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579782#comment-16579782
]
ASF GitHub Bot commented on FLINK-9850:
---
pnowojski commented on issue #6367: [FLINK
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` (
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` (`TaskSt
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579779#comment-16579779
]
buptljy commented on FLINK-10119:
-
[~twalthr] Okay, I am going to add two optional prope
[
https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579760#comment-16579760
]
ASF GitHub Bot commented on FLINK-10022:
NicoK commented on a change in pull req
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:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IOMetrics.j
[
https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579758#comment-16579758
]
ASF GitHub Bot commented on FLINK-10022:
NicoK commented on a change in pull req
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:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IOMetrics.j
dalongliu created FLINK-10144:
-
Summary: No unused import "import akka.actor.ActorRef" in class
"org.apache.flink.runtime.messages.TaskManagerMessages"
Key: FLINK-10144
URL: https://issues.apache.org/jira/browse/FLINK
[
https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579743#comment-16579743
]
ASF GitHub Bot commented on FLINK-8290:
---
azagrebin commented on issue #5304: [FLINK
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 Apach
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-10141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579739#comment-16579739
]
ASF GitHub Bot commented on FLINK-10141:
NicoK opened a new pull request #6553:
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,
[
https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579737#comment-16579737
]
ASF GitHub Bot commented on FLINK-10022:
zentol commented on a change in pull re
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:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IOMetrics.
[
https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579732#comment-16579732
]
ASF GitHub Bot commented on FLINK-9850:
---
yanghua commented on issue #6367: [FLINK-9
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 `PrintingOutputFor
[
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 such
[
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 such
[
https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579726#comment-16579726
]
Piotr Nowojski commented on FLINK-8545:
---
This `AppendStreamTable` would still carry
[
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
[
https://issues.apache.org/jira/browse/FLINK-10130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579710#comment-16579710
]
Paul Lin commented on FLINK-10130:
--
It could be solved by [HDFS name
services|https:/
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579706#comment-16579706
]
ASF GitHub Bot commented on FLINK-7205:
---
asfgit closed pull request #6381: [FLINK-7
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 this
[
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: 913b0413882939c30da4ad4df0cabc84dfe
1 - 100 of 263 matches
Mail list logo