[jira] [Commented] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state

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

[jira] [Commented] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state

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

[jira] [Updated] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state

[ https://issues.apache.org/jira/browse/FLINK-9489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9489: -- Labels: pull-request-available (was: ) > Checkpoint timers as part of managed keyed state inst

[GitHub] flink issue #6333: [FLINK-9489] Checkpoint timers as part of managed keyed s...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/6333 CC @tillrohrmann ---

[GitHub] flink pull request #6333: [FLINK-9489] Checkpoint timers as part of managed ...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/6333 [FLINK-9489] Checkpoint timers as part of managed keyed state instead of raw keyed state ## What is the purpose of the change This PR integrates priority queue state (timers) with th

[jira] [Commented] (FLINK-8858) Add support for INSERT INTO in SQL Client

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

[GitHub] flink pull request #6332: [FLINK-8858] [sql-client] Add support for INSERT I...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6332#discussion_r202507962 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java --- @@ -329,14 +341,46 @@ public voi

[jira] [Commented] (FLINK-8858) Add support for INSERT INTO in SQL Client

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

[GitHub] flink pull request #6332: [FLINK-8858] [sql-client] Add support for INSERT I...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6332#discussion_r202507930 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java --- @@ -354,6 +398,23 @@ private void callSelect(S

[jira] [Commented] (FLINK-8858) Add support for INSERT INTO in SQL Client

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

[GitHub] flink pull request #6332: [FLINK-8858] [sql-client] Add support for INSERT I...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6332#discussion_r202507864 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java --- @@ -173,55 +180,92 @@ public void open() {

[jira] [Commented] (FLINK-9407) Support orc rolling sink writer

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

[jira] [Commented] (FLINK-9407) Support orc rolling sink writer

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

[GitHub] flink pull request #6075: [FLINK-9407] [hdfs connector] Support orc rolling ...

Github user sagarl commented on a diff in the pull request: https://github.com/apache/flink/pull/6075#discussion_r200217627 --- Diff: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/OrcFileWriter.java --- @@ -0,0 +1,252 @@ +/*

[GitHub] flink pull request #6075: [FLINK-9407] [hdfs connector] Support orc rolling ...

Github user sagarl commented on a diff in the pull request: https://github.com/apache/flink/pull/6075#discussion_r200217021 --- Diff: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/OrcFileWriter.java --- @@ -0,0 +1,252 @@ +/*

[jira] [Commented] (FLINK-8858) Add support for INSERT INTO in SQL Client

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

[GitHub] flink pull request #6332: [FLINK-8858] [sql-client] Add support for INSERT I...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6332#discussion_r202507463 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java --- @@ -97,14 +97,34 @@ private void start() {

[jira] [Commented] (FLINK-8858) Add support for INSERT INTO in SQL Client

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

[GitHub] flink pull request #6332: [FLINK-8858] [sql-client] Add support for INSERT I...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6332#discussion_r202507424 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java --- @@ -85,6 +86,9 @@ public CliClient(SessionCont

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink issue #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified table ...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6323 Thank you @pnowojski. I hope I could address all your comments. I will clean the commit history and improve the commit messages during merging. ---

[jira] [Closed] (FLINK-9818) Add cluster component command line parser

[ https://issues.apache.org/jira/browse/FLINK-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9818. Resolution: Fixed Fixed via ab9bd87e521d19db7c7d783268a3532d2e876a5d > Add cluster component comma

[jira] [Assigned] (FLINK-7087) Implement Flip-6 container entry point

[ https://issues.apache.org/jira/browse/FLINK-7087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7087: Assignee: Till Rohrmann > Implement Flip-6 container entry point > ---

[jira] [Closed] (FLINK-7087) Implement Flip-6 container entry point

[ https://issues.apache.org/jira/browse/FLINK-7087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7087. Resolution: Fixed Fixed via 8f467c1e9727d5a86d38d0b49753c534a1a161da > Implement Flip-6 container

[jira] [Closed] (FLINK-9488) Create common entry point for master and workers

[ https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9488. Resolution: Fixed Fixed via 8f467c1e9727d5a86d38d0b49753c534a1a161da > Create common entry point f

[jira] [Closed] (FLINK-9821) Let dynamic properties overwrite configuration settings in TaskManagerRunner

[ https://issues.apache.org/jira/browse/FLINK-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9821. Resolution: Fixed Fixed via 740f2fbf2e65fa988c6a577989ccd8923729be45 > Let dynamic properties over

[jira] [Closed] (FLINK-9820) Let dynamic properties overwrite configuration settings in ClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-9820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9820. Resolution: Fixed Fixed via 2fbbf8ee662647c71581f5cd989226be820fed0f > Let dynamic properties over

[jira] [Closed] (FLINK-9819) Create start up scripts for the StandaloneJobClusterEntryPoint

[ https://issues.apache.org/jira/browse/FLINK-9819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9819. Resolution: Fixed Fixed via 5a4bdf2c9fd1693ad3b90dbbd3bcb589ed15c101 > Create start up scripts for

[jira] [Closed] (FLINK-9822) Add Dockerfile for StandaloneJobClusterEntryPoint image

[ https://issues.apache.org/jira/browse/FLINK-9822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9822. Resolution: Fixed Fixed via 56e5381cb7aba01f1d7ecfa11e4be7f505a35baf > Add Dockerfile for Standalo

[jira] [Commented] (FLINK-9488) Create common entry point for master and workers

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

[jira] [Resolved] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9619. -- Resolution: Fixed Fix Version/s: (was: 1.5.2) Fixed via c9ad0a07ef0339ced74057fc1780

[jira] [Commented] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

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

[GitHub] flink pull request #6317: [FLINK-9820] Forward dynamic properties to Flink c...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6317 ---

[jira] [Commented] (FLINK-9821) Let dynamic properties overwrite configuration settings in TaskManagerRunner

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

[GitHub] flink pull request #6331: [FLINK-9701] [state] (follow up) Use StateTtlConfi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6331 ---

[GitHub] flink pull request #6318: [FLINK-9821] Forward dynamic properties to configu...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6318 ---

[GitHub] flink pull request #6319: [FLINK-9822] Add Dockerfile for StandaloneJobClust...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6319 ---

[jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

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

[jira] [Closed] (FLINK-9823) Add Kubernetes deployment files for standalone job cluster

[ https://issues.apache.org/jira/browse/FLINK-9823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-9823. Resolution: Fixed Fixed via 387a3bc198cfea016abd92953c7fce28e641cf67 > Add Kubernetes deployment f

[GitHub] flink pull request #6314: [FLINK-9818] Add cluster component command line pa...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6314 ---

[jira] [Commented] (FLINK-9818) Add cluster component command line parser

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

[GitHub] flink pull request #6283: [FLINK-9143] Use cluster strategy if none was set ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6283 ---

[jira] [Commented] (FLINK-9820) Let dynamic properties overwrite configuration settings in ClusterEntrypoint

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

[jira] [Commented] (FLINK-9823) Add Kubernetes deployment files for standalone job cluster

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

[GitHub] flink pull request #6185: [FLINK-9619][YARN] Eagerly close the connection wi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6185 ---

[GitHub] flink pull request #6315: [FLINK-9488] Add container entry point StandaloneJ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6315 ---

[jira] [Commented] (FLINK-9819) Create start up scripts for the StandaloneJobClusterEntryPoint

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

[jira] [Commented] (FLINK-9701) Activate TTL in state descriptors

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

[GitHub] flink pull request #6316: [FLINK-9819] Add startup scripts for standalone jo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6316 ---

[jira] [Commented] (FLINK-9822) Add Dockerfile for StandaloneJobClusterEntryPoint image

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

[jira] [Updated] (FLINK-9619) Always close the task manager connection when the container is completed in YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-9619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9619: -- Labels: pull-request-available (was: ) > Always close the task manager connection when the con

[GitHub] flink pull request #6320: [FLINK-9823] Add Kubernetes deployment ymls

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6320 ---

[jira] [Resolved] (FLINK-9701) Activate TTL in state descriptors

[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9701. -- Resolution: Fixed Fix Version/s: 1.6.0 Fixed via 1632681e41cbc1092a6b4d47a58adfffba6af5d

[jira] [Resolved] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9143. -- Resolution: Fixed Fix Version/s: 1.6.0 Fixed via 57872d53c4584faace6dc8e4038ad1f2d068a45

[jira] [Assigned] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored

[ https://issues.apache.org/jira/browse/FLINK-9143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9143: Assignee: Dawid Wysakowicz (was: yuqi) > Restart strategy defined in flink-conf.yaml is i

[jira] [Reopened] (FLINK-9701) Activate TTL in state descriptors

[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-9701: -- > Activate TTL in state descriptors > - > > Key: FL

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Assigned] (FLINK-9762) CoreOptions.TMP_DIRS wrongly managed on Yarn

[ https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9762: --- Assignee: (was: vinoyang) > CoreOptions.TMP_DIRS wrongly managed on Yarn > -

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202507057 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalTableSourceScan.scala --- @@ -52,12 +52,9 @@ clas

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506906 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactoryService.scala --- @@ -18,143 +18,358 @@ package

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[jira] [Commented] (FLINK-9816) Support Netty SslEngine based on openSSL

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

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506769 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void setSSLVerifyHostname(Configur

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506820 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void setSSLVerifyHostname(Configur

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202505334 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -249,14 +326,40 @@ public static SSLContext createSSLServerContext(C

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506868 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void setSSLVerifyHostname(Configur

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506811 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void setSSLVerifyHostname(Configur

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506709 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -163,80 +163,157 @@ public static void setSSLVerifyHostname(Configur

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202506694 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java --- @@ -249,14 +326,40 @@ public static SSLContext createSSLServerContext(C

[GitHub] flink pull request #6328: [FLINK-9816][network] add option to configure SSL ...

Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6328#discussion_r202505321 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyClientServerSslTest.java --- @@ -160,6 +160,7 @@ private Configuration

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506861 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactoryService.scala --- @@ -18,143 +18,358 @@ package

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506766 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactoryService.scala --- @@ -18,143 +18,358 @@ package

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506740 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactoryService.scala --- @@ -18,143 +18,358 @@ package

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506661 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/exceptions.scala --- @@ -143,118 +143,82 @@ case class CatalogAlreadyExistEx

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506625 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFormatFactory.scala --- @@ -16,42 +16,17 @@ * limitations u

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506574 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalTableSourceUtil.scala --- @@ -44,32 +43,27 @@ object ExternalTab

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506512 --- Diff: flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/Kafka08JsonTableSourceFactoryTest.java --- @@

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506494 --- Diff: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/SourceSink.java --- @@ -51,16 +51,10 @@ public void addPropert

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506193 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/factories/TableFactory.scala --- @@ -16,14 +16,14 @@ * limitations under t

[jira] [Commented] (FLINK-8558) Add unified format interfaces and format discovery

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

[GitHub] flink pull request #6323: [FLINK-8558] [FLINK-8866] [table] Finalize unified...

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6323#discussion_r202506126 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java --- @@ -54,51 +56,105

[jira] [Commented] (FLINK-9325) generate the _meta file for checkpoint only when the writing is truly successful

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

[GitHub] flink issue #5982: [FLINK-9325][checkpoint]generate the meta file for checkp...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5982 @StephanEwen Thanks! Looking forward~ ---

[jira] [Assigned] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei reassigned FLINK-9849: --- Assignee: zhangminglei > Upgrade hbase version to 2.0.1 for hbase connector > --

  1   2   3   4   5   >