[
https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-4373:
--
Summary: Introduce SlotID, AllocationID, ResourceProfile (was: Introduce
SlotID & ResourceProfile)
> I
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418405#comment-15418405
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
Thanks Max. I have reorganized the secure test case and removed custom
JRunner implementation for Kafka. Kept single secure test case for HDFS, Kafka
and Yarn modules. Please take a look.
---
I
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu updated FLINK-4375:
---
Summary: Introduce rpc protocols implemented by job manager (was:
Introduce rpc protocols provided by
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418355#comment-15418355
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418349#comment-15418349
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-3870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418303#comment-15418303
]
ASF GitHub Bot commented on FLINK-3870:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418264#comment-15418264
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user wenlong88 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418260#comment-15418260
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user wenlong88 commented on a diff i
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/1963
Hi @danielblazevski , I find a way to solve this. Just copy the
`FlinkCodeStyle.xml` to the config/codestyles directory (for me is
`~/Library/Preferences/IntelliJIdea15/codestyles`) and restarting t
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418259#comment-15418259
]
ASF GitHub Bot commented on FLINK-4355:
---
Github user wenlong88 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15418104#comment-15418104
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417952#comment-15417952
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user mushketyk closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417954#comment-15417954
]
ASF GitHub Bot commented on FLINK-3318:
---
GitHub user mushketyk reopened a pull reque
Github user mushketyk closed the pull request at:
https://github.com/apache/flink/pull/2361
---
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
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417947#comment-15417947
]
ASF GitHub Bot commented on FLINK-3318:
---
GitHub user mushketyk opened a pull request
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2361
[FLINK-3318][cep] Add support for quantifiers to CEP's pattern API
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into considerati
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417880#comment-15417880
]
Elias Levy commented on FLINK-4035:
---
FWIW I generated a flink-connector-kafka-0.9_2.11-1
[
https://issues.apache.org/jira/browse/FLINK-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417764#comment-15417764
]
ASF GitHub Bot commented on FLINK-4198:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2359
I think this breaks the API compatibility.
This issue was scheduled as part of the API breaking changes for FLINK 2.0
Compatibility for `@Public` annotated methods is something we prom
Stephan Ewen created FLINK-4386:
---
Summary: Add as way to assert that code runs in the RpcEndpoint's
Main Thread
Key: FLINK-4386
URL: https://issues.apache.org/jira/browse/FLINK-4386
Project: Flink
Timo Walther created FLINK-4385:
---
Summary: Union on Timestamp fields does not work
Key: FLINK-4385
URL: https://issues.apache.org/jira/browse/FLINK-4385
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417632#comment-15417632
]
ASF GitHub Bot commented on FLINK-4382:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2358
Not completely sure about the message stashing. Why not drop the messages?
That would be safer (less to clean up, no overflow).
Is this mainly to not loose the messages from the "self gat
[
https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417626#comment-15417626
]
ASF GitHub Bot commented on FLINK-4384:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2360
[FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEndpoint
NOTE: This builds on top of #2357 - only the second commit belongs actually
to this pull request is relevant.
Add a `sched
[
https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417617#comment-15417617
]
Stephan Ewen commented on FLINK-4374:
-
True, but the test should not try a Tuple2 if t
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417611#comment-15417611
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2357
+1 from my side
I would suggest as a followup to find out the gateway type for reflection.
The `ReflectionUtil` helps with that.
---
If your project is set up for it, you can reply to t
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417609#comment-15417609
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2357#discussion_r74463001
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/messages/RpcInvocation.java
---
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the
GitHub user kishorekgarg opened a pull request:
https://github.com/apache/flink/pull/2359
[FLINK-4198] Replace org.apache.flink.streaming.api.windowing.time.Tiâ¦
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into co
[
https://issues.apache.org/jira/browse/FLINK-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417562#comment-15417562
]
ASF GitHub Bot commented on FLINK-4198:
---
GitHub user kishorekgarg opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4383:
Assignee: Till Rohrmann
> Check parameters for serializability before sending a remote RpcI
[
https://issues.apache.org/jira/browse/FLINK-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417538#comment-15417538
]
ASF GitHub Bot commented on FLINK-4382:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2358
[FLINK-4382] Buffer rpc calls until the RpcEndpoint has been started
This PR allows the AkkaRpcActor to stash messages until the corresponding
RcpEndpoint
has been started. When receiving a
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417522#comment-15417522
]
Elias Levy commented on FLINK-4326:
---
That would be my expectation. Writing out the PID
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417467#comment-15417467
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user iemejia commented on the issue:
Github user iemejia commented on the issue:
https://github.com/apache/flink/pull/2340
And remember that my ultimate goal is not to host that image but that we
can convert it into an official one.
---
If your project is set up for it, you can reply to this email and have your
reply ap
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417465#comment-15417465
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user iemejia commented on the issue:
Github user iemejia commented on the issue:
https://github.com/apache/flink/pull/2340
Of course, who do you think I am :P
You can check a ready to run build here in case you don't want to test that
one. But it is true that we need some kind of automatized tests for the image.
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417458#comment-15417458
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2357#discussion_r74446628
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java ---
@@ -172,6 +173,13 @@ public void runAsync(Runnable runnable) {
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417450#comment-15417450
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2340
Thanks! Looks good. Did you run the changes with Docker?
---
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-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417447#comment-15417447
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2340#discussion_r74445659
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,25 +22,30 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure Flink
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417442#comment-15417442
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2340#discussion_r74445485
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,25 +22,30 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure Flink
Stephan Ewen created FLINK-4384:
---
Summary: Add a "scheduleRunAsync()" feature to the RpcEndpoint
Key: FLINK-4384
URL: https://issues.apache.org/jira/browse/FLINK-4384
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417432#comment-15417432
]
Stephan Ewen commented on FLINK-4382:
-
Would it buffer the messages, or simply discard
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2275
>HDFS and Yarn are handled through the @BeforeClass and @AfterClass style
and they do not use custom JRunner implementation. As you have suggested, I
could keep just one or two tests for each of the modu
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417431#comment-15417431
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4368.
---
> Eagerly initialize RrcProtocol members
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417423#comment-15417423
]
ASF GitHub Bot commented on FLINK-4366:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417422#comment-15417422
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user tillrohrmann commented on a dif
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2354
Something like `NonParallelSingleOutputStreamOperator` but that's quite a
mouthful. (`SingleOutputStreamOperator` is already too long for my taste ...).
Or maybe `NonParallelStreamOperator`.
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2357#discussion_r74443700
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
---
@@ -0,0 +1,176 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417417#comment-15417417
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2357
Yes you're right @StephanEwen. We shouldn't stop the actor upon receiving
an unknown message type. I'll change the behaviour.
---
If your project is set up for it, you can reply to this email a
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417415#comment-15417415
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2357#discussion_r74443304
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/messages/RpcInvocation.java
---
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417412#comment-15417412
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2357#discussion_r74443020
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
---
@@ -0,0 +1,176 @@
+/*
+ * Licensed to the Apache S
Till Rohrmann created FLINK-4383:
Summary: Check parameters for serializability before sending a
remote RpcInvocation message
Key: FLINK-4383
URL: https://issues.apache.org/jira/browse/FLINK-4383
Proj
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2337
@StephanEwen I have updated the PR.
---
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
Till Rohrmann created FLINK-4382:
Summary: Buffer rpc calls until RpcEndpoint is properly started
Key: FLINK-4382
URL: https://issues.apache.org/jira/browse/FLINK-4382
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417394#comment-15417394
]
ASF GitHub Bot commented on FLINK-3042:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417385#comment-15417385
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2357#discussion_r74439866
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/messages/RpcInvocation.java
---
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417379#comment-15417379
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2357#discussion_r74439096
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java
---
@@ -0,0 +1,176 @@
+/*
+ * Licensed to the Apache So
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2357
Good stuff!
I am not sure we should throw an Exception in the `AkkaRpcActor` upon
receiving an incorrect message. In the past we decided to only log those cases.
Seems to easy to bring d
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417376#comment-15417376
]
ASF GitHub Bot commented on FLINK-4362:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417338#comment-15417338
]
Stephan Ewen commented on FLINK-4377:
-
Yes, this can currently happen. The only way to
[
https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417309#comment-15417309
]
ASF GitHub Bot commented on FLINK-4362:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417302#comment-15417302
]
Stephan Ewen commented on FLINK-4370:
-
In theory, putting it in "tools" and referencin
[
https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417316#comment-15417316
]
Timo Walther commented on FLINK-4374:
-
The null support in general is a bit inconsiste
[
https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4368:
-
Assignee: Stephan Ewen
> Eagerly initialize RrcProtocol members
>
[
https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4368.
--
Resolution: Done
Added via 08af7def60d54c22126b902e6fa57101d5fbb8fa
> Eagerly initialize RrcPro
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2357
[FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies
This PR introduces a generic `AkkaRpcActor` which receives rpc calls as a
`RpcInvocation` message. The `RpcInvocation` message
[
https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417298#comment-15417298
]
Stephan Ewen commented on FLINK-4374:
-
Tuples do not support null fields, so the test
Aljoscha Krettek created FLINK-4381:
---
Summary: Refactor State to Prepare For Key-Group State Backends
Key: FLINK-4381
URL: https://issues.apache.org/jira/browse/FLINK-4381
Project: Flink
Is
Aljoscha Krettek created FLINK-4380:
---
Summary: Introduce KeyGroupAssigner and Max-Parallelism Parameter
Key: FLINK-4380
URL: https://issues.apache.org/jira/browse/FLINK-4380
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417270#comment-15417270
]
Timo Walther commented on FLINK-4359:
-
Once the roadmap for that is defined (most like
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417286#comment-15417286
]
Greg Hogan commented on FLINK-4326:
---
Isn't the expectation that the supervisor would mon
Ufuk Celebi created FLINK-4379:
--
Summary: Add Rescalable Non-Partitioned State
Key: FLINK-4379
URL: https://issues.apache.org/jira/browse/FLINK-4379
Project: Flink
Issue Type: New Feature
GitHub user wenlong88 opened a pull request:
https://github.com/apache/flink/pull/2356
[FLINK-4378]Enable RollingSink to custom HDFS client configuration
Adding a new interface to rolling sink
You can merge this pull request into a Git repository by running:
$ git pull https:/
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417255#comment-15417255
]
Ismaël Mejía commented on FLINK-4326:
-
A separation of (daemon/console) scripts would
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417249#comment-15417249
]
ASF GitHub Bot commented on FLINK-4378:
---
GitHub user wenlong88 opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417241#comment-15417241
]
Greg Hogan commented on FLINK-4370:
---
I'd rather add this to its proper place ({{.idea}})
Wenlong Lyu created FLINK-4378:
--
Summary: Enable RollingSink to custom HDFS client configuration
Key: FLINK-4378
URL: https://issues.apache.org/jira/browse/FLINK-4378
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417229#comment-15417229
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2342
I think we need to change more than just that single variable. The other
variables should match, e.g.
`recovery.jobmanager.port => high-availability.jobmanager.port` and also
`recovery.zookeeper.* =>
[
https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417208#comment-15417208
]
Jark Wu commented on FLINK-4370:
Yes. We can put this files into tools folder (or other) a
[
https://issues.apache.org/jira/browse/FLINK-4335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417195#comment-15417195
]
Robert Metzger commented on FLINK-4335:
---
I see. The jar ID is an internal id of the
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417187#comment-15417187
]
Jark Wu commented on FLINK-4359:
Okay, I see.
I'm interested in this, and I'm glad if I c
[
https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417185#comment-15417185
]
Greg Hogan commented on FLINK-4370:
---
We've had pull requests rejected due to formatting
Sajeev Ramakrishnan created FLINK-4377:
--
Summary: akka.remote.OversizedPayloadException: Discarding
oversized payload
Key: FLINK-4377
URL: https://issues.apache.org/jira/browse/FLINK-4377
Project
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417169#comment-15417169
]
ASF GitHub Bot commented on FLINK-4282:
---
GitHub user Renkai opened a pull request:
1 - 100 of 198 matches
Mail list logo
