[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272880#comment-16272880
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user greghogan commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272879#comment-16272879
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user greghogan commented on a diff in the pull
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5094
No worries! It's always good to have another pair of eyes looking over
complex logic like this :-)
---
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272854#comment-16272854
]
ASF GitHub Bot commented on FLINK-8158:
---
Github user fhueske commented on the issue:
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r154121821
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java
---
@@ -43,8 +46,8 @@
private
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r154122694
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/MetricOptions.java ---
@@ -25,20 +25,9 @@
public class MetricOptions {
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272890#comment-16272890
]
ASF GitHub Bot commented on FLINK-8176:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5107
[FLINK-8176][flip6] Start SubmittedJobGraphStore in Dispatcher
## What is the purpose of the change
The FLIP-6 dispatcher never calls `start()` on its SubmittedJobGraphStore
instance. Hence,
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/4935
Hi, @tzulitai
After i read kafkaConsumer code again, i found that the per partition kafka
lag metric is register in method `FetchManagerMetrics#recordPartitionLag` But
the when the client get
[
https://issues.apache.org/jira/browse/FLINK-8027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8027.
Resolution: Fixed
Fixed via b0bd65db9bb9d41ad85634d08dc8b9dae2cfa8dd
> Generalize existing rest
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4985
---
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5094
Never mind~ Thanks for reminding me of the ideas :-)
---
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272857#comment-16272857
]
ASF GitHub Bot commented on FLINK-8158:
---
Github user xccui commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272850#comment-16272850
]
ASF GitHub Bot commented on FLINK-8158:
---
Github user hequn8128 commented on the issue:
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/5094
Ops... finally understand what you mean. Thank your very much for your
explain. @fhueske @xccui . I will close this pr :)
---
[
https://issues.apache.org/jira/browse/FLINK-8027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272947#comment-16272947
]
ASF GitHub Bot commented on FLINK-8027:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272898#comment-16272898
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r154128004
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -246,5 +258,11 @@ protected JobManagerRunner
[
https://issues.apache.org/jira/browse/FLINK-8158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272853#comment-16272853
]
ASF GitHub Bot commented on FLINK-8158:
---
Github user hequn8128 closed the pull request at:
Github user hequn8128 closed the pull request at:
https://github.com/apache/flink/pull/5094
---
[
https://issues.apache.org/jira/browse/FLINK-7762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272313#comment-16272313
]
ASF GitHub Bot commented on FLINK-7762:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272321#comment-16272321
]
ASF GitHub Bot commented on FLINK-8149:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5069
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5017
---
[
https://issues.apache.org/jira/browse/FLINK-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272322#comment-16272322
]
ASF GitHub Bot commented on FLINK-8076:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5075
---
[
https://issues.apache.org/jira/browse/FLINK-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8149.
Resolution: Fixed
> Replace usages of deprecated SerializationSchema
>
[
https://issues.apache.org/jira/browse/FLINK-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272341#comment-16272341
]
Tzu-Li (Gordon) Tai commented on FLINK-8149:
Merged:
1.5 -
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/4988
This pr is very helpful for us. Thank you. I have tried it on our cluster
with yarn job modeï¼and it works well. My only suggestion is to change the
default value of rest.address to 0.0.0.0
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272445#comment-16272445
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272451#comment-16272451
]
ASF GitHub Bot commented on FLINK-7748:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272449#comment-16272449
]
ASF GitHub Bot commented on FLINK-7748:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-8076.
Resolution: Fixed
Release Note: The AWS KPL version used in the Kinesis
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5104
[FLINK-8172][network] Write directly to memorySegment in RecordSerializer
This increases throughput of network stack by factor of 2, because
previously method getMemorySegment() was called twice
[
https://issues.apache.org/jira/browse/FLINK-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272358#comment-16272358
]
ASF GitHub Bot commented on FLINK-8172:
---
GitHub user pnowojski opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-8176:
---
Assignee: Gary Yao
> Dispatcher does not start SubmittedJobGraphStore
>
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8176:
Description:
{{Dispatcher}} never calls start on its {{SubmittedJobGraphStore}} instance.
Hence, when a
Gary Yao created FLINK-8176:
---
Summary: Dispatcher does not start SubmittedJobGraphStore
Key: FLINK-8176
URL: https://issues.apache.org/jira/browse/FLINK-8176
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272437#comment-16272437
]
ASF GitHub Bot commented on FLINK-8172:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5104#discussion_r154024973
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java
---
@@ -107,6 +110,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272440#comment-16272440
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154026730
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -584,4 +587,60 @@ static CloseRequest
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154027456
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/DummyEnvironment.java
---
@@ -190,4 +191,8 @@ public InputGate
[
https://issues.apache.org/jira/browse/FLINK-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272452#comment-16272452
]
ASF GitHub Bot commented on FLINK-7748:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272448#comment-16272448
]
ASF GitHub Bot commented on FLINK-7748:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272447#comment-16272447
]
ASF GitHub Bot commented on FLINK-7748:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272450#comment-16272450
]
ASF GitHub Bot commented on FLINK-7748:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154026050
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/TaskEventDispatcherTest.java
---
@@ -0,0 +1,168 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272446#comment-16272446
]
ASF GitHub Bot commented on FLINK-7748:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154023982
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -671,7 +671,7 @@ else if (current == ExecutionState.CANCELING)
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154025597
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/TaskEventDispatcherTest.java
---
@@ -0,0 +1,168 @@
+/*
+ * Licensed to
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154021028
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadTask.java
---
@@ -223,8 +225,10 @@ private void
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154023066
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/ResultPartitionWriter.java
---
@@ -34,12 +31,10 @@
* The
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4761#discussion_r154027358
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java
---
@@ -325,9 +325,10 @@ public
Github user yew1eb commented on a diff in the pull request:
https://github.com/apache/flink/pull/5071#discussion_r154031899
--- Diff: docs/monitoring/metrics.md ---
@@ -94,8 +94,8 @@ Alternatively you can also use your own `Counter`
implementation:
{% highlight java %}
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154031923
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -208,8 +244,79 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272420#comment-16272420
]
ASF GitHub Bot commented on FLINK-8030:
---
Github user shuai-xu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8176:
Labels: flip-6 (was: )
> Dispatcher does not start SubmittedJobGraphStore
>
Fabian Hueske created FLINK-8177:
Summary: Flink cannot be built for Hadoop 2.9.0
Key: FLINK-8177
URL: https://issues.apache.org/jira/browse/FLINK-8177
Project: Flink
Issue Type: Bug
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154027406
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -283,10 +283,13 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272466#comment-16272466
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272465#comment-16272465
]
ASF GitHub Bot commented on FLINK-7907:
---
Github user yew1eb commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273345#comment-16273345
]
Eron Wright commented on FLINK-8174:
-
We're working on a fix that will allow Flink to use both
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273280#comment-16273280
]
ASF GitHub Bot commented on FLINK-8104:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5040#discussion_r154181460
--- Diff: docs/dev/table/tableApi.md ---
@@ -2993,6 +2993,30 @@ MAP.at(ANY)
+
+
+
+ Row functions
+
[
https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273185#comment-16273185
]
Aljoscha Krettek commented on FLINK-8174:
-
Are there any updates on this?
> Mesos RM unable to
[
https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273261#comment-16273261
]
Robert Metzger commented on FLINK-5506:
---
[~greghogan] or [~vkalavri] do you have an idea how to work
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5040#discussion_r154179674
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/utils/RowTypeTestBase.scala
---
@@ -0,0 +1,64 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273279#comment-16273279
]
ASF GitHub Bot commented on FLINK-8104:
---
Github user walterddr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273365#comment-16273365
]
Aljoscha Krettek commented on FLINK-8174:
-
thanks!
> Mesos RM unable to accept offers for
[
https://issues.apache.org/jira/browse/FLINK-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-8180:
--
Description:
The change in 1.4 of algorithm results from Tuples to POJOs broke the writing
of results
Greg Hogan created FLINK-8180:
-
Summary: Refactor driver outputs
Key: FLINK-8180
URL: https://issues.apache.org/jira/browse/FLINK-8180
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-8180:
--
Description:
The change in 1.4 of algorithm results from Tuples to POJOs broke the writing
of results
[
https://issues.apache.org/jira/browse/FLINK-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-8180:
--
Description:
The change in 1.4 of algorithm results from Tuples to POJOs broke the writing
of results
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273688#comment-16273688
]
Cristian commented on FLINK-8162:
-
Bump [~tzulitai]
> Kinesis Connector to report millisBehindLatest
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/5103
---
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273624#comment-16273624
]
Tao Xia edited comment on FLINK-8173 at 11/30/17 11:05 PM:
---
hi [~fhueske] i
[
https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273591#comment-16273591
]
ASF GitHub Bot commented on FLINK-7595:
---
Github user zentol closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273624#comment-16273624
]
Tao Xia commented on FLINK-8173:
hi [~fhueske] i tried to use toAppendStream[java.lang.CharSequence]
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273923#comment-16273923
]
Tao Xia commented on FLINK-8173:
Is it supported to run Table SQL query on Avro objects?
I also tried the
Tzu-Li (Gordon) Tai created FLINK-8181:
--
Summary: Kafka producer's FlinkFixedPartitioner returns different
partitions when a target topic is rescaled
Key: FLINK-8181
URL:
[
https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-8181:
---
Description:
On fixing FLINK-6288 and migrating the original
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5102
LGTM.
+1 to merge this now, and we think about removing the source as well as
reworking the doc example to not use it (I think it might be nice to directly
kick off the docs with an intro
[
https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-7694:
Labels: flip-6 (was: flip6)
> Port JobMetricsHandler to new REST handler
>
[
https://issues.apache.org/jira/browse/FLINK-8149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272298#comment-16272298
]
ASF GitHub Bot commented on FLINK-8149:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5069
Ah, I just realized that my comment on the last review is irrelevant, since
`org.apache.flink.streaming.util.serialization.SerializationSchema` extends
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154009420
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -584,4 +587,60 @@ static CloseRequest
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272320#comment-16272320
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272335#comment-16272335
]
Tzu-Li (Gordon) Tai commented on FLINK-8076:
Merged!
1.5:
Piotr Nowojski created FLINK-8178:
-
Summary: Introduce not threadsafe write only BufferBuilder
Key: FLINK-8178
URL: https://issues.apache.org/jira/browse/FLINK-8178
Project: Flink
Issue
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5105
[FLINK-8178][network] Introduce not threadsafe write only BufferBuilder
This pr depends on #5104
While Buffer class is used in multithreaded context it requires
synchronisation.
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5103
ð looks good. Can I merge this or do you want to go ahead?
---
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272512#comment-16272512
]
Fabian Hueske edited comment on FLINK-8173 at 11/30/17 10:52 AM:
-
Yes, you
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272512#comment-16272512
]
Fabian Hueske edited comment on FLINK-8173 at 11/30/17 10:51 AM:
-
Yes, you
GitHub user zhanglibing1990 opened a pull request:
https://github.com/apache/flink/pull/5106
TestCommit
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution in the best possible
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5104
2 times improvement is for network stack only. With other things in play
(like even simple operators) it will be smaller.
As we discussed offline, I didn't want tightening up the
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272512#comment-16272512
]
Fabian Hueske commented on FLINK-8173:
--
Yes, you should change
[
https://issues.apache.org/jira/browse/FLINK-8172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272496#comment-16272496
]
ASF GitHub Bot commented on FLINK-8172:
---
Github user pnowojski commented on the issue:
Fabian Hueske created FLINK-8179:
Summary: Convert CharSequence to String when registering /
converting a Table
Key: FLINK-8179
URL: https://issues.apache.org/jira/browse/FLINK-8179
Project: Flink
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5103
feel free to merge it.
---
1 - 100 of 128 matches
Mail list logo
