On Fri, Jul 28, 2017 at 4:03 PM, Stephan Ewen wrote:
> Seems like no one raised a concern so far about dropping the savepoint
> format compatibility for 1.1 in 1.4.
>
> Leaving this thread open for some more days, but from the sentiment, it
> seems like we should go ahead?
+1
Hey Mike!
Thanks for the detailed information about your setup. I'm also puzzled
by this...
(1) Which version of Flink are you using? We recently merged some
changes to the JAR distribution components, which might cause this
(although I think that's unlikely).
(2) As a temporary work around you
I haven't followed this discussion in detail nor am I familiar with
the service authorization topic or Flakka, but a) sounds like a lot of
maintenance work to me.
If possible I would go with c) and maybe start a discussion about
dropping Scala 2.10 support to check whether that is a viable option
Hey Luis,
this is correct, yes. Note that these are "only" limitations of the
implementation and there is no fundamental reason to do it like this.
The different characteristics of intermediate results allow us to make
trade-offs here as seen fit.
Furthermore, the type of intermediate result desc
Hey devs,
I would like to stop serving the documentation for all Flink versions
prior to 1.0.
Do you have any concerns about this?
These Flink versions are very old without any upgrade path to newer
versions but they still get a lot of traffic and most new users don't
realize that they are looki
I think that broken/redirect links are not an issue,
>> as either way the information provided is far outdated
>> (== wrong).
>>
>> As for the warning, we cannot put it in the header instead
>> of the footer? Sth like, this page may contain outdated info,
>>
Quick update: If there are no objections, I will start looking into
how to stop serving the docs for Flink < 1.0 after tomorrow.
On Wed, Aug 16, 2017 at 10:45 PM, Ufuk Celebi wrote:
> Thanks for your early feedback Kostas and Ted.
>
> @Kostas: I have a proposal for a more obvious
>
>>>>> Please go ahead +1
>>>>>
>>>>> Thank you for taking care!
>>>>>
>>>>> On Tue, Aug 22, 2017 at 6:02 PM, Aljoscha Krettek
>>>>> wrote:
>>>>>
>>>>>> +1
>>>>
Great post. :-) Really looking forward to both releases.
– Ufuk
On Mon, Nov 20, 2017 at 4:19 PM, Aljoscha Krettek wrote:
> Hi everyone,
>
> Mike, Stephan and I wrote a blog post outlining the big new features
> scheduled for Flink 1.5 and also quickly describing the features of the
> soon-to-
Hey Shivam,
check this out:
https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/restart_strategies.html
Does it answer your questions?
– Ufuk
On Tue, Dec 26, 2017 at 9:30 AM, Shivam Sharma <28shivamsha...@gmail.com> wrote:
> I am submitting my Flink Job on Yarn(Amazon EMR)
>
> On Tu
Hey Gregory,
1) There is no special support for ResultSet in Flink, so you have to
manually parse it and emit records of the type you want.
2) In your asyncInvoke you don't need to submit to the executorService
since the client is already async and returns a future. You can use
the code in run()
Hey Rafi,
this is indeed a very nice feature to have. :-) I'm afraid that this
is currently hard to do manually with CEP. Let me pull in Dawid and
Klou (cc'd) who have worked a lot on CEP. They can probably update you
on the plan for FLINK-7129.
Best,
Ufuk
On Tue, Dec 26, 2017 at 8:47 PM, Shiv
ator so that it can support
> multiple
> patterns and match incoming events against all of them. For this I have no
> clear
> deadline in my mind, but given that there are more and more people asking
> for
> it, I think it is going to be added soon.
>
> Thanks for raising the
Since users already reported this on the ML, I'm big +1 to release immediately.
On Tue, Feb 27, 2018 at 7:45 AM, Tzu-Li (Gordon) Tai
wrote:
> Since we’re still a bit undecided on FLINK-8451, I think it would be best to
> release 1.4.2 with FLINK-8741 now.
> Otherwise, Kafka connectors using cust
Hey Amit!
Thanks for posting this here. I don't think it's an issue of the
buffer pool per se. Instead I think there are two potential causes
here:
1. The generated flow doesn't use blocking intermediate results for a
branching-joining flow.
=> I think we can check it if you run and post the outp
Thanks!
+1 (binding)
- Installed following quickstart with 1.12 Helm chart (--set
webhook.create=false) ✅
- Reviewed the announcement post
(https://github.com/apache/flink-web/pull/794#pullrequestreview-2888337481) ✅
- Deployed example application and triggered job exceptions that were visible
Ufuk Celebi created FLINK-14145:
---
Summary: getLatestCheckpoint returns wrong checkpoint
Key: FLINK-14145
URL: https://issues.apache.org/jira/browse/FLINK-14145
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-15828:
---
Summary: Integrate docker-flink/docker-flink into Flink release
process
Key: FLINK-15828
URL: https://issues.apache.org/jira/browse/FLINK-15828
Project: Flink
Ufuk Celebi created FLINK-15829:
---
Summary: Request apache/flink-docker repository
Key: FLINK-15829
URL: https://issues.apache.org/jira/browse/FLINK-15829
Project: Flink
Issue Type: Sub-task
Ufuk Celebi created FLINK-15830:
---
Summary: Migrate docker-flink/docker-flink to apache/flink-docker
Key: FLINK-15830
URL: https://issues.apache.org/jira/browse/FLINK-15830
Project: Flink
Issue
Ufuk Celebi created FLINK-15831:
---
Summary: Add Docker image publication to release documentation
Key: FLINK-15831
URL: https://issues.apache.org/jira/browse/FLINK-15831
Project: Flink
Issue
Ufuk Celebi created FLINK-9389:
--
Summary: Improve error message when cancelling job in state
canceled via REST API
Key: FLINK-9389
URL: https://issues.apache.org/jira/browse/FLINK-9389
Project: Flink
Ufuk Celebi created FLINK-9690:
--
Summary: Restoring state with FlinkKafkaProducer and Kafka 1.1.0
client fails
Key: FLINK-9690
URL: https://issues.apache.org/jira/browse/FLINK-9690
Project: Flink
Ufuk Celebi created FLINK-9700:
--
Summary: Document FlinkKafkaProducer behaviour for Kafka versions
> 0.11
Key: FLINK-9700
URL: https://issues.apache.org/jira/browse/FLINK-9700
Project: Fl
Ufuk Celebi created FLINK-9832:
--
Summary: Allow commas in job submission query params
Key: FLINK-9832
URL: https://issues.apache.org/jira/browse/FLINK-9832
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-10318:
---
Summary: Add option to build Hadoop-free job image to build.sh
Key: FLINK-10318
URL: https://issues.apache.org/jira/browse/FLINK-10318
Project: Flink
Issue
Ufuk Celebi created FLINK-10436:
---
Summary: Example config uses deprecated key jobmanager.rpc.address
Key: FLINK-10436
URL: https://issues.apache.org/jira/browse/FLINK-10436
Project: Flink
Ufuk Celebi created FLINK-10439:
---
Summary: Race condition during job suspension
Key: FLINK-10439
URL: https://issues.apache.org/jira/browse/FLINK-10439
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-10441:
---
Summary: Don't log warning when creating upload directory
Key: FLINK-10441
URL: https://issues.apache.org/jira/browse/FLINK-10441
Project: Flink
Issue
Ufuk Celebi created FLINK-10743:
---
Summary: Use 0 processExitCode for ApplicationStatus.CANCELED
Key: FLINK-10743
URL: https://issues.apache.org/jira/browse/FLINK-10743
Project: Flink
Issue
Ufuk Celebi created FLINK-10751:
---
Summary: Checkpoints should be retained when job reaches suspended
state
Key: FLINK-10751
URL: https://issues.apache.org/jira/browse/FLINK-10751
Project: Flink
Ufuk Celebi created FLINK-10948:
---
Summary: Add option to write out termination message with
application status
Key: FLINK-10948
URL: https://issues.apache.org/jira/browse/FLINK-10948
Project: Flink
Ufuk Celebi created FLINK-10971:
---
Summary: Dependency convergence issue when building
flink-s3-fs-presto
Key: FLINK-10971
URL: https://issues.apache.org/jira/browse/FLINK-10971
Project: Flink
Ufuk Celebi created FLINK-11127:
---
Summary: Make metrics query service establish connection to
JobManager
Key: FLINK-11127
URL: https://issues.apache.org/jira/browse/FLINK-11127
Project: Flink
Ufuk Celebi created FLINK-11402:
---
Summary: User code can fail with an UnsatisfiedLinkError in the
presence of multiple classloaders
Key: FLINK-11402
URL: https://issues.apache.org/jira/browse/FLINK-11402
Ufuk Celebi created FLINK-11525:
---
Summary: Add option to manually set job ID
Key: FLINK-11525
URL: https://issues.apache.org/jira/browse/FLINK-11525
Project: Flink
Issue Type: New Feature
Ufuk Celebi created FLINK-11533:
---
Summary: Retrieve job class name from JAR manifest in
ClassPathJobGraphRetriever
Key: FLINK-11533
URL: https://issues.apache.org/jira/browse/FLINK-11533
Project: Flink
Ufuk Celebi created FLINK-11534:
---
Summary: Don't exit JVM after job termination with standalone job
Key: FLINK-11534
URL: https://issues.apache.org/jira/browse/FLINK-11534
Project: Flink
Ufuk Celebi created FLINK-11544:
---
Summary: Add option manually set job ID for job submissions via
REST API
Key: FLINK-11544
URL: https://issues.apache.org/jira/browse/FLINK-11544
Project: Flink
Ufuk Celebi created FLINK-11546:
---
Summary: Add option to manually set job ID in CLI
Key: FLINK-11546
URL: https://issues.apache.org/jira/browse/FLINK-11546
Project: Flink
Issue Type: Sub-task
Ufuk Celebi created FLINK-11545:
---
Summary: Add option to manually set job ID in
StandaloneJobClusterEntryPoint
Key: FLINK-11545
URL: https://issues.apache.org/jira/browse/FLINK-11545
Project: Flink
Ufuk Celebi created FLINK-11752:
---
Summary: Move flink-python to opt
Key: FLINK-11752
URL: https://issues.apache.org/jira/browse/FLINK-11752
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-11784:
---
Summary: KryoSerializerSnapshotTest occasionally fails on Travis
Key: FLINK-11784
URL: https://issues.apache.org/jira/browse/FLINK-11784
Project: Flink
Issue
Ufuk Celebi created FLINK-12060:
---
Summary: Unify change pom version scripts
Key: FLINK-12060
URL: https://issues.apache.org/jira/browse/FLINK-12060
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-12313:
---
Summary:
SynchronousCheckpointITCase.taskCachedThreadPoolAllowsForSynchronousCheckpoints
is unstable
Key: FLINK-12313
URL: https://issues.apache.org/jira/browse/FLINK-12313
Ufuk Celebi created FLINK-12813:
---
Summary: Add Hadoop profile in building from source docs
Key: FLINK-12813
URL: https://issues.apache.org/jira/browse/FLINK-12813
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2925:
--
Summary: Client does not show root cause of Exception
Key: FLINK-2925
URL: https://issues.apache.org/jira/browse/FLINK-2925
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2927:
--
Summary: Provide default required configuration keys in flink-conf
of binary distribution
Key: FLINK-2927
URL: https://issues.apache.org/jira/browse/FLINK-2927
Project
Ufuk Celebi created FLINK-2928:
--
Summary: Confusing job status visualisation in web frontend
Key: FLINK-2928
URL: https://issues.apache.org/jira/browse/FLINK-2928
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2929:
--
Summary: Recovery of jobs on cluster restarts
Key: FLINK-2929
URL: https://issues.apache.org/jira/browse/FLINK-2929
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2930:
--
Summary: ExecutionConfig execution retry delay not respected
Key: FLINK-2930
URL: https://issues.apache.org/jira/browse/FLINK-2930
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2958:
--
Summary: StreamingJobGraphGenerator sets hard coded number
execution retry
Key: FLINK-2958
URL: https://issues.apache.org/jira/browse/FLINK-2958
Project: Flink
Ufuk Celebi created FLINK-2959:
--
Summary: Remove number of execution retries configuration from
Environment
Key: FLINK-2959
URL: https://issues.apache.org/jira/browse/FLINK-2959
Project: Flink
Ufuk Celebi created FLINK-2962:
--
Summary: Cluster startup script refers to unused variable
Key: FLINK-2962
URL: https://issues.apache.org/jira/browse/FLINK-2962
Project: Flink
Issue Type
Ufuk Celebi created FLINK-2969:
--
Summary: FlinkYarnSessionCli with recovery enabled fails when
killing TaskManager
Key: FLINK-2969
URL: https://issues.apache.org/jira/browse/FLINK-2969
Project: Flink
Ufuk Celebi created FLINK-2970:
--
Summary: Yarn client cannot connect to new job manager
Key: FLINK-2970
URL: https://issues.apache.org/jira/browse/FLINK-2970
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-2976:
--
Summary: Save and load checkpoints manually
Key: FLINK-2976
URL: https://issues.apache.org/jira/browse/FLINK-2976
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-2986:
--
Summary: Typo in KvState interface snapshot method name
Key: FLINK-2986
URL: https://issues.apache.org/jira/browse/FLINK-2986
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3000:
--
Summary: Add ShutdownHook to YARN CLI to prevent lingering sessions
Key: FLINK-3000
URL: https://issues.apache.org/jira/browse/FLINK-3000
Project: Flink
Issue
Ufuk Celebi created FLINK-3003:
--
Summary: Add container allocation timeout to YARN CLI
Key: FLINK-3003
URL: https://issues.apache.org/jira/browse/FLINK-3003
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3009:
--
Summary: Cannot build docs with Jekyll 3.0.0
Key: FLINK-3009
URL: https://issues.apache.org/jira/browse/FLINK-3009
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3019:
--
Summary: CLI does not list running/restarting jobs
Key: FLINK-3019
URL: https://issues.apache.org/jira/browse/FLINK-3019
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3028:
--
Summary: Cannot cancel restarting job via web frontend
Key: FLINK-3028
URL: https://issues.apache.org/jira/browse/FLINK-3028
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3050:
--
Summary: Add custom Exception type to suppress job restarts
Key: FLINK-3050
URL: https://issues.apache.org/jira/browse/FLINK-3050
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3055:
--
Summary: ExecutionVertex has duplicate method
getParallelSubtaskIndex and getSubTaskIndex
Key: FLINK-3055
URL: https://issues.apache.org/jira/browse/FLINK-3055
Project
Ufuk Celebi created FLINK-3091:
--
Summary: Provide ZooKeeper root path in startup scripts
Key: FLINK-3091
URL: https://issues.apache.org/jira/browse/FLINK-3091
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3105:
--
Summary: Submission in per job YARN cluster mode reuses properties
file of long-lived session
Key: FLINK-3105
URL: https://issues.apache.org/jira/browse/FLINK-3105
Ufuk Celebi created FLINK-3107:
--
Summary: ZooKeeperCheckpointIDCounter.start() can block JobManager
actor
Key: FLINK-3107
URL: https://issues.apache.org/jira/browse/FLINK-3107
Project: Flink
Ufuk Celebi created FLINK-3111:
--
Summary: Short lived client interaction logs warning in job manager
Key: FLINK-3111
URL: https://issues.apache.org/jira/browse/FLINK-3111
Project: Flink
Issue
Ufuk Celebi created FLINK-3120:
--
Summary: Set number of event loop thread and number of buffer pool
arenas to same number
Key: FLINK-3120
URL: https://issues.apache.org/jira/browse/FLINK-3120
Project
Ufuk Celebi created FLINK-3130:
--
Summary: Visualize throughput of tasks
Key: FLINK-3130
URL: https://issues.apache.org/jira/browse/FLINK-3130
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3131:
--
Summary: Expose checkpoint metrics
Key: FLINK-3131
URL: https://issues.apache.org/jira/browse/FLINK-3131
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3132:
--
Summary: Restructure streaming guide
Key: FLINK-3132
URL: https://issues.apache.org/jira/browse/FLINK-3132
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3157:
--
Summary: Web frontend json files contain author attribution
Key: FLINK-3157
URL: https://issues.apache.org/jira/browse/FLINK-3157
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3172:
--
Summary: Specify jobmanager port in HA mode
Key: FLINK-3172
URL: https://issues.apache.org/jira/browse/FLINK-3172
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3180:
--
Summary: MemoryLogger does not log direct memory
Key: FLINK-3180
URL: https://issues.apache.org/jira/browse/FLINK-3180
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3182:
--
Summary: TaskManagersHandler can block web frontend
Key: FLINK-3182
URL: https://issues.apache.org/jira/browse/FLINK-3182
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3183:
--
Summary: Display direct memory stats in web frontend
Key: FLINK-3183
URL: https://issues.apache.org/jira/browse/FLINK-3183
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3185:
--
Summary: Silent failure during job graph recovery
Key: FLINK-3185
URL: https://issues.apache.org/jira/browse/FLINK-3185
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3232:
--
Summary: Add option to eagerly deploy channels
Key: FLINK-3232
URL: https://issues.apache.org/jira/browse/FLINK-3232
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3235:
--
Summary: Drop Flink-on-Tez code
Key: FLINK-3235
URL: https://issues.apache.org/jira/browse/FLINK-3235
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3244:
--
Summary: Add log messages to savepoint coordinator restore
Key: FLINK-3244
URL: https://issues.apache.org/jira/browse/FLINK-3244
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3249:
--
Summary: Wrong "unknown partition state/input gate" error messages
Key: FLINK-3249
URL: https://issues.apache.org/jira/browse/FLINK-3249
Project: Flink
Ufuk Celebi created FLINK-3250:
--
Summary: Savepoint coordinator requires too strict parallelism
match
Key: FLINK-3250
URL: https://issues.apache.org/jira/browse/FLINK-3250
Project: Flink
Issue
Ufuk Celebi created FLINK-3251:
--
Summary: Checkpoint stats show ghost numbers
Key: FLINK-3251
URL: https://issues.apache.org/jira/browse/FLINK-3251
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3252:
--
Summary: Checkpoint stats only displayed after click on graph
Key: FLINK-3252
URL: https://issues.apache.org/jira/browse/FLINK-3252
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3258:
--
Summary: Merge AbstractInvokable's registerInputOutput and invoke
Key: FLINK-3258
URL: https://issues.apache.org/jira/browse/FLINK-3258
Project: Flink
Ufuk Celebi created FLINK-3259:
--
Summary: Redirect programming guides to new layout
Key: FLINK-3259
URL: https://issues.apache.org/jira/browse/FLINK-3259
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3283:
--
Summary: Failed Kafka 0.9 test on duplicate message
Key: FLINK-3283
URL: https://issues.apache.org/jira/browse/FLINK-3283
Project: Flink
Issue Type: Test
Ufuk Celebi created FLINK-3299:
--
Summary: Remove ApplicationID from Environment
Key: FLINK-3299
URL: https://issues.apache.org/jira/browse/FLINK-3299
Project: Flink
Issue Type: Improvement
Ufuk Celebi created FLINK-3310:
--
Summary: Add back pressure statistics to web frontend
Key: FLINK-3310
URL: https://issues.apache.org/jira/browse/FLINK-3310
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3342:
--
Summary: Operator checkpoint statistics state size overflow
Key: FLINK-3342
URL: https://issues.apache.org/jira/browse/FLINK-3342
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3364:
--
Summary: Don't initialize SavepointStore in JobManager constructor
Key: FLINK-3364
URL: https://issues.apache.org/jira/browse/FLINK-3364
Project: Flink
Ufuk Celebi created FLINK-3369:
--
Summary: RemoteTransportException should be instance of
CancelTaskException
Key: FLINK-3369
URL: https://issues.apache.org/jira/browse/FLINK-3369
Project: Flink
Ufuk Celebi created FLINK-3374:
--
Summary: CEPITCase testSimplePatternEventTime fails
Key: FLINK-3374
URL: https://issues.apache.org/jira/browse/FLINK-3374
Project: Flink
Issue Type: Test
Ufuk Celebi created FLINK-3396:
--
Summary: Job submission Savepoint restore logic flawed
Key: FLINK-3396
URL: https://issues.apache.org/jira/browse/FLINK-3396
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3411:
--
Summary: Failed recovery can lead to removal of HA state
Key: FLINK-3411
URL: https://issues.apache.org/jira/browse/FLINK-3411
Project: Flink
Issue Type: Bug
Ufuk Celebi created FLINK-3443:
--
Summary: JobManager cancel and clear everything fails jobs instead
of cancelling
Key: FLINK-3443
URL: https://issues.apache.org/jira/browse/FLINK-3443
Project: Flink
Ufuk Celebi created FLINK-3446:
--
Summary: Back pressure tracker throws NPE for archived jobs
Key: FLINK-3446
URL: https://issues.apache.org/jira/browse/FLINK-3446
Project: Flink
Issue Type
Ufuk Celebi created FLINK-3451:
--
Summary: NettyServer port is determined via
NetUtils.getAvailablePort()
Key: FLINK-3451
URL: https://issues.apache.org/jira/browse/FLINK-3451
Project: Flink
601 - 700 of 991 matches
Mail list logo
