[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)