[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153156#comment-16153156
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on a diff i
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r136904188
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java
---
@@ -372,6 +375,52 @@ public void
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4485
@NicoK , I have submitted the updates based on last comments.
Your concerns of interaction between requesting memory segments and
creating buffer pool is really necessary. I also noticed th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153153#comment-16153153
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on the issu
Hequn Cheng created FLINK-7578:
--
Summary: WindowStream should support rich AggregateFunction
Key: FLINK-7578
URL: https://issues.apache.org/jira/browse/FLINK-7578
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu resolved FLINK-7169.
Resolution: Fixed
> Support AFTER MATCH SKIP function in CEP library API
> -
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-7573:
Description:
Currently, all connectors as far as I have known that merely support the TCP
transport
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-7573:
Description:
Currently, all connectors as far as I have known that merely support the TCP
transport
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153064#comment-16153064
]
mingleizhang commented on FLINK-7573:
-
I want to reach an agreement on this issue befo
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153063#comment-16153063
]
mingleizhang commented on FLINK-7573:
-
Thanks [~yew1eb] You are right.
> Introduce H
[
https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang resolved FLINK-6995.
-
Resolution: Fixed
Fix Version/s: 1.3.2
> Add a warning to outdated documentation
>
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153060#comment-16153060
]
Hai Zhou commented on FLINK-7573:
-
Hi [~mingleizhang], Maybe you need to know first:
TCP p
[
https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153058#comment-16153058
]
mingleizhang commented on FLINK-7573:
-
Hi, [~tzulitai] I guess you should be more fami
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153054#comment-16153054
]
sunjincheng commented on FLINK-7465:
Hi [~jparkie] Thanks for your suggestion. At curr
[
https://issues.apache.org/jira/browse/FLINK-7558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-7558.
--
Resolution: Fixed
Release Note: Fixed in e6fddbc3e5bdb42764191990ac29ba382bbe6016
> Improve SQL Va
[
https://issues.apache.org/jira/browse/FLINK-7572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153007#comment-16153007
]
ASF GitHub Bot commented on FLINK-7572:
---
GitHub user sunjincheng121 opened a pull re
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4640
[FLINK-7572][table]Improve TableSchema and FlinkTable validation exceâ¦
## What is the purpose of the change
Currently, the exception message of `TableScheam` and `FlinkTable` a little
c
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16153002#comment-16153002
]
ASF GitHub Bot commented on FLINK-7524:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4639#discussion_r136879648
--- Diff:
flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java
---
@@ -61,13 +75,14 @@ public final void registerClosable(C close
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152992#comment-16152992
]
ASF GitHub Bot commented on FLINK-7524:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4639#discussion_r136877817
--- Diff:
flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java
---
@@ -61,13 +75,14 @@ public final void registerClosable(C
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152991#comment-16152991
]
ASF GitHub Bot commented on FLINK-7524:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4639#discussion_r136877616
--- Diff:
flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java
---
@@ -61,13 +75,14 @@ public final void registerClosable(C
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152989#comment-16152989
]
ASF GitHub Bot commented on FLINK-7524:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4639#discussion_r136877433
--- Diff:
flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java
---
@@ -61,13 +75,14 @@ public final void registerClosable(C close
[
https://issues.apache.org/jira/browse/FLINK-5281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152803#comment-16152803
]
ASF GitHub Bot commented on FLINK-5281:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3026
@twalthr and @KurtYoung Do you think this PR is still going somewhere or
should we rather close it?
---
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152795#comment-16152795
]
ASF GitHub Bot commented on FLINK-7491:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4585
Thanks @suez1224, I'm quite busy atm but will try to have a look soon.
Thanks, Fabian
---
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4634#discussion_r136852688
--- Diff: docs/dev/stream/operators/windows.md ---
@@ -663,25 +623,42 @@ input
.keyBy()
.window()
.process(new MyProcessWindowFunc
[
https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152802#comment-16152802
]
ASF GitHub Bot commented on FLINK-2980:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3124
@fhueske Is this PR (which has been open) for a while) still relevant for
the current state of the Table API?
---
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152776#comment-16152776
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152773#comment-16152773
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152791#comment-16152791
]
ASF GitHub Bot commented on FLINK-7568:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152788#comment-16152788
]
ASF GitHub Bot commented on FLINK-7564:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4633
Thanks for the PR @xccui.
This is good to merge.
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136847905
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala
---
@@ -19,9 +19,21 @@
package org.apache.flink.table
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3829
Hi @lincoln-lil, thanks for the JIRA!
We usually have code and documentation changes in one PR. This way the docs
are always up to date.
I responded to the open questions.
Please let
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136850229
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -106,6 +106,43 @@ abstract class BatchTab
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152746#comment-16152746
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152724#comment-16152724
]
ASF GitHub Bot commented on FLINK-7568:
---
Github user alpinegizmo commented on a diff
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/4634#discussion_r136843813
--- Diff: docs/dev/stream/operators/windows.md ---
@@ -663,25 +623,42 @@ input
.keyBy()
.window()
.process(new MyProcessWindowF
[
https://issues.apache.org/jira/browse/FLINK-3831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou reassigned FLINK-3831:
---
Assignee: Hai Zhou
Environment:
Apache Maven 3.3.9, Java version: 1.8.0_144
Description:
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152733#comment-16152733
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4534:
--
Description:
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r136845193
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,140 @@ abstract class TableEnviro
[
https://issues.apache.org/jira/browse/FLINK-7568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152732#comment-16152732
]
ASF GitHub Bot commented on FLINK-7568:
---
Github user alpinegizmo commented on a diff
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/4634#discussion_r136845008
--- Diff: docs/dev/stream/operators/windows.md ---
@@ -490,15 +490,35 @@ public abstract class ProcessWindowFunction impl
Iterable elemen
[
https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7525:
--
Description:
In this email thread
http://search-hadoop.com/m/Flink/VkLeQlf0QOnc7YA?subj=Security+Control+of+run
[
https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7488:
--
Description:
{code}
compareNetworkBufShellScriptWithJava(org.apache.flink.dist.TaskManagerHeapSizeCalculationJav
[
https://issues.apache.org/jira/browse/FLINK-7433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7433:
--
Description:
{code}
try {
if (throwable != null) {
completed.put
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152697#comment-16152697
]
ASF GitHub Bot commented on FLINK-7524:
---
GitHub user StefanRRichter opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-7524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152698#comment-16152698
]
ASF GitHub Bot commented on FLINK-7524:
---
Github user StefanRRichter commented on the
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4638
[FLINK-6563] [table] Add time indicator support to KafkaTableSource.
## What is the purpose of the change
Add support for time indicators (processing time, ingestion time, event
time) for K
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4639
[FLINK-7524] Remove potentially blocking behaviour from AbstractCloseâ¦
â¦ableRegistry
## What is the purpose of the change
This PR removes potential for blocking behaviour
Hai Zhou created FLINK-7577:
---
Summary: flink-core
Key: FLINK-7577
URL: https://issues.apache.org/jira/browse/FLINK-7577
Project: Flink
Issue Type: Sub-task
Components: Build System
[
https://issues.apache.org/jira/browse/FLINK-7575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-7575:
--
Assignee: James Lafa
> Dashboard jobs/tasks metrics display 0 when metrics are not yet availabl
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152696#comment-16152696
]
ASF GitHub Bot commented on FLINK-6563:
---
GitHub user fhueske opened a pull request:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4639
CC @aljoscha
---
[
https://issues.apache.org/jira/browse/FLINK-7576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152676#comment-16152676
]
ASF GitHub Bot commented on FLINK-7576:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4637
[FLINK-7576] [futures] Add FutureUtils.retryWithDelay
## What is the purpose of the change
FutureUtils.retryWithDelay executes the given operation of type
Callable> n times and wait
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152674#comment-16152674
]
Fabian Hueske commented on FLINK-6563:
--
Hi [~wheat9], I addressed this issue but did
[
https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152673#comment-16152673
]
ASF GitHub Bot commented on FLINK-7411:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4517#discussion_r136836067
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -220,6 +216,7 @@ void releaseBuffer() {
Till Rohrmann created FLINK-7576:
Summary: Add FutureUtils.retryWithDelay
Key: FLINK-7576
URL: https://issues.apache.org/jira/browse/FLINK-7576
Project: Flink
Issue Type: New Feature
James Lafa created FLINK-7575:
-
Summary: Dashboard jobs/tasks metrics display 0 when metrics are
not yet available
Key: FLINK-7575
URL: https://issues.apache.org/jira/browse/FLINK-7575
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152668#comment-16152668
]
ASF GitHub Bot commented on FLINK-7412:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4518#discussion_r136834211
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -440,12 +440,11 @@ ByteBuf write(ByteBufAllocator
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4517#discussion_r136831143
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -378,11 +373,14 @@ ByteBuf write(ByteBufAllocator
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4517#discussion_r136831126
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -313,20 +308,20 @@ ByteBuf write(ByteBufAllocator
[
https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152654#comment-16152654
]
ASF GitHub Bot commented on FLINK-7411:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152656#comment-16152656
]
ASF GitHub Bot commented on FLINK-7411:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152655#comment-16152655
]
ASF GitHub Bot commented on FLINK-7411:
---
Github user pnowojski commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152657#comment-16152657
]
ASF GitHub Bot commented on FLINK-7411:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4517#discussion_r136827653
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -130,34 +128,31 @@ protected void decode(ChannelH
[
https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152653#comment-16152653
]
ASF GitHub Bot commented on FLINK-7411:
---
Github user pnowojski commented on a diff i
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4517#discussion_r136831169
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -439,20 +437,23 @@ ByteBuf write(ByteBufAllocator
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4517#discussion_r136830945
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -242,21 +239,22 @@ ByteBuf write(ByteBufAllocator
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152633#comment-16152633
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user pnowojski commented on the issu
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4239
@aljoscha I have addressed you "high level" comments and fixed some bugs.
Please latest 5 commits (one of them is a new dependency on another PR:
https://github.com/apache/flink/pull/4631 )
---
[
https://issues.apache.org/jira/browse/FLINK-3828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou reassigned FLINK-3828:
---
Assignee: Hai Zhou
Environment: Apache Maven 3.3.9, Java version: 1.8.0_144
Description:
{
Hai Zhou created FLINK-7574:
---
Summary: flink-clients
Key: FLINK-7574
URL: https://issues.apache.org/jira/browse/FLINK-7574
Project: Flink
Issue Type: Sub-task
Components: Build System
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4636#discussion_r136822032
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java ---
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152612#comment-16152612
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152615#comment-16152615
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4636#discussion_r136822393
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java ---
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152605#comment-16152605
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152614#comment-16152614
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152606#comment-16152606
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152608#comment-16152608
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152607#comment-16152607
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152611#comment-16152611
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4636#discussion_r136821811
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java ---
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software Fou
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4636#discussion_r136822467
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java ---
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152609#comment-16152609
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152610#comment-16152610
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16152613#comment-16152613
]
ASF GitHub Bot commented on FLINK-2268:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4636#discussion_r136818368
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeInformationGen.scala
---
@@ -320,14 +315,6 @@ private[flink] trait TypeInformatio
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4636#discussion_r136822623
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java ---
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the Apache Software Fou
1 - 100 of 127 matches
Mail list logo
