[
https://issues.apache.org/jira/browse/FLINK-30730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30730:
-
Description:
When training data contains null values, StringIndexer throws a exception. The
reason is t
chenhaiyang created FLINK-30731:
---
Summary: Translate "Set Operations" page of "Querys" into Chinese
Key: FLINK-30731
URL: https://issues.apache.org/jira/browse/FLINK-30731
Project: Flink
Issue
gaborgsomogyi commented on code in PR #21705:
URL: https://github.com/apache/flink/pull/21705#discussion_r1073208380
##
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java:
##
@@ -485,6 +485,18 @@ public class KubernetesConfigOpt
NightRunner opened a new pull request, #21713:
URL: https://github.com/apache/flink/pull/21713
Page "Application Development"/"Table API&SQL"/"SQL"/"Queries"/Set
Operations translate to chinese.
## What is the purpose of the change
Translate /dev/table/sql/queries/set-ops.md
[
https://issues.apache.org/jira/browse/FLINK-30731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30731:
---
Labels: pull-request-available (was: )
> Translate "Set Operations" page of "Querys" into C
[
https://issues.apache.org/jira/browse/FLINK-30731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678121#comment-17678121
]
chenhaiyang commented on FLINK-30731:
-
Hi [~jark] ,The pull request for this issue h
flinkbot commented on PR #21713:
URL: https://github.com/apache/flink/pull/21713#issuecomment-1386654627
## CI report:
* 2a0581b5a83803e5c8658908e99200cffc89d168 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30730:
-
Summary: StringIndexer cannot handle null values correctly (was:
StringIndexer cannot handle null value
Myasuka commented on PR #20049:
URL: https://github.com/apache/flink/pull/20049#issuecomment-1386662086
@afedulov since FLIP-238 had been resolved, shall we continue this work and
make it done in flink-1.17 release?
--
This is an automated message from the Apache Git Service.
To respond t
[
https://issues.apache.org/jira/browse/FLINK-30730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30730:
-
Description:
When training data contains null values, StringIndexer throws a exception. The
reason is t
pnowojski commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1386685819
> The other thing that looks strange if I take a step back, is that we now
have to different while (true) loops. One in the
MailboxProcessor#runMailboxLoop the other in SourceOperator a
lincoln-lil commented on code in PR #21683:
URL: https://github.com/apache/flink/pull/21683#discussion_r1073038341
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/analyze/FlinkStreamPlanAnalyzers.scala:
##
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-27716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-27716:
Assignee: Jiang Xin
> Add Python API docs in ML
> -
>
>
Matthias Pohl created FLINK-30732:
-
Summary: "Running HA (hashmap, sync) end-to-end test" failed with
exit code 1
Key: FLINK-30732
URL: https://issues.apache.org/jira/browse/FLINK-30732
Project: Flink
Myasuka opened a new pull request, #21714:
URL: https://github.com/apache/flink/pull/21714
## What is the purpose of the change
Update the doc of kafka-per-partition watermark to the new source.
## Brief change log
Update the doc of kafka-per-partition watermark to th
[
https://issues.apache.org/jira/browse/FLINK-30724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30724:
---
Labels: pull-request-available (was: )
> Update doc of kafka per-partition watermark to FLI
[
https://issues.apache.org/jira/browse/FLINK-30732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30732:
--
Attachment: FLINK-30732.tar.gz
> "Running HA (hashmap, sync) end-to-end test" failed with exit
[
https://issues.apache.org/jira/browse/FLINK-30732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678129#comment-17678129
]
Matthias Pohl commented on FLINK-30732:
---
I attached the logs for the build mention
SinBex commented on code in PR #21634:
URL: https://github.com/apache/flink/pull/21634#discussion_r1073254764
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/failover/RestartTasksInBatchJobBenchmarkTest.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to th
SinBex commented on code in PR #21634:
URL: https://github.com/apache/flink/pull/21634#discussion_r1073256359
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmark.java:
##
@@ -20,20 +20,28 @@
import org.apache.
[
https://issues.apache.org/jira/browse/FLINK-30732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678132#comment-17678132
]
Matthias Pohl commented on FLINK-30732:
---
I'm linking FLINK-23210 as related becaus
[
https://issues.apache.org/jira/browse/FLINK-30732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30732:
--
Labels: test-stability (was: )
> "Running HA (hashmap, sync) end-to-end test" failed with exi
flinkbot commented on PR #21714:
URL: https://github.com/apache/flink/pull/21714#issuecomment-1386704806
## CI report:
* 1f241186a3371722253a181729375342bcb7f1e7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Matthias Pohl created FLINK-30733:
-
Summary: The AzureCI Slack bot does not list all failed builds in
the Slack channel
Key: FLINK-30733
URL: https://issues.apache.org/jira/browse/FLINK-30733
Project:
SinBex commented on code in PR #21634:
URL: https://github.com/apache/flink/pull/21634#discussion_r1073262413
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/scheduling/InitSchedulingStrategyBenchmarkTest.java:
##
@@ -44,4 +46,20 @@ public void initSc
lincoln-lil commented on code in PR #21683:
URL: https://github.com/apache/flink/pull/21683#discussion_r1073264039
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/TwoStageOptimizedAggregateRule.scala:
##
@@ -59,11 +59,1
XComp commented on code in PR #17:
URL:
https://github.com/apache/flink-connector-pulsar/pull/17#discussion_r1073266310
##
flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SharedSplitAssignerTest.java:
##
@@ -1,121 +0,0 @@
-/*
-
luoyuxia commented on code in PR #21601:
URL: https://github.com/apache/flink/pull/21601#discussion_r1073260992
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveAverageAggFunction.java:
##
@@ -0,0 +1,207 @@
+/*
+ * Licensed to the
MartijnVisser commented on PR #51:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/51#issuecomment-1386716971
@reswqa Can you push an additional commit to see if the CI starts?
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
zjureel commented on PR #426:
URL:
https://github.com/apache/flink-table-store/pull/426#issuecomment-1386728578
Hi @JingsongLi I have rebase from master for this PR, could you help to
review again when you get time? THX
--
This is an automated message from the Apache Git Service.
To res
lincoln-lil commented on code in PR #21683:
URL: https://github.com/apache/flink/pull/21683#discussion_r1073281001
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/analyze/NonDeterministicUpdateAnalyzer.java:
##
@@ -0,0 +1,80 @@
+/*
+ * Licensed to
ferenc-csaky commented on PR #16927:
URL: https://github.com/apache/flink/pull/16927#issuecomment-1386739768
> @thebalu Thanks for reaching out. I didn't get this PR merged because the
community has no capacity to review it, especially since this PR is hard to
test. I would revisit it and m
1996fanrui commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1386744572
I saw the `PushingAsyncDataInput#emitNext` and `SourceReader#pollNext`
returns the `InputStatus`. It's similar to `DataOutput#emitRecord`. So sounds
good to me, +1 for `DataOutput#emit
SinBex commented on code in PR #21634:
URL: https://github.com/apache/flink/pull/21634#discussion_r1073294808
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/scheduling/StartSchedulingInBatchJobBenchmarkTest.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed
SinBex commented on code in PR #21634:
URL: https://github.com/apache/flink/pull/21634#discussion_r1073294808
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/scheduling/StartSchedulingInBatchJobBenchmarkTest.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed
zentol commented on code in PR #51:
URL: https://github.com/apache/flink-training/pull/51#discussion_r1073306239
##
.github/workflows/ci.yml:
##
@@ -0,0 +1,41 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOT
zentol commented on code in PR #51:
URL: https://github.com/apache/flink-training/pull/51#discussion_r1073306501
##
.github/workflows/ci.yml:
##
@@ -0,0 +1,41 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOT
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1073306704
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplit.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-30577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678164#comment-17678164
]
Gyula Fora commented on FLINK-30577:
Target 1.4.0 feature freeze is early February
lindong28 commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1386777544
Hmm... if we add the method `boolean DataOutput#emitRecord(...)`, can you
explain what Java Doc we should use to explain the semantics of the returned
boolean value?
Intuitively,
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1073329519
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/RingRange.java:
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-30721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678174#comment-17678174
]
Pedro Mázala commented on FLINK-30721:
--
Gotcha [~martijnvisser]. We can remove this
echauchot commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1073332349
##
flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/RingRange.java:
##
@@ -0,0 +1,98 @@
+/*
+ * Licensed to the
lindong28 commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1386793709
Thanks for the detailed explanation @pnowojski :) Let me provides comments
below.
> It would be strange for me that in order to fully implement this interface
and use it as it's
Fan Hong created FLINK-30734:
Summary: KBinsDiscretizer handles Double.NaN incorrectly
Key: FLINK-30734
URL: https://issues.apache.org/jira/browse/FLINK-30734
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-30734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan Hong updated FLINK-30734:
-
Affects Version/s: ml-2.1.0
> KBinsDiscretizer handles Double.NaN incorrectly
>
luoyuxia commented on code in PR #21668:
URL: https://github.com/apache/flink/pull/21668#discussion_r1073328257
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveLookupJoinITCase.java:
##
@@ -378,6 +378,31 @@ public void
testLookupJoinW
luoyuxia commented on code in PR #21668:
URL: https://github.com/apache/flink/pull/21668#discussion_r1073351578
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveLookupJoinITCase.java:
##
@@ -378,6 +378,31 @@ public void
testLookupJoinW
MartijnVisser commented on PR #118:
URL: https://github.com/apache/flink-shaded/pull/118#issuecomment-1386822470
> The same streamlining should be applied to the dynamic tcnative module
We can't do that for the dynamic tcnative module, per
https://github.com/apache/flink-shaded/blob/m
chenhaiyang created FLINK-30735:
---
Summary: Translate "Top-N" page of "Querys" into Chinese
Key: FLINK-30735
URL: https://issues.apache.org/jira/browse/FLINK-30735
Project: Flink
Issue Type: Sub
NightRunner opened a new pull request, #21715:
URL: https://github.com/apache/flink/pull/21715
Translate "Top-N" page of "Querys" into Chinese
## What is the purpose of the change
Translate /dev/table/sql/queries/topn.md
## Brief change log
Translate /dev/table/sql
[
https://issues.apache.org/jira/browse/FLINK-30735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30735:
---
Labels: pull-request-available (was: )
> Translate "Top-N" page of "Querys" into Chinese
>
lincoln-lil commented on code in PR #21676:
URL: https://github.com/apache/flink/pull/21676#discussion_r1073356514
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/batch/sql/RowLevelDeleteTest.java:
##
@@ -53,24 +57,37 @@ public
RowLevelDelet
[
https://issues.apache.org/jira/browse/FLINK-30735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678177#comment-17678177
]
chenhaiyang commented on FLINK-30735:
-
Hi [~jark] ,The pull request for this issue h
[
https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-16850.
--
Fix Version/s: 1.17.0
Resolution: Fixed
Already updated the description of the "Major release"
[
https://issues.apache.org/jira/browse/FLINK-29945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-29945:
--
Summary: Supports to submit SQL to a embedded SQL Gateway in the SQL Client
(was: Refactor ‘E
[
https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678182#comment-17678182
]
Yun Gao commented on FLINK-27518:
-
Sorry for it takes more time than I thought to finish
flinkbot commented on PR #21715:
URL: https://github.com/apache/flink/pull/21715#issuecomment-1386834992
## CI report:
* a873402a8c42d531f9467ae3824fe40444a78ab7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
echauchot commented on PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1386836888
@zentol I did not author the `RingRange` and `SplitsGenerator` classes. I
got them from the `Apache Beam` Cassandra connector. I agree, some notions need
clarification. I'l
pnowojski commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1386850790
> If it's ok, ReaderOutput#collect and RecordEmitter#emitRecord should
return a boolean as well. And the loop will be moved from
SourceOperator#emitNext to SourceReader#pollNext.
pnowojski commented on code in PR #21690:
URL: https://github.com/apache/flink/pull/21690#discussion_r1073379125
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -993,7 +997,7 @@ public MailboxExecutorFactory getMailboxExecuto
haoxins opened a new pull request, #506:
URL: https://github.com/apache/flink-kubernetes-operator/pull/506
just docs style issue
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comme
[
https://issues.apache.org/jira/browse/FLINK-30709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678190#comment-17678190
]
Piotr Nowojski commented on FLINK-30709:
Thanks for following up on my comment!
pnowojski commented on PR #21697:
URL: https://github.com/apache/flink/pull/21697#issuecomment-1386861784
Generally speaking change looks good to me, but let's wait for the
FLINK-30623 to be merged first.
--
This is an automated message from the Apache Git Service.
To respond to the messa
zentol commented on code in PR #64:
URL: https://github.com/apache/flink-benchmarks/pull/64#discussion_r1073395171
##
.github/workflows/ci.yml:
##
@@ -0,0 +1,50 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the N
Tartarus0zm opened a new pull request, #21716:
URL: https://github.com/apache/flink/pull/21716
## What is the purpose of the change
Supports native hive avg function for hive dialect.
## Brief change log
* Supports native hive avg function for hive dialect
zentol commented on code in PR #64:
URL: https://github.com/apache/flink-benchmarks/pull/64#discussion_r1073395171
##
.github/workflows/ci.yml:
##
@@ -0,0 +1,50 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the N
[
https://issues.apache.org/jira/browse/FLINK-29720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29720:
---
Labels: pull-request-available (was: )
> Supports hive average function by native implemeta
XComp commented on code in PR #21691:
URL: https://github.com/apache/flink/pull/21691#discussion_r1073310290
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClientTest.java:
##
@@ -55,11 +54,12 @@
/** Tests for {@link NettyPartition
Tartarus0zm commented on PR #21716:
URL: https://github.com/apache/flink/pull/21716#issuecomment-1386878941
@lsyldliu @luoyuxia @godfreyhe @beyond1920 hello, please take a look, if
you have time, thanks
--
This is an automated message from the Apache Git Service.
To respond to the messa
fsk119 opened a new pull request, #21717:
URL: https://github.com/apache/flink/pull/21717
…teway in the SQL Client
## What is the purpose of the change
*After rework, the SQL Client uses the SQL Gateway as the base.*
## Brief change log
*(for example:)*
[
https://issues.apache.org/jira/browse/FLINK-29945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29945:
---
Labels: pull-request-available (was: )
> Supports to submit SQL to a embedded SQL Gateway i
flinkbot commented on PR #21716:
URL: https://github.com/apache/flink/pull/21716#issuecomment-1386884113
## CI report:
* cfd591214819cd58522892e9b9f8ea3076c5e8e0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21717:
URL: https://github.com/apache/flink/pull/21717#issuecomment-1386884294
## CI report:
* 54ca159e9f1709684b216e6836ae5f409be92a5b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
lsyldliu commented on PR #21605:
URL: https://github.com/apache/flink/pull/21605#issuecomment-1386886860
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
fsk119 commented on PR #21700:
URL: https://github.com/apache/flink/pull/21700#issuecomment-1386893525
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
Tartarus0zm commented on PR #21716:
URL: https://github.com/apache/flink/pull/21716#issuecomment-1386899952
Repeated with https://github.com/apache/flink/pull/21601
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
Tartarus0zm closed pull request #21716: [FLINK-29720][hive] Supports hive
average function by native implemetatoin
URL: https://github.com/apache/flink/pull/21716
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
1996fanrui commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1386900013
>> If it's ok, ReaderOutput#collect and RecordEmitter#emitRecord should
return a boolean as well. And the loop will be moved from
SourceOperator#emitNext to SourceReader#pollNext.
>
1996fanrui commented on code in PR #21690:
URL: https://github.com/apache/flink/pull/21690#discussion_r1073416193
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java:
##
@@ -993,7 +997,7 @@ public MailboxExecutorFactory getMailboxExecut
[
https://issues.apache.org/jira/browse/FLINK-30703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678204#comment-17678204
]
Matthias Pohl commented on FLINK-30703:
---
{quote}quoted text{quote}Matthias Pohl It
[
https://issues.apache.org/jira/browse/FLINK-30703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678204#comment-17678204
]
Matthias Pohl edited comment on FLINK-30703 at 1/18/23 11:58 AM:
-
lindong28 commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1386947530
```
Returns true if caller can call this method more times within a single
invocation of the `PushingAsyncDataInput#emitNext` method. Otherwise returned
value false means the cal
Chesnay Schepler created FLINK-30736:
Summary: Exclude generated sources from checkstyle
Key: FLINK-30736
URL: https://issues.apache.org/jira/browse/FLINK-30736
Project: Flink
Issue Type:
lincoln-lil commented on code in PR #21676:
URL: https://github.com/apache/flink/pull/21676#discussion_r1073455685
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/DeletePushDownUtils.java:
##
@@ -0,0 +1,283 @@
+/*
+ * Licensed to the Ap
lincoln-lil commented on code in PR #21676:
URL: https://github.com/apache/flink/pull/21676#discussion_r1071900617
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -780,6 +784,7 @@ public CompiledPlan compileP
[
https://issues.apache.org/jira/browse/FLINK-30736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30736:
-
Component/s: Connector / Parent
> Exclude generated sources from checkstyle
> --
Chesnay Schepler created FLINK-30737:
Summary: Setup
Key: FLINK-30737
URL: https://issues.apache.org/jira/browse/FLINK-30737
Project: Flink
Issue Type: Technical Debt
Reporter
[
https://issues.apache.org/jira/browse/FLINK-30737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-30737:
Assignee: Chesnay Schepler
> Setup basic CI
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-30737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30737:
-
Component/s: Connector / Parent
> Setup basic CI
> --
>
> Ke
[
https://issues.apache.org/jira/browse/FLINK-30737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30737:
-
Summary: Setup basic CI (was: Setup)
> Setup basic CI
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-30737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30737:
-
Fix Version/s: connector-parent-1.0
> Setup basic CI
> --
>
>
lincoln-lil commented on code in PR #21676:
URL: https://github.com/apache/flink/pull/21676#discussion_r1073356514
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/batch/sql/RowLevelDeleteTest.java:
##
@@ -53,24 +57,37 @@ public
RowLevelDelet
lincoln-lil commented on code in PR #21676:
URL: https://github.com/apache/flink/pull/21676#discussion_r1073455685
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/DeletePushDownUtils.java:
##
@@ -0,0 +1,283 @@
+/*
+ * Licensed to the Ap
lincoln-lil commented on code in PR #21676:
URL: https://github.com/apache/flink/pull/21676#discussion_r1073465880
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/DeletePushDownUtils.java:
##
@@ -0,0 +1,283 @@
+/*
+ * Licensed to the Ap
zentol merged PR #2:
URL: https://github.com/apache/flink-connector-shared-utils/pull/2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr.
[
https://issues.apache.org/jira/browse/FLINK-30639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30639:
-
Fix Version/s: connector-parent-1.0
> Publish SBOM for externalized connectors
> ---
[
https://issues.apache.org/jira/browse/FLINK-30639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678215#comment-17678215
]
Chesnay Schepler commented on FLINK-30639:
--
connector-parent: aa659f7694d2e50df
Chesnay Schepler created FLINK-30738:
Summary: Disable verbose mode
Key: FLINK-30738
URL: https://issues.apache.org/jira/browse/FLINK-30738
Project: Flink
Issue Type: Sub-task
C
Yun Tang created FLINK-30739:
Summary: SqlGatewayRestEndpointStatementITCase failed with
NullPointer
Key: FLINK-30739
URL: https://issues.apache.org/jira/browse/FLINK-30739
Project: Flink
Issue
1 - 100 of 307 matches
Mail list logo
