Kurt Young created FLINK-4348:
-
Summary: implement communication from ResourceManager to
TaskManager
Key: FLINK-4348
URL: https://issues.apache.org/jira/browse/FLINK-4348
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-4342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15414924#comment-15414924
]
ASF GitHub Bot commented on FLINK-4342:
---
Github user aljoscha commented on the issue
zhangjing created FLINK-4349:
Summary: ResourceManager interaction
Key: FLINK-4349
URL: https://issues.apache.org/jira/browse/FLINK-4349
Project: Flink
Issue Type: Task
Reporter: zhan
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2346
LGTM!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feat
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15414927#comment-15414927
]
Robert Metzger commented on FLINK-4341:
---
I'll implement a little testing job to see
[
https://issues.apache.org/jira/browse/FLINK-4349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing closed FLINK-4349.
Resolution: Invalid
> ResourceManager interaction
> ---
>
> Key: FLI
zhangjing created FLINK-4350:
Summary: ResourceManager interaction
Key: FLINK-4350
URL: https://issues.apache.org/jira/browse/FLINK-4350
Project: Flink
Issue Type: Sub-task
Components:
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4341:
Description:
This issue was first encountered with Flink release 1.1.0 (commit 45f7825). I
was prev
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-4341:
-
Assignee: Robert Metzger
> Checkpoint state size grows unbounded when task parallelism no
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15414944#comment-15414944
]
Stephan Ewen commented on FLINK-4341:
-
Scott, we are trying to set up a test to see if
zhangjing created FLINK-4351:
Summary: TaskExecutor interaction
Key: FLINK-4351
URL: https://issues.apache.org/jira/browse/FLINK-4351
Project: Flink
Issue Type: Sub-task
Components: Clu
zhangjing created FLINK-4352:
Summary: JobClient interaction
Key: FLINK-4352
URL: https://issues.apache.org/jira/browse/FLINK-4352
Project: Flink
Issue Type: Sub-task
Components: Cluste
zhangjing created FLINK-4353:
Summary: cluster components failure process
Key: FLINK-4353
URL: https://issues.apache.org/jira/browse/FLINK-4353
Project: Flink
Issue Type: Sub-task
Rep
Zhijiang Wang created FLINK-4354:
Summary: TaskManager to ResourceManager heartbeats
Key: FLINK-4354
URL: https://issues.apache.org/jira/browse/FLINK-4354
Project: Flink
Issue Type: Sub-task
Github user mushketyk closed the pull request at:
https://github.com/apache/flink/pull/2339
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is e
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2339
I realized that there is still some work to do here. I'll reopen this pull
request a bit later.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15414989#comment-15414989
]
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=15414988#comment-15414988
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user mushketyk commented on the issu
Zhijiang Wang created FLINK-4355:
Summary: TaskManager registration at ResourceManager
Key: FLINK-4355
URL: https://issues.apache.org/jira/browse/FLINK-4355
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Assignee: (was: Zhijiang Wang)
> TaskManager to ResourceManager heartbeats
> -
zhangjing created FLINK-4356:
Summary: JobMaster HA
Key: FLINK-4356
URL: https://issues.apache.org/jira/browse/FLINK-4356
Project: Flink
Issue Type: Sub-task
Reporter: zhangjing
1.
[
https://issues.apache.org/jira/browse/FLINK-4350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4350:
-
Summary: interaction between new JobMaster and new ResourceManager (was:
ResourceManager interaction)
>
[
https://issues.apache.org/jira/browse/FLINK-4350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4350:
-
Summary: interaction between new JobManager and new ResourceManager (was:
interaction between new JobMast
[
https://issues.apache.org/jira/browse/FLINK-4351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4351:
-
Summary: interaction between new JobManager and new TaskManager (was:
TaskExecutor interaction)
> intera
[
https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415014#comment-15415014
]
ASF GitHub Bot commented on FLINK-4340:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2345
@wenlong88 I was talking about this effort to enable key-group sharding in
Flink: https://issues.apache.org/jira/browse/FLINK-3755
With this is becomes necessary to checkpoint the keyed stat
[
https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4352:
-
Summary: interaction between new JobManager and JobClient (was: JobClient
interaction)
> interaction bet
[
https://issues.apache.org/jira/browse/FLINK-4353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4353:
-
Summary: new JobManager handle cluster components failure (was: cluster
components failure process)
> ne
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
Hi, I have updated this PR, adding javadoc and an example as @tzulitai
advised and created Enums for PUT, DELETE, INCREMENT and APPEND as @ramkrish86
advised.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415017#comment-15415017
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4356:
-
Summary: new JobManager HA (was: JobMaster HA)
> new JobManager HA
> -
>
>
Zhijiang Wang created FLINK-4357:
Summary: TaskManager responses slot allocation
Key: FLINK-4357
URL: https://issues.apache.org/jira/browse/FLINK-4357
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Description: RM initiates Heartbeat with ResourceManagerLeaderID. TM
responses to RM with slot all
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4354:
-
Summary: TaskManager responses heartbeats from ResourceManager (was:
TaskManager responses Resour
[
https://issues.apache.org/jira/browse/FLINK-4357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4357:
-
Summary: TaskManager responses slot allocation from ResourceManager (was:
TaskManager responses s
[
https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4316.
---
> Make flink-core independent of Hadoop
> -
>
> Key: F
[
https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4316.
-
Resolution: Fixed
Fixed via a2f9aabac7606199c640d228cc432e5242330bc9
> Make flink-core independen
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2338
---
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-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415039#comment-15415039
]
ASF GitHub Bot commented on FLINK-4316:
---
Github user asfgit closed the pull request
Zhijiang Wang created FLINK-4358:
Summary: TaskManager deploys task into slot
Key: FLINK-4358
URL: https://issues.apache.org/jira/browse/FLINK-4358
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-4359:
---
Summary: Add INTERVAL type
Key: FLINK-4359
URL: https://issues.apache.org/jira/browse/FLINK-4359
Project: Flink
Issue Type: New Feature
Components: T
Zhijiang Wang created FLINK-4360:
Summary: TaskManager slot registration at JobManager
Key: FLINK-4360
URL: https://issues.apache.org/jira/browse/FLINK-4360
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415058#comment-15415058
]
Tzu-Li (Gordon) Tai commented on FLINK-4341:
I just did a test on revision 45f
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2346
---
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-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415058#comment-15415058
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4341 at 8/10/16 10:03 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415058#comment-15415058
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4341 at 8/10/16 10:03 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415060#comment-15415060
]
ASF GitHub Bot commented on FLINK-4342:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4342.
---
> Fix dependencies of flink-connector-filesystem
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4342.
-
Resolution: Fixed
Fixed via 5910af5e81bc2f85076d2f8d6d02f8acaf89c5a4
> Fix dependencies of flink-
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415058#comment-15415058
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4341 at 8/10/16 10:06 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4346:
Component/s: (was: Cluster Management)
Distributed Coordination
> Implement bas
Stephan Ewen created FLINK-4361:
---
Summary: Replace Scala Futures
Key: FLINK-4361
URL: https://issues.apache.org/jira/browse/FLINK-4361
Project: Flink
Issue Type: Sub-task
Components:
[
https://issues.apache.org/jira/browse/FLINK-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4346:
Assignee: Till Rohrmann
> Implement basic RPC abstraction
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415064#comment-15415064
]
Robert Metzger commented on FLINK-4341:
---
In my tests so far, the Kinesis consumer is
Stephan Ewen created FLINK-4362:
---
Summary: Auto generate message sender classes via Java Proxies
Key: FLINK-4362
URL: https://issues.apache.org/jira/browse/FLINK-4362
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4346:
-
Description:
As part of refactoring of the cluster management, we can introduce a new RPC
abstrac
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2347
[FLINK-4236] fix error handling for jar files with no main method
This change shows only entry classes with a valid main method. It
ignores classes which contain no main method.
You can merge this p
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415071#comment-15415071
]
ASF GitHub Bot commented on FLINK-4236:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4236:
--
Fix Version/s: 1.1.2
> Flink Dashboard stops showing list of uploaded jars if main metho
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415074#comment-15415074
]
Stephan Ewen commented on FLINK-4341:
-
[~skidder] Do you set something like "allowed l
Zhijiang Wang created FLINK-4363:
Summary: TaskManager basic startup of all components
Key: FLINK-4363
URL: https://issues.apache.org/jira/browse/FLINK-4363
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-4355:
---
Assignee: Stephan Ewen
> TaskManager registration at ResourceManager
> --
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4355:
Description:
If the {{TaskManager}} is unregistered, it should try and register at the
{{ResourceMa
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang reassigned FLINK-4363:
Assignee: Zhijiang Wang
> TaskManager basic startup of all components
> ---
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4363:
-
Assignee: (was: Zhijiang Wang)
> TaskManager basic startup of all components
> ---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2347
+1
---
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 i
[
https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415099#comment-15415099
]
ASF GitHub Bot commented on FLINK-4236:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang Wang updated FLINK-4358:
-
Assignee: Zhijiang Wang
> TaskManager deploys task into slot
> --
[
https://issues.apache.org/jira/browse/FLINK-4350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangjing updated FLINK-4350:
-
Description:
1. Send Slot Request to ResourceManager
2. Cancel SlotRequest to ResourceManager
3. Register
Zhijiang Wang created FLINK-4364:
Summary: TaskManage responses heartbeats from JobManager
Key: FLINK-4364
URL: https://issues.apache.org/jira/browse/FLINK-4364
Project: Flink
Issue Type: Sub
[
https://issues.apache.org/jira/browse/FLINK-3445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-3445:
Assignee: (was: Chesnay Schepler)
> make JDBCInputFormat implement ResultTypeQueryable
>
Chesnay Schepler created FLINK-4365:
---
Summary: [metrics] MetricConfig has no documentation
Key: FLINK-4365
URL: https://issues.apache.org/jira/browse/FLINK-4365
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-3690.
---
Resolution: Fixed
The ResourceManager is still undergoing changes. Should be resolved
[
https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415154#comment-15415154
]
Maximilian Michels edited comment on FLINK-4318 at 8/10/16 11:51 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415154#comment-15415154
]
Maximilian Michels commented on FLINK-4318:
---
The docs are built from a list of G
[
https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15415154#comment-15415154
]
Maximilian Michels edited comment on FLINK-4318 at 8/10/16 11:51 AM:
---
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2340#discussion_r74229920
--- 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=15415158#comment-15415158
]
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_r74229989
--- 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=15415159#comment-15415159
]
ASF GitHub Bot commented on FLINK-3155:
---
Github user mxm commented on a diff in the
[
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:
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-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
[
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:
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=15415204#comment-15415204
]
Jark Wu commented on FLINK-4359:
Do we have any ideas how to implement StreamSQL window? B
[
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:
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-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
[
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-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
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
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
[
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
[
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-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
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-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 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
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
1 - 100 of 179 matches
Mail list logo
