[jira] [Closed] (FLINK-13860) Flink Apache Kudu Connector

[ https://issues.apache.org/jira/browse/FLINK-13860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto closed FLINK-13860. - Resolution: Invalid > Flink Apache Kudu Connector > --- > > Key:

[GitHub] [flink] dawidwys commented on issue #11785: [FLINK-17206][table] refactor function catalog to support delayed UDF initialization.

dawidwys commented on issue #11785: URL: https://github.com/apache/flink/pull/11785#issuecomment-616377734 Hi @WeiZhong94 thank you for working on this. Personally I would choose a different approach in a couple of places. Let me describe how I see it. The ultimate goal is to have:

[GitHub] [flink] zhuzhurk commented on a change in pull request #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

zhuzhurk commented on a change in pull request #11770: URL: https://github.com/apache/flink/pull/11770#discussion_r411170916 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategyTest.java ## @@ -0,0 +1,162 @@ +/

[jira] [Updated] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

[ https://issues.apache.org/jira/browse/FLINK-17257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17257: --- Labels: pull-request-available (was: ) > AbstractYarnClusterTest does not compile with Hado

[GitHub] [flink] xintongsong commented on issue #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

xintongsong commented on issue #11817: URL: https://github.com/apache/flink/pull/11817#issuecomment-616376921 cc @zhuzhurk This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] xintongsong opened a new pull request #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

xintongsong opened a new pull request #11817: URL: https://github.com/apache/flink/pull/11817 ## What is the purpose of the change In AbstractYarnClusterTest, we create ApplicationReport with the static method ApplicationReport.newInstance, which is annotated as private and unstable

[GitHub] [flink] flinkbot edited a comment on issue #11816: [FLINK-16763][python][doc] Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples

flinkbot edited a comment on issue #11816: URL: https://github.com/apache/flink/pull/11816#issuecomment-616363629 ## CI report: * 0ada8ce36bd618fa5e9c869ca6cf0e4c059dda92 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/160986902) Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #11785: [FLINK-17206][table] refactor function catalog to support delayed UDF initialization.

flinkbot edited a comment on issue #11785: URL: https://github.com/apache/flink/pull/11785#issuecomment-615087743 ## CI report: * 131d640159c9f367ef0d682b4616228d6bed939d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160979463) Azure: [PENDING](https://dev

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087463#comment-17087463 ] Stephan Ewen commented on FLINK-17012: -- [~pnowojski] Given that you work on the Str

[GitHub] [flink] flinkbot edited a comment on issue #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on issue #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN * 778239dfa00a84ab8457d49eedc759b601028676 Tr

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087462#comment-17087462 ] Stephan Ewen commented on FLINK-17012: -- It is true that this needs a constructor wr

[jira] [Assigned] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

[ https://issues.apache.org/jira/browse/FLINK-17257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17257: --- Assignee: Xintong Song > AbstractYarnClusterTest does not compile with Hadoop 2.10 > --

[jira] [Created] (FLINK-17259) Have scala 2.12 support

João Boto created FLINK-17259: - Summary: Have scala 2.12 support Key: FLINK-17259 URL: https://issues.apache.org/jira/browse/FLINK-17259 Project: Flink Issue Type: Improvement Component

[jira] [Created] (FLINK-17258) Enable unaligned checkpoints in tests by default

Arvid Heise created FLINK-17258: --- Summary: Enable unaligned checkpoints in tests by default Key: FLINK-17258 URL: https://issues.apache.org/jira/browse/FLINK-17258 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

Xintong Song created FLINK-17257: Summary: AbstractYarnClusterTest does not compile with Hadoop 2.10 Key: FLINK-17257 URL: https://issues.apache.org/jira/browse/FLINK-17257 Project: Flink Iss

[GitHub] [flink] hequn8128 commented on a change in pull request #11668: [FLINK-17013][python] Support Python UDTF in old planner under batch mode

hequn8128 commented on a change in pull request #11668: URL: https://github.com/apache/flink/pull/11668#discussion_r411152627 ## File path: flink-python/pyflink/table/tests/test_udtf.py ## @@ -41,44 +41,67 @@ def test_table_function(self): DataType

[GitHub] [flink] GJL commented on a change in pull request #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

GJL commented on a change in pull request #11770: URL: https://github.com/apache/flink/pull/11770#discussion_r411148799 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategyTest.java ## @@ -0,0 +1,162 @@ +/* + *

[GitHub] [flink] twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

twalthr commented on a change in pull request #11692: URL: https://github.com/apache/flink/pull/11692#discussion_r411158004 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PeriodicWatermarkAssignerProvider.java

[GitHub] [flink] KurtYoung commented on a change in pull request #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

KurtYoung commented on a change in pull request #11397: URL: https://github.com/apache/flink/pull/11397#discussion_r411156938 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -196,8 +196,12 @@ public void open() {

[GitHub] [flink] dawidwys edited a comment on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dawidwys edited a comment on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616363030 I understood the underlying issue. I don't get though how this PR works the issue around. How do the adjustments make it less probable? ---

[GitHub] [flink] flinkbot commented on issue #11816: [FLINK-16763][python][doc] Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples

flinkbot commented on issue #11816: URL: https://github.com/apache/flink/pull/11816#issuecomment-616363629 ## CI report: * 0ada8ce36bd618fa5e9c869ca6cf0e4c059dda92 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[GitHub] [flink] flinkbot edited a comment on issue #11815: [FLINK-17253] Support viewfs for hadoop version < 2.7

flinkbot edited a comment on issue #11815: URL: https://github.com/apache/flink/pull/11815#issuecomment-616355624 ## CI report: * 82b7e411419bbd8a1011bdc78e2a916dbc1256a7 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/160984484) Azure: [PENDING](https://dev

[GitHub] [flink] dawidwys edited a comment on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dawidwys edited a comment on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616363030 I understood the underlying issue. I don't get though how this PR works the issue around. This is an automated

[GitHub] [flink] dawidwys commented on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dawidwys commented on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616363030 I understood the underlying issue. I don't get though how this PR works around the issue. This is an automated messag

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * 4c854e0afe5cb934d919f37eb0891719063938ac Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/160752603) Azure: [FAILURE](https://de

[GitHub] [flink] dawidwys commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

dawidwys commented on a change in pull request #11692: URL: https://github.com/apache/flink/pull/11692#discussion_r411153299 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/abilities/SupportsPartitioning.java ## @@ -0,0 +1,109 @

[GitHub] [flink] twalthr commented on a change in pull request #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

twalthr commented on a change in pull request #11397: URL: https://github.com/apache/flink/pull/11397#discussion_r411152388 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -196,8 +196,12 @@ public void open() {

[GitHub] [flink] xintongsong commented on a change in pull request #11787: [FLINK-16746] Deprecate legacy heap memory option for JM and expose the new ones in docs

xintongsong commented on a change in pull request #11787: URL: https://github.com/apache/flink/pull/11787#discussion_r411148809 ## File path: flink-jepsen/src/jepsen/flink/db.clj ## @@ -41,7 +41,7 @@ {:high-availability "zookeeper" :high-availability.

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087435#comment-17087435 ] Wenlong Lyu commented on FLINK-17012: - hi, [~sewen] thanks for the explanation. but

[GitHub] [flink] flinkbot commented on issue #11816: [FLINK-16763][python][doc] Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples

flinkbot commented on issue #11816: URL: https://github.com/apache/flink/pull/11816#issuecomment-616359471 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the progress

[GitHub] [flink] dawidwys commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

dawidwys commented on a change in pull request #11692: URL: https://github.com/apache/flink/pull/11692#discussion_r411147490 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PeriodicWatermarkAssignerProvider.java ###

[jira] [Updated] (FLINK-16763) Should not use BatchTableEnvironment for Python UDF in the document of flink-1.10

[ https://issues.apache.org/jira/browse/FLINK-16763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16763: --- Labels: pull-request-available (was: ) > Should not use BatchTableEnvironment for Python UD

[GitHub] [flink] hequn8128 opened a new pull request #11816: [FLINK-16763][python][doc] Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples

hequn8128 opened a new pull request #11816: URL: https://github.com/apache/flink/pull/11816 ## What is the purpose of the change Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples since for flink-1.10, Python UDF is not supported in old planner unde

[GitHub] [flink] dianfu edited a comment on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dianfu edited a comment on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616355772 It's a good idea to add description in the PR commit message and will do that. For this issue itself, I have already explained in the JIRA. Let me try to explain it in the PR aga

[jira] [Commented] (FLINK-17189) Table with processing time attribute can not be read from Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-17189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087431#comment-17087431 ] Timo Walther commented on FLINK-17189: -- Hi [~lirui], yes, the {{TimestampKind}} i

[jira] [Assigned] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-16408: - Assignee: Till Rohrmann > Bind user code class loader to lifetime of a slot > -

[GitHub] [flink] flinkbot edited a comment on issue #11813: [FLINK-17249] Bump universal Kafka connector to Kafka 2.2.2

flinkbot edited a comment on issue #11813: URL: https://github.com/apache/flink/pull/11813#issuecomment-616239083 ## CI report: * 49a1530e3b0320a7053c977c2d36c1eed49245a2 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160974132) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot commented on issue #11815: [FLINK-17253] Support viewfs for hadoop version < 2.7

flinkbot commented on issue #11815: URL: https://github.com/apache/flink/pull/11815#issuecomment-616355624 ## CI report: * 82b7e411419bbd8a1011bdc78e2a916dbc1256a7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[GitHub] [flink] flinkbot edited a comment on issue #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on issue #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 2b64d49dac7f89d4abf600fda1d7beb5b34d3fc5 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160982313) Azure: [FAILURE](https://dev

[GitHub] [flink] dianfu commented on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dianfu commented on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616355772 It's a good idea to add description in the PR commit message and will do that. For this issue itself, I have already explained in the JIRA. Let me try to explain it in the PR again:

[GitHub] [flink] flinkbot edited a comment on issue #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on issue #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN * 778239dfa00a84ab8457d49eedc759b601028676 Tr

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * 4c854e0afe5cb934d919f37eb0891719063938ac Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/160752603) Azure: [FAILURE](https://de

<    3   4   5   6   7   8