[GitHub] flink issue #2482: [FLINK-4579] [StateBackend] Add StateBackendFactory for R...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2482 Added a shortcut (rocksdb) for configuring RocksDB state backend and added the dedicated option config `state.backend.rocksdb.checkpointdir`. --- If your project is set up for it, you can reply to t

[jira] [Commented] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515569#comment-15515569 ] ASF GitHub Bot commented on FLINK-4579: --- Github user wuchong commented on the issue:

[jira] [Commented] (FLINK-4668) Fix positive random int generation

[ https://issues.apache.org/jira/browse/FLINK-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515563#comment-15515563 ] ASF GitHub Bot commented on FLINK-4668: --- GitHub user apivovarov opened a pull reques

[GitHub] flink pull request #2539: [FLINK-4668] Fix positive random int generation

GitHub user apivovarov opened a pull request: https://github.com/apache/flink/pull/2539 [FLINK-4668] Fix positive random int generation https://issues.apache.org/jira/browse/FLINK-4668 You can merge this pull request into a Git repository by running: $ git pull https://github.c

[jira] [Created] (FLINK-4668) Fix positive random int generation

Alexander Pivovarov created FLINK-4668: -- Summary: Fix positive random int generation Key: FLINK-4668 URL: https://issues.apache.org/jira/browse/FLINK-4668 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515544#comment-15515544 ] ASF GitHub Bot commented on FLINK-4624: --- Github user s1ck commented on the issue:

[GitHub] flink issue #2527: [FLINK-4624] Allow for null values in Graph Summarization

Github user s1ck commented on the issue: https://github.com/apache/flink/pull/2527 > I'd also like to add a ToNullValue translator that would accept any type and convert to NullValue. I don't know if I get this right. Do you mean an additional test case with `NullValue` as ve

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515541#comment-15515541 ] ASF GitHub Bot commented on FLINK-4624: --- Github user s1ck commented on the issue:

[GitHub] flink issue #2527: [FLINK-4624] Allow for null values in Graph Summarization

Github user s1ck commented on the issue: https://github.com/apache/flink/pull/2527 > Would a graph translator simplify the conversion from Long to String? You can do graph.run(new TranslateEdgeValues<...>(new StringToLong()) and write a simple public class StringToLong implements Tran

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515537#comment-15515537 ] ASF GitHub Bot commented on FLINK-4624: --- Github user s1ck commented on the issue:

[GitHub] flink issue #2527: [FLINK-4624] Allow for null values in Graph Summarization

Github user s1ck commented on the issue: https://github.com/apache/flink/pull/2527 > I'm not following why specifying the TypeInformation is now required with the change to using Either. Is the type system failing to handle this properly? You are right, I was experimenting with ret

[jira] [Created] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend

Vijay Srinivasaraghavan created FLINK-4667: -- Summary: Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend Key: FLINK-4667 URL: https://issues.apache.org/jira

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515524#comment-15515524 ] ASF GitHub Bot commented on FLINK-4624: --- Github user s1ck commented on a diff in the

[GitHub] flink pull request #2527: [FLINK-4624] Allow for null values in Graph Summar...

Github user s1ck commented on a diff in the pull request: https://github.com/apache/flink/pull/2527#discussion_r80186110 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/Summarization.java --- @@ -226,11 +247,15 @@ public void setGroupRepresentati

[jira] [Updated] (FLINK-4666) Make constants to be final in ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Pivovarov updated FLINK-4666: --- Summary: Make constants to be final in ParameterTool (was: Make constants final in Pa

[jira] [Commented] (FLINK-4666) Make constants to be final in ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-4666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515504#comment-15515504 ] ASF GitHub Bot commented on FLINK-4666: --- GitHub user apivovarov opened a pull reques

[GitHub] flink pull request #2538: [FLINK-4666] Make constants to be final in Paramet...

GitHub user apivovarov opened a pull request: https://github.com/apache/flink/pull/2538 [FLINK-4666] Make constants to be final in ParameterTool https://issues.apache.org/jira/browse/FLINK-4666 You can merge this pull request into a Git repository by running: $ git pull https:/

[jira] [Created] (FLINK-4666) Make constants final in ParameterTool

Alexander Pivovarov created FLINK-4666: -- Summary: Make constants final in ParameterTool Key: FLINK-4666 URL: https://issues.apache.org/jira/browse/FLINK-4666 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515452#comment-15515452 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the iss

[GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc...

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2495 @StephanEwen Just trying to explain what my intention was. This is particularly to address the sorters. Solution We could create memory allocators inside the batch task corresponding t

[jira] [Commented] (FLINK-4547) when call connect method in AkkaRpcService using same address and same rpc gateway class, the returned gateways are equal with respect to equals and hashCode

[ https://issues.apache.org/jira/browse/FLINK-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515323#comment-15515323 ] ASF GitHub Bot commented on FLINK-4547: --- Github user beyond1920 commented on the iss

[GitHub] flink issue #2455: [FLINK-4547] [cluster management] when call connect metho...

Github user beyond1920 commented on the issue: https://github.com/apache/flink/pull/2455 @tillrohrmann , I rebase the PR. Thanks. --- 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

[jira] [Commented] (FLINK-4665) Remove boxing/unboxing to parse a primitive

[ https://issues.apache.org/jira/browse/FLINK-4665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515279#comment-15515279 ] ASF GitHub Bot commented on FLINK-4665: --- GitHub user apivovarov opened a pull reques

[GitHub] flink pull request #2537: [FLINK-4665] Remove boxing/unboxing to parse a pri...

GitHub user apivovarov opened a pull request: https://github.com/apache/flink/pull/2537 [FLINK-4665] Remove boxing/unboxing to parse a primitive https://issues.apache.org/jira/browse/FLINK-4665 You can merge this pull request into a Git repository by running: $ git pull https:/

[jira] [Created] (FLINK-4665) Remove boxing/unboxing to parse a primitive

Alexander Pivovarov created FLINK-4665: -- Summary: Remove boxing/unboxing to parse a primitive Key: FLINK-4665 URL: https://issues.apache.org/jira/browse/FLINK-4665 Project: Flink Issue T

[jira] [Resolved] (FLINK-4537) ResourceManager registration with JobManager

[ https://issues.apache.org/jira/browse/FLINK-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjing resolved FLINK-4537. -- Resolution: Resolved > ResourceManager registration with JobManager > --

[jira] [Resolved] (FLINK-4535) ResourceManager registration with TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjing resolved FLINK-4535. -- Resolution: Resolved > ResourceManager registration with TaskExecutor >

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515209#comment-15515209 ] Jark Wu commented on FLINK-4263: I have no idea how to code generate the values input form

[jira] [Commented] (FLINK-4630) add netty tcp source support

[ https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515193#comment-15515193 ] shijinkui commented on FLINK-4630: -- [~StephanEwen] Though flink already have a SocketTex

[jira] [Updated] (FLINK-4630) add netty tcp source support

[ https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-4630: - Description: When source stream get start, listen a provided tcp port, receive stream data from user data

[jira] [Updated] (FLINK-4630) add netty tcp source support

[ https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-4630: - Description: When source stream get start, listen a provided tcp port, receive stream data from user data

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515022#comment-15515022 ] ASF GitHub Bot commented on FLINK-2055: --- Github user delding commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 Hi @ramkrish86 , CassandraTupleWriteAheadSink extends GenericWriteAheadSink that deals with the checkpoint mechanism --- If your project is set up for it, you can reply to this email and have your

[jira] [Closed] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui closed FLINK-4661. Resolution: Won't Fix > Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT > ---

[jira] [Commented] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514995#comment-15514995 ] shijinkui commented on FLINK-4661: -- hi, [~StephanEwen] [~twalthr] My local nexus proxy is

[jira] [Commented] (FLINK-4664) Add translator to NullValue

[ https://issues.apache.org/jira/browse/FLINK-4664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514462#comment-15514462 ] ASF GitHub Bot commented on FLINK-4664: --- GitHub user greghogan opened a pull request

[GitHub] flink pull request #2536: [FLINK-4664] [gelly] Add translator to NullValue

GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2536 [FLINK-4664] [gelly] Add translator to NullValue This translator is appropriate for translating vertex and edge values to NullValue when the values are not used in an algorithm. You can merge thi

[jira] [Created] (FLINK-4664) Add translator to NullValue

Greg Hogan created FLINK-4664: - Summary: Add translator to NullValue Key: FLINK-4664 URL: https://issues.apache.org/jira/browse/FLINK-4664 Project: Flink Issue Type: New Feature Compone

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514265#comment-15514265 ] ASF GitHub Bot commented on FLINK-3719: --- Github user iampeter commented on the issue

[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

Github user iampeter commented on the issue: https://github.com/apache/flink/pull/2467 @mushketyk thanks for this feature, very useful indeed. I'd like to ask you to reconsider some things: 1. First of all, I think it would be good to wrap split.js in an Angular directive

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514143#comment-15514143 ] ASF GitHub Bot commented on FLINK-4624: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2527: [FLINK-4624] Allow for null values in Graph Summar...

Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2527#discussion_r80109825 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/Summarization.java --- @@ -226,11 +247,15 @@ public void setGroupReprese

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514124#comment-15514124 ] ASF GitHub Bot commented on FLINK-4624: --- Github user greghogan commented on the issu

[GitHub] flink issue #2527: [FLINK-4624] Allow for null values in Graph Summarization

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2527 I'm not following why specifying the `TypeInformation` is now required with the change to using `Either`. Is the type system failing to handle this properly? --- If your project is set up for it,

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514093#comment-15514093 ] Zhenzhong Xu commented on FLINK-4218: - I think simply have retries potentially with co

[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514015#comment-15514015 ] Matt Zimmer commented on FLINK-4660: [~StephanEwen] We last tested with latest on mast

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513996#comment-15513996 ] ASF GitHub Bot commented on FLINK-4624: --- Github user greghogan commented on the issu

[GitHub] flink issue #2527: [FLINK-4624] Allow for null values in Graph Summarization

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2527 I'd also like to add a `ToNullValue` translator that would accept any type and convert to `NullValue`. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513945#comment-15513945 ] ASF GitHub Bot commented on FLINK-4624: --- Github user greghogan commented on the issu

[GitHub] flink issue #2527: [FLINK-4624] Allow for null values in Graph Summarization

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2527 Would a graph translator simplify the conversion from Long to String? You can do `graph.run(new TranslateEdgeValues<...>(new StringToLong())` and write a simple `public class StringToLong implement

[jira] [Commented] (FLINK-4596) RESTART_STRATEGY is not really pluggable

[ https://issues.apache.org/jira/browse/FLINK-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513734#comment-15513734 ] Monal Daxini commented on FLINK-4596: - Hi [~StephanEwen] what are your thoughts on thi

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513450#comment-15513450 ] Timo Walther commented on FLINK-4263: - I think they don't need to be basic types even

[jira] [Commented] (FLINK-4662) Bump Calcite version up to 1.9

[ https://issues.apache.org/jira/browse/FLINK-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513420#comment-15513420 ] ASF GitHub Bot commented on FLINK-4662: --- GitHub user wuchong opened a pull request:

[GitHub] flink pull request #2535: [FLINK-4662] Bump Calcite version up to 1.9

GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2535 [FLINK-4662] Bump Calcite version up to 1.9 Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes t

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513401#comment-15513401 ] Jark Wu commented on FLINK-4263: It seems that the data types in {{VALUES}} are always Rex

[jira] [Resolved] (FLINK-4628) User class loader unavailable during input split assignment

[ https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4628. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 345b2529a8acdd59d67e89ea930ec69ad69a55d3

[jira] [Closed] (FLINK-4628) User class loader unavailable during input split assignment

[ https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4628. --- > User class loader unavailable during input split assignment > --

[jira] [Resolved] (FLINK-4603) KeyedStateBackend cannot restore user code classes

[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4603. - Resolution: Fixed Fixed via 3b8fe95ec728d59e3ffba2901450c56d7cca2b24 > KeyedStateBackend cannot r

[jira] [Closed] (FLINK-4603) KeyedStateBackend cannot restore user code classes

[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4603. --- > KeyedStateBackend cannot restore user code classes > --

[jira] [Commented] (FLINK-4587) Yet another java.lang.NoSuchFieldError: INSTANCE

[ https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513337#comment-15513337 ] Stephan Ewen commented on FLINK-4587: - It depends on which maven version you are using

[GitHub] flink issue #2523: [FLINK-4556] Make Queryable State Key-Group Aware

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2523 please review @aljoscha or @StephanEwen --- 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 feat

[jira] [Commented] (FLINK-4556) Make Queryable State Key-Group Aware

[ https://issues.apache.org/jira/browse/FLINK-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513330#comment-15513330 ] ASF GitHub Bot commented on FLINK-4556: --- Github user StefanRRichter commented on the

[jira] [Assigned] (FLINK-4554) Add support for array types

[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4554: --- Assignee: Timo Walther > Add support for array types > --- > >

[jira] [Commented] (FLINK-4661) Failure to find org.apache.flink:flink-runtime_2.10:jar:tests:1.2-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513311#comment-15513311 ] Timo Walther commented on FLINK-4661: - Today [~fhueske] and me also have problems in c

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513302#comment-15513302 ] Timo Walther commented on FLINK-4263: - I also had a look at it. Replacing {{Seq[Row]}}

[jira] [Commented] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513265#comment-15513265 ] ASF GitHub Bot commented on FLINK-4663: --- Github user zentol commented on the issue:

[GitHub] flink issue #2534: [FLINK-4663] Flink JDBCOutputFormat logs wrong WARN messa...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2534 +1 to merge. --- 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

[jira] [Reopened] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-4663: -- Hi [~the.swapni...@gmail.com], thanks for providing a fix! We will close the issue once the pull req

[jira] [Resolved] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Chougule resolved FLINK-4663. - Resolution: Fixed Resolved. Created PR https://github.com/apache/flink/pull/2534 Kindly re

[jira] [Updated] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Chougule updated FLINK-4663: Priority: Minor (was: Major) > Flink JDBCOutputFormat logs wrong WARN message > ---

[GitHub] flink pull request #2534: [FLINK-4663] Flink JDBCOutputFormat logs wrong WAR...

GitHub user swapnil-chougule opened a pull request: https://github.com/apache/flink/pull/2534 [FLINK-4663] Flink JDBCOutputFormat logs wrong WARN message - Fixed Fixed wrong WARN message logged by JDBCOutputFormat while adding row (writing record to prepared statement) as "Colum

[jira] [Commented] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513241#comment-15513241 ] ASF GitHub Bot commented on FLINK-4663: --- GitHub user swapnil-chougule opened a pull

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513234#comment-15513234 ] Stephan Ewen commented on FLINK-4218: - [~zhenzhongxu] Adding you to this conversation.

[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513227#comment-15513227 ] Stephan Ewen commented on FLINK-4660: - We looked through this a bit, and the problem m

[jira] [Commented] (FLINK-4603) KeyedStateBackend cannot restore user code classes

[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513199#comment-15513199 ] ASF GitHub Bot commented on FLINK-4603: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2533: [FLINK-4603] Fixes: KeyedStateBackend cannot resto...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2533 --- 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

[jira] [Commented] (FLINK-4628) User class loader unavailable during input split assignment

[ https://issues.apache.org/jira/browse/FLINK-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513198#comment-15513198 ] ASF GitHub Bot commented on FLINK-4628: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2505: [FLINK-4628] provide user class loader during inpu...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2505 --- 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

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513162#comment-15513162 ] ASF GitHub Bot commented on FLINK-4496: --- Github user kl0u commented on the issue:

[GitHub] flink issue #2434: [FLINK-4496] Refactor the TimeServiceProvider to take a T...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/2434 Thanks @mxm and @aljoscha ! I already have the followup on this open here: https://github.com/apache/flink/pull/2532 --- If your project is set up for it, you can reply to this email and have

[GitHub] flink issue #2434: [FLINK-4496] Refactor the TimeServiceProvider to take a T...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2434 +1 Looks like a sensible change. Looking forward to fixing the `ContinuousFileReaderOperator`. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513157#comment-15513157 ] ASF GitHub Bot commented on FLINK-4496: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513129#comment-15513129 ] ASF GitHub Bot commented on FLINK-4485: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513131#comment-15513131 ] ASF GitHub Bot commented on FLINK-4485: --- Github user mxm commented on the issue:

[GitHub] flink issue #2499: [FLINK-4485] close and remove user class loader after job...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2499 Merging after tests pass. --- 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,

[GitHub] flink issue #2499: [FLINK-4485] close and remove user class loader after job...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2499 This needed another fix because in some tests we use the system class loader instead of a class loader instantiated by the BlobLibraryCacheManager. If we close that one, we cause tests to fail. The solut

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

[ https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513099#comment-15513099 ] ASF GitHub Bot commented on FLINK-3580: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2468 --- 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

[jira] [Assigned] (FLINK-4662) Bump Calcite version up to 1.9

[ https://issues.apache.org/jira/browse/FLINK-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4662: -- Assignee: Jark Wu > Bump Calcite version up to 1.9 > -- > >

[jira] [Updated] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-4663: -- Assignee: Swapnil Chougule > Flink JDBCOutputFormat logs wrong WARN message > --

[jira] [Commented] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512971#comment-15512971 ] Swapnil Chougule commented on FLINK-4663: - Hi Team, Can anybody give me permissio

[jira] [Updated] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

[ https://issues.apache.org/jira/browse/FLINK-4663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Chougule updated FLINK-4663: Description: Flink JDBCOutputFormat logs wrong WARN message as "Column SQL types array does

[jira] [Commented] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

[ https://issues.apache.org/jira/browse/FLINK-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512941#comment-15512941 ] ASF GitHub Bot commented on FLINK-4544: --- Github user zentol commented on the issue:

[GitHub] flink issue #2445: [FLINK-4544] Refactor old CPU metric initialization

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2445 that should be doable, yes. --- 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 wishe

[jira] [Commented] (FLINK-4560) enforcer java version as 1.7

[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512936#comment-15512936 ] ASF GitHub Bot commented on FLINK-4560: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2458: [FLINK-4560] enforcer java version as 1.7

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2458 From my side, this is good to merge. Unless someone objects, I will merge this later today... --- If your project is set up for it, you can reply to this email and have your reply appear on G

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512934#comment-15512934 ] ASF GitHub Bot commented on FLINK-3719: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2467 Piotr (who wrote most of the web ui) also wants to leave some comments. Let's wait for him. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Created] (FLINK-4663) Flink JDBCOutputFormat logs wrong WARN message

Swapnil Chougule created FLINK-4663: --- Summary: Flink JDBCOutputFormat logs wrong WARN message Key: FLINK-4663 URL: https://issues.apache.org/jira/browse/FLINK-4663 Project: Flink Issue Type

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512932#comment-15512932 ] ASF GitHub Bot commented on FLINK-3719: --- Github user StephanEwen commented on the is

  1   2   >