Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
doujutun3207
flink
提交
b1cb66f0
F
flink
项目概览
doujutun3207
/
flink
与 Fork 源项目一致
从无法访问的项目Fork
通知
24
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
F
flink
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
b1cb66f0
编写于
9月 23, 2014
作者:
T
Till Rohrmann
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Updated license headers of scala files to conform to scala-checkstyle.
上级
f15ff9b0
变更
69
隐藏空白更改
内联
并排
Showing
69 changed file
with
84 addition
and
79 deletion
+84
-79
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java
...in/java/org/apache/flink/configuration/Configuration.java
+4
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
...a/org/apache/flink/examples/scala/clustering/KMeans.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/ConnectedComponents.scala
...ache/flink/examples/scala/graph/ConnectedComponents.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/EnumTrianglesBasic.scala
...pache/flink/examples/scala/graph/EnumTrianglesBasic.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/EnumTrianglesOpt.scala
.../apache/flink/examples/scala/graph/EnumTrianglesOpt.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/PageRankBasic.scala
...org/apache/flink/examples/scala/graph/PageRankBasic.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/TransitiveClosureNaive.scala
...e/flink/examples/scala/graph/TransitiveClosureNaive.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/misc/PiEstimation.scala
...a/org/apache/flink/examples/scala/misc/PiEstimation.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/ml/LinearRegression.scala
...org/apache/flink/examples/scala/ml/LinearRegression.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/relational/WebLogAnalysis.scala
...ache/flink/examples/scala/relational/WebLogAnalysis.scala
+1
-1
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala
...org/apache/flink/examples/scala/wordcount/WordCount.scala
+1
-1
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/FlinkMiniCluster.java
...rg/apache/flink/runtime/minicluster/FlinkMiniCluster.java
+1
-1
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.java
...ache/flink/runtime/minicluster/LocalFlinkMiniCluster.java
+1
-1
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
.../main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
+3
-3
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/EventCollector.scala
.../org/apache/flink/runtime/jobmanager/EventCollector.scala
+2
-2
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
...cala/org/apache/flink/runtime/jobmanager/JobManager.scala
+2
-0
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/NetworkConnectionConfiguration.scala
.../runtime/taskmanager/NetworkConnectionConfiguration.scala
+1
-1
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
...la/org/apache/flink/runtime/taskmanager/TaskManager.scala
+2
-3
flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala
...rg/apache/flink/runtime/jobmanager/JobManagerITCase.scala
+1
-1
flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManager.scala
...pache/flink/runtime/testingUtils/TestingTaskManager.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/AggregateDataSet.scala
...n/scala/org/apache/flink/api/scala/AggregateDataSet.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
...a/src/main/scala/org/apache/flink/api/scala/DataSet.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
...ala/org/apache/flink/api/scala/ExecutionEnvironment.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala
...ain/scala/org/apache/flink/api/scala/GroupedDataSet.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/coGroupDataSet.scala
...ain/scala/org/apache/flink/api/scala/coGroupDataSet.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/Counter.scala
...in/scala/org/apache/flink/api/scala/codegen/Counter.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/MacroContextHolder.scala
...g/apache/flink/api/scala/codegen/MacroContextHolder.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TreeGen.scala
...in/scala/org/apache/flink/api/scala/codegen/TreeGen.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala
...ala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeDescriptors.scala
.../org/apache/flink/api/scala/codegen/TypeDescriptors.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeInformationGen.scala
...g/apache/flink/api/scala/codegen/TypeInformationGen.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/crossDataSet.scala
.../main/scala/org/apache/flink/api/scala/crossDataSet.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/joinDataSet.scala
...c/main/scala/org/apache/flink/api/scala/joinDataSet.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/package.scala
...a/src/main/scala/org/apache/flink/api/scala/package.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassComparator.scala
...pache/flink/api/scala/typeutils/CaseClassComparator.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassSerializer.scala
...pache/flink/api/scala/typeutils/CaseClassSerializer.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassTypeInfo.scala
.../apache/flink/api/scala/typeutils/CaseClassTypeInfo.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/TypeUtils.scala
...cala/org/apache/flink/api/scala/typeutils/TypeUtils.scala
+1
-1
flink-scala/src/main/scala/org/apache/flink/api/scala/unfinishedKeyPairOperation.scala
...g/apache/flink/api/scala/unfinishedKeyPairOperation.scala
+1
-1
flink-tests/src/test/resources/logback-test.xml
flink-tests/src/test/resources/logback-test.xml
+8
-8
flink-tests/src/test/scala/org/apache/flink/api/scala/DeltaIterationSanityCheckTest.scala
...pache/flink/api/scala/DeltaIterationSanityCheckTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
...org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/functions/SemanticPropertiesTranslationTest.scala
...i/scala/functions/SemanticPropertiesTranslationTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/io/CollectionInputFormatTest.scala
...apache/flink/api/scala/io/CollectionInputFormatTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/io/CsvInputFormatTest.scala
...la/org/apache/flink/api/scala/io/CsvInputFormatTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/AggregateOperatorTest.scala
...che/flink/api/scala/operators/AggregateOperatorTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/CoGroupOperatorTest.scala
...pache/flink/api/scala/operators/CoGroupOperatorTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/DistinctOperatorTest.scala
...ache/flink/api/scala/operators/DistinctOperatorTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/GroupingTest.scala
...a/org/apache/flink/api/scala/operators/GroupingTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/JoinOperatorTest.scala
...g/apache/flink/api/scala/operators/JoinOperatorTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/AggregateTranslationTest.scala
...cala/operators/translation/AggregateTranslationTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/DeltaIterationTranslationTest.scala
...operators/translation/DeltaIterationTranslationTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/DistinctTranslationTest.scala
...scala/operators/translation/DistinctTranslationTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/ReduceTranslationTest.scala
...i/scala/operators/translation/ReduceTranslationTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/GenericPairComparatorTest.scala
...e/flink/api/scala/runtime/GenericPairComparatorTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILD2Test.scala
...che/flink/api/scala/runtime/TupleComparatorILD2Test.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILD3Test.scala
...che/flink/api/scala/runtime/TupleComparatorILD3Test.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILDC3Test.scala
...he/flink/api/scala/runtime/TupleComparatorILDC3Test.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILDX1Test.scala
...he/flink/api/scala/runtime/TupleComparatorILDX1Test.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILDXC2Test.scala
...e/flink/api/scala/runtime/TupleComparatorILDXC2Test.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorISD1Test.scala
...che/flink/api/scala/runtime/TupleComparatorISD1Test.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorISD2Test.scala
...che/flink/api/scala/runtime/TupleComparatorISD2Test.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorISD3Test.scala
...che/flink/api/scala/runtime/TupleComparatorISD3Test.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerTest.scala
.../apache/flink/api/scala/runtime/TupleSerializerTest.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerTestInstance.scala
...flink/api/scala/runtime/TupleSerializerTestInstance.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/tuple/base/PairComparatorTestBase.scala
...api/scala/runtime/tuple/base/PairComparatorTestBase.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/tuple/base/TupleComparatorTestBase.scala
...pi/scala/runtime/tuple/base/TupleComparatorTestBase.scala
+1
-1
flink-tests/src/test/scala/org/apache/flink/api/scala/types/TypeInformationGenTest.scala
...apache/flink/api/scala/types/TypeInformationGenTest.scala
+1
-1
pom.xml
pom.xml
+1
-0
未找到文件。
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java
浏览文件 @
b1cb66f0
...
...
@@ -436,7 +436,10 @@ public class Configuration implements IOReadableWritable, java.io.Serializable,
@Override
public
Configuration
clone
()
{
return
this
.
clone
();
Configuration
config
=
new
Configuration
();
config
.
addAll
(
this
);
return
config
;
}
/**
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/ConnectedComponents.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/EnumTrianglesBasic.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/EnumTrianglesOpt.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/PageRankBasic.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/graph/TransitiveClosureNaive.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/misc/PiEstimation.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/ml/LinearRegression.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/relational/WebLogAnalysis.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-examples/flink-scala-examples/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/FlinkMiniCluster.java
浏览文件 @
b1cb66f0
...
...
@@ -52,7 +52,7 @@ abstract public class FlinkMiniCluster {
final
int
index
);
ActorSystem
startJobManagerActorSystem
(
final
Configuration
configuration
)
{
int
port
=
configuration
.
getInteger
(
ConfigConstants
.
JOB_MANAGER_IPC_
ADDRESS
_KEY
,
int
port
=
configuration
.
getInteger
(
ConfigConstants
.
JOB_MANAGER_IPC_
PORT
_KEY
,
ConfigConstants
.
DEFAULT_JOB_MANAGER_IPC_PORT
);
return
AkkaUtils
.
createActorSystem
(
HOSTNAME
,
port
,
configuration
);
...
...
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.java
浏览文件 @
b1cb66f0
...
...
@@ -92,7 +92,7 @@ public class LocalFlinkMiniCluster extends FlinkMiniCluster {
int
taskManagerRPC
=
1024
+
forkNumber
*
300
+
100
;
int
taskManagerDATA
=
1024
+
forkNumber
*
300
+
200
;
configuration
.
setInteger
(
ConfigConstants
.
JOB_MANAGER_IPC_
ADDRESS
_KEY
,
jobManagerRPC
);
configuration
.
setInteger
(
ConfigConstants
.
JOB_MANAGER_IPC_
PORT
_KEY
,
jobManagerRPC
);
configuration
.
setInteger
(
ConfigConstants
.
TASK_MANAGER_IPC_PORT_KEY
,
taskManagerRPC
);
configuration
.
setInteger
(
ConfigConstants
.
TASK_MANAGER_DATA_PORT_KEY
,
taskManagerDATA
);
}
...
...
flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala
浏览文件 @
b1cb66f0
...
...
@@ -96,9 +96,9 @@ object AkkaUtils {
s
"""akka.daemonic = on
|akka.loggers = ["akka.event.slf4j.Slf4jLogger"]
|akka.loglevel = "
INFO
"
|akka.loglevel = "
DEBUG
"
|akka.logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
|akka.stdout-loglevel = "
INFO
"
|akka.stdout-loglevel = "
DEBUG
"
|akka.jvm-exit-on-fata-error = off
|akka.actor.provider = "akka.remote.RemoteActorRefProvider"
|akka.remote.netty.tcp.transport-class = "akka.remote.transport.netty.NettyTransport"
...
...
@@ -132,4 +132,4 @@ object AkkaUtils {
val
future
=
Patterns
.
ask
(
actor
,
msg
,
FUTURE_TIMEOUT
)
Await
.
result
(
future
,
AWAIT_DURATION
).
asInstanceOf
[
T
]
}
}
\ No newline at end of file
}
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/EventCollector.scala
浏览文件 @
b1cb66f0
...
...
@@ -77,8 +77,8 @@ ActorLogging with WrapAsScala {
val
currentTime
=
System
.
currentTimeMillis
()
collectedEvents
.
retain
{
(
jobID
,
events
)
=>
val
(
outdatedElements
,
currentElements
)
=
events
.
partition
{
event
=>
event
.
getTimestamp
+
timerTaskInterval
<
currentTime
val
(
outdatedElements
,
currentElements
)
=
events
.
partition
{
event
=>
event
.
getTimestamp
+
timerTaskInterval
<
currentTime
}
outdatedElements
foreach
(
archiveEvent
(
jobID
,
_
))
...
...
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
浏览文件 @
b1cb66f0
...
...
@@ -82,6 +82,8 @@ Int) extends Actor with ActorLogMessages with ActorLogging with WrapAsScala {
instanceManager
.
addInstanceListener
(
scheduler
)
log
.
info
(
s
"Started job manager. Waiting for incoming messages."
)
override
def
postStop
()
:
Unit
=
{
log
.
info
(
s
"Stopping job manager ${self.path}."
)
instanceManager
.
shutdown
()
...
...
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/NetworkConnectionConfiguration.scala
浏览文件 @
b1cb66f0
...
...
@@ -19,4 +19,4 @@
package
org.apache.flink.runtime.taskmanager
case
class
NetworkConnectionConfiguration
(
numBuffers
:
Int
,
bufferSize
:
Int
,
numInThreads
:
Int
,
numOutThreads
:
Int
,
lowWaterMark
:
Int
,
highWaterMark
:
Int
)
\ No newline at end of file
numOutThreads
:
Int
,
lowWaterMark
:
Int
,
highWaterMark
:
Int
)
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
浏览文件 @
b1cb66f0
...
...
@@ -575,9 +575,8 @@ object TaskManager {
TASK_MANAGER_NAME
);
}
def
startActorWithConfiguration
(
hostname
:
String
,
configuration
:
Configuration
)(
implicit
system
:
ActorSystem
)
=
{
def
startActorWithConfiguration
(
hostname
:
String
,
configuration
:
Configuration
)
(
implicit
system
:
ActorSystem
)
=
{
(
startActor
_
).
tupled
(
parseConfiguration
(
hostname
,
configuration
))
}
...
...
flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala
浏览文件 @
b1cb66f0
...
...
@@ -571,4 +571,4 @@ WordSpecLike with Matchers with BeforeAndAfterAll {
}
}
}
}
\ No newline at end of file
}
flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManager.scala
浏览文件 @
b1cb66f0
...
...
@@ -51,4 +51,4 @@ trait TestingTaskManager extends ActorLogMessages {
case
None
=>
}
}
}
\ No newline at end of file
}
flink-scala/src/main/scala/org/apache/flink/api/scala/AggregateDataSet.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/coGroupDataSet.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/Counter.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/MacroContextHolder.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TreeGen.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeDescriptors.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeInformationGen.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/crossDataSet.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/joinDataSet.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/package.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassComparator.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassSerializer.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassTypeInfo.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/TypeUtils.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-scala/src/main/scala/org/apache/flink/api/scala/unfinishedKeyPairOperation.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/resources/logback-test.xml
浏览文件 @
b1cb66f0
...
...
@@ -23,15 +23,15 @@
</encoder>
</appender>
<root
level=
"
ERROR
"
>
<root
level=
"
DEBUG
"
>
<appender-ref
ref=
"STDOUT"
/>
</root>
<
logger
name=
"org.apache.flink.runtime.operators.RegularPactTask"
level=
"OFF"
/
>
<
logger
name=
"org.apache.flink.runtime.client.JobClient"
level=
"OFF"
/
>
<
logger
name=
"org.apache.flink.runtime.taskmanager.Task"
level=
"OFF"
/
>
<
logger
name=
"org.apache.flink.runtime.jobmanager.JobManager"
level=
"OFF"
/
>
<
logger
name=
"org.apache.flink.runtime.taskmanager.TaskManager"
level=
"OFF"
/
>
<
logger
name=
"org.apache.flink.runtime.executiongraph.ExecutionGraph"
level=
"OFF"
/
>
<
logger
name=
"org.apache.flink.runtime.jobmanager.EventCollector"
level=
"OFF"
/
>
<
!--<logger name="org.apache.flink.runtime.operators.RegularPactTask" level="OFF"/>--
>
<
!--<logger name="org.apache.flink.runtime.client.JobClient" level="OFF"/>--
>
<
!--<logger name="org.apache.flink.runtime.taskmanager.Task" level="OFF"/>--
>
<
!--<logger name="org.apache.flink.runtime.jobmanager.JobManager" level="OFF"/>--
>
<
!--<logger name="org.apache.flink.runtime.taskmanager.TaskManager" level="OFF"/>--
>
<
!--<logger name="org.apache.flink.runtime.executiongraph.ExecutionGraph" level="OFF"/>--
>
<
!--<logger name="org.apache.flink.runtime.jobmanager.EventCollector" level="OFF"/>--
>
</configuration>
\ No newline at end of file
flink-tests/src/test/scala/org/apache/flink/api/scala/DeltaIterationSanityCheckTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/ScalaAPICompletenessTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/functions/SemanticPropertiesTranslationTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/io/CollectionInputFormatTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/io/CsvInputFormatTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/AggregateOperatorTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/CoGroupOperatorTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/DistinctOperatorTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/GroupingTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/JoinOperatorTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/AggregateTranslationTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/DeltaIterationTranslationTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/DistinctTranslationTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/ReduceTranslationTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/GenericPairComparatorTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILD2Test.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILD3Test.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILDC3Test.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILDX1Test.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorILDXC2Test.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorISD1Test.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorISD2Test.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleComparatorISD3Test.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerTestInstance.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/tuple/base/PairComparatorTestBase.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/tuple/base/TupleComparatorTestBase.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
flink-tests/src/test/scala/org/apache/flink/api/scala/types/TypeInformationGenTest.scala
浏览文件 @
b1cb66f0
...
...
@@ -7,7 +7,7 @@
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
...
...
pom.xml
浏览文件 @
b1cb66f0
...
...
@@ -65,6 +65,7 @@ under the License.
<module>
flink-addons
</module>
<module>
flink-quickstart
</module>
<module>
flink-dist
</module>
<module>
testing
</module>
</modules>
<properties>
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录