[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639916#comment-16639916 ] ASF GitHub Bot commented on FLINK-10461: azagrebin commented on a change in pull request #6777:

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r223029260 ## File path:

[GitHub] yanghua commented on issue #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

yanghua commented on issue #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#issuecomment-427417452 @pnowojski and @xccui Does this PR look good to you?

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640005#comment-16640005 ] ASF GitHub Bot commented on FLINK-10340: yanghua commented on issue #6700: [FLINK-10340][table]

[GitHub] isunjin commented on issue #6739: [FLINK-10289] [JobManager] Classify Exceptions to different category for apply different failover strategy

isunjin commented on issue #6739: [FLINK-10289] [JobManager] Classify Exceptions to different category for apply different failover strategy URL: https://github.com/apache/flink/pull/6739#issuecomment-427431004 @StefanRRichter Thank you, pushed the change.

[GitHub] twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client

twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client URL: https://github.com/apache/flink/pull/6791#discussion_r223035081 ## File path:

[GitHub] twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client

twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client URL: https://github.com/apache/flink/pull/6791#discussion_r223033380 ## File path:

[GitHub] twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client

twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client URL: https://github.com/apache/flink/pull/6791#discussion_r223033140 ## File path:

[GitHub] twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client

twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client URL: https://github.com/apache/flink/pull/6791#discussion_r223034776 ## File path:

[GitHub] twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client

twalthr commented on a change in pull request #6791: [FLINK-8865][sql-client] Add CLI query code completion in SQL Client URL: https://github.com/apache/flink/pull/6791#discussion_r223032399 ## File path:

[GitHub] markcho commented on issue #6793: [hotfix] [docs] Update cluster setup docs to reflect the new syntax of jobmanager.sh script.

markcho commented on issue #6793: [hotfix] [docs] Update cluster setup docs to reflect the new syntax of jobmanager.sh script. URL: https://github.com/apache/flink/pull/6793#issuecomment-427422038 @azagrebin Does the reviewer merge the change into the master branch? It should also be

[jira] [Commented] (FLINK-8865) Add CLI query code completion in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639923#comment-16639923 ] ASF GitHub Bot commented on FLINK-8865: --- twalthr commented on a change in pull request #6791:

[jira] [Commented] (FLINK-8865) Add CLI query code completion in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639924#comment-16639924 ] ASF GitHub Bot commented on FLINK-8865: --- twalthr commented on a change in pull request #6791:

[jira] [Commented] (FLINK-8865) Add CLI query code completion in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639925#comment-16639925 ] ASF GitHub Bot commented on FLINK-8865: --- twalthr commented on a change in pull request #6791:

[jira] [Commented] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640034#comment-16640034 ] ASF GitHub Bot commented on FLINK-10412: yanghua commented on issue #6755: [FLINK-10412]

[GitHub] bbaja42 opened a new pull request #6798: [docs] Fixed typo, please instead of pelase

bbaja42 opened a new pull request #6798: [docs] Fixed typo, please instead of pelase URL: https://github.com/apache/flink/pull/6798 ## Contribution Checklist - Make sure that the pull request corresponds to a [JIRA issue](https://issues.apache.org/jira/projects/FLINK/issues).

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

[ https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640003#comment-16640003 ] ASF GitHub Bot commented on FLINK-9682: --- yanghua commented on issue #6266: [FLINK-9682] Add

[GitHub] yanghua commented on issue #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

yanghua commented on issue #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#issuecomment-427416654 @tillrohrmann and @aljoscha any opinion about this PR broke the API

[jira] [Commented] (FLINK-10427) Port JobSubmitTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640029#comment-16640029 ] ASF GitHub Bot commented on FLINK-10427: asfgit closed pull request #6768: [FLINK-10427]

[jira] [Resolved] (FLINK-10427) Port JobSubmitTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10427. --- Resolution: Fixed Fixed via deef139e02efc3b728654a202e2ad5247bc93a46

[GitHub] asfgit closed pull request #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base

asfgit closed pull request #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base URL: https://github.com/apache/flink/pull/6768 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[GitHub] twalthr commented on issue #6445: [FLINK-8302] [table] Add SHIFT_LEFT and SHIFT_RIGHT

twalthr commented on issue #6445: [FLINK-8302] [table] Add SHIFT_LEFT and SHIFT_RIGHT URL: https://github.com/apache/flink/pull/6445#issuecomment-427397780 @fhueske @pnowojski what is your opinion here? should we do the Spark/Hive way for now? We can still support other syntax in the

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639935#comment-16639935 ] ASF GitHub Bot commented on FLINK-8302: --- twalthr commented on issue #6445: [FLINK-8302] [table] Add

[jira] [Commented] (FLINK-8865) Add CLI query code completion in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639922#comment-16639922 ] ASF GitHub Bot commented on FLINK-8865: --- twalthr commented on a change in pull request #6791:

[jira] [Commented] (FLINK-10289) Classify Exceptions to different category for apply different failover strategy

[ https://issues.apache.org/jira/browse/FLINK-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640071#comment-16640071 ] ASF GitHub Bot commented on FLINK-10289: isunjin commented on issue #6739: [FLINK-10289]

[GitHub] azagrebin commented on issue #6793: [hotfix] [docs] Update cluster setup docs to reflect the new syntax of jobmanager.sh script.

azagrebin commented on issue #6793: [hotfix] [docs] Update cluster setup docs to reflect the new syntax of jobmanager.sh script. URL: https://github.com/apache/flink/pull/6793#issuecomment-427433251 @markcho, one of committers will merge it if there is no more comments from them. cc

[jira] [Assigned] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

[ https://issues.apache.org/jira/browse/FLINK-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10454: - Assignee: Till Rohrmann > Travis fails on ScheduleOrUpdateConsumersTest >

[jira] [Commented] (FLINK-5405) Add streaming connection to twitter through a internet proxy

[ https://issues.apache.org/jira/browse/FLINK-5405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640016#comment-16640016 ] Luis Angel Hernández Acosta commented on FLINK-5405: Can you be more specific? > Add

[jira] [Commented] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

[ https://issues.apache.org/jira/browse/FLINK-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640032#comment-16640032 ] ASF GitHub Bot commented on FLINK-10454: tillrohrmann opened a new pull request #6799:

[jira] [Updated] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

[ https://issues.apache.org/jira/browse/FLINK-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10454: --- Labels: pull-request-available test-stability (was: test-stability) > Travis fails on

[GitHub] tillrohrmann opened a new pull request #6799: [FLINK-10454][tests] Start MiniCluster with rest port 0

tillrohrmann opened a new pull request #6799: [FLINK-10454][tests] Start MiniCluster with rest port 0 URL: https://github.com/apache/flink/pull/6799 ## What is the purpose of the change Start the MiniCluster used by `ScheduleOrUpdateConsumersTest` and

[jira] [Commented] (FLINK-10471) State TTL cleanup using RocksDb compaction filter

[ https://issues.apache.org/jira/browse/FLINK-10471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639954#comment-16639954 ] Andrey Zagrebin commented on FLINK-10471: - [RocksDB PR for Flink compaction

[GitHub] yanghua commented on issue #6755: [FLINK-10412] toString field in AbstractID should be transient to avoid been serialized

yanghua commented on issue #6755: [FLINK-10412] toString field in AbstractID should be transient to avoid been serialized URL: https://github.com/apache/flink/pull/6755#issuecomment-427420831 @tillrohrmann and @zentol What's your opinion?

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r223030850 ## File path:

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r223034163 ## File path:

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639912#comment-16639912 ] ASF GitHub Bot commented on FLINK-10461: azagrebin commented on a change in pull request #6777:

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639911#comment-16639911 ] ASF GitHub Bot commented on FLINK-10461: azagrebin commented on a change in pull request #6777:

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r223029260 ## File path:

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639909#comment-16639909 ] ASF GitHub Bot commented on FLINK-10461: azagrebin commented on a change in pull request #6777:

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639910#comment-16639910 ] ASF GitHub Bot commented on FLINK-10461: azagrebin commented on a change in pull request #6777:

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r223030317 ## File path:

[GitHub] azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

azagrebin commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r223032334 ## File path:

[jira] [Commented] (FLINK-8865) Add CLI query code completion in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639926#comment-16639926 ] ASF GitHub Bot commented on FLINK-8865: --- twalthr commented on a change in pull request #6791:

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639908#comment-16639908 ] ASF GitHub Bot commented on FLINK-10461: azagrebin commented on a change in pull request #6777:

[GitHub] tillrohrmann closed pull request #6799: [FLINK-10454][tests] Start MiniCluster with rest port 0

tillrohrmann closed pull request #6799: [FLINK-10454][tests] Start MiniCluster with rest port 0 URL: https://github.com/apache/flink/pull/6799 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[jira] [Resolved] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

[ https://issues.apache.org/jira/browse/FLINK-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10454. --- Resolution: Fixed Fixed via

[jira] [Updated] (FLINK-10496) CommandLineParser arguments interleaving

[ https://issues.apache.org/jira/browse/FLINK-10496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] eugen yushin updated FLINK-10496: - Component/s: Docker > CommandLineParser arguments interleaving >

[jira] [Updated] (FLINK-10496) CommandLineParser arguments interleaving

[ https://issues.apache.org/jira/browse/FLINK-10496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] eugen yushin updated FLINK-10496: - Labels: pull-request-available (was: ) > CommandLineParser arguments interleaving >

[jira] [Created] (FLINK-10496) CommandLineParser arguments interleaving

eugen yushin created FLINK-10496: Summary: CommandLineParser arguments interleaving Key: FLINK-10496 URL: https://issues.apache.org/jira/browse/FLINK-10496 Project: Flink Issue Type:

[jira] [Updated] (FLINK-10496) CommandLineParser arguments interleaving

[ https://issues.apache.org/jira/browse/FLINK-10496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] eugen yushin updated FLINK-10496: - Issue Type: Bug (was: Improvement) > CommandLineParser arguments interleaving >

[jira] [Updated] (FLINK-10421) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10421: --- Labels: pull-request-available test-stability (was: test-stability) > Shaded Hadoop S3A

[jira] [Commented] (FLINK-10421) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640191#comment-16640191 ] ASF GitHub Bot commented on FLINK-10421: tillrohrmann opened a new pull request #6800:

[jira] [Commented] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

[ https://issues.apache.org/jira/browse/FLINK-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16640188#comment-16640188 ] ASF GitHub Bot commented on FLINK-10454: tillrohrmann closed pull request #6799:

[GitHub] tillrohrmann opened a new pull request #6800: [FLINK-10421][tests] Exclude FluentPropertyBeanIntrospector info message in common.sh

tillrohrmann opened a new pull request #6800: [FLINK-10421][tests] Exclude FluentPropertyBeanIntrospector info message in common.sh URL: https://github.com/apache/flink/pull/6800 ## What is the purpose of the change FluentPropertyBeanIntrospector logs an info message containing the

[jira] [Created] (FLINK-10495) Add HYPOT math function supported in Table API and SQL

Aleksei Izmalkin created FLINK-10495: Summary: Add HYPOT math function supported in Table API and SQL Key: FLINK-10495 URL: https://issues.apache.org/jira/browse/FLINK-10495 Project: Flink

[jira] [Updated] (FLINK-10495) Add HYPOT math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-10495: Issue Type: Sub-task (was: Task) Parent: FLINK-6810 > Add HYPOT math function supported

[jira] [Commented] (FLINK-10075) HTTP connections to a secured REST endpoint flood the log

[ https://issues.apache.org/jira/browse/FLINK-10075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639500#comment-16639500 ] ASF GitHub Bot commented on FLINK-10075: azagrebin opened a new pull request #6796:

[GitHub] azagrebin opened a new pull request #6796: [FLINK-10075] Redirect non-ssl requests to https url if ssl is enabled

azagrebin opened a new pull request #6796: [FLINK-10075] Redirect non-ssl requests to https url if ssl is enabled URL: https://github.com/apache/flink/pull/6796 ## What is the purpose of the change This PR introduces a wrapper around SSL handler in rest server endpoint. The

[jira] [Updated] (FLINK-10075) HTTP connections to a secured REST endpoint flood the log

[ https://issues.apache.org/jira/browse/FLINK-10075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10075: --- Labels: pull-request-available (was: ) > HTTP connections to a secured REST endpoint flood

[GitHub] TisonKun commented on issue #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base

TisonKun commented on issue #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base URL: https://github.com/apache/flink/pull/6768#issuecomment-427297515 Thanks for your review @tillrohrmann ! This is an automated

[jira] [Assigned] (FLINK-10421) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10421: - Assignee: Till Rohrmann > Shaded Hadoop S3A end-to-end test failed on Travis >

[jira] [Commented] (FLINK-10289) Classify Exceptions to different category for apply different failover strategy

[ https://issues.apache.org/jira/browse/FLINK-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639445#comment-16639445 ] ASF GitHub Bot commented on FLINK-10289: StefanRRichter commented on issue #6739: [FLINK-10289]

[jira] [Commented] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

[ https://issues.apache.org/jira/browse/FLINK-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639491#comment-16639491 ] Till Rohrmann commented on FLINK-10454: --- [~Tison] could you link the maven logs where you

[jira] [Comment Edited] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

[ https://issues.apache.org/jira/browse/FLINK-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639508#comment-16639508 ] tison edited comment on FLINK-10454 at 10/5/18 9:07 AM:

[jira] [Updated] (FLINK-10421) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10421: -- Priority: Critical (was: Major) > Shaded Hadoop S3A end-to-end test failed on Travis >

[jira] [Updated] (FLINK-10421) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10421: -- Fix Version/s: 1.7.0 > Shaded Hadoop S3A end-to-end test failed on Travis >

[jira] [Commented] (FLINK-10386) Remove legacy class TaskExecutionStateListener

[ https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639321#comment-16639321 ] ASF GitHub Bot commented on FLINK-10386: TisonKun edited a comment on issue #6729: [FLINK-10386]

[GitHub] TisonKun edited a comment on issue #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener

TisonKun edited a comment on issue #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener URL: https://github.com/apache/flink/pull/6729#issuecomment-427071700 All "Why are we removing these assertions?" is as you say, we do not send those state updates via

[jira] [Commented] (FLINK-10495) Add HYPOT math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639411#comment-16639411 ] Hequn Cheng commented on FLINK-10495: - [~Aleksei_Izmalkin] Done. Thanks for your contributions. >

[jira] [Commented] (FLINK-10495) Add HYPOT math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639376#comment-16639376 ] Aleksei Izmalkin commented on FLINK-10495: -- I will work on this issue. Hello [~yanghua], please

[jira] [Commented] (FLINK-10487) fix invalid Flink SQL example

[ https://issues.apache.org/jira/browse/FLINK-10487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639402#comment-16639402 ] ASF GitHub Bot commented on FLINK-10487: fhueske commented on issue #6790: [FLINK-10487] [table]

[GitHub] StefanRRichter commented on issue #6739: [FLINK-10289] [JobManager] Classify Exceptions to different category for apply different failover strategy

StefanRRichter commented on issue #6739: [FLINK-10289] [JobManager] Classify Exceptions to different category for apply different failover strategy URL: https://github.com/apache/flink/pull/6739#issuecomment-427281153 @isunjin I think this looks good now. I wonder if we should rename the

[GitHub] kl0u opened a new pull request #6795: [FLINK-9752][s3-fs-connector] Add s3 recoverable writer.

kl0u opened a new pull request #6795: [FLINK-9752][s3-fs-connector] Add s3 recoverable writer. URL: https://github.com/apache/flink/pull/6795 ## What is the purpose of the change Adds the recoverable writer for S3. The new recoverable writer is only available for **Hadoop S3**

[jira] [Commented] (FLINK-9752) Add an S3 RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639420#comment-16639420 ] ASF GitHub Bot commented on FLINK-9752: --- kl0u opened a new pull request #6795:

[jira] [Updated] (FLINK-9752) Add an S3 RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9752: -- Labels: pull-request-available (was: ) > Add an S3 RecoverableWriter >

[jira] [Commented] (FLINK-10454) Travis fails on ScheduleOrUpdateConsumersTest

[ https://issues.apache.org/jira/browse/FLINK-10454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639508#comment-16639508 ] tison commented on FLINK-10454: --- https://travis-ci.org/apache/flink/jobs/434894763

[jira] [Commented] (FLINK-10427) Port JobSubmitTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639513#comment-16639513 ] ASF GitHub Bot commented on FLINK-10427: TisonKun commented on issue #6768: [FLINK-10427]

[jira] [Commented] (FLINK-10421) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639534#comment-16639534 ] Till Rohrmann commented on FLINK-10421: --- The problem seems to be related to this string

[GitHub] fhueske commented on issue #6790: [FLINK-10487] [table] fix invalid Flink SQL example and add runnable SQL example for Java API

fhueske commented on issue #6790: [FLINK-10487] [table] fix invalid Flink SQL example and add runnable SQL example for Java API URL: https://github.com/apache/flink/pull/6790#issuecomment-427271829 Thanks for the update @bowenli86! +1 to merge

[jira] [Commented] (FLINK-10421) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639529#comment-16639529 ] Till Rohrmann commented on FLINK-10421: --- Another instance:

[GitHub] kl0u commented on issue #6795: [FLINK-9752][s3-fs-connector] Add s3 recoverable writer.

kl0u commented on issue #6795: [FLINK-9752][s3-fs-connector] Add s3 recoverable writer. URL: https://github.com/apache/flink/pull/6795#issuecomment-427311243 R @igalshilman @pnowojski This is an automated message from the

[jira] [Commented] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639603#comment-16639603 ] ASF GitHub Bot commented on FLINK-9328: --- StefanRRichter closed pull request #5984:

[GitHub] StefanRRichter closed pull request #5984: [FLINK-9328][state] Fix RocksDBStateBackend restore problem due to StateBackendTestBase not registering snapshots

StefanRRichter closed pull request #5984: [FLINK-9328][state] Fix RocksDBStateBackend restore problem due to StateBackendTestBase not registering snapshots URL: https://github.com/apache/flink/pull/5984 This is a PR merged from a forked repository. As GitHub hides the original diff on

[GitHub] StefanRRichter commented on issue #5984: [FLINK-9328][state] Fix RocksDBStateBackend restore problem due to StateBackendTestBase not registering snapshots

StefanRRichter commented on issue #5984: [FLINK-9328][state] Fix RocksDBStateBackend restore problem due to StateBackendTestBase not registering snapshots URL: https://github.com/apache/flink/pull/5984#issuecomment-427313984 Outdated. This was already fixed in master.

[jira] [Commented] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639602#comment-16639602 ] ASF GitHub Bot commented on FLINK-9328: --- StefanRRichter commented on issue #5984:

[jira] [Commented] (FLINK-5405) Add streaming connection to twitter through a internet proxy

[ https://issues.apache.org/jira/browse/FLINK-5405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639628#comment-16639628 ] Mariia Borovikova commented on FLINK-5405: -- Can I work on this ticket? > Add streaming

[GitHub] mxm closed pull request #6761: [FLINK-10279] [documentation] Make jython limitations more obvious in documentation.

mxm closed pull request #6761: [FLINK-10279] [documentation] Make jython limitations more obvious in documentation. URL: https://github.com/apache/flink/pull/6761 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[GitHub] StefanRRichter commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

StefanRRichter commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#issuecomment-427323755 @isunjin Ok, I think I was just connecting a different type of problem with the word "corruption", but the

[jira] [Commented] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

[ https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639672#comment-16639672 ] Huyen Levan commented on FLINK-9940: [~aljoscha] after having created a PR, do I need to do anything

[jira] [Commented] (FLINK-9752) Add an S3 RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639594#comment-16639594 ] ASF GitHub Bot commented on FLINK-9752: --- kl0u commented on issue #6795:

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639654#comment-16639654 ] ASF GitHub Bot commented on FLINK-10205: StefanRRichter commented on issue #6684:

[jira] [Resolved] (FLINK-10279) Make jython limitations more obvious in documentation

[ https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-10279. Resolution: Fixed Fixed via 982fa402a0a9c65356c5e89b25569ed7a8ca89a5 > Make

[jira] [Commented] (FLINK-10279) Make jython limitations more obvious in documentation

[ https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639582#comment-16639582 ] ASF GitHub Bot commented on FLINK-10279: mxm closed pull request #6761: [FLINK-10279]

[GitHub] aai95 opened a new pull request #6797: [FLINK-10495] [table] Add HYPOT math function supported in Table API and SQL

aai95 opened a new pull request #6797: [FLINK-10495] [table] Add HYPOT math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6797 ## What is the purpose of the change *This pull request adds `Hypot` math function supported in Table API and SQL.*

[jira] [Commented] (FLINK-10495) Add HYPOT math function supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639700#comment-16639700 ] ASF GitHub Bot commented on FLINK-10495: aai95 opened a new pull request #6797: [FLINK-10495]

[jira] [Commented] (FLINK-10088) error when trying to run flink-sql-client on windows

[ https://issues.apache.org/jira/browse/FLINK-10088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639764#comment-16639764 ] xueyu commented on FLINK-10088: --- hi, [~anubhavtarar], did you run sql-client.sh using the command " sh

[GitHub] dawidwys closed pull request #6781: [FLINK-10470] Add method to check if pattern can produce empty matches

dawidwys closed pull request #6781: [FLINK-10470] Add method to check if pattern can produce empty matches URL: https://github.com/apache/flink/pull/6781 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Resolved] (FLINK-10470) Add method to check if pattern can produce empty matches

[ https://issues.apache.org/jira/browse/FLINK-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-10470. -- Resolution: Fixed Fix Version/s: 1.7.0 > Add method to check if pattern can

[GitHub] WheresAlice commented on a change in pull request #6259: [FLINK-9679] Implement AvroSerializationSchema

WheresAlice commented on a change in pull request #6259: [FLINK-9679] Implement AvroSerializationSchema URL: https://github.com/apache/flink/pull/6259#discussion_r223005167 ## File path: flink-formats/flink-avro-confluent-registry/pom.xml ## @@ -29,6 +29,10 @@ under the

[jira] [Commented] (FLINK-10470) Add method to check if pattern can produce empty matches

[ https://issues.apache.org/jira/browse/FLINK-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639833#comment-16639833 ] ASF GitHub Bot commented on FLINK-10470: dawidwys closed pull request #6781: [FLINK-10470] Add

  1   2   >