[
https://issues.apache.org/jira/browse/FLINK-8217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16284616#comment-16284616
]
ASF GitHub Bot commented on FLINK-8217:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5138
@greghogan this is a subtask of FLINK-8192.
@tzulitai What do you think of having a FLIP to FLINK-8192?
---
[
https://issues.apache.org/jira/browse/FLINK-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16284570#comment-16284570
]
ASF GitHub Bot commented on FLINK-8227:
---
GitHub user dianfu opened a pull request:
GitHub user dianfu opened a pull request:
https://github.com/apache/flink/pull/5142
[FLINK-8227] Optimize the performance of SharedBufferSerializer
## What is the purpose of the change
*This pull request optimize the performance of SharedBufferSerializer*
## Verifyi
Dian Fu created FLINK-8227:
--
Summary: Optimize the performance of SharedBufferSerializer
Key: FLINK-8227
URL: https://issues.apache.org/jira/browse/FLINK-8227
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16284560#comment-16284560
]
Dian Fu commented on FLINK-8226:
It will cause exceptions such as when serializing the NFA
[
https://issues.apache.org/jira/browse/FLINK-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16284558#comment-16284558
]
ASF GitHub Bot commented on FLINK-8226:
---
GitHub user dianfu opened a pull request:
GitHub user dianfu opened a pull request:
https://github.com/apache/flink/pull/5141
[FLINK-8226] [cep] Dangling reference generated after NFA clean up timed
out SharedBufferEntry
â¦med out SharedBufferEntry
*Thank you very much for contributing to Apache Flink - we ar
Dian Fu created FLINK-8226:
--
Summary: Dangling reference generated after NFA clean up timed out
SharedBufferEntry
Key: FLINK-8226
URL: https://issues.apache.org/jira/browse/FLINK-8226
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16284543#comment-16284543
]
ASF GitHub Bot commented on FLINK-7797:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/5140
[FLINK-7797] [table] Add support for windowed outer joins for streaming
tables
## What is the purpose of the change
This PR adds support for windowed outer joins for streaming tables.
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16284230#comment-16284230
]
ASF GitHub Bot commented on FLINK-8116:
---
Github user ankitiitb1069 commented on a di
Github user ankitiitb1069 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r155877893
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -34,17 +34,17 @@
* The r
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283741#comment-16283741
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5134
I also think being more on the cautious side is actually a good thing.
Given how scared and confused many people and companies are with respect to
open source and accidentally infringement of IP,
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283734#comment-16283734
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5134
@greg I think there is one more requirement by the ASF (not necessarily the
Apache License itself), which is making sure that downstream consumers of
Apache projects are always explicitly aware w
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4987#discussion_r155804733
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -757,6 +775,64 @@ public void heartbeatFromResourceManager(final
[
https://issues.apache.org/jira/browse/FLINK-8029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283732#comment-16283732
]
ASF GitHub Bot commented on FLINK-8029:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-8029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283718#comment-16283718
]
ASF GitHub Bot commented on FLINK-8029:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4987#discussion_r155802027
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
---
@@ -27,8 +27,6 @@
/**
* Interface for a metric r
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5072
@greghogan, I saw the following in the `flink-core` POM:
```
org.xerial.snappy
snappy-java
```
I think this PR just upgrades the snappy-java version fro
[
https://issues.apache.org/jira/browse/FLINK-7984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283716#comment-16283716
]
ASF GitHub Bot commented on FLINK-7984:
---
Github user yew1eb commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283699#comment-16283699
]
ASF GitHub Bot commented on FLINK-8030:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4988#discussion_r155797999
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java
---
@@ -0,0 +1,402 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283657#comment-16283657
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5134
@pnowojski see FLINK-2848 and FLINK-2973. Also the BSD + Patents
conversation along with Flink's dependence on Amazon's Kinesis library
(likewise [Category X](https://www.apache.org/legal/resolved.
[
https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283523#comment-16283523
]
ASF GitHub Bot commented on FLINK-8192:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5138
Changes to the public API require a
[FLIP](https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals).
---
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283481#comment-16283481
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155770364
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManagerTest.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283477#comment-16283477
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155770104
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManagerTest.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283470#comment-16283470
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155768880
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283413#comment-16283413
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155758219
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283397#comment-16283397
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155754738
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -266,104 +279,367 @@ public void disconnectResourceManage
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283365#comment-16283365
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5134
@greghogan That may or may not be possible, not 100% sure. Re-distributing
it does certainly not work.
To my current understanding, the Apache guidelines say we would need to
make sure t
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155751694
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -266,104 +279,367 @@ public void disconnectResourceManage
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283364#comment-16283364
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283318#comment-16283318
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283319#comment-16283319
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155746723
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class TableEnviron
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155746766
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class TableEnviron
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283309#comment-16283309
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user pnowojski commented on the issu
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5134
It seems like `commons-lang` doesn't have any issues with using `jmh` in
tests: https://commons.apache.org/proper/commons-lang/dependencies.html
However @greghogan do you remember my previo
[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283304#comment-16283304
]
ASF GitHub Bot commented on FLINK-4812:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5125#discussion_r155742906
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
---
@@ -80,7 +91,10 @@ public void init() thr
[
https://issues.apache.org/jira/browse/FLINK-8224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283302#comment-16283302
]
ASF GitHub Bot commented on FLINK-8224:
---
GitHub user shuai-xu opened a pull request:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5139
[FLINK-8224] [runtime] shutdown application when job terminated in job mode
## What is the purpose of the change
This current job cluster entrypoint doesn't call resource manage to
shutdow
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283293#comment-16283293
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283292#comment-16283292
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155741290
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class TableEnviron
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155741244
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -411,6 +411,7 @@ abstract class TableEnvironm
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16283289#comment-16283289
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155740555
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -98,7 +98,9 @@ abstract class BatchTable
Sendoh created FLINK-8225:
-
Summary: Use JsonRowDeserializationSchema without Kafka connector
dependency
Key: FLINK-8225
URL: https://issues.apache.org/jira/browse/FLINK-8225
Project: Flink
Issue T
shuai.xu created FLINK-8224:
---
Summary: Should shudownApplication when job terminated in job mode
Key: FLINK-8224
URL: https://issues.apache.org/jira/browse/FLINK-8224
Project: Flink
Issue Type: Bug
61 matches
Mail list logo