[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4364:
-
Description: The {{JobManager}} initiates heartbeat messages via (JobID,
JmLeaderID), and the {{Ta
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Description:
The {{ResourceManager}} may tell the {{TaskManager}} to give a slot to a
specific {{
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Description:
The {{ResourceManager}} may tell the {{TaskManager}} to give a slot to a
specific {{
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416602#comment-15416602
]
Renkai Ge commented on FLINK-4282:
--
I have the same opinion with [~aljoscha],the offset p
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416585#comment-15416585
]
Aditi Viswanathan commented on FLINK-4282:
--
And if they want to use their own met
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416580#comment-15416580
]
Aditi Viswanathan commented on FLINK-4282:
--
We could maybe also provide another o
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416572#comment-15416572
]
Aditi Viswanathan commented on FLINK-4282:
--
Hi Renkai,
If you look at the PR you
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416556#comment-15416556
]
Renkai Ge commented on FLINK-4282:
--
If there is no proper solution to this issue now,I wa
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4357:
Assignee: Zhijiang Wang
> Implement TaskManager side of slot allocation from ResourceManage
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4360:
Assignee: Zhijiang Wang
> Implement TaskManager registration slot at JobManager
> -
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4364:
-
Summary: Implement TaskManager side of heartbeat from JobManager (was:
Implement TaskManager side
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4364:
-
Summary: Implement TaskManager side of heartbeats from JobManager (was:
TaskManage responses hear
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4363:
-
Description: Similar with current {{TaskManager}},but implement
initialization and startup all com
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4363:
-
Summary: Implement TaskManager basic startup of all components in java
(was: TaskManager basic st
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4360:
-
Summary: Implement TaskManager registration slot at JobManager (was:
Implement TaskManager offer
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4360:
-
Description: The {{TaskManager}} offers a slot to a {{JobManager}} at the
{{ResourceManager}}’s be
[
https://issues.apache.org/jira/browse/FLINK-4360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4360:
-
Summary: Implement TaskManager offer slot to JobManager (was: TaskManager
slot registration at Jo
[
https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4358:
-
Description:
The {{TaskManager}} may receive task deployment request (bound to
slot/allocationID)
[
https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4358:
-
Summary: Implement TaskManager deployment task into slot (was: TaskManager
deploys task into slot
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4355:
-
Summary: Implement TaskManager side of registration at ResourceManager
(was: TaskManager registra
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Summary: Implement TaskManager side of slot allocation from ResourceManager
(was: Implement TaskM
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Summary: Implement TaskManager side slot allocation from ResourceManager
(was: TaskManager respon
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Description:
The {{ResourceManager}} may tell the {{TaskManager}} to give a slot to a
specific {{
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Summary: Implement TaskManager side of heartbeat from ResourceManager
(was: TaskManager response
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4354:
Assignee: Zhijiang Wang
> TaskManager responses heartbeats from ResourceManager
> -
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Description:
The {{ResourceManager}} initiates heartbeat messages via the {{RmLeaderID}}.
The {{T
[
https://issues.apache.org/jira/browse/FLINK-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4366:
--
Assignee: Jark Wu
> Enforce parallelism=1 For AllWindowedStream
> -
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416179#comment-15416179
]
ASF GitHub Bot commented on FLINK-4359:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2348
The first line is Scala Table API, second line is Java Table API and the
string with the INTERVAL prefix is standard SQL. So we cannot change the
standard ;)
Yes, I think that is the reason.
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416096#comment-15416096
]
ASF GitHub Bot commented on FLINK-4355:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2353
[FLINK-4355] [cluster management] Implement TaskManager side of
registration at ResourceManager.
This implements the first part of the `TaskManager` (here temporarily
called `TaskExecutor` to a
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415984#comment-15415984
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
BTW, the example runs well on my machine when I set hbase-client version to
2.0.0-SNAPSHOT, but travis-ci build failed due to "Failed to collect
dependencies at org.apache.habse:hbase-client:jar:2.0.
[
https://issues.apache.org/jira/browse/FLINK-4104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415897#comment-15415897
]
ASF GitHub Bot commented on FLINK-4104:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2258
Hi @greghogan, sorry I somehow missed this PR ð
I really like the restructuring, thanks! I don't think it's a problem to
rename to `gelly/index.html`. Just make sure to also update the link in
`
[
https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415735#comment-15415735
]
ASF GitHub Bot commented on FLINK-4368:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2351
@tillrohrmann What do you think about this?
The downside that I can see is that the RPC endpoint can actually receive
calls before the constructor is completed, basically as soon as the b
Zhenzhong Xu created FLINK-4372:
---
Summary: Add ability to take savepoints from job manager web UI
Key: FLINK-4372
URL: https://issues.apache.org/jira/browse/FLINK-4372
Project: Flink
Issue Type
Zhenzhong Xu created FLINK-4371:
---
Summary: Add ability to take savepoints from job manager RESTful
API
Key: FLINK-4371
URL: https://issues.apache.org/jira/browse/FLINK-4371
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4336:
Summary: Expose ability to take a savepoint from job manager (was: Expose
ability to take a savepoi
[
https://issues.apache.org/jira/browse/FLINK-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415687#comment-15415687
]
Robert Metzger commented on FLINK-4336:
---
Yes. Its a good idea to split the backend a
[
https://issues.apache.org/jira/browse/FLINK-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415639#comment-15415639
]
Zhenzhong Xu commented on FLINK-4336:
-
[~rmetzger] Sure, let me look into the implemen
[
https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415624#comment-15415624
]
ASF GitHub Bot commented on FLINK-4370:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2352
[FLINK-4370] Add an IntelliJ Inspections Profile
This adds an IntelliJ inspections profile for Flink in the `.idea` folder.
When the code is imported into IntelliJ, it should automatically pi
[
https://issues.apache.org/jira/browse/FLINK-4335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415619#comment-15415619
]
Zhenzhong Xu commented on FLINK-4335:
-
[~rmetzger] Thanks for the comment, I will impl
Stephan Ewen created FLINK-4370:
---
Summary: Offer a default IntelliJ inspection profile with Flink
Key: FLINK-4370
URL: https://issues.apache.org/jira/browse/FLINK-4370
Project: Flink
Issue Type
Aljoscha Krettek created FLINK-4369:
---
Summary: Evictingwindowoperator Must Actually Evict Elements
Key: FLINK-4369
URL: https://issues.apache.org/jira/browse/FLINK-4369
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415532#comment-15415532
]
ASF GitHub Bot commented on FLINK-4329:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415533#comment-15415533
]
ASF GitHub Bot commented on FLINK-4368:
---
GitHub user StephanEwen opened a pull reque
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2350
[FLINK-4329] Fix Streaming File Source Timestamps/Watermarks Handling
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink continuous_file_fi
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2351
[FLINK-4368] [distributed runtime] Eagerly initialize the RPC endpoint
members
This eagerly initialized the RPC members like
- self gateway
- self reference
- main thread execu
Stephan Ewen created FLINK-4368:
---
Summary: Eagerly initialize RrcProtocol members
Key: FLINK-4368
URL: https://issues.apache.org/jira/browse/FLINK-4368
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415436#comment-15415436
]
Pushpendra Jaiswal commented on FLINK-4331:
---
I also think this is the issue with
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pushpendra Jaiswal resolved FLINK-4331.
---
Resolution: Fixed
> Flink is not able to serialize scala classes / Task Not Serializab
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pushpendra Jaiswal closed FLINK-4331.
-
> Flink is not able to serialize scala classes / Task Not Serializable
> -
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415410#comment-15415410
]
Stephan Ewen commented on FLINK-4331:
-
Can you share some more of the code? Without kn
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pushpendra Jaiswal updated FLINK-4331:
--
Priority: Minor (was: Major)
> Flink is not able to serialize scala classes / Task Not
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415368#comment-15415368
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415397#comment-15415397
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user iemejia commented on a diff in
Github user iemejia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2340#discussion_r74261518
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,25 +22,30 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure F
[
https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415394#comment-15415394
]
ASF GitHub Bot commented on FLINK-4340:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2345
We are very much trying to avoid different db instances per operator. Each
db instance will add quite a big new memory footprint. For higher
max-parallelism, this will be a problem.
The
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415382#comment-15415382
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user iemejia commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415381#comment-15415381
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user iemejia commented on a diff in
Github user iemejia commented on the issue:
https://github.com/apache/flink/pull/2340
We should maybe wait for 1.1.1 to be up before doing this merge, I will add
the commit for this and probably rebase everything once it is ready. Is it ok ?
---
If your project is set up for it, you
Github user iemejia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2340#discussion_r74259291
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,25 +22,30 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure F
Robert Metzger created FLINK-4367:
-
Summary: Offer separate API for watermark generation and timestamp
extraction
Key: FLINK-4367
URL: https://issues.apache.org/jira/browse/FLINK-4367
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415360#comment-15415360
]
Pushpendra Jaiswal edited comment on FLINK-4331 at 8/10/16 2:45 PM:
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415360#comment-15415360
]
Pushpendra Jaiswal edited comment on FLINK-4331 at 8/10/16 2:43 PM:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2231
Okay, cool. Thank you. I'll probably open a pull request with your and my
changes. I'll let you know so that you can help reviewing it.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415365#comment-15415365
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user radekg commented on the issue:
Github user radekg commented on the issue:
https://github.com/apache/flink/pull/2231
@rmetzger it's absolutely fine to reuse the code. If I can help in any way,
please let me know.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415363#comment-15415363
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2231
@radekg, are you okay with me using your pull request as a base for adding
Kafka 0.10 to Flink?
I've started changing your code from the PR so that we don't need to copy
so much code: https://gi
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415360#comment-15415360
]
Pushpendra Jaiswal commented on FLINK-4331:
---
Hi [~StephanEwen]
Thanks for the up
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415360#comment-15415360
]
Pushpendra Jaiswal edited comment on FLINK-4331 at 8/10/16 2:36 PM:
[
https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415348#comment-15415348
]
ASF GitHub Bot commented on FLINK-4340:
---
Github user wenlong88 commented on the issu
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/2345
3q, @aljoscha
Maybe we can use different db instance for different key group. this
approach can only work well when key group number is limited to a certain
number which can not be too large.
[
https://issues.apache.org/jira/browse/FLINK-4365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415343#comment-15415343
]
ASF GitHub Bot commented on FLINK-4365:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2349
[FLINK-4365] [metrics] Add documentation to MetricConfig
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If yo
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2348
Is the `INTERVAL` prefix needed to make it work with the parser? Otherwise
it would be nice to just write `2 DAYS`, or something like that.
By the way, the reason for the two different inter
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415303#comment-15415303
]
ASF GitHub Bot commented on FLINK-4359:
---
Github user aljoscha commented on the issue
Github user nielsbasjes commented on the issue:
https://github.com/apache/flink/pull/2330
I will add a unit test for this.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415291#comment-15415291
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user nielsbasjes commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415274#comment-15415274
]
Stephan Ewen commented on FLINK-4331:
-
[~pushpendra.jaiswa...@gmail.com] Any update on
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415264#comment-15415264
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user iemejia commented on a diff in
Github user iemejia commented on a diff in the pull request:
https://github.com/apache/flink/pull/2340#discussion_r74243197
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,25 +22,30 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure F
Aljoscha Krettek created FLINK-4366:
---
Summary: Enforce parallelism=1 For AllWindowedStream
Key: FLINK-4366
URL: https://issues.apache.org/jira/browse/FLINK-4366
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415259#comment-15415259
]
Robert Metzger commented on FLINK-4336:
---
I think this is a useful feature for the we
[
https://issues.apache.org/jira/browse/FLINK-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4336:
--
Component/s: State Backends, Checkpointing
> Expose ability to take a savepoint from job manager
[
https://issues.apache.org/jira/browse/FLINK-4335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415251#comment-15415251
]
Robert Metzger commented on FLINK-4335:
---
Hi Zhenzhong,
the parallelism and user defi
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2348
@aljoscha would be great if you could have a quick look on it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415205#comment-15415205
]
ASF GitHub Bot commented on FLINK-4359:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415204#comment-15415204
]
Jark Wu commented on FLINK-4359:
Do we have any ideas how to implement StreamSQL window? B
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2348
[FLINK-4359] [table] Add INTERVAL type
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take a
[
https://issues.apache.org/jira/browse/FLINK-4359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415206#comment-15415206
]
ASF GitHub Bot commented on FLINK-4359:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4329:
--
Summary: Fix Streaming File Source Timestamps/Watermarks Handling (was:
Fixes Streaming File So
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2340
Thanks for the PR! It would be nice to have the install path configurable.
Also, we should use ASF's load balancing script for downloading the binaries.
---
If your project is set up for it, you can rep
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415160#comment-15415160
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415159#comment-15415159
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user mxm commented on a diff in the
1 - 100 of 179 matches
Mail list logo
