[jira] [Created] (FLINK-10115) Upload Project to WEB UI has issue
Yazdan Shirvany created FLINK-10115:
---
Summary: Upload Project to WEB UI has issue
Key: FLINK-10115
URL: https://issues.apache.org/jira/browse/FLINK-10115
Project: Flink
Issue Type: Bug
Components: Webfrontend
Reporter: Yazdan Shirvany
Fix For: 1.6.0
Uploading jar files via WEB UI not working. After {{initializing upload...}} it
only shows {{saving...}} and file never shows up on UI to be able to submit it
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Created] (FLINK-10112) https://ci.apache.org title for release 1.6 shows 1.6-SNAPSHOT
Yazdan Shirvany created FLINK-10112: --- Summary: https://ci.apache.org title for release 1.6 shows 1.6-SNAPSHOT Key: FLINK-10112 URL: https://issues.apache.org/jira/browse/FLINK-10112 Project: Flink Issue Type: Bug Affects Versions: 1.6.0 Reporter: Yazdan Shirvany Flink 1.6 has been released but I still can see 1.6-SNAPSHOT on [https://ci.apache.org/] and when I click to any of the options it redirects me to master docs with 1.7-SNAPSHOT title -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9848) When Parallelism more than available task slots Flink stays idle
Yazdan Shirvany created FLINK-9848: -- Summary: When Parallelism more than available task slots Flink stays idle Key: FLINK-9848 URL: https://issues.apache.org/jira/browse/FLINK-9848 Project: Flink Issue Type: Bug Components: Cluster Management Affects Versions: 1.5.1, 1.5.0 Reporter: Yazdan Shirvany Assignee: Yazdan Shirvany Attachments: idleJob.jpg For version 1.4.x when select Parallelism > Available task Slots Flink throw bellow error NoResourceAvailableException: Not enough free slots available to run the job but for version 1.5.x there are two different behaviors: Sometimes job ran successfully and sometimes it stay in "Running" status for a log time (I waited more than 3 minutes) and never throw error In bellow image Available task slots is 1 and job has been submitted with Parallelism = 4 Flink Version 1.5.1 !idleJob.jpg! -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9771) "Show Plan" option under Submit New Job in WebUI not working
Yazdan Shirvany created FLINK-9771:
--
Summary: "Show Plan" option under Submit New Job in WebUI not
working
Key: FLINK-9771
URL: https://issues.apache.org/jira/browse/FLINK-9771
Project: Flink
Issue Type: Bug
Components: Job-Submission, Webfrontend
Affects Versions: 1.5.0, 1.5.1, 1.6.0
Reporter: Yazdan Shirvany
{{Show Plan}} button under {{Submit new job}} in WebUI not working.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Created] (FLINK-9679) Implement AvroSerializationSchema
Yazdan Shirvany created FLINK-9679: -- Summary: Implement AvroSerializationSchema Key: FLINK-9679 URL: https://issues.apache.org/jira/browse/FLINK-9679 Project: Flink Issue Type: Improvement Affects Versions: 1.6.0 Reporter: Yazdan Shirvany Assignee: Yazdan Shirvany Implement AvroSerializationSchema using Confluent Schema Registry -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9551) FlinkCEP Scala Combining Patterns table has two missing pattern
Yazdan Shirvany created FLINK-9551:
--
Summary: FlinkCEP Scala Combining Patterns table has two missing
pattern
Key: FLINK-9551
URL: https://issues.apache.org/jira/browse/FLINK-9551
Project: Flink
Issue Type: Improvement
Components: Documentation
Reporter: Yazdan Shirvany
Assignee: Yazdan Shirvany
in FlinkCEP documentation section related to {{Combining Patterns}} Scala Table
has a missing patterns compare to Java table
{{begin(#pattern_sequence)}}
and also
{{begin()}} pattern has missing {{#name}} params
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Created] (FLINK-9550) FlinkCEP snippet example has some syntax errors
Yazdan Shirvany created FLINK-9550: -- Summary: FlinkCEP snippet example has some syntax errors Key: FLINK-9550 URL: https://issues.apache.org/jira/browse/FLINK-9550 Project: Flink Issue Type: Improvement Reporter: Yazdan Shirvany Assignee: Yazdan Shirvany I tried to work with FlinckCEP documentarians and my assumption was the snippet example should work but I got some syntax errors that needed to be fix. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9549) Fix FlickCEP Docs broken link and minor style changes
Yazdan Shirvany created FLINK-9549: -- Summary: Fix FlickCEP Docs broken link and minor style changes Key: FLINK-9549 URL: https://issues.apache.org/jira/browse/FLINK-9549 Project: Flink Issue Type: Improvement Reporter: Yazdan Shirvany Assignee: Yazdan Shirvany -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9518) SSL setup Docs config example has wrong keys password
Yazdan Shirvany created FLINK-9518:
--
Summary: SSL setup Docs config example has wrong keys password
Key: FLINK-9518
URL: https://issues.apache.org/jira/browse/FLINK-9518
Project: Flink
Issue Type: Improvement
Components: Documentation
Affects Versions: 1.4.2, 1.4.1, 1.5.0
Reporter: Yazdan Shirvany
Assignee: Yazdan Shirvany
In creating keystores and turststore section password is set to \{{password}}
but in setup config section it is \{{abc123}}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Created] (FLINK-9517) Fixing broken links on CLI Docs
Yazdan Shirvany created FLINK-9517: -- Summary: Fixing broken links on CLI Docs Key: FLINK-9517 URL: https://issues.apache.org/jira/browse/FLINK-9517 Project: Flink Issue Type: Improvement Reporter: Yazdan Shirvany Assignee: Yazdan Shirvany broken links for cli page -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9509) CLI usage are not same as CLI docs
Yazdan Shirvany created FLINK-9509: -- Summary: CLI usage are not same as CLI docs Key: FLINK-9509 URL: https://issues.apache.org/jira/browse/FLINK-9509 Project: Flink Issue Type: Improvement Affects Versions: 1.5.0 Reporter: Yazdan Shirvany Assignee: Yazdan Shirvany `./bin/flink -h` for version 1.5.0 output is different from document usage on CLI here [https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/cli.html#usage] -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9508) General Spell Check on Flink Docs
Yazdan Shirvany created FLINK-9508: -- Summary: General Spell Check on Flink Docs Key: FLINK-9508 URL: https://issues.apache.org/jira/browse/FLINK-9508 Project: Flink Issue Type: Improvement Components: Documentation Affects Versions: 1.4.2, 1.4.1, 1.5.0 Reporter: Yazdan Shirvany Assignee: Yazdan Shirvany Fixing Flink docs misspelling -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9505) End-to-end test: Quickstarts for Scala
Yazdan Shirvany created FLINK-9505: -- Summary: End-to-end test: Quickstarts for Scala Key: FLINK-9505 URL: https://issues.apache.org/jira/browse/FLINK-9505 Project: Flink Issue Type: Sub-task Reporter: Yazdan Shirvany -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9451) End-to-end test: Scala Quickstarts
Yazdan Shirvany created FLINK-9451:
--
Summary: End-to-end test: Scala Quickstarts
Key: FLINK-9451
URL: https://issues.apache.org/jira/browse/FLINK-9451
Project: Flink
Issue Type: Sub-task
Components: Quickstarts
Affects Versions: 1.4.2, 1.4.1, 1.5.0
Reporter: Yazdan Shirvany
We could add an end-to-end test which verifies Flink's quickstarts scala. It
should do the following:
# create a new Flink project using the quickstarts archetype
# add a new Flink dependency to the {{pom.xml}} (e.g. Flink connector or
library)
# run {{mvn clean package -Pbuild-jar}}
# verify that no core dependencies are contained in the jar file
# Run the program
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Created] (FLINK-9372) Typo on Elasticsearch website link (elastic.io --> elastic.co)
Yazdan Shirvany created FLINK-9372: -- Summary: Typo on Elasticsearch website link (elastic.io --> elastic.co) Key: FLINK-9372 URL: https://issues.apache.org/jira/browse/FLINK-9372 Project: Flink Issue Type: Improvement Components: Documentation, ElasticSearch Connector Affects Versions: 1.4.2, 1.4.1, 1.5.0, 1.5.1 Reporter: Yazdan Shirvany Assignee: Yazdan Shirvany Typo on website link in Elasticsearch Java Docs (elastic.io --> elastic.co) -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9348) scalastyle documentatiom for IntelliJ IDE setup
Yazdan Shirvany created FLINK-9348: -- Summary: scalastyle documentatiom for IntelliJ IDE setup Key: FLINK-9348 URL: https://issues.apache.org/jira/browse/FLINK-9348 Project: Flink Issue Type: Bug Components: Documentation Affects Versions: 1.4.2, 1.4.1 Reporter: Yazdan Shirvany Documentation regarding enabling scalastyle for IntelliJ IDEA Setup in contribution page -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9343) Add Async Example with External Rest API call
Yazdan Shirvany created FLINK-9343: -- Summary: Add Async Example with External Rest API call Key: FLINK-9343 URL: https://issues.apache.org/jira/browse/FLINK-9343 Project: Flink Issue Type: Improvement Components: Examples Affects Versions: 1.4.2, 1.4.1, 1.4.0 Reporter: Yazdan Shirvany Async I/O is a good way to call External resources such as REST API and enrich the stream with external data. Adding example to simulate Async GET api call on an input stream. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9333) QuickStart Docs Spelling fix and some info regarding IntelliJ JVM Options
Yazdan Shirvany created FLINK-9333: -- Summary: QuickStart Docs Spelling fix and some info regarding IntelliJ JVM Options Key: FLINK-9333 URL: https://issues.apache.org/jira/browse/FLINK-9333 Project: Flink Issue Type: Bug Components: Documentation Affects Versions: 1.4.2, 1.4.1 Reporter: Yazdan Shirvany - Spelling fix for QuickStart Project Template for Java - Adding more details regarding changing JVM options in IntelliJ IDEA -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-9317) Async I/O API Example For Scala has Variable Name error
Yazdan Shirvany created FLINK-9317:
--
Summary: Async I/O API Example For Scala has Variable Name error
Key: FLINK-9317
URL: https://issues.apache.org/jira/browse/FLINK-9317
Project: Flink
Issue Type: Bug
Components: Documentation
Affects Versions: 1.4.2, 1.4.1
Reporter: Yazdan Shirvany
h2. Async I/O API Scala Example has duplicated {{resultFuture variable with
different data type.}}
{{resultFuture: ResultFuture[(String, String)]}}
{{ val resultFuture: Future[String]}}
{{this cause error on compile as variables have same naming.}}
{{In order to example works properly we need to update variable names to be
distinct,}}
{{```}}
override def asyncInvoke(input: (String,String, String), resultFuture:
ResultFuture[(String,String, String, String)]): Unit = {
// issue the asynchronous request, receive a future for the result
val *resultFutureRequested*: Future[String] = Future {
// client2.query(str)
client.getAccountReferenceId(token, input._1)
}
// set the callback to be executed once the request by the client is complete
// the callback simply forwards the result to the result future
*resultFutureRequested*.onSuccess {
case result: String => {
resultFuture.complete(Iterable((input._1, input._2, input._3, result)))
}
}
}
{{```}}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
