Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4513
@dawidwys I have updated the PR and it currently only contains changes of
the RichFunction.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136338#comment-16136338
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dianfu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136280#comment-16136280
]
Haohui Mai commented on FLINK-7398:
---
+1 on logging trait. I'll submit a PR.
Adding a ch
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136247#comment-16136247
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user XuPingyong commented on the iss
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4525
Thanks @StephanEwen , so I think `null` values can be returned from
`InputFormat#nextRecord` anytime, even not end.
Can `null` values be passed to `InputFormat#nextRecord`, or checkNull
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4570
[FLINK-7438][DataStream API]Remove useless import, avoid warnings
## What is the purpose of the change
Avoid warningsï¼details: [ISSUE
#FLINK-7438](https://issues.apache.org/jira/browse/FLINK-74
[
https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136217#comment-16136217
]
ASF GitHub Bot commented on FLINK-7438:
---
GitHub user yew1eb opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136210#comment-16136210
]
ASF GitHub Bot commented on FLINK-7479:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4563
@dawidwys Have updated the PR according to your comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136194#comment-16136194
]
Hai Zhou commented on FLINK-4422:
-
Hi [~StephanEwen], This is still a issue?
If yes, I wou
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136174#comment-16136174
]
Jark Wu commented on FLINK-7465:
Hi [~sunjincheng121],
Regarding to the when to configure
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136167#comment-16136167
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4473
@tzulitai any more feedbacks? We have a ticket on my company for this task,
and I'd like to mark it as finished if possible :)
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136166#comment-16136166
]
ASF GitHub Bot commented on FLINK-7366:
---
GitHub user bowenli86 reopened a pull reque
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136163#comment-16136163
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user bowenli86 closed the pull reque
GitHub user bowenli86 reopened a pull request:
https://github.com/apache/flink/pull/4522
[FLINK-7366][kinesis connector] Upgrade kinesis producer library in
flink-connector-kinesis
## What is the purpose of the change
We need to upgrade KPL and KCL to pick up the enhanced p
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136162#comment-16136162
]
ASF GitHub Bot commented on FLINK-7366:
---
Github user bowenli86 commented on the issu
Github user bowenli86 closed the pull request at:
https://github.com/apache/flink/pull/4522
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is e
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4522
@tzulitai any more feedbacks? We have a ticket on my company for this task,
and I'd like to mark it as finished if possible :)
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136140#comment-16136140
]
Jark Wu edited comment on FLINK-7398 at 8/22/17 1:47 AM:
-
+1 Loggi
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136140#comment-16136140
]
Jark Wu commented on FLINK-7398:
+1 Logging trait.
BTW, I think to avoid the misusage of
[
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
Ted Yu created FLINK-7488:
-
Summary: TaskManagerHeapSizeCalculationJavaBashTest sometimes fails
Key: FLINK-7488
URL: https://issues.apache.org/jira/browse/FLINK-7488
Project: Flink
Issue Type: Test
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136062#comment-16136062
]
sunjincheng commented on FLINK-7465:
[~fhueske] I want add accuracy and maxElement as
[
https://issues.apache.org/jira/browse/FLINK-7482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-7482.
-
Resolution: Not A Bug
Hi [~felixcheung]. This is a great question for the dev or user [mailing
lists|http
[
https://issues.apache.org/jira/browse/FLINK-7454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16136025#comment-16136025
]
ASF GitHub Bot commented on FLINK-7454:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4547
any feedback?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-7398:
--
Attachment: Example.png
> Table API operators/UDFs must not store Logger
> -
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135534#comment-16135534
]
Jacob Park edited comment on FLINK-7398 at 8/21/17 6:28 PM:
[~
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-7398:
--
Attachment: (was: Example.png)
> Table API operators/UDFs must not store Logger
> --
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135534#comment-16135534
]
Jacob Park edited comment on FLINK-7398 at 8/21/17 6:17 PM:
[~
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135534#comment-16135534
]
Jacob Park edited comment on FLINK-7398 at 8/21/17 6:17 PM:
[~
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-7398:
--
Attachment: Example.png
[~wheat9] Why not follow Apache Spark's example for this problem?
https://gith
[
https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135429#comment-16135429
]
ASF GitHub Bot commented on FLINK-5886:
---
Github user zohar-mizrahi commented on the
Github user zohar-mizrahi commented on the issue:
https://github.com/apache/flink/pull/3838
The thing is that I use the
```PythonEnvironmentConfig.pythonTmpCachePath``` attribute to deliver
information from the ```PythonStreamBinder``` to a class that is called from
the python script
Nico Kruber created FLINK-7487:
--
Summary: test instability in ClassLoaderITCase (no resources
available)
Key: FLINK-7487
URL: https://issues.apache.org/jira/browse/FLINK-7487
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-7487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-7487:
---
Labels: test-stability (was: )
> test instability in ClassLoaderITCase (no resources available)
> ---
[
https://issues.apache.org/jira/browse/FLINK-5671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber closed FLINK-5671.
--
Resolution: Auto Closed
Closing this now since there is not enough information to track this down and
a
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r134248050
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala
---
@@ -19,9 +19,21 @@
package org.apache.flink.t
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135246#comment-16135246
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135244#comment-16135244
]
ASF GitHub Bot commented on FLINK-7040:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4569
@tillrohrmann @kl0u Would be great if you could take a look.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not ha
[
https://issues.apache.org/jira/browse/FLINK-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135238#comment-16135238
]
ASF GitHub Bot commented on FLINK-7040:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4569
[FLINK-7040] [REST] Add basics for REST communication
## What is the purpose of the change
This PR implements the fundamentals for generic Client/Server REST
communication that will be used
Bhumika Bayani created FLINK-7486:
-
Summary: flink-mesos: Support for adding unique attribute /
group_by attribute constraints
Key: FLINK-7486
URL: https://issues.apache.org/jira/browse/FLINK-7486
Pro
[
https://issues.apache.org/jira/browse/FLINK-7483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135209#comment-16135209
]
ASF GitHub Bot commented on FLINK-7483:
---
Github user tedyu commented on the issue:
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/4568
lgtm
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
[
https://issues.apache.org/jira/browse/FLINK-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-1180.
---
Resolution: Won't Do
> Add support for Hadoop MapReduce.* API Mappers and Reducers
> -
[
https://issues.apache.org/jira/browse/FLINK-838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-838.
--
Resolution: Won't Do
> Implement full Hadoop Compatibility for Apache Flink
> ---
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135189#comment-16135189
]
ASF GitHub Bot commented on FLINK-7477:
---
Github user aljoscha closed the pull reques
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/4566
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is en
[
https://issues.apache.org/jira/browse/FLINK-7480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7480.
---
Resolution: Fixed
Implemented in a3143bcb0dd2895025bd6f693f4240604a5f1840
> Set HADOOP_CONF_D
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7477.
---
Resolution: Fixed
Implemented in 0a0f6ed6c3d6cff702e4322293340274bea5e7d9
> Use "hadoop class
[
https://issues.apache.org/jira/browse/FLINK-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135176#comment-16135176
]
Aljoscha Krettek commented on FLINK-7300:
-
I think you're right, we're logging exc
[
https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7484:
Component/s: CEP
> com.esotericsoftware.kryo.KryoException: java.lang.IndexOutOfBoundsExcept
[
https://issues.apache.org/jira/browse/FLINK-7485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135172#comment-16135172
]
Jark Wu commented on FLINK-7485:
Hi [~sunjincheng121] this issue is duplicated with FLINK
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135159#comment-16135159
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135158#comment-16135158
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135156#comment-16135156
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135155#comment-16135155
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135157#comment-16135157
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r134186403
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,140 @@ abstract class TableEn
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r134185829
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,140 @@ abstract class TableEn
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r134186937
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,140 @@ abstract class TableEn
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r134184973
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/StreamTableEnvironment.scala
---
@@ -132,6 +132,44 @@ abstract class Str
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r134228841
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CsvSQLTableSink.scala
---
@@ -0,0 +1,55 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135152#comment-16135152
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r134185390
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,140 @@ abstract class TableEn
[
https://issues.apache.org/jira/browse/FLINK-7483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135141#comment-16135141
]
ASF GitHub Bot commented on FLINK-7483:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4568
FYI: the test instability of `JobManagerCleanupITCase` will be fixed by
#4358, the next BLOB-PR in line - I don't want to mess up the following PRs
anymore (again) by integrating it separately or here
[
https://issues.apache.org/jira/browse/FLINK-7439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135132#comment-16135132
]
ASF GitHub Bot commented on FLINK-7439:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/4536
@sunjincheng121 @fhueske I would be great if you can have a look ;-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-7485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-7485.
--
Resolution: Duplicate
> Using DataView interface to improve (MIN/MAX)WithRetractAggFunction.
> -
[
https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135101#comment-16135101
]
Shashank Agarwal commented on FLINK-7484:
-
Hi [~yew1eb]
It's very big code base, W
[
https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135084#comment-16135084
]
Hai Zhou commented on FLINK-7438:
-
Hi [~aljoscha]
I would like to work on this issue.:D
>
[
https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135076#comment-16135076
]
Hai Zhou edited comment on FLINK-7438 at 8/21/17 12:01 PM:
---
I th
[
https://issues.apache.org/jira/browse/FLINK-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135076#comment-16135076
]
Hai Zhou commented on FLINK-7438:
-
I think the reason for this problem is
[https://issues
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4358
sorry for the mess, but let me also drag in #4568 and adapt the code in
here (which is moved from `BlobCache` to `PermanentBlobCache` by this PR)
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135066#comment-16135066
]
ASF GitHub Bot commented on FLINK-7068:
---
Github user NicoK commented on the issue:
sunjincheng created FLINK-7485:
--
Summary: Using DataView interface to improve
(MIN/MAX)WithRetractAggFunction.
Key: FLINK-7485
URL: https://issues.apache.org/jira/browse/FLINK-7485
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135046#comment-16135046
]
Hai Zhou commented on FLINK-7484:
-
Hi [~shashank734]
Can you upload your code？
> com.eso
Shashank Agarwal created FLINK-7484:
---
Summary: com.esotericsoftware.kryo.KryoException:
java.lang.IndexOutOfBoundsException: Index: 7, Size: 5
Key: FLINK-7484
URL: https://issues.apache.org/jira/browse/FLINK-748
[
https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135030#comment-16135030
]
ASF GitHub Bot commented on FLINK-5886:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3838
The check failed because the spotbugs plugin found something; this plugin
isn't run by default when calling `mvn verify`. You can run the spotbugs
locally by adding `-Dspotbugs` to the maven invocatio
[
https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135018#comment-16135018
]
ASF GitHub Bot commented on FLINK-5886:
---
Github user zohar-mizrahi commented on the
Github user zohar-mizrahi commented on the issue:
https://github.com/apache/flink/pull/3838
I'm trying to track down the root cause for the checks failures without a
success. Obviously, the given project (flink-libraries/flink-streaming-python)
in master branch passes the `verify` wit
[
https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135012#comment-16135012
]
Sumit Sarin commented on FLINK-4831:
Hey Chesner,
After going through slf4j and log4j
[
https://issues.apache.org/jira/browse/FLINK-7483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135007#comment-16135007
]
ASF GitHub Bot commented on FLINK-7483:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4568
@tedyu this fixes the two issues you found in #4238. Could you have a
quick look, also?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-7483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135000#comment-16135000
]
ASF GitHub Bot commented on FLINK-7483:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4568
[FLINK-7483][blob] prevent cleanup of re-registered jobs
## What is the purpose of the change
Since #4238, when a job is registered but was released before and the ref
count hit `0`, its clea
Nico Kruber created FLINK-7483:
--
Summary: BlobCache cleanup timer not reset after job
re-registration
Key: FLINK-7483
URL: https://issues.apache.org/jira/browse/FLINK-7483
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16134985#comment-16134985
]
ASF GitHub Bot commented on FLINK-7479:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4563
Thanks @dawidwys for the suggestion. I will update the PR accordingly.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project d
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16134982#comment-16134982
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dianfu commented on the issue:
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4513
Thanks @dawidwys for the remind. Yes, you're right and that make sense to
me. I will update the the PR and remove ConditionRegistry related changes.
---
If your project is set up for it, you can repl
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16134963#comment-16134963
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dawidwys commented on the issue
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/4513
Hmm, I read back all the comments to previous PRs and I think the consesus
was that we do not want to introduce the ConditionRegistry at that time, but
start with just FLINK-6938 to enable SQL integ
[
https://issues.apache.org/jira/browse/FLINK-7227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Usman Younas reassigned FLINK-7227:
---
Assignee: Usman Younas
> OR expression with more than 2 predicates is not pushed into a Table
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16134933#comment-16134933
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user wuchong commented on a diff in
1 - 100 of 169 matches
Mail list logo
