Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2452
OK, how about reopen pull requests #2439 ? Just update storm version to
1.0, and it can support storm 1.0+ version program.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-4638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505773#comment-15505773
]
ASF GitHub Bot commented on FLINK-4638:
---
Github user lw-lin commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505774#comment-15505774
]
ASF GitHub Bot commented on FLINK-4450:
---
GitHub user liuyuzhong reopened a pull requ
GitHub user liuyuzhong reopened a pull request:
https://github.com/apache/flink/pull/2439
[FLINK-4450]update storm verion to 1.0.0 in flink-storm and
flink-storm-examples
This pull is for update storm version to 1.0.0
https://issues.apache.org/jira/browse/FLINK-4450
Becau
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2515#discussion_r79544108
--- Diff:
flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java ---
@@ -161,7 +161,7 @@
}
if (offHeapAddress
[
https://issues.apache.org/jira/browse/FLINK-4638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505769#comment-15505769
]
ASF GitHub Bot commented on FLINK-4638:
---
GitHub user lw-lin opened a pull request:
GitHub user lw-lin opened a pull request:
https://github.com/apache/flink/pull/2515
[FLINK-4638] Fix exception message for MemorySegment
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lw-lin/flink fix-msg
Alternatively you can
Liwei Lin created FLINK-4638:
Summary: Fix exception message for MemorySegment
Key: FLINK-4638
URL: https://issues.apache.org/jira/browse/FLINK-4638
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505669#comment-15505669
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2510#discussion_r79539655
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/JoinDriver.java
---
@@ -128,17 +130,22 @@ public void prepare() throws Exception{
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505568#comment-15505568
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2495
@StephanEwen
Thank you. I agree this is a super important piece of FLINK where the
memory is involved and that is one reason why I wanted to know its managment
and usage and wanted to work on
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2452
Sorry for chiming in late. Left some comments on the ML thread.
Overall I think it's ok to switch focus on supporting 1.0+ Storm versions
only.
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for hadoop-
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently y
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3734:
--
Description:
{code}
DataInputView in = inputState.getState(getUserCodeClassloader());
final long nextEv
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4573:
--
Description:
{code}
try {
[
https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4533:
--
Description:
Access to meters in AbstractReporter is protected by AbstractReporter.this.
Access to meters in S
[
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 wuchong commented on the issue:
https://github.com/apache/flink/pull/2482
Hi @StephanEwen , if we want to have a shortcut (`rocksdb`), what should
we do? Add the rocksdb dependency into `flink-streaming-java` module ? Or use
java reflect ?
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505289#comment-15505289
]
ASF GitHub Bot commented on FLINK-4579:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505243#comment-15505243
]
刘喆 edited comment on FLINK-4632 at 9/20/16 1:26 AM:
Yes. The job's sta
[
https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15505243#comment-15505243
]
刘喆 commented on FLINK-4632:
---
Yes. The job's status is canceling, then hung. Web page is ok, cli
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504633#comment-15504633
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2495
Is there a section that describes the design that this follows in more
detail? I would like to take a look and comment.
I am a bit skeptical whether this is going in the right direction.
[
https://issues.apache.org/jira/browse/FLINK-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4625.
-
Resolution: Fixed
Fixed via 5066125f9a377d232f77f6fbcac3c22ebea66b39
> Guard Flink processes agai
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2452
There is not a lot of response on the mailing list. Apparently switching to
the newer Storm version does not bother anyone.
My guess would be to switch to Strom 1.0+ and remove the storm
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2503
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504597#comment-15504597
]
ASF GitHub Bot commented on FLINK-4625:
---
Github user asfgit closed the pull request
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79477333
--- Diff:
flink-batch-connectors/flink-hbase/src/test/resources/hbase-site.xml ---
@@ -1,43 +0,0 @@
-
-
-
-
--- End diff --
I'm n
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504585#comment-15504585
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2460
I agree. +1 for moving the examples.
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2458
Hi!
Can you explain a bit what this pull request fixes? I think Maven complains
by itself if the JDK is of a lower version than the compiler target version. So
what changes here?
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2460
I think this is actually a good idea. The Table API module should not
contain the examples.
@fhueske @twalthr What do you think about this?
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504575#comment-15504575
]
ASF GitHub Bot commented on FLINK-4562:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504563#comment-15504563
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504565#comment-15504565
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504568#comment-15504568
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504562#comment-15504562
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504569#comment-15504569
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504567#comment-15504567
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504570#comment-15504570
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504566#comment-15504566
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504564#comment-15504564
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79477173
--- Diff:
flink-batch-connectors/flink-hbase/src/test/resources/log4j-test.properties ---
@@ -15,9 +15,16 @@
# specific language governing permissions an
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79472506
--- Diff:
flink-batch-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/TestTableInputFormat.java
---
@@ -0,0 +1,112 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79469241
--- Diff:
flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
---
@@ -93,32 +102,45 @@ private HTable create
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79469197
--- Diff:
flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
---
@@ -93,32 +102,45 @@ private HTable create
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79469573
--- Diff:
flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
---
@@ -131,37 +153,27 @@ public T nextRecord(
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79470876
--- Diff:
flink-batch-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/TestTableInputFormat.java
---
@@ -0,0 +1,112 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79468879
--- Diff:
flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
---
@@ -67,15 +67,24 @@
protected abst
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r79469513
--- Diff:
flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
---
@@ -131,37 +153,27 @@ public T nextRecord(
[
https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504538#comment-15504538
]
ASF GitHub Bot commented on FLINK-4560:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2465
I think this is good, please add.
It may make sense to have a comment at the top that states that these are
advanced network options that one typically does not have to touch.
---
If yo
[
https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504525#comment-15504525
]
ASF GitHub Bot commented on FLINK-4447:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504532#comment-15504532
]
ASF GitHub Bot commented on FLINK-4447:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504519#comment-15504519
]
ASF GitHub Bot commented on FLINK-4510:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504522#comment-15504522
]
ASF GitHub Bot commented on FLINK-4447:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2465#discussion_r79476468
--- Diff: docs/setup/config.md ---
@@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`.
These parameters configure the default HDFS used by
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2453
Will have a look at this again soon.
---
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
ena
[
https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504516#comment-15504516
]
ASF GitHub Bot commented on FLINK-4490:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2447
Was manually merges as of eac6088a75e813a015b778f4cfc4cce0cf2a53ce
---
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-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504517#comment-15504517
]
ASF GitHub Bot commented on FLINK-4490:
---
Github user StephanEwen closed the pull req
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2465#discussion_r79476351
--- Diff: docs/setup/config.md ---
@@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`.
These parameters configure the default HDFS used by
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/2447
---
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
Github user cjstehno commented on the issue:
https://github.com/apache/flink/pull/2369
Any thoughts on when this might make it into a release? We are having
issues running Flink with Kafka 0.10 and would like to have an idea of whether
we can/should wait for this or pull it and try bu
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504506#comment-15504506
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user cjstehno commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504498#comment-15504498
]
Fabian Hueske commented on FLINK-4624:
--
Hmm, that sounds strange. The purpose of the
[
https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504485#comment-15504485
]
ASF GitHub Bot commented on FLINK-4447:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2465#discussion_r79474627
--- Diff: docs/setup/config.md ---
@@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`.
These parameters configure the default HDFS used by
[
https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504478#comment-15504478
]
ASF GitHub Bot commented on FLINK-3719:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2467
This is a useful extension.
I have pinged someone with more web UI experience to take a look at how it
is implemented.
Concerning licenses: Where are the png images for the sliders fr
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504464#comment-15504464
]
ASF GitHub Bot commented on FLINK-2662:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2508
I think you are right.
+1 to merge then
---
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
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504447#comment-15504447
]
Martin Junghanns commented on FLINK-4624:
-
No, I wanted to have an {{Either}} as f
[
https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504434#comment-15504434
]
ASF GitHub Bot commented on FLINK-4579:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2482
Looks good. I think we could even go one step further and have a shortcut
(`rocksdb`) similar to `filesystem` and `jobmanager`.
We should then also have dedicated options, like
`state.ba
[
https://issues.apache.org/jira/browse/FLINK-4594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504429#comment-15504429
]
ASF GitHub Bot commented on FLINK-4594:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2481
Good to merge!
---
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
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2513#discussion_r79470571
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
---
@@ -670,12 +676,15 @@ public void run(SourceContext c
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2513#discussion_r79466613
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
---
@@ -670,12 +676,15 @@ public void run(SourceContext ctx)
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504308#comment-15504308
]
Fabian Hueske edited comment on FLINK-4624 at 9/19/16 6:55 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504308#comment-15504308
]
Fabian Hueske commented on FLINK-4624:
--
Did you try to ship the {{Either}} types as p
[
https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504300#comment-15504300
]
ASF GitHub Bot commented on FLINK-4520:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2487
Thank you for that big contribution. Siddhi looks like a cool approach to
CEP.
Before digging into the details, I would like to start a discussion about
whether we should have this as a
[
https://issues.apache.org/jira/browse/FLINK-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504283#comment-15504283
]
ASF GitHub Bot commented on FLINK-4609:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2490
This isn't improving performance but moving the null checks before first
access and removing the duplicate `DataSet` references.
---
If your project is set up for it, you can reply to this email a
Vijay Srinivasaraghavan created FLINK-4637:
--
Summary: Address Yarn proxy incompatibility with Flink Web UI when
service level authorization is enabled
Key: FLINK-4637
URL: https://issues.apache.org/jira/b
Vijay Srinivasaraghavan created FLINK-4635:
--
Summary: Implement Data Transfer Authentication using shared
secret configuration
Key: FLINK-4635
URL: https://issues.apache.org/jira/browse/FLINK-4635
Fabian Hueske created FLINK-4636:
Summary: AbstractCEPPatternOperator fails to restore state
Key: FLINK-4636
URL: https://issues.apache.org/jira/browse/FLINK-4636
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504238#comment-15504238
]
ASF GitHub Bot commented on FLINK-4609:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2490
Playing Devil's advocate here:
Does this really improve anything meaningful? This is an API-level
operator, not anything runtime related, so the additional null check is not
really impor
[
https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504208#comment-15504208
]
Stephan Ewen commented on FLINK-4513:
-
The fix is to actually edit the Kafka section o
[
https://issues.apache.org/jira/browse/FLINK-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian closed FLINK-4614.
--
Resolution: Not A Problem
> Kafka connector documentation refers to Flink 1.2-SN
[
https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neelesh Srinivas Salian closed FLINK-4513.
--
Resolution: Not A Problem
> Kafka connector documentation refers to Flink 1.1-SN
[
https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504226#comment-15504226
]
ASF GitHub Bot commented on FLINK-4513:
---
Github user nssalian commented on the issue
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2493
Thanks @StephanEwen . Closing this one as well.
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504225#comment-15504225
]
ASF GitHub Bot commented on FLINK-4513:
---
Github user nssalian closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-4610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15504218#comment-15504218
]
ASF GitHub Bot commented on FLINK-4610:
---
Github user StephanEwen commented on the is
1 - 100 of 225 matches
Mail list logo
